+++ /dev/null
-/* === S Y N F I G ========================================================= */
-/*! \file ipc.cpp
-** \brief Template File
-**
-** $Id$
-**
-** \legal
-** Copyright (c) 2002-2005 Robert B. Quattlebaum Jr., Adrian Bentley
-** Copyright (c) 2007 Chris Moore
-**
-** This package is free software; you can redistribute it and/or
-** modify it under the terms of the GNU General Public License as
-** published by the Free Software Foundation; either version 2 of
-** the License, or (at your option) any later version.
-**
-** This package is distributed in the hope that it will be useful,
-** but WITHOUT ANY WARRANTY; without even the implied warranty of
-** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-** General Public License for more details.
-** \endlegal
-*/
-/* ========================================================================= */
-
-/* === H E A D E R S ======================================================= */
-
-#ifdef USING_PCH
-# include "pch.h"
-#else
-#ifdef HAVE_CONFIG_H
-# include <config.h>
-#endif
-
-#include "ipc.h"
-
-#ifdef HAVE_SYS_TYPES_H
-#include <sys/types.h>
-#endif
-
-#ifdef HAVE_SYS_STAT_H
-#include <sys/stat.h>
-#endif
-
-#ifdef HAVE_SYS_ERRNO_H
-#include <sys/errno.h>
-#endif
-
-#include <synfig/main.h>
-#include "app.h"
-
-#ifdef HAVE_UNISTD_H
-#include <unistd.h>
-#endif
-
-#ifdef HAVE_FCNTL_H
-#include <fcntl.h>
-#endif
-
-#ifdef _WIN32
-#include <windows.h>
-#define BUFSIZE 128
-#define read _read
-#endif
-
-#include "toolbox.h"
-#include <glibmm/dispatcher.h>
-#include <synfig/mutex.h>
-#include <synfig/string.h>
-#include <glibmm/thread.h>
-
-#include "general.h"
-
-#endif
-
-/* === U S I N G =========================================================== */
-
-using namespace std;
-using namespace etl;
-using namespace synfig;
-using namespace studio;
-
-/* === M A C R O S ========================================================= */
-
-/* === G L O B A L S ======================================================= */
-
-#ifdef _WIN32
-#define WIN32_PIPE_PATH "\\\\.\\pipe\\SynfigStudio.Cmd"
-static synfig::Mutex cmd_mutex;
-static std::list<synfig::String> cmd_queue;
-static Glib::Dispatcher* cmd_dispatcher;
-static void
-pipe_listen_thread()
-{
- for(;;)
- {
- HANDLE pipe_handle;
- pipe_handle=CreateNamedPipe(
- WIN32_PIPE_PATH, // pipe name
- PIPE_ACCESS_INBOUND, // Access type
- PIPE_READMODE_BYTE /*|PIPE_NOWAIT*/,
- PIPE_UNLIMITED_INSTANCES,
- BUFSIZE,
- BUFSIZE,
- NMPWAIT_USE_DEFAULT_WAIT,
- NULL
- );
- if(pipe_handle==INVALID_HANDLE_VALUE)
- {
- synfig::error("IPC(): Call to CreateNamedPipe failed. Ignore next error. GetLastError=%d",GetLastError());
- return;
- }
-
- bool connected;
- connected=ConnectNamedPipe(pipe_handle,NULL)?true:(GetLastError()==ERROR_PIPE_CONNECTED);
- DWORD read_bytes;
- bool success;
-
- Glib::Thread::yield();
-
- if(connected)
- do {
- String data;
- char c;
- do
- {
- success= ReadFile(
- pipe_handle,
- &c, // buffer pointer
- 1, // buffer size
- &read_bytes,
- NULL
- );
- if(success && read_bytes==1 && c!='\n')
- data+=c;
- }while(c!='\n');
- synfig::Mutex::Lock lock(cmd_mutex);
- cmd_queue.push_back(data);
- cmd_dispatcher->emit();
- } while(success && read_bytes);
-
- CloseHandle(pipe_handle);
- }
-}
-
-static void
-empty_cmd_queue()
-{
- synfig::Mutex::Lock lock(cmd_mutex);
- while(!cmd_queue.empty())
- {
- IPC::process_command(cmd_queue.front());
- cmd_queue.pop_front();
- }
-}
-
-#endif
-
-/* === P R O C E D U R E S ================================================= */
-
-/* === M E T H O D S ======================================================= */
-
-IPC::IPC()
-{
-#ifdef _WIN32
-
- cmd_dispatcher=new Glib::Dispatcher;
- cmd_dispatcher->connect(sigc::ptr_fun(empty_cmd_queue));
-
- Glib::Thread::create(
- sigc::ptr_fun(pipe_listen_thread),
- false
- );
-
-#else
-
- remove(fifo_path().c_str());
- fd=-1;
-
- if(mkfifo(fifo_path().c_str(), S_IRWXU)!=0)
- {
- synfig::error("IPC(): mkfifo failed for "+fifo_path());
- }
-
- {
- fd=open(fifo_path().c_str(),O_RDWR);
-
-
- if(fd<0)
- {
- synfig::error("IPC(): Failed to open fifo \"%s\". (errno=?)",fifo_path().c_str());
- //synfig::error("IPC(): Failed to open fifo \"%s\". (errno=%d)",fifo_path().c_str(),::errno);
- }
- else
- {
- file=SmartFILE(fdopen(fd,"r"));
-
- Glib::signal_io().connect(
- sigc::mem_fun(this,&IPC::fifo_activity),
- fd,
- Glib::IO_IN|Glib::IO_PRI|Glib::IO_ERR|Glib::IO_HUP|Glib::IO_NVAL
- );
- }
- }
-#endif
-}
-
-IPC::~IPC()
-{
- //if(file)
- // fclose(file.get());
-
- remove(fifo_path().c_str());
-
- //if(fd>=0)
- // close(fd);
-}
-
-synfig::String
-IPC::fifo_path()
-{
-#ifdef _WIN32
- return WIN32_PIPE_PATH;
-#else
- return Glib::build_filename(App::get_user_app_directory(),"fifo");
-#endif
-}
-
-bool
-IPC::fifo_activity(Glib::IOCondition cond)
-{
- if(cond&(Glib::IO_ERR|Glib::IO_HUP|Glib::IO_NVAL))
- {
- if(cond&(Glib::IO_ERR))
- synfig::error("IPC::fifo_activity(): IO_ERR");
- if(cond&(Glib::IO_HUP))
- synfig::error("IPC::fifo_activity(): IO_HUP");
- if(cond&(Glib::IO_NVAL))
- synfig::error("IPC::fifo_activity(): IO_NVAL");
- return false;
- }
-
- String command;
- {
- char tmp;
- do {
- if(read(fd,&tmp,sizeof(tmp))<=0)
- break;
- if(tmp!='\n')
- command+=tmp;
- } while(tmp!='\n');
- }
-
- synfig::info("%s:%d: fifo activity: '%s'", __FILE__, __LINE__, command.c_str());
- process_command(command);
- return true;
-}
-
-bool
-IPC::process_command(const synfig::String& command_line)
-{
- if(command_line.empty())
- return false;
-
- char cmd = command_line[0];
-
- String args(command_line.begin()+1,command_line.end());
-
- // erase leading spaces
- while (!args.empty() && args[0] == ' ')
- args.erase(args.begin());
-
- // erase trailing newlines and spaces
- while (!args.empty() && (args[args.size()-1] == '\n' || args[args.size()-1] == ' '))
- args.erase(args.end()-1);
-
- switch(toupper(cmd))
- {
- case 'F': // Focus/Foreground
- App::signal_present_all()();
- break;
- case 'N': // New file
- App::signal_present_all()();
- App::new_instance();
- break;
- case 'O': // Open <arg>
- App::signal_present_all()();
- App::open(args);
- break;
- case 'X': // Quit
- case 'Q': // Quit
- App::quit();
- break;
- default:
- synfig::warning("Received unknown command '%c' with arg '%s'",cmd,args.c_str());
- break;
- }
-
- return true;
-}
-
-synfig::SmartFILE
-IPC::make_connection()
-{
- SmartFILE ret;
-#ifdef _WIN32
- HANDLE pipe_handle;
- pipe_handle=CreateFile(
- fifo_path().c_str(),
- GENERIC_WRITE, // desired access
- 0, // share mode
- NULL, // security attributes
- OPEN_EXISTING, // creation disposition
- FILE_ATTRIBUTE_NORMAL, // flags and attributes
- NULL // template file
- );
- if(pipe_handle==INVALID_HANDLE_VALUE)
- {
- DWORD error = GetLastError();
-#ifndef _DEBUG
- if( error != ERROR_FILE_NOT_FOUND )
-#endif
- synfig::warning("IPC::make_connection(): Unable to connect to previous instance. GetLastError=%d",error);
- }
- int fd=_open_osfhandle(reinterpret_cast<long int>(pipe_handle),_O_APPEND|O_WRONLY);
-#else
- struct stat file_stat;
- if(stat(fifo_path().c_str(),&file_stat)!=0)
- return ret;
-
- if(!S_ISFIFO(file_stat.st_mode))
- return ret;
-
- int fd=open(fifo_path().c_str(),O_WRONLY|O_NONBLOCK);
-#endif
-
- if(fd>=0)
- ret=SmartFILE(fdopen(fd,"w"));
-
-#ifdef _DEBUG
- // synfig::info("uplink fd=%d",fd);
-#endif
-
- return ret;
-}
projects / synfig.git / blobdiff