/* * Copyright (C) 2009 Intel Corporation * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) version 3. * * This library 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 * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA * 02110-1301 USA */ #ifdef HAVE_CONFIG_H #include "config.h" #endif #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifdef USE_GNOME_KEYRING extern "C" { #include } #endif #ifdef HAS_NOTIFY #include #endif class DBusMessage; static DBusMessage *SyncEvoHandleException(DBusMessage *msg); #define DBUS_CXX_EXCEPTION_HANDLER SyncEvoHandleException #include "gdbus-cxx-bridge.h" using namespace SyncEvo; static GMainLoop *loop = NULL; static bool shutdownRequested = false; static LogRedirect *redirectPtr; /** * Anything that can be owned by a client, like a connection * or session. */ class Resource { public: virtual ~Resource() {} }; class Session; class Connection; class Client; class DBusTransportAgent; class DBusUserInterface; class DBusServer; class DBusSyncException : public DBusCXXException, public Exception { public: DBusSyncException(const std::string &file, int line, const std::string &what) : Exception(file, line, what) {} /** * get exception name, used to convert to dbus error name * subclasses should override it */ virtual std::string getName() const { return "org.syncevolution.Exception"; } virtual const char* getMessage() const { return Exception::what(); } }; /** * exceptions classes deriving from DBusException * org.syncevolution.NoSuchConfig */ class NoSuchConfig: public DBusSyncException { public: NoSuchConfig(const std::string &file, int line, const std::string &error): DBusSyncException(file, line, error) {} virtual std::string getName() const { return "org.syncevolution.NoSuchConfig";} }; /** * org.syncevolution.NoSuchSource */ class NoSuchSource : public DBusSyncException { public: NoSuchSource(const std::string &file, int line, const std::string &error): DBusSyncException(file, line, error) {} virtual std::string getName() const { return "org.syncevolution.NoSuchSource";} }; /** * org.syncevolution.InvalidCall */ class InvalidCall : public DBusSyncException { public: InvalidCall(const std::string &file, int line, const std::string &error): DBusSyncException(file, line, error) {} virtual std::string getName() const { return "org.syncevolution.InvalidCall";} }; /** * org.syncevolution.SourceUnusable * CheckSource will use this when the source cannot be used for whatever reason */ class SourceUnusable : public DBusSyncException { public: SourceUnusable(const std::string &file, int line, const std::string &error): DBusSyncException(file, line, error) {} virtual std::string getName() const { return "org.syncevolution.SourceUnusable";} }; /** * implement syncevolution exception handler * to cover its default implementation */ static DBusMessage* SyncEvoHandleException(DBusMessage *msg) { /** give an opportunity to let syncevolution handle exception */ Exception::handle(); try { throw; } catch (const dbus_error &ex) { return b_dbus_create_error(msg, ex.dbusName().c_str(), "%s", ex.what()); } catch (const DBusCXXException &ex) { return b_dbus_create_error(msg, ex.getName().c_str(), "%s", ex.getMessage()); } catch (const std::runtime_error &ex) { return b_dbus_create_error(msg, "org.syncevolution.Exception", "%s", ex.what()); } catch (...) { return b_dbus_create_error(msg, "org.syncevolution.Exception", "unknown"); } } /** * Implements the read-only methods in a Session and the Server. * Only data is the server configuration name, everything else * is created and destroyed inside the methods. */ class ReadOperations { public: const std::string m_configName; DBusServer &m_server; ReadOperations(const std::string &config_name, DBusServer &server); /** the double dictionary used to represent configurations */ typedef std::map< std::string, StringMap > Config_t; /** the array of reports filled by getReports() */ typedef std::vector< StringMap > Reports_t; /** the array of databases used by getDatabases() */ typedef SyncSource::Database SourceDatabase; typedef SyncSource::Databases SourceDatabases_t; /** implementation of D-Bus GetConfigs() */ void getConfigs(bool getTemplates, std::vector &configNames); /** implementation of D-Bus GetConfig() for m_configName as server configuration */ void getConfig(bool getTemplate, Config_t &config); /** implementation of D-Bus GetReports() for m_configName as server configuration */ void getReports(uint32_t start, uint32_t count, Reports_t &reports); /** Session.CheckSource() */ void checkSource(const string &sourceName); /** Session.GetDatabases() */ void getDatabases(const string &sourceName, SourceDatabases_t &databases); private: /** * This virtual function is used to let subclass set * filters to config. Only used internally. * Return true if filters exists and have been set. * Otherwise, nothing is set to config */ virtual bool setFilters(SyncConfig &config) { return false; } /** * utility method which constructs a SyncConfig which references a local configuration (never a template) * * In general, the config must exist, except in two cases: * - configName = @default (considered always available) * - mustExist = false (used when reading a templates for a context which might not exist yet) */ boost::shared_ptr getLocalConfig(const std::string &configName, bool mustExist = true); }; /** * dbus_traits for SourceDatabase. Put it here for * avoiding polluting gxx-dbus-bridge.h */ template<> struct dbus_traits : public dbus_struct_traits > > >{}; /** * Automatic termination and track clients * The dbus server will automatic terminate once it is idle in a given time. * If any attached clients or connections, it never terminate. * Once no actives, timer is started to detect the time of idle. * Note that there will be less-than TERM_INTERVAL inaccuracy in seconds, * that's because we do check every TERM_INTERVAL seconds. */ class AutoTerm { int m_refs; time_t m_interval; guint m_checkSource; time_t m_lastUsed; /** * This callback is called as soon as we might have to terminate. * If it finds that the server has been used in the meantime, it * will simply set another timeout and check again later. */ static gboolean checkCallback(gpointer data) { AutoTerm *at = static_cast(data); if (!at->m_refs) { // currently idle, but also long enough? time_t now = time(NULL); if (at->m_lastUsed + at->m_interval <= now) { // yes, shut down event loop and daemon shutdownRequested = true; g_main_loop_quit(loop); } else { // check again later at->m_checkSource = g_timeout_add_seconds(at->m_lastUsed + at->m_interval - now, checkCallback, data); } } // always remove the current timeout, its job is done return FALSE; } public: /** * constructor * If interval is less than 0, it means 'unlimited' and never terminate */ AutoTerm(int interval) : m_refs(0), m_checkSource(0), m_lastUsed(0) { if (interval <= 0) { m_interval = 0; // increasing reference counts prevents shutdown forever ref(); } else { m_interval = interval; } reset(); } ~AutoTerm() { if (m_checkSource) { g_source_remove(m_checkSource); } } //increase the actives objects void ref(int refs = 1) { m_refs += refs; reset(); } //decrease the actives objects void unref(int refs = 1) { m_refs -= refs; if(m_refs <= 0) { m_refs = 0; } reset(); } /** * To be called each time the server interacts with a client, * which includes adding or removing a client. If necessary, * this installs a timeout to stop the daemon when it has been * idle long enough. */ void reset() { if (m_refs > 0) { // in use, don't need timeout if (m_checkSource) { g_source_remove(m_checkSource); m_checkSource = 0; } } else { // An already active timeout will trigger at the chosen time, // then notice that the server has been used in the meantime and // reset the timer. Therefore we don't have to remove it. m_lastUsed = time(NULL); if (!m_checkSource) { m_checkSource = g_timeout_add_seconds(m_interval, checkCallback, static_cast(this)); } } } }; class InfoReq; /** * Query bluetooth devices from org.bluez * The basic workflow is: * 1) get default adapter from bluez by calling 'DefaultAdapter' method of org.bluez.Manager * 2) get all devices of the adapter by calling 'ListDevices' method of org.bluez.Adapter * 3) iterate all devices and get properties for each one by calling 'GetProperties' method of org.bluez.Device. * Then check its UUIDs whether it contains sync services and put it in the sync device list if it is * * To track changes of devices dynamically, here also listen signals from bluez: * org.bluez.Manager - DefaultAdapterChanged: default adapter is changed and thus have to get its devices * and update sync device list * org.bluez.Adapter - DeviceCreated, DeviceRemoved: device is created or removed and device list is updated * org.bluez.Device - PropertyChanged: property is changed and device information is changed and tracked * * This class is to manage querying bluetooth devices from org.bluez. Also * it acts a proxy to org.bluez.Manager. */ class BluezManager : public DBusRemoteObject { public: BluezManager(DBusServer &server); virtual const char *getDestination() const {return "org.bluez";} virtual const char *getPath() const {return "/";} virtual const char *getInterface() const {return "org.bluez.Manager";} virtual DBusConnection *getConnection() const {return m_bluezConn.get();} bool isDone() { return m_done; } private: class BluezDevice; /** * This class acts a proxy to org.bluez.Adapter. * Call methods of org.bluez.Adapter and listen signals from it * to get devices list and track its changes */ class BluezAdapter: public DBusRemoteObject { public: BluezAdapter (BluezManager &manager, const string &path); virtual const char *getDestination() const {return "org.bluez";} virtual const char *getPath() const {return m_path.c_str();} virtual const char *getInterface() const {return "org.bluez.Adapter";} virtual DBusConnection *getConnection() const {return m_manager.getConnection();} void checkDone(bool forceDone = false) { if(forceDone || m_devReplies >= m_devNo) { m_devReplies = m_devNo = 0; m_manager.setDone(true); } else { m_manager.setDone(false); } } std::vector >& getDevices() { return m_devices; } private: /** callback of 'ListDevices' signal. Used to get all available devices of the adapter */ void listDevicesCb(const std::vector &devices, const string &error); /** callback of 'DeviceRemoved' signal. Used to track a device is removed */ void deviceRemoved(const DBusObject_t &object); /** callback of 'DeviceCreated' signal. Used to track a new device is created */ void deviceCreated(const DBusObject_t &object); BluezManager &m_manager; /** the object path of adapter */ std::string m_path; /** the number of device for the default adapter */ int m_devNo; /** the number of devices having reply */ int m_devReplies; /** all available devices */ std::vector > m_devices; /** represents 'DeviceRemoved' signal of org.bluez.Adapter*/ SignalWatch1 m_deviceRemoved; /** represents 'DeviceAdded' signal of org.bluez.Adapter*/ SignalWatch1 m_deviceAdded; friend class BluezDevice; }; /** * This class acts a proxy to org.bluez.Device. * Call methods of org.bluez.Device and listen signals from it * to get properties of device and track its changes */ class BluezDevice: public DBusRemoteObject { public: typedef map, string > > PropDict; BluezDevice (BluezAdapter &adapter, const string &path); virtual const char *getDestination() const {return "org.bluez";} virtual const char *getPath() const {return m_path.c_str();} virtual const char *getInterface() const {return "org.bluez.Device";} virtual DBusConnection *getConnection() const {return m_adapter.m_manager.getConnection();} string getMac() { return m_mac; } /** * check whether the current device has sync service * if yes, put it in the adapter's sync devices list */ void checkSyncService(const std::vector &uuids); private: /** callback of 'GetProperties' method. The properties of the device is gotten */ void getPropertiesCb(const PropDict &props, const string &error); /** callback of 'PropertyChanged' signal. Changed property is tracked */ void propertyChanged(const string &name, const boost::variant, string> &prop); BluezAdapter &m_adapter; /** the object path of the device */ string m_path; /** name of the device */ string m_name; /** mac address of the device */ string m_mac; /** whether the calling of 'GetProperties' is returned */ bool m_reply; typedef SignalWatch2, string> > PropertySignal; /** represents 'PropertyChanged' signal of org.bluez.Device */ PropertySignal m_propertyChanged; friend class BluezAdapter; }; /* * check whether the data is generated. If errors, force initilization done */ void setDone(bool done) { m_done = done; } /** callback of 'DefaultAdapter' method to get the default bluetooth adapter */ void defaultAdapterCb(const DBusObject_t &adapter, const string &error); /** callback of 'DefaultAdapterChanged' signal to track changes of the default adapter */ void defaultAdapterChanged(const DBusObject_t &adapter); DBusServer &m_server; DBusConnectionPtr m_bluezConn; boost::shared_ptr m_adapter; /** represents 'DefaultAdapterChanged' signal of org.bluez.Adapter*/ SignalWatch1 m_adapterChanged; /** flag to indicate whether the calls are all returned */ bool m_done; }; /** * a listener to listen changes of session * currently only used to track changes of running a sync in a session */ class SessionListener { public: /** * method is called when a sync is successfully started. * Here 'successfully started' means the synthesis engine starts * to access the sources. */ virtual void syncSuccessStart() {} /** * method is called when a sync is done. Also * sync status are passed. */ virtual void syncDone(SyncMLStatus status) {} virtual ~SessionListener() {} }; /** * Manager to manage automatic sync. * Once a configuration is enabled with automatic sync, possibly http or obex-bt or both, one or more * tasks for different URLs are added in the task map, grouped by their intervals. * A task have to be checked whether there is an existing same task in the working queue. Once actived, * it is put in the working queue. * * At any time, there is at most one session for the first task. Once it is active by DBusServer, * we prepare it and make it ready to run. After completion, a new session is created again for the * next task. And so on. * * The DBusServer is in charge of dispatching requests from dbus clients and automatic sync tasks. * See DBusServer::run(). * * Here there are 3 scenarios which have been considered to do automatic sync right now: * 1) For a config enables autosync, an interval has passed. * 2) Once users log in or resume and an interval has passed. Not implemented yet. * 3) Evolution data server notify any changes. Not implemented yet. */ class AutoSyncManager : public SessionListener { DBusServer &m_server; /** * A single task for automatic sync. * Each task maintain one task for only one sync URL, which never combines * more than one sync URLs. The difference from 'syncURL' property here is * that different URLs may have different transports with different statuses. * Another reason is that SyncContext only use the first URL if it has many sync * URLs when running. So we split, schedule and process them one by one. * Each task contains one peer name, peer duration and peer url. * It is created in initialization and may be updated due to config change. * It is scheduled by AutoSyncManager to be put in the working queue. */ class AutoSyncTask { public: /** the peer name of a config */ string m_peer; /** the time that the peer must at least have been around (seconds) */ unsigned int m_delay; /** the 'syncURL' used by synchronization. It always contains only one sync URL. */ string m_url; AutoSyncTask(const string &peer, unsigned int delay, const string &url) : m_peer(peer), m_delay(delay), m_url(url) {} /** compare whether two tasks are the same. May refine it later with more information */ bool operator==(const AutoSyncTask &right) const { if(boost::iequals(m_peer, right.m_peer) && boost::iequals(m_url, right.m_url)) { return true; } return false; } }; /** * AutoSyncTaskList is used to manage sync tasks which are grouped by the * interval. Each list has one timeout gsource. */ class AutoSyncTaskList : public list { AutoSyncManager &m_manager; /** the interval used to create timeout source (seconds) */ unsigned int m_interval; /** timeout gsource */ GLibEvent m_source; /** callback of timeout source */ static gboolean taskListTimeoutCb(gpointer data); public: AutoSyncTaskList(AutoSyncManager &manager, unsigned int interval) : m_manager(manager), m_interval(interval), m_source(0) {} ~AutoSyncTaskList() { if(m_source) { g_source_remove(m_source); } } /** create timeout source once all tasks are added */ void createTimeoutSource(); /** check task list and put task into working queue */ void scheduleTaskList(); }; #ifdef HAS_NOTIFY /** * This class is to send notifications to notification server. * Notifications are sent via 'send'. Once a new noficication is * to be sent, the old notification will be closed and a new one * is created for the new requirement. */ class Notification { public: Notification(); ~Notification(); /** callback of click button(actions) of notification */ static void notifyAction(NotifyNotification *notify, gchar *action, gpointer userData); /** * send a notification in the notification server * Action for 'view' may pop up a sync-ui, but needs some * parameters. 'viewParams' is the params used by sync-ui. */ void send(const char *summary, const char *body, const char *viewParams = NULL); private: /** flag to indicate whether libnotify is initalized successfully */ bool m_init; /** flag to indicate whether libnotify accepts actions */ bool m_actions; /** the current notification */ NotifyNotification *m_notification; }; #endif /** init a config and set up auto sync task for it */ void initConfig(const string &configName); /** remove tasks from m_peerMap and m_workQueue created from the config */ void remove(const string &configName); /** a map to contain all auto sync tasks. All initialized tasks are stored here. * Tasks here are grouped by auto sync interval */ typedef std::map > PeerMap; PeerMap m_peerMap; /** * a working queue that including tasks which are pending for doing sync. * Tasks here are picked from m_peerMap and scheduled to do auto sync */ list m_workQueue; /** * the current active task, which may own a session */ boost::shared_ptr m_activeTask; /** * the only session created for active task and is put in the session queue. * at most one session at any time no matter how many tasks we actually have */ boost::shared_ptr m_session; /** the current sync of session is successfully started */ bool m_syncSuccessStart; #ifdef HAS_NOTIFY /** used to send notifications */ Notification m_notify; #endif /** * It reads all peers which are enabled to do auto sync and store them in * the m_peerMap and then add timeout sources in the main loop to schedule * auto sync tasks. */ void init(); /** operations on tasks queue */ void clearAllTasks() { m_workQueue.clear(); } /** check m_peerMap and put all tasks in it to working queue */ void scheduleAll(); /** * add an auto sync task in the working queue * Do check before adding a task in the working queue * Return true if the task is added in the list. */ bool addTask(const AutoSyncTask &syncTask); /** find an auto sync task in the working queue or is running */ bool findTask(const AutoSyncTask &syncTask); /** * check whether a task is suitable to put in the working queue * Manager has the information needed to make the decision */ bool taskLikelyToRun(const AutoSyncTask &syncTask); public: AutoSyncManager(DBusServer &server) : m_server(server), m_syncSuccessStart(false) { init(); } /** * prevent dbus server automatic termination when it has * any auto sync task enabled in the configs. * If returning true, prevent automatic termination. */ bool preventTerm() { return !m_peerMap.empty(); } /** * called when a config is changed. This causes re-loading the config */ void update(const string &configName); /* Is there any auto sync task in the queue? */ bool hasTask() { return !m_workQueue.empty(); } /** * pick the front task from the working queue and create a session for it. * The session won't be used to do sync until it is active so 'prepare' is * for calling 'sync' to make the session ready to run * If there has been a session for the front task, do nothing */ void startTask(); /** check whether the active session is owned by Automatic Sync Manger */ bool hasActiveSession(); /** set config and run sync to make the session ready to run */ void prepare(); /** * Acts as a session listener to track sync statuses if the session is * belonged to auto sync manager to do auto sync. * Two methods to listen to session sync changes. */ virtual void syncSuccessStart(); virtual void syncDone(SyncMLStatus status); }; /** * A timer helper to check whether now is timeout according to * user's setting. Timeout is calculated in milliseconds */ class Timer { timeval m_startTime; ///< start time unsigned long m_timeoutMs; ///< timeout in milliseconds, set by user /** * calculate duration between now and start time * return value is in milliseconds */ unsigned long duration(const timeval &minuend, const timeval &subtrahend) { unsigned long result = 0; if(minuend.tv_sec > subtrahend.tv_sec || (minuend.tv_sec == subtrahend.tv_sec && minuend.tv_usec > subtrahend.tv_usec)) { result = minuend.tv_sec - subtrahend.tv_sec; result *= 1000; result += (minuend.tv_usec - subtrahend.tv_usec) / 1000; } return result; } public: /** * constructor * @param timeoutMs timeout in milliseconds */ Timer(unsigned long timeoutMs = 0) : m_timeoutMs(timeoutMs) { reset(); } /** * reset the timer and mark start time as current time */ void reset() { gettimeofday(&m_startTime, NULL); } /** * check whether it is timeout */ bool timeout() { return timeout(m_timeoutMs); } /** * check whether the duration timer records is longer than the given duration */ bool timeout(unsigned long timeoutMs) { timeval now; gettimeofday(&now, NULL); return duration(now, m_startTime) >= timeoutMs; } }; class PresenceStatus { bool m_httpPresence; bool m_btPresence; bool m_initiated; DBusServer &m_server; /** two timers to record when the statuses of network and bt are changed */ Timer m_httpTimer; Timer m_btTimer; enum PeerStatus { /* The transport is not available (local problem) */ NOTRANSPORT, /* The peer is not contactable (remote problem) */ UNREACHABLE, /* Not for sure whether the peer is presence but likely*/ MIGHTWORK, INVALID }; typedef map > > StatusMap; typedef pair > > StatusPair; typedef pair PeerStatusPair; StatusMap m_peers; static std::string status2string (PeerStatus status) { switch (status) { case NOTRANSPORT: return "no transport"; break; case UNREACHABLE: return "not present"; break; case MIGHTWORK: return ""; break; case INVALID: return "invalid transport status"; } // not reached, keep compiler happy return ""; } public: PresenceStatus (DBusServer &server) :m_httpPresence (false), m_btPresence (false), m_initiated (false), m_server (server), m_httpTimer(), m_btTimer() { } enum TransportType{ HTTP_TRANSPORT, BT_TRANSPORT, INVALID_TRANSPORT }; void init(); /* Implement DBusServer::checkPresence*/ void checkPresence (const string &peer, string& status, std::vector &transport); void updateConfigPeers (const std::string &peer, const ReadOperations::Config_t &config); void updatePresenceStatus (bool httpPresence, bool btPresence); void updatePresenceStatus (bool newStatus, TransportType type); bool getHttpPresence() { return m_httpPresence; } bool getBtPresence() { return m_btPresence; } Timer& getHttpTimer() { return m_httpTimer; } Timer& getBtTimer() { return m_btTimer; } }; /* * Implements org.moblin.connman.Manager * GetProperty : getPropCb * PropertyChanged: propertyChanged **/ class ConnmanClient : public DBusRemoteObject { public: ConnmanClient (DBusServer &server); virtual const char *getDestination() const {return "org.moblin.connman";} virtual const char *getPath() const {return "/";} virtual const char *getInterface() const {return "org.moblin.connman.Manager";} virtual DBusConnection *getConnection() const {return m_connmanConn.get();} void propertyChanged(const string &name, const boost::variant, string> &prop); void getPropCb(const std::map > >& props, const string &error); private: DBusServer &m_server; DBusConnectionPtr m_connmanConn; SignalWatch2 , string> > m_propertyChanged; }; /** * Implements the main org.syncevolution.Server interface. * * All objects created by it get a reference to the creating * DBusServer instance so that they can call some of its * methods. Because that instance holds references to all * of these objects and deletes them before destructing itself, * that reference is guaranteed to remain valid. */ class DBusServer : public DBusObjectHelper, public LoggerBase { GMainLoop *m_loop; uint32_t m_lastSession; typedef std::list< std::pair< boost::shared_ptr, boost::shared_ptr > > Clients_t; Clients_t m_clients; /* clients that attach the server explicitly * the pair is . Each attach has * to be matched with one detach. */ std::list > m_attachedClients; /* Event source that regurally pool network manager * */ GLibEvent m_pollConnman; /** * The session which currently holds the main lock on the server. * To avoid issues with concurrent modification of data or configs, * only one session may make such modifications at a time. A * plain pointer which is reset by the session's deconstructor. * * A weak pointer alone did not work because it does not provide access * to the underlying pointer after the last corresponding shared * pointer is gone (which triggers the deconstructing of the session). */ Session *m_activeSession; /** * The weak pointer that corresponds to m_activeSession. */ boost::weak_ptr m_activeSessionRef; /** * The running sync session. Having a separate reference to it * ensures that the object won't go away prematurely, even if all * clients disconnect. */ boost::shared_ptr m_syncSession; typedef std::list< boost::weak_ptr > WorkQueue_t; /** * A queue of pending, idle Sessions. Sorted by priority, most * important one first. Currently this is used to give client * requests a boost over remote connections and (in the future) * automatic syncs. * * Active sessions are removed from this list and then continue * to exist as long as a client in m_clients references it or * it is the currently running sync session (m_syncSession). */ WorkQueue_t m_workQueue; /** * a hash of pending InfoRequest */ typedef std::map > InfoReqMap; // hash map of pending info requests InfoReqMap m_infoReqMap; // the index of last info request uint32_t m_lastInfoReq; // a hash to represent matched templates for devices, the key is // the peer name typedef std::map > MatchedTemplates; MatchedTemplates m_matchedTempls; BluezManager m_bluezManager; /** devices which have sync services */ SyncConfig::DeviceList m_syncDevices; /** * Watch callback for a specific client or connection. */ void clientGone(Client *c); /** Server.Attach() */ void attachClient(const Caller_t &caller, const boost::shared_ptr &watch); /** Server.Detach() */ void detachClient(const Caller_t &caller); /** Server.Connect() */ void connect(const Caller_t &caller, const boost::shared_ptr &watch, const StringMap &peer, bool must_authenticate, const std::string &session, DBusObject_t &object); /** Server.StartSession() */ void startSession(const Caller_t &caller, const boost::shared_ptr &watch, const std::string &server, DBusObject_t &object); /** Server.GetConfig() */ void getConfig(const std::string &config_name, bool getTemplate, ReadOperations::Config_t &config) { ReadOperations ops(config_name, *this); ops.getConfig(getTemplate , config); } /** Server.GetReports() */ void getReports(const std::string &config_name, uint32_t start, uint32_t count, ReadOperations::Reports_t &reports) { ReadOperations ops(config_name, *this); ops.getReports(start, count, reports); } /** Server.CheckSource() */ void checkSource(const std::string &configName, const std::string &sourceName) { ReadOperations ops(configName, *this); ops.checkSource(sourceName); } /** Server.GetDatabases() */ void getDatabases(const std::string &configName, const string &sourceName, ReadOperations::SourceDatabases_t &databases) { ReadOperations ops(configName, *this); ops.getDatabases(sourceName, databases); } void getConfigs(bool getTemplates, std::vector &configNames) { ReadOperations ops("", *this); ops.getConfigs(getTemplates, configNames); } /** Server.CheckPresence() */ void checkPresence(const std::string &server, std::string &status, std::vector &transports); /** Server.GetSessions() */ void getSessions(std::vector &sessions); /** Server.InfoResponse() */ void infoResponse(const Caller_t &caller, const std::string &id, const std::string &state, const std::map &response); friend class InfoReq; /** emit InfoRequest */ void emitInfoReq(const InfoReq &); /** get the next id of InfoRequest */ std::string getNextInfoReq(); /** remove InfoReq from hash map */ void removeInfoReq(const InfoReq &req); /* * Decrease refs for a client. If allRefs, it tries to remove all refs from 'Attach()' * for the client. Otherwise, decrease one ref for the client. */ void detachClientRefs(const Caller_t &caller, bool allRefs); /** Server.SessionChanged */ EmitSignal2 sessionChanged; /** Server.PresenceChanged */ EmitSignal3 presence; /** * Server.TemplatesChanged, triggered each time m_syncDevices, the * input for the templates, is changed */ EmitSignal0 templatesChanged; /** Server.InfoRequest */ EmitSignal6 &> infoRequest; /** Server.LogOutput */ EmitSignal3 logOutput; friend class Session; PresenceStatus m_presence; ConnmanClient m_connman; /** manager to automatic sync */ AutoSyncManager m_autoSync; //automatic termination AutoTerm m_autoTerm; //records the parent logger, dbus server acts as logger to //send signals to clients and put logs in the parent logger. LoggerBase &m_parentLogger; public: DBusServer(GMainLoop *loop, const DBusConnectionPtr &conn, int duration); ~DBusServer(); /** access to the GMainLoop reference used by this DBusServer instance */ GMainLoop *getLoop() { return m_loop; } /** process D-Bus calls until the server is ready to quit */ void run(); /** * look up client by its ID */ boost::shared_ptr findClient(const Caller_t &ID); /** * find client by its ID or create one anew */ boost::shared_ptr addClient(const DBusConnectionPtr &conn, const Caller_t &ID, const boost::shared_ptr &watch); /** detach this resource from all clients which own it */ void detach(Resource *resource); /** * Enqueue a session. Might also make it ready immediately, * if nothing else is first in the queue. To be called * by the creator of the session, *after* the session is * ready to run. */ void enqueue(const boost::shared_ptr &session); /** * Remove all sessions with this device ID from the * queue. If the active session also has this ID, * the session will be aborted and/or deactivated. */ int killSessions(const std::string &peerDeviceID); /** * Remove a session from the work queue. If it is running a sync, * it will keep running and nothing will change. Otherwise, if it * is "ready" (= holds a lock on its configuration), then release * that lock. */ void dequeue(Session *session); /** * Checks whether the server is ready to run another session * and if so, activates the first one in the queue. */ void checkQueue(); boost::shared_ptr createInfoReq(const string &type, const std::map ¶meters, const Session *session); void autoTermRef(int counts = 1) { m_autoTerm.ref(counts); } void autoTermUnref(int counts = 1) { m_autoTerm.unref(counts); } /** callback to reset for auto termination checking */ void autoTermCallback() { m_autoTerm.reset(); } /** poll_nm callback for connman, used for presence detection*/ void connmanCallback(const std::map > >& props, const string &error); PresenceStatus& getPresenceStatus() {return m_presence;} void clearPeerTempls() { m_matchedTempls.clear(); } void addPeerTempl(const string &templName, const boost::shared_ptr peerTempl); boost::shared_ptr getPeerTempl(const string &peer); /** * methods to operate device list. See DeviceList definition. * The device id here is the identifier of device, the same as definition in DeviceList. * In bluetooth devices, it refers to actually the mac address of the bluetooth. * The finger print and match mode is used to match templates. */ /** get sync devices */ void getDeviceList(SyncConfig::DeviceList &devices); /** get a device according to device id. If not found, return false. */ bool getDevice(const string &deviceId, SyncConfig::DeviceDescription &device); /** add a device */ void addDevice(const SyncConfig::DeviceDescription &device); /** remove a device by device id. If not found, do nothing */ void removeDevice(const string &deviceId); /** update a device with the given device information. If not found, do nothing */ void updateDevice(const string &deviceId, const SyncConfig::DeviceDescription &device); /** emit a presence signal */ void emitPresence(const string &server, const string &status, const string &transport) { presence(server, status, transport); } /** * Returns new unique session ID. Implemented with a running * counter. Checks for overflow, but not currently for active * sessions. */ std::string getNextSession(); AutoSyncManager &getAutoSyncManager() { return m_autoSync; } /** * implement virtual method from LogStdout. * Not only print the message in the console * but also send them as signals to clients */ virtual void messagev(Level level, const char *prefix, const char *file, int line, const char *function, const char *format, va_list args); }; /** * Tracks a single client and all sessions and connections that it is * connected to. Referencing them ensures that they stay around as * long as needed. */ class Client { typedef std::list< boost::shared_ptr > Resources_t; Resources_t m_resources; public: const Caller_t m_ID; Client(const Caller_t &ID) : m_ID(ID) {} ~Client() { SE_LOG_DEBUG(NULL, NULL, "D-Bus client %s is destructing", m_ID.c_str()); } /** * Attach a specific resource to this client. As long as the * resource is attached, it cannot be freed. Can be called * multiple times, which means that detach() also has to be called * the same number of times to finally detach the resource. */ void attach(boost::shared_ptr resource) { m_resources.push_back(resource); } /** * Detach once from the given resource. Has to be called as * often as attach() to really remove all references to the * session. It's an error to call detach() more often than * attach(). */ void detach(Resource *resource) { for (Resources_t::iterator it = m_resources.begin(); it != m_resources.end(); ++it) { if (it->get() == resource) { // got it m_resources.erase(it); return; } } SE_THROW_EXCEPTION(InvalidCall, "cannot detach from resource that client is not attached to"); } void detach(boost::shared_ptr resource) { detach(resource.get()); } /** * Remove all references to the given resource, regardless whether * it was referenced not at all or multiple times. */ void detachAll(Resource *resource) { Resources_t::iterator it = m_resources.begin(); while (it != m_resources.end()) { if (it->get() == resource) { it = m_resources.erase(it); } else { ++it; } } } void detachAll(boost::shared_ptr resource) { detachAll(resource.get()); } /** * return corresponding smart pointer for a certain resource, * empty pointer if not found */ boost::shared_ptr findResource(Resource *resource) { for (Resources_t::iterator it = m_resources.begin(); it != m_resources.end(); ++it) { if (it->get() == resource) { // got it return *it; } } return boost::shared_ptr(); } }; struct SourceStatus { SourceStatus() : m_mode("none"), m_status("idle"), m_error(0) {} void set(const std::string &mode, const std::string &status, uint32_t error) { m_mode = mode; m_status = status; m_error = error; } std::string m_mode; std::string m_status; uint32_t m_error; }; template<> struct dbus_traits : public dbus_struct_traits > > > {}; struct SourceProgress { SourceProgress() : m_phase(""), m_prepareCount(-1), m_prepareTotal(-1), m_sendCount(-1), m_sendTotal(-1), m_receiveCount(-1), m_receiveTotal(-1) {} std::string m_phase; int32_t m_prepareCount, m_prepareTotal; int32_t m_sendCount, m_sendTotal; int32_t m_receiveCount, m_receiveTotal; }; template<> struct dbus_traits : public dbus_struct_traits > > > > > > > {}; /** * This class is mainly to implement two virtual functions 'askPassword' * and 'savePassword' of ConfigUserInterface. The main functionality is * to only get and save passwords in the gnome keyring. */ class DBusUserInterface : public SyncContext { public: DBusUserInterface(const std::string &config); /* * Ask password from gnome keyring, if not found, empty string * is returned */ string askPassword(const string &passwordName, const string &descr, const ConfigPasswordKey &key); //save password to gnome keyring, if not successful, false is returned. bool savePassword(const string &passwordName, const string &password, const ConfigPasswordKey &key); /** * Read stdin via InfoRequest/Response. */ void readStdin(string &content); }; /** * A running sync engine which keeps answering on D-Bus whenever * possible and updates the Session while the sync runs. */ class DBusSync : public DBusUserInterface { Session &m_session; public: DBusSync(const std::string &config, Session &session); ~DBusSync() {} protected: virtual boost::shared_ptr createTransportAgent(); virtual void displaySyncProgress(sysync::TProgressEventEnum type, int32_t extra1, int32_t extra2, int32_t extra3); virtual void displaySourceProgress(sysync::TProgressEventEnum type, SyncSource &source, int32_t extra1, int32_t extra2, int32_t extra3); virtual void reportStepCmd(sysync::uInt16 stepCmd); /** called when a sync is successfully started */ virtual void syncSuccessStart(); /** * Implement checkForSuspend and checkForAbort. * They will check whether dbus clients suspend * or abort the session in addition to checking * whether suspend/abort were requested via * signals, using SyncContext's signal handling. */ virtual bool checkForSuspend(); virtual bool checkForAbort(); virtual int sleep(int intervals); /** * Implement askPassword to retrieve password in gnome-keyring. * If not found, then ask it from dbus clients. */ string askPassword(const string &passwordName, const string &descr, const ConfigPasswordKey &key); }; /** * Hold progress info and try to estimate current progress */ class ProgressData { public: /** * big steps, each step contains many operations, such as * data prepare, message send/receive. * The partitions of these steps are based on profiling data * for many usage scenarios and different sync modes */ enum ProgressStep { /** an invalid step */ PRO_SYNC_INVALID = 0, /** * sync prepare step: do some preparations and checkings, * such as source preparation, engine preparation */ PRO_SYNC_PREPARE, /** * session init step: transport connection set up, * start a session, authentication and dev info generation * normally it needs one time syncML messages send-receive. * Sometimes it may need messages send/receive many times to * handle authentication */ PRO_SYNC_INIT, /** * prepare sync data and send data, also receive data from server. * Also may need send/receive messages more than one time if too * much data. * assume 5 items to be sent by default */ PRO_SYNC_DATA, /** * item receive handling, send client's status to server and * close the session * assume 5 items to be received by default */ PRO_SYNC_UNINIT, /** number of sync steps */ PRO_SYNC_TOTAL }; /** * internal mode to represent whether it is possible that data is sent to * server or received from server. This could help remove some incorrect * hypothesis. For example, if only to client, then it is no data item * sending to server. */ enum InternalMode { INTERNAL_NONE = 0, INTERNAL_ONLY_TO_CLIENT = 1, INTERNAL_ONLY_TO_SERVER = 1 << 1, INTERNAL_TWO_WAY = 1 + (1 << 1) }; /** * treat a one-time send-receive without data items * as an internal standard unit. * below are ratios of other operations compared to one * standard unit. * These ratios might be dynamicall changed in the future. */ /** PRO_SYNC_PREPARE step ratio to standard unit */ static const float PRO_SYNC_PREPARE_RATIO = 0.2; /** data prepare for data items to standard unit. All are combined by profiling data */ static const float DATA_PREPARE_RATIO = 0.10; /** one data item send's ratio to standard unit */ static const float ONEITEM_SEND_RATIO = 0.05; /** one data item receive&parse's ratio to standard unit */ static const float ONEITEM_RECEIVE_RATIO = 0.05; /** connection setup to standard unit */ static const float CONN_SETUP_RATIO = 0.5; /** assume the number of data items */ static const int DEFAULT_ITEMS = 5; /** default times of message send/receive in each step */ static const int MSG_SEND_RECEIVE_TIMES = 1; ProgressData(int32_t &progress); /** * change the big step */ void setStep(ProgressStep step); /** * calc progress when a message is sent */ void sendStart(); /** * calc progress when a message is received from server */ void receiveEnd(); /** * re-calc progress proportions according to syncmode hint * typically, if only refresh-from-client, then * client won't receive data items. */ void addSyncMode(SyncMode mode); /** * calc progress when data prepare for sending */ void itemPrepare(); /** * calc progress when a data item is received */ void itemReceive(const string &source, int count, int total); private: /** update progress data */ void updateProg(float ratio); /** dynamically adapt the proportion of each step by their current units */ void recalc(); /** internally check sync mode */ void checkInternalMode(); /** get total units of current step and remaining steps */ float getRemainTotalUnits(); /** get default units of given step */ static float getDefaultUnits(ProgressStep step); private: /** a reference of progress percentage */ int32_t &m_progress; /** current big step */ ProgressStep m_step; /** count of message send/receive in current step. Cleared in the start of a new step */ int m_sendCounts; /** internal sync mode combinations */ int m_internalMode; /** proportions when each step is end */ float m_syncProp[PRO_SYNC_TOTAL]; /** remaining units of each step according to current step */ float m_syncUnits[PRO_SYNC_TOTAL]; /** proportion of a standard unit, may changes dynamically */ float m_propOfUnit; /** current sync source */ string m_source; }; class CmdlineWrapper; /** * Represents and implements the Session interface. Use * boost::shared_ptr to track it and ensure that there are references * to it as long as the connection is needed. */ class Session : public DBusObjectHelper, public Resource, private ReadOperations, private boost::noncopyable { DBusServer &m_server; const std::string m_sessionID; std::string m_peerDeviceID; bool m_serverMode; SharedBuffer m_initialMessage; string m_initialMessageType; boost::weak_ptr m_connection; std::string m_connectionError; bool m_useConnection; /** temporary config changes */ FilterConfigNode::ConfigFilter m_syncFilter; FilterConfigNode::ConfigFilter m_sourceFilter; typedef std::map SourceFilters_t; SourceFilters_t m_sourceFilters; /** whether dbus clients set temporary configs */ bool m_tempConfig; /** whether dbus clients update or clear configs, not include temporary set */ bool m_setConfig; /** * True while clients are allowed to make calls other than Detach(), * which is always allowed. Some calls are not allowed while this * session runs a sync, which is indicated by a non-NULL m_sync * pointer. */ bool m_active; /** * Indicates whether this session was initiated by the peer or locally. */ bool m_remoteInitiated; /** * The SyncEvolution instance which currently prepares or runs a sync. */ boost::shared_ptr m_sync; /** * the sync status for session */ enum SyncStatus { SYNC_QUEUEING, ///< waiting to become ready for use SYNC_IDLE, ///< ready, session is initiated but sync not started SYNC_RUNNING, ///< sync is running SYNC_ABORT, ///< sync is aborting SYNC_SUSPEND, ///< sync is suspending SYNC_DONE, ///< sync is done SYNC_ILLEGAL }; /** current sync status */ SyncStatus m_syncStatus; /** step info: whether engine is waiting for something */ bool m_stepIsWaiting; /** * Priority which determines position in queue. * Lower is more important. PRI_DEFAULT is zero. */ int m_priority; int32_t m_progress; /** progress data, holding progress calculation related info */ ProgressData m_progData; typedef std::map SourceStatuses_t; SourceStatuses_t m_sourceStatus; uint32_t m_error; typedef std::map SourceProgresses_t; SourceProgresses_t m_sourceProgress; /** timer for fire status/progress usages */ Timer m_statusTimer; Timer m_progressTimer; /** restore used */ string m_restoreDir; bool m_restoreBefore; /** the total number of sources to be restored */ int m_restoreSrcTotal; /** the number of sources that have been restored */ int m_restoreSrcEnd; enum RunOperation { OP_SYNC = 0, OP_RESTORE = 1, OP_CMDLINE = 2, OP_NULL }; static string runOpToString(RunOperation op); RunOperation m_runOperation; /** listener to listen to changes of sync */ SessionListener *m_listener; /** Cmdline to execute command line args */ boost::shared_ptr m_cmdline; /** Session.Detach() */ void detach(const Caller_t &caller); /** Session.GetStatus() */ void getStatus(std::string &status, uint32_t &error, SourceStatuses_t &sources); /** Session.GetProgress() */ void getProgress(int32_t &progress, SourceProgresses_t &sources); /** Session.Restore() */ void restore(const string &dir, bool before,const std::vector &sources); /** Session.checkPresence() */ void checkPresence (string &status); /** Session.Execute() */ void execute(const vector &args, const map &vars); /** * Must be called each time that properties changing the * overall status are changed. Ensures that the corresponding * D-Bus signal is sent. * * Doesn't always send the signal immediately, because often it is * likely that more status changes will follow shortly. To ensure * that the "final" status is sent, call with flush=true. * * @param flush force sending the current status */ void fireStatus(bool flush = false); /** like fireStatus() for progress information */ void fireProgress(bool flush = false); /** Session.StatusChanged */ EmitSignal3 emitStatus; /** Session.ProgressChanged */ EmitSignal2 emitProgress; static string syncStatusToString(SyncStatus state); public: Session(DBusServer &server, const std::string &peerDeviceID, const std::string &config_name, const std::string &session); ~Session(); enum { PRI_CMDLINE = -10, PRI_DEFAULT = 0, PRI_CONNECTION = 10, PRI_AUTOSYNC = 20 }; /** * Default priority is 0. Higher means less important. */ void setPriority(int priority) { m_priority = priority; } int getPriority() const { return m_priority; } void initServer(SharedBuffer data, const std::string &messageType); void setConnection(const boost::shared_ptr c) { m_connection = c; m_useConnection = c; } boost::weak_ptr getConnection() { return m_connection; } bool useConnection() { return m_useConnection; } /** * After the connection closes, the Connection instance is * destructed immediately. This is necessary so that the * corresponding cleanup can remove all other classes * only referenced by the Connection. * * This leads to the problem that an active sync cannot * query the final error code of the connection. This * is solved by setting a generic error code here when * the sync starts and overwriting it when the connection * closes. */ void setConnectionError(const std::string error) { m_connectionError = error; } std::string getConnectionError() { return m_connectionError; } DBusServer &getServer() { return m_server; } std::string getConfigName() { return m_configName; } std::string getSessionID() const { return m_sessionID; } std::string getPeerDeviceID() const { return m_peerDeviceID; } /** * TRUE if the session is ready to take over control */ bool readyToRun() { return (m_syncStatus != SYNC_DONE) && (m_runOperation != OP_NULL); } /** * transfer control to the session for the duration of the sync, * returns when the sync is done (successfully or unsuccessfully) */ void run(); /** * called when the session is ready to run (true) or * lost the right to make changes (false) */ void setActive(bool active); bool getActive() { return m_active; } void syncProgress(sysync::TProgressEventEnum type, int32_t extra1, int32_t extra2, int32_t extra3); void sourceProgress(sysync::TProgressEventEnum type, SyncSource &source, int32_t extra1, int32_t extra2, int32_t extra3); string askPassword(const string &passwordName, const string &descr, const ConfigPasswordKey &key); /** Session.SetConfig() */ void setConfig(bool update, bool temporary, const ReadOperations::Config_t &config); typedef StringMap SourceModes_t; /** Session.Sync() */ void sync(const std::string &mode, const SourceModes_t &source_modes); /** Session.Abort() */ void abort(); /** Session.Suspend() */ void suspend(); bool isSuspend() { return m_syncStatus == SYNC_SUSPEND; } bool isAbort() { return m_syncStatus == SYNC_ABORT; } /** * step info for engine: whether the engine is blocked by something * If yes, 'waiting' will be appended as specifiers in the status string. * see GetStatus documentation. */ void setStepInfo(bool isWaiting); /** sync is successfully started */ void syncSuccessStart(); /** * add a listener of the session. Old set listener is returned */ SessionListener* addListener(SessionListener *listener); void setRemoteInitiated (bool remote) { m_remoteInitiated = remote;} private: /** set m_syncFilter and m_sourceFilters to config */ virtual bool setFilters(SyncConfig &config); }; /** * a wrapper to maintain the execution of command line * arguments from dbus clients. It is in charge of * redirecting output of cmd line to logging system. */ class CmdlineWrapper { /** * inherit from stream buf to redirect the output. * Set a log until we gets a '\n' separator since we know * the command line message often ends with '\n'. The reason * is to avoid setting less characters in one log and thus * sending many signals to dbus clients. */ class CmdlineStreamBuf : public std::streambuf { public: virtual ~CmdlineStreamBuf() { //flush cached characters if(!m_str.empty()) { SE_LOG(LoggerBase::SHOW, NULL, NULL, "%s", m_str.c_str()); } } protected: /** * inherit from std::streambuf, all characters are cached in m_str * until a character '\n' is reached. */ virtual int_type overflow (int_type ch) { if(ch == '\n') { //don't append this character for logging system will append it SE_LOG(LoggerBase::SHOW, NULL, NULL, "%s", m_str.c_str()); m_str.clear(); } else if (ch != EOF) { m_str += ch; } return ch; } /** the cached output characters */ string m_str; }; /** streambuf used for m_cmdlineOutStream */ CmdlineStreamBuf m_outStreamBuf; /** stream for command line out and err arguments */ std::ostream m_cmdlineOutStream; /** * implement factory method to create DBusSync instances * This can check 'abort' and 'suspend' command from clients. */ class DBusCmdline : public Cmdline { Session &m_session; public: DBusCmdline(Session &session, const vector &args, ostream &out, ostream &err) :Cmdline(args, out, err), m_session(session) {} SyncContext* createSyncClient() { return new DBusSync(m_server, m_session); } }; /** instance to run command line arguments */ DBusCmdline m_cmdline; /** environment variables passed from client */ map m_envVars; public: /** * constructor to create cmdline instance. * Here just one stream is used and error message in * command line is output to this stream for it is * different from Logger::ERROR. */ CmdlineWrapper(Session &session, const vector &args, const map &vars) : m_cmdlineOutStream(&m_outStreamBuf), m_cmdline(session, args, m_cmdlineOutStream, m_cmdlineOutStream), m_envVars(vars) {} bool parse() { return m_cmdline.parse(); } void run() { //temporarily set environment variables and restore them after running list > changes; BOOST_FOREACH(const StringPair &var, m_envVars) { changes.push_back(boost::shared_ptr(new ScopedEnvChange(var.first, var.second))); } // exceptions must be handled (= printed) before returning, // so that our client gets the output try { if (!m_cmdline.run()) { SE_THROW_EXCEPTION(DBusSyncException, "command line execution failure"); } } catch (...) { redirectPtr->flush(); throw; } // always forward all currently pending redirected output // before closing the session redirectPtr->flush(); } }; /** * Represents and implements the Connection interface. * * The connection interacts with a Session by creating the Session and * exchanging data with it. For that, the connection registers itself * with the Session and unregisters again when it goes away. * * In contrast to clients, the Session only keeps a weak_ptr, which * becomes invalid when the referenced object gets deleted. Typically * this means the Session has to abort, unless reconnecting is * supported. */ class Connection : public DBusObjectHelper, public Resource { DBusServer &m_server; StringMap m_peer; bool m_mustAuthenticate; enum { SETUP, /**< ready for first message */ PROCESSING, /**< received message, waiting for engine's reply */ WAITING, /**< waiting for next follow-up message */ FINAL, /**< engine has sent final reply, wait for ACK by peer */ DONE, /**< peer has closed normally after the final reply */ FAILED /**< in a failed state, no further operation possible */ } m_state; std::string m_failure; /** first parameter for Session::sync() */ std::string m_syncMode; /** second parameter for Session::sync() */ Session::SourceModes_t m_sourceModes; const std::string m_sessionID; boost::shared_ptr m_session; /** * main loop that our DBusTransportAgent is currently waiting in, * NULL if not waiting */ GMainLoop *m_loop; /** * get our peer session out of the DBusTransportAgent, * if it is currently waiting for us (indicated via m_loop) */ void wakeupSession(); /** * buffer for received data, waiting here for engine to ask * for it via DBusTransportAgent::getReply(). */ SharedBuffer m_incomingMsg; std::string m_incomingMsgType; struct SANContent { std::vector m_syncType; std::vector m_contentType; std::vector m_serverURI; }; /** * The content of a parsed SAN package to be processed via * connection.ready */ boost::shared_ptr m_SANContent; std::string m_peerBtAddr; /** * records the reason for the failure, sends Abort signal and puts * the connection into the FAILED state. */ void failed(const std::string &reason); /** * returns " ( via )" */ static std::string buildDescription(const StringMap &peer); /** Connection.Process() */ void process(const Caller_t &caller, const std::pair &message, const std::string &message_type); /** Connection.Close() */ void close(const Caller_t &caller, bool normal, const std::string &error); /** wrapper around sendAbort */ void abort(); /** Connection.Abort */ EmitSignal0 sendAbort; bool m_abortSent; /** Connection.Reply */ EmitSignal5 &, const std::string &, const StringMap &, bool, const std::string &> reply; friend class DBusTransportAgent; public: const std::string m_description; Connection(DBusServer &server, const DBusConnectionPtr &conn, const std::string &session_num, const StringMap &peer, bool must_authenticate); ~Connection(); /** session requested by us is ready to run a sync */ void ready(); /** connection is no longer needed, ensure that it gets deleted */ void shutdown(); /** peer is not trusted, must authenticate as part of SyncML */ bool mustAuthenticate() const { return m_mustAuthenticate; } }; /** * A proxy for a Connection instance. The Connection instance can go * away (weak pointer, must be locked and and checked each time it is * needed). The agent must remain available as long as the engine * needs and basically becomes unusuable once the connection dies. * * Reconnecting is not currently supported. */ class DBusTransportAgent : public TransportAgent { GMainLoop *m_loop; Session &m_session; boost::weak_ptr m_connection; std::string m_url; std::string m_type; /* * When the callback is invoked, we always abort the current * transmission. If it is invoked while we are not in the wait() * of this transport, then we remember that in m_eventTriggered * and return from wait() right away. The main loop is only * quit when the transport is waiting in it. This is a precaution * to not interfere with other parts of the code. */ TransportCallback m_callback; void *m_callbackData; int m_callbackInterval; GLibEvent m_eventSource; bool m_eventTriggered; bool m_waiting; SharedBuffer m_incomingMsg; std::string m_incomingMsgType; void doWait(boost::shared_ptr &connection); static gboolean timeoutCallback(gpointer transport); public: DBusTransportAgent(GMainLoop *loop, Session &session, boost::weak_ptr connection); ~DBusTransportAgent(); virtual void setURL(const std::string &url) { m_url = url; } virtual void setContentType(const std::string &type) { m_type = type; } virtual void send(const char *data, size_t len); virtual void cancel() {} virtual void shutdown(); virtual Status wait(bool noReply = false); virtual void setCallback (TransportCallback cb, void * udata, int interval) { m_callback = cb; m_callbackData = udata; m_callbackInterval = interval; m_eventSource = 0; } virtual void getReply(const char *&data, size_t &len, std::string &contentType); }; /** * A wrapper for handling info request and response. */ class InfoReq { public: typedef std::map InfoMap; // status of current request enum Status { ST_RUN, // request is running ST_OK, // ok, response is gotten ST_TIMEOUT, // timeout ST_CANCEL // request is cancelled }; /** * constructor * The default timeout is 120 seconds */ InfoReq(DBusServer &server, const string &type, const InfoMap ¶meters, const Session *session, uint32_t timeout = 120); ~InfoReq(); /** * check whether the request is ready. Also give an opportunity * to poll the sources and then check the response is ready * @return the state of the request */ Status check(); /** * wait the response until timeout, abort or suspend. It may be blocked. * The response is returned though the parameter 'response' when the Status is * 'ST_OK'. Otherwise, corresponding statuses are returned. * @param response the received response if gotten * @param interval the interval to check abort, suspend and timeout, in seconds * @return the current status */ Status wait(InfoMap &response, uint32_t interval = 3); /** * get response when it is ready. If false, nothing will be set in response */ bool getResponse(InfoMap &response); /** cancel the request. If request is done, cancel won't do anything */ void cancel(); /** get current status in string format */ string getStatusStr() const { return statusToString(m_status); } private: static string statusToString(Status status); enum InfoState { IN_REQ, //request IN_WAIT, // waiting IN_DONE // done }; static string infoStateToString(InfoState state); /** callback for the timemout source */ static gboolean checkCallback(gpointer data); /** check whether the request is timeout */ bool checkTimeout(); friend class DBusServer; /** set response from dbus clients */ void setResponse(const Caller_t &caller, const string &state, const InfoMap &response); /** send 'done' state if needed */ void done(); string getId() const { return m_id; } string getSessionPath() const { return m_session ? m_session->getPath() : ""; } string getInfoStateStr() const { return infoStateToString(m_infoState); } string getHandler() const { return m_handler; } string getType() const { return m_type; } const InfoMap& getParam() const { return m_param; } DBusServer &m_server; /** caller's session, might be NULL */ const Session *m_session; /** unique id of this info request */ string m_id; /** info req state defined in dbus api */ InfoState m_infoState; /** status to indicate the info request is timeout, ok, abort, etc */ Status m_status; /** the handler of the responsed dbus client */ Caller_t m_handler; /** the type of the info request */ string m_type; /** parameters from info request callers */ InfoMap m_param; /** response returned from dbus clients */ InfoMap m_response; /** default timeout is 120 seconds */ uint32_t m_timeout; /** a timer */ Timer m_timer; }; /***************** ReadOperations implementation ****************/ ReadOperations::ReadOperations(const std::string &config_name, DBusServer &server) : m_configName(config_name), m_server(server) {} void ReadOperations::getConfigs(bool getTemplates, std::vector &configNames) { if (getTemplates) { // get device list from dbus server, currently only bluetooth devices SyncConfig::DeviceList devices; m_server.getDeviceList(devices); //clear existing templates in dbus server m_server.clearPeerTempls(); SyncConfig::TemplateList list = SyncConfig::getPeerTemplates(devices); std::map numbers; BOOST_FOREACH(const boost::shared_ptr peer, list) { //if it is not a template for device if(peer->m_fingerprint.empty()) { configNames.push_back(peer->m_templateId); } else { string templName = "Bluetooth_"; templName += peer->m_deviceId; templName += "_"; std::map::iterator it = numbers.find(peer->m_deviceId); if(it == numbers.end()) { numbers.insert(std::make_pair(peer->m_deviceId, 1)); templName += "1"; } else { it->second++; stringstream seq; seq << it->second; templName += seq.str(); } configNames.push_back(templName); m_server.addPeerTempl(templName, peer); } } } else { SyncConfig::ConfigList list = SyncConfig::getConfigs(); BOOST_FOREACH(const SyncConfig::ConfigList::value_type &server, list) { configNames.push_back(server.first); } } } boost::shared_ptr ReadOperations::getLocalConfig(const string &configName, bool mustExist) { string peer, context; SyncConfig::splitConfigString(SyncConfig::normalizeConfigString(configName), peer, context); boost::shared_ptr syncConfig(new DBusUserInterface(configName)); /** if config was not set temporarily */ if (!setFilters(*syncConfig)) { // the default configuration can always be opened for reading, // everything else must exist if ((context != "default" || peer != "") && mustExist && !syncConfig->exists()) { SE_THROW_EXCEPTION(NoSuchConfig, "No configuration '" + configName + "' found"); } } return syncConfig; } void ReadOperations::getConfig(bool getTemplate, Config_t &config) { map localConfigs; boost::shared_ptr dbusConfig; boost::shared_ptr dbusUI; SyncConfig *syncConfig; string syncURL; /** get server template */ if(getTemplate) { string peer, context; boost::shared_ptr peerTemplate = m_server.getPeerTempl(m_configName); if(peerTemplate) { SyncConfig::splitConfigString(SyncConfig::normalizeConfigString(peerTemplate->m_templateId), peer, context); dbusConfig = SyncConfig::createPeerTemplate(peerTemplate->m_path); // if we have cached template information, add match information for it localConfigs.insert(pair("description", peerTemplate->m_description)); stringstream score; score << peerTemplate->m_rank; localConfigs.insert(pair("score", score.str())); // Actually this fingerprint is transferred by getConfigs, which refers to device name localConfigs.insert(pair("deviceName", peerTemplate->m_fingerprint)); // This is the fingerprint of the template localConfigs.insert(pair("fingerPrint", peerTemplate->m_matchedModel)); // This is the template name presented to UI (or device class) if (!peerTemplate->m_templateName.empty()) { localConfigs.insert(pair("templateName", peerTemplate->m_templateName)); } // if the peer is client, then replace syncURL with bluetooth // MAC address syncURL = "obex-bt://"; syncURL += peerTemplate->m_deviceId; } else { SyncConfig::splitConfigString(SyncConfig::normalizeConfigString(m_configName), peer, context); dbusConfig = SyncConfig::createPeerTemplate(peer); } if(!dbusConfig.get()) { SE_THROW_EXCEPTION(NoSuchConfig, "No template '" + m_configName + "' found"); } // use the shared properties from the right context as filter // so that the returned template preserves existing properties boost::shared_ptr shared = getLocalConfig(string("@") + context, false); ConfigProps props; shared->getProperties()->readProperties(props); dbusConfig->setConfigFilter(true, "", props); BOOST_FOREACH(std::string source, shared->getSyncSources()) { SyncSourceNodes nodes = shared->getSyncSourceNodes(source, ""); props.clear(); nodes.getProperties()->readProperties(props); // Special case "type" property: the value in the context // is not preserved. Every new peer must ensure that // its own value is compatible (= same backend) with // the other peers. props.erase("type"); dbusConfig->setConfigFilter(false, source, props); } syncConfig = dbusConfig.get(); } else { dbusUI = getLocalConfig(m_configName); //try to check password and read password from gnome keyring if possible ConfigPropertyRegistry& registry = SyncConfig::getRegistry(); BOOST_FOREACH(const ConfigProperty *prop, registry) { prop->checkPassword(*dbusUI, m_configName, *dbusUI->getProperties()); } list configuredSources = dbusUI->getSyncSources(); BOOST_FOREACH(const string &sourceName, configuredSources) { ConfigPropertyRegistry& registry = SyncSourceConfig::getRegistry(); SyncSourceNodes sourceNodes = dbusUI->getSyncSourceNodes(sourceName); BOOST_FOREACH(const ConfigProperty *prop, registry) { prop->checkPassword(*dbusUI, m_configName, *dbusUI->getProperties(), sourceName, sourceNodes.getProperties()); } } syncConfig = dbusUI.get(); } /** get sync properties and their values */ ConfigPropertyRegistry &syncRegistry = SyncConfig::getRegistry(); BOOST_FOREACH(const ConfigProperty *prop, syncRegistry) { bool isDefault = false; string value = prop->getProperty(*syncConfig->getProperties(), &isDefault); if(boost::iequals(prop->getName(), "syncURL") && !syncURL.empty() ) { localConfigs.insert(pair(prop->getName(), syncURL)); } else if(!isDefault) { localConfigs.insert(pair(prop->getName(), value)); } } // insert 'configName' of the chosen config (m_configName is not normalized) localConfigs.insert(pair("configName", syncConfig->getConfigName())); config.insert(pair >("", localConfigs)); /* get configurations from sources */ list sources = syncConfig->getSyncSources(); BOOST_FOREACH(const string &name, sources) { localConfigs.clear(); SyncSourceNodes sourceNodes = syncConfig->getSyncSourceNodes(name); ConfigPropertyRegistry &sourceRegistry = SyncSourceConfig::getRegistry(); BOOST_FOREACH(const ConfigProperty *prop, sourceRegistry) { bool isDefault = false; string value = prop->getProperty(*sourceNodes.getProperties(), &isDefault); if(!isDefault) { localConfigs.insert(pair(prop->getName(), value)); } } config.insert(pair >( "source/" + name, localConfigs)); } } void ReadOperations::getReports(uint32_t start, uint32_t count, Reports_t &reports) { SyncContext client(m_configName, false); std::vector dirs; client.getSessions(dirs); uint32_t index = 0; // newest report firstly for( int i = dirs.size() - 1; i >= 0; --i) { /** if start plus count is bigger than actual size, then return actual - size reports */ if(index >= start && index - start < count) { const string &dir = dirs[i]; std::map aReport; // insert a 'dir' as an ID for the current report aReport.insert(pair("dir", dir)); SyncReport report; // peerName is also extracted from the dir string peerName = client.readSessionInfo(dir,report); boost::shared_ptr config(new SyncConfig(m_configName)); string storedPeerName = config->getPeerName(); //if can't find peer name, use the peer name from the log dir if(!storedPeerName.empty()) { peerName = storedPeerName; } /** serialize report to ConfigProps and then copy them to reports */ HashFileConfigNode node("/dev/null","",true); node << report; ConfigProps props; node.readProperties(props); BOOST_FOREACH(const ConfigProps::value_type &entry, props) { aReport.insert(entry); } // a new key-value pair <"peer", [peer name]> is transferred aReport.insert(pair("peer", peerName)); reports.push_back(aReport); } index++; } } void ReadOperations::checkSource(const std::string &sourceName) { boost::shared_ptr config(new SyncConfig(m_configName)); setFilters(*config); list sourceNames = config->getSyncSources(); list::iterator it; for(it = sourceNames.begin(); it != sourceNames.end(); ++it) { if(*it == sourceName) { break; } } if(it == sourceNames.end()) { SE_THROW_EXCEPTION(NoSuchSource, "'" + m_configName + "' has no '" + sourceName + "' source"); } bool checked = false; try { // this can already throw exceptions when the config is invalid SyncSourceParams params(sourceName, config->getSyncSourceNodes(sourceName)); auto_ptr syncSource(SyncSource::createSource(params, false, config.get())); if (syncSource.get()) { syncSource->open(); // success! checked = true; } } catch (...) { Exception::handle(); } if (!checked) { SE_THROW_EXCEPTION(SourceUnusable, "The source '" + sourceName + "' is not usable"); } } void ReadOperations::getDatabases(const string &sourceName, SourceDatabases_t &databases) { boost::shared_ptr config(new SyncConfig(m_configName)); setFilters(*config); SyncSourceParams params(sourceName, config->getSyncSourceNodes(sourceName)); const SourceRegistry ®istry(SyncSource::getSourceRegistry()); BOOST_FOREACH(const RegisterSyncSource *sourceInfo, registry) { SyncSource *source = sourceInfo->m_create(params); if (!source) { continue; } else if (source == RegisterSyncSource::InactiveSource) { SE_THROW_EXCEPTION(NoSuchSource, "'" + m_configName + "' backend of source '" + sourceName + "' is not supported"); } else { auto_ptr autoSource(source); databases = autoSource->getDatabases(); return; } } SE_THROW_EXCEPTION(NoSuchSource, "'" + m_configName + "' has no '" + sourceName + "' source"); } /***************** DBusUserInterface implementation **********************/ DBusUserInterface::DBusUserInterface(const std::string &config): SyncContext(config, true) { } inline const char *passwdStr(const std::string &str) { return str.empty() ? NULL : str.c_str(); } string DBusUserInterface::askPassword(const string &passwordName, const string &descr, const ConfigPasswordKey &key) { string password; #ifdef USE_GNOME_KEYRING /** here we use server sync url without protocol prefix and * user account name as the key in the keyring */ /* It is possible to let CmdlineSyncClient decide which of fields in ConfigPasswordKey it would use * but currently only use passed key instead */ GnomeKeyringResult result; GList* list; result = gnome_keyring_find_network_password_sync(passwdStr(key.user), passwdStr(key.domain), passwdStr(key.server), passwdStr(key.object), passwdStr(key.protocol), passwdStr(key.authtype), key.port, &list); /** if find password stored in gnome keyring */ if(result == GNOME_KEYRING_RESULT_OK && list && list->data ) { GnomeKeyringNetworkPasswordData *key_data; key_data = (GnomeKeyringNetworkPasswordData*)list->data; password = key_data->password; gnome_keyring_network_password_list_free(list); return password; } #endif //if not found, return empty return ""; } bool DBusUserInterface::savePassword(const string &passwordName, const string &password, const ConfigPasswordKey &key) { #ifdef USE_GNOME_KEYRING /* It is possible to let CmdlineSyncClient decide which of fields in ConfigPasswordKey it would use * but currently only use passed key instead */ guint32 itemId; GnomeKeyringResult result; // write password to keyring result = gnome_keyring_set_network_password_sync(NULL, passwdStr(key.user), passwdStr(key.domain), passwdStr(key.server), passwdStr(key.object), passwdStr(key.protocol), passwdStr(key.authtype), key.port, password.c_str(), &itemId); /* if set operation is failed */ if(result != GNOME_KEYRING_RESULT_OK) { #ifdef GNOME_KEYRING_220 SyncContext::throwError("Try to save " + passwordName + " in gnome-keyring but get an error. " + gnome_keyring_result_to_message(result)); #else /** if gnome-keyring version is below 2.20, it doesn't support 'gnome_keyring_result_to_message'. */ stringstream value; value << (int)result; SyncContext::throwError("Try to save " + passwordName + " in gnome-keyring but get an error. The gnome-keyring error code is " + value.str() + "."); #endif } return true; #else /** if no support of gnome-keyring, don't save anything */ return false; #endif } void DBusUserInterface::readStdin(string &content) { throwError("reading stdin in D-Bus server not supported, use --daemon=no in command line"); } /***************** DBusSync implementation **********************/ DBusSync::DBusSync(const std::string &config, Session &session) : DBusUserInterface(config), m_session(session) { } boost::shared_ptr DBusSync::createTransportAgent() { if (m_session.useConnection()) { // use the D-Bus Connection to send and receive messages boost::shared_ptr agent(new DBusTransportAgent(m_session.getServer().getLoop(), m_session, m_session.getConnection())); // We don't know whether we'll run as client or server. // But we as we cannot resend messages via D-Bus even if running as // client (API not designed for it), let's use the hard timeout // from RetryDuration here. int timeout = getRetryDuration(); if (timeout) { agent->setCallback(transport_cb, reinterpret_cast(static_cast(timeout)), timeout); } return agent; } else { // no connection, use HTTP via libsoup/GMainLoop GMainLoop *loop = m_session.getServer().getLoop(); boost::shared_ptr agent = SyncContext::createTransportAgent(loop); return agent; } } void DBusSync::displaySyncProgress(sysync::TProgressEventEnum type, int32_t extra1, int32_t extra2, int32_t extra3) { SyncContext::displaySyncProgress(type, extra1, extra2, extra3); m_session.syncProgress(type, extra1, extra2, extra3); } void DBusSync::displaySourceProgress(sysync::TProgressEventEnum type, SyncSource &source, int32_t extra1, int32_t extra2, int32_t extra3) { SyncContext::displaySourceProgress(type, source, extra1, extra2, extra3); m_session.sourceProgress(type, source, extra1, extra2, extra3); } void DBusSync::reportStepCmd(sysync::uInt16 stepCmd) { switch(stepCmd) { case sysync::STEPCMD_SENDDATA: case sysync::STEPCMD_RESENDDATA: case sysync::STEPCMD_NEEDDATA: //sending or waiting data m_session.setStepInfo(true); break; default: // otherwise, processing m_session.setStepInfo(false); break; } } void DBusSync::syncSuccessStart() { m_session.syncSuccessStart(); } bool DBusSync::checkForSuspend() { return m_session.isSuspend() || SyncContext::checkForSuspend(); } bool DBusSync::checkForAbort() { return m_session.isAbort() || SyncContext::checkForAbort(); } int DBusSync::sleep(int intervals) { time_t start = time(NULL); while (true) { g_main_context_iteration(NULL, false); time_t now = time(NULL); if (checkForSuspend() || checkForAbort()) { return (intervals - now + start); } if (intervals - now + start <= 0) { return intervals - now +start; } } } string DBusSync::askPassword(const string &passwordName, const string &descr, const ConfigPasswordKey &key) { string password = DBusUserInterface::askPassword(passwordName, descr, key); if(password.empty()) { password = m_session.askPassword(passwordName, descr, key); } return password; } /***************** Session implementation ***********************/ void Session::detach(const Caller_t &caller) { boost::shared_ptr client(m_server.findClient(caller)); if (!client) { throw runtime_error("unknown client"); } client->detach(this); } static void setSyncFilters(const ReadOperations::Config_t &config,FilterConfigNode::ConfigFilter &syncFilter,std::map &sourceFilters) { ReadOperations::Config_t::const_iterator it; for (it = config.begin(); it != config.end(); it++) { map::const_iterator sit; if(it->first.empty()) { for (sit = it->second.begin(); sit != it->second.end(); sit++) { syncFilter.insert(*sit); } } else { string name = it->first; if(name.find("source/") == 0) { name = name.substr(7); ///> 7 is the length of "source/" FilterConfigNode::ConfigFilter &sourceFilter = sourceFilters[name]; for (sit = it->second.begin(); sit != it->second.end(); sit++) { sourceFilter.insert(*sit); } } } } } void Session::setConfig(bool update, bool temporary, const ReadOperations::Config_t &config) { if (!m_active) { SE_THROW_EXCEPTION(InvalidCall, "session is not active, call not allowed at this time"); } if (m_runOperation != OP_NULL) { string msg = StringPrintf("%s started, cannot change configuration at this time", runOpToString(m_runOperation).c_str()); SE_THROW_EXCEPTION(InvalidCall, msg); } if (!update && temporary) { throw std::runtime_error("Clearing existing configuration and temporary configuration changes which only affects the duration of the session are mutually exclusive"); } m_server.getPresenceStatus().updateConfigPeers (m_configName, config); /** check whether we need remove the entire configuration */ if(!update && config.empty()) { boost::shared_ptr syncConfig(new SyncConfig(getConfigName())); if(syncConfig.get()) { syncConfig->remove(); } return; } if(temporary) { /* save temporary configs in session filters */ setSyncFilters(config, m_syncFilter, m_sourceFilters); m_tempConfig = true; } else { FilterConfigNode::ConfigFilter syncFilter; std::map sourceFilters; setSyncFilters(config, syncFilter, sourceFilters); /* need to save configurations */ boost::shared_ptr from(new SyncConfig(getConfigName())); /* if it is not clear mode and config does not exist, an error throws */ if(update && !from->exists()) { SE_THROW_EXCEPTION(NoSuchConfig, "The configuration '" + getConfigName() + "' doesn't exist" ); } if(!update) { list sources = from->getSyncSources(); list::iterator it; for(it = sources.begin(); it != sources.end(); ++it) { string source = "source/"; source += *it; ReadOperations::Config_t::const_iterator configIt = config.find(source); if(configIt == config.end()) { /** if no config for this source, we remove it */ from->removeSyncSource(*it); } else { /** just clear visiable properties, remove them and their values */ from->clearSyncSourceProperties(*it); } } from->clearSyncProperties(); } /** generate new sources in the config map */ for (ReadOperations::Config_t::const_iterator it = config.begin(); it != config.end(); ++it) { string sourceName = it->first; if(sourceName.find("source/") == 0) { sourceName = sourceName.substr(7); ///> 7 is the length of "source/" from->getSyncSourceNodes(sourceName); } } /* apply user settings */ from->setConfigFilter(true, "", syncFilter); map::iterator it; for ( it = sourceFilters.begin(); it != sourceFilters.end(); it++ ) { from->setConfigFilter(false, it->first, it->second); } boost::shared_ptr syncConfig(new DBusSync(getConfigName(), *this)); syncConfig->copy(*from, NULL); syncConfig->preFlush(*syncConfig); syncConfig->flush(); m_setConfig = true; } } void Session::initServer(SharedBuffer data, const std::string &messageType) { m_serverMode = true; m_initialMessage = data; m_initialMessageType = messageType; } void Session::sync(const std::string &mode, const SourceModes_t &source_modes) { if (!m_active) { SE_THROW_EXCEPTION(InvalidCall, "session is not active, call not allowed at this time"); } if (m_runOperation == OP_SYNC) { string msg = StringPrintf("%s started, cannot start again", runOpToString(m_runOperation).c_str()); SE_THROW_EXCEPTION(InvalidCall, msg); } else if (m_runOperation != OP_NULL) { string msg = StringPrintf("%s started, cannot start sync", runOpToString(m_runOperation).c_str()); SE_THROW_EXCEPTION(InvalidCall, msg); } m_sync.reset(new DBusSync(getConfigName(), *this)); if (m_serverMode) { m_sync->initServer(m_sessionID, m_initialMessage, m_initialMessageType); boost::shared_ptr c = m_connection.lock(); if (c && !c->mustAuthenticate()) { // unsetting username/password disables checking them m_syncFilter["password"] = ""; m_syncFilter["username"] = ""; } } if (m_remoteInitiated) { m_sync->setRemoteInitiated (true); } // Apply temporary config filters. The parameters of this function // override the source filters, if set. m_sync->setConfigFilter(true, "", m_syncFilter); FilterConfigNode::ConfigFilter filter; filter = m_sourceFilter; if (!mode.empty()) { filter[SyncSourceConfig::m_sourcePropSync.getName()] = mode; } m_sync->setConfigFilter(false, "", filter); BOOST_FOREACH(const std::string &source, m_sync->getSyncSources()) { filter = m_sourceFilters[source]; SourceModes_t::const_iterator it = source_modes.find(source); if (it != source_modes.end()) { filter[SyncSourceConfig::m_sourcePropSync.getName()] = it->second; } m_sync->setConfigFilter(false, source, filter); } // Update status and progress. From now on, all configured sources // have their default entry (referencing them by name creates the // entry). BOOST_FOREACH(const std::string source, m_sync->getSyncSources()) { m_sourceStatus[source]; m_sourceProgress[source]; } fireProgress(true); fireStatus(true); m_runOperation = OP_SYNC; // now that we have a DBusSync object, return from the main loop // and once that is done, transfer control to that object g_main_loop_quit(loop); } void Session::abort() { if (m_runOperation != OP_SYNC && m_runOperation != OP_CMDLINE) { SE_THROW_EXCEPTION(InvalidCall, "sync not started, cannot abort at this time"); } m_syncStatus = SYNC_ABORT; fireStatus(true); // state change, return to caller so that it can react g_main_loop_quit(m_server.getLoop()); } void Session::suspend() { if (m_runOperation != OP_SYNC && m_runOperation != OP_CMDLINE) { SE_THROW_EXCEPTION(InvalidCall, "sync not started, cannot suspend at this time"); } m_syncStatus = SYNC_SUSPEND; fireStatus(true); g_main_loop_quit(m_server.getLoop()); } void Session::getStatus(std::string &status, uint32_t &error, SourceStatuses_t &sources) { status = syncStatusToString(m_syncStatus); if (m_stepIsWaiting) { status += ";waiting"; } error = m_error; sources = m_sourceStatus; } void Session::getProgress(int32_t &progress, SourceProgresses_t &sources) { progress = m_progress; sources = m_sourceProgress; } void Session::fireStatus(bool flush) { std::string status; uint32_t error; SourceStatuses_t sources; /** not force flushing and not timeout, return */ if(!flush && !m_statusTimer.timeout()) { return; } m_statusTimer.reset(); getStatus(status, error, sources); emitStatus(status, error, sources); } void Session::fireProgress(bool flush) { int32_t progress; SourceProgresses_t sources; /** not force flushing and not timeout, return */ if(!flush && !m_progressTimer.timeout()) { return; } m_progressTimer.reset(); getProgress(progress, sources); emitProgress(progress, sources); } string Session::syncStatusToString(SyncStatus state) { switch(state) { case SYNC_QUEUEING: return "queueing"; case SYNC_IDLE: return "idle"; case SYNC_RUNNING: return "running"; case SYNC_ABORT: return "aborting"; case SYNC_SUSPEND: return "suspending"; case SYNC_DONE: return "done"; default: return ""; }; } Session::Session(DBusServer &server, const std::string &peerDeviceID, const std::string &config_name, const std::string &session) : DBusObjectHelper(server.getConnection(), std::string("/org/syncevolution/Session/") + session, "org.syncevolution.Session", boost::bind(&DBusServer::autoTermCallback, &server)), ReadOperations(config_name, server), m_server(server), m_sessionID(session), m_peerDeviceID(peerDeviceID), m_serverMode(false), m_useConnection(false), m_tempConfig(false), m_setConfig(false), m_active(false), m_remoteInitiated(false), m_syncStatus(SYNC_QUEUEING), m_stepIsWaiting(false), m_priority(PRI_DEFAULT), m_progress(0), m_progData(m_progress), m_error(0), m_statusTimer(100), m_progressTimer(50), m_restoreBefore(true), m_restoreSrcTotal(0), m_restoreSrcEnd(0), m_runOperation(OP_NULL), m_listener(NULL), emitStatus(*this, "StatusChanged"), emitProgress(*this, "ProgressChanged") { add(this, &Session::detach, "Detach"); add(static_cast(this), &ReadOperations::getConfigs, "GetConfigs"); add(static_cast(this), &ReadOperations::getConfig, "GetConfig"); add(this, &Session::setConfig, "SetConfig"); add(static_cast(this), &ReadOperations::getReports, "GetReports"); add(static_cast(this), &ReadOperations::checkSource, "CheckSource"); add(static_cast(this), &ReadOperations::getDatabases, "GetDatabases"); add(this, &Session::sync, "Sync"); add(this, &Session::abort, "Abort"); add(this, &Session::suspend, "Suspend"); add(this, &Session::getStatus, "GetStatus"); add(this, &Session::getProgress, "GetProgress"); add(this, &Session::restore, "Restore"); add(this, &Session::checkPresence, "checkPresence"); add(this, &Session::execute, "Execute"); add(emitStatus); add(emitProgress); } Session::~Session() { /* update auto sync manager when a config is changed */ if(m_setConfig) { m_server.getAutoSyncManager().update(m_configName); } m_server.dequeue(this); } void Session::setActive(bool active) { m_active = active; if (active) { if (m_syncStatus == SYNC_QUEUEING) { m_syncStatus = SYNC_IDLE; fireStatus(true); } boost::shared_ptr c = m_connection.lock(); if (c) { c->ready(); } } } void Session::syncProgress(sysync::TProgressEventEnum type, int32_t extra1, int32_t extra2, int32_t extra3) { switch(type) { case sysync::PEV_SESSIONSTART: m_progData.setStep(ProgressData::PRO_SYNC_INIT); fireProgress(true); break; case sysync::PEV_SESSIONEND: if((uint32_t)extra1 != m_error) { m_error = extra1; fireStatus(true); } m_progData.setStep(ProgressData::PRO_SYNC_INVALID); fireProgress(true); break; case sysync::PEV_SENDSTART: m_progData.sendStart(); break; case sysync::PEV_SENDEND: case sysync::PEV_RECVSTART: case sysync::PEV_RECVEND: m_progData.receiveEnd(); fireProgress(); break; case sysync::PEV_DISPLAY100: case sysync::PEV_SUSPENDCHECK: case sysync::PEV_DELETING: break; case sysync::PEV_SUSPENDING: m_syncStatus = SYNC_SUSPEND; fireStatus(true); break; default: ; } } void Session::sourceProgress(sysync::TProgressEventEnum type, SyncSource &source, int32_t extra1, int32_t extra2, int32_t extra3) { switch(m_runOperation) { case OP_SYNC: { SourceProgress &progress = m_sourceProgress[source.getName()]; SourceStatus &status = m_sourceStatus[source.getName()]; switch(type) { case sysync::PEV_SYNCSTART: if(source.getFinalSyncMode() != SYNC_NONE) { m_progData.setStep(ProgressData::PRO_SYNC_UNINIT); fireProgress(); } break; case sysync::PEV_SYNCEND: if(source.getFinalSyncMode() != SYNC_NONE) { status.set(PrettyPrintSyncMode(source.getFinalSyncMode()), "done", extra1); fireStatus(true); } break; case sysync::PEV_PREPARING: if(source.getFinalSyncMode() != SYNC_NONE) { progress.m_phase = "preparing"; progress.m_prepareCount = extra1; progress.m_prepareTotal = extra2; m_progData.itemPrepare(); fireProgress(true); } break; case sysync::PEV_ITEMSENT: if(source.getFinalSyncMode() != SYNC_NONE) { progress.m_phase = "sending"; progress.m_sendCount = extra1; progress.m_sendTotal = extra2; fireProgress(true); } break; case sysync::PEV_ITEMRECEIVED: if(source.getFinalSyncMode() != SYNC_NONE) { progress.m_phase = "receiving"; progress.m_receiveCount = extra1; progress.m_receiveTotal = extra2; m_progData.itemReceive(source.getName(), extra1, extra2); fireProgress(true); } break; case sysync::PEV_ALERTED: if(source.getFinalSyncMode() != SYNC_NONE) { status.set(PrettyPrintSyncMode(source.getFinalSyncMode()), "running", 0); fireStatus(true); m_progData.setStep(ProgressData::PRO_SYNC_DATA); m_progData.addSyncMode(source.getFinalSyncMode()); fireProgress(); } break; default: ; } break; } case OP_RESTORE: { switch(type) { case sysync::PEV_ALERTED: // count the total number of sources to be restored m_restoreSrcTotal++; break; case sysync::PEV_SYNCSTART: { if (source.getFinalSyncMode() != SYNC_NONE) { SourceStatus &status = m_sourceStatus[source.getName()]; // set statuses as 'restore-from-backup' status.set(PrettyPrintSyncMode(source.getFinalSyncMode()), "running", 0); fireStatus(true); } break; } case sysync::PEV_SYNCEND: { if (source.getFinalSyncMode() != SYNC_NONE) { m_restoreSrcEnd++; SourceStatus &status = m_sourceStatus[source.getName()]; status.set(PrettyPrintSyncMode(source.getFinalSyncMode()), "done", 0); m_progress = 100 * m_restoreSrcEnd / m_restoreSrcTotal; fireStatus(true); fireProgress(true); } break; } default: break; } break; } default: break; } } void Session::run() { if (m_runOperation != OP_NULL) { try { m_syncStatus = SYNC_RUNNING; fireStatus(true); switch(m_runOperation) { case OP_SYNC: { SyncMLStatus status; m_progData.setStep(ProgressData::PRO_SYNC_PREPARE); try { status = m_sync->sync(); } catch (...) { status = m_sync->handleException(); } if (!m_error) { m_error = status; } // if there is a connection, then it is no longer needed boost::shared_ptr c = m_connection.lock(); if (c) { c->shutdown(); } // report 'sync done' event to listener if(m_listener) { m_listener->syncDone(status); } break; } case OP_RESTORE: m_sync->restore(m_restoreDir, m_restoreBefore ? SyncContext::DATABASE_BEFORE_SYNC : SyncContext::DATABASE_AFTER_SYNC); break; case OP_CMDLINE: try { m_cmdline->run(); } catch (...) { SyncMLStatus status = Exception::handle(); if (!m_error) { m_error = status; } } default: break; }; } catch (...) { // we must enter SYNC_DONE under all circumstances, // even when failing during connection shutdown m_syncStatus = SYNC_DONE; m_stepIsWaiting = false; fireStatus(true); throw; } m_syncStatus = SYNC_DONE; m_stepIsWaiting = false; fireStatus(true); } } bool Session::setFilters(SyncConfig &config) { /** apply temporary configs to config */ config.setConfigFilter(true, "", m_syncFilter); // set all sources in the filter to config BOOST_FOREACH(const SourceFilters_t::value_type &value, m_sourceFilters) { config.setConfigFilter(false, value.first, value.second); } return m_tempConfig; } void Session::setStepInfo(bool isWaiting) { // if stepInfo doesn't change, then ignore it to avoid duplicate status info if(m_stepIsWaiting != isWaiting) { m_stepIsWaiting = isWaiting; fireStatus(true); } } void Session::restore(const string &dir, bool before, const std::vector &sources) { if (!m_active) { SE_THROW_EXCEPTION(InvalidCall, "session is not active, call not allowed at this time"); } if (m_runOperation == OP_RESTORE) { string msg = StringPrintf("restore started, cannot restore again"); SE_THROW_EXCEPTION(InvalidCall, msg); } else if (m_runOperation != OP_NULL) { // actually this never happen currently, for during the real restore process, // it never poll the sources in default main context string msg = StringPrintf("%s started, cannot restore", runOpToString(m_runOperation).c_str()); SE_THROW_EXCEPTION(InvalidCall, msg); } m_sync.reset(new DBusSync(getConfigName(), *this)); if(!sources.empty()) { BOOST_FOREACH(const std::string &source, sources) { FilterConfigNode::ConfigFilter filter; filter[SyncSourceConfig::m_sourcePropSync.getName()] = "two-way"; m_sync->setConfigFilter(false, source, filter); } // disable other sources FilterConfigNode::ConfigFilter disabled; disabled[SyncSourceConfig::m_sourcePropSync.getName()] = "disabled"; m_sync->setConfigFilter(false, "", disabled); } m_restoreBefore = before; m_restoreDir = dir; m_runOperation = OP_RESTORE; // initiate status and progress and sourceProgress is not calculated currently BOOST_FOREACH(const std::string source, m_sync->getSyncSources()) { m_sourceStatus[source]; } fireProgress(true); fireStatus(true); g_main_loop_quit(loop); } string Session::runOpToString(RunOperation op) { switch(op) { case OP_SYNC: return "sync"; case OP_RESTORE: return "restore"; case OP_CMDLINE: return "cmdline"; default: return ""; }; } void Session::execute(const vector &args, const map &vars) { if (!m_active) { SE_THROW_EXCEPTION(InvalidCall, "session is not active, call not allowed at this time"); } if (m_runOperation == OP_CMDLINE) { SE_THROW_EXCEPTION(InvalidCall, "cmdline started, cannot start again"); } else if (m_runOperation != OP_NULL) { string msg = StringPrintf("%s started, cannot start cmdline", runOpToString(m_runOperation).c_str()); SE_THROW_EXCEPTION(InvalidCall, msg); } //create ostream with a specified streambuf m_cmdline.reset(new CmdlineWrapper(*this, args, vars)); if(!m_cmdline->parse()) { m_cmdline.reset(); SE_THROW_EXCEPTION(DBusSyncException, "arguments parsing error"); } m_runOperation = OP_CMDLINE; g_main_loop_quit(loop); } inline void insertPair(std::map ¶ms, const string &key, const string &value) { if(!value.empty()) { params.insert(pair(key, value)); } } string Session::askPassword(const string &passwordName, const string &descr, const ConfigPasswordKey &key) { std::map params; insertPair(params, "description", descr); insertPair(params, "user", key.user); insertPair(params, "SyncML server", key.server); insertPair(params, "domain", key.domain); insertPair(params, "object", key.object); insertPair(params, "protocol", key.protocol); insertPair(params, "authtype", key.authtype); insertPair(params, "port", key.port ? StringPrintf("%u",key.port) : ""); boost::shared_ptr req = m_server.createInfoReq("password", params, this); std::map response; if(req->wait(response) == InfoReq::ST_OK) { std::map::iterator it = response.find("password"); if (it == response.end()) { SE_THROW_EXCEPTION_STATUS(StatusException, "user didn't provide password, abort", SyncMLStatus(sysync::LOCERR_USERABORT)); } else { return it->second; } } SE_THROW_EXCEPTION_STATUS(StatusException, "can't get the password from clients. The password request is '" + req->getStatusStr() + "'", STATUS_PASSWORD_TIMEOUT); return ""; } /*Implementation of Session.CheckPresence */ void Session::checkPresence (string &status) { vector transport; m_server.m_presence.checkPresence (m_configName, status, transport); } void Session::syncSuccessStart() { // if listener, report 'sync started' to it if(m_listener) { m_listener->syncSuccessStart(); } } SessionListener* Session::addListener(SessionListener *listener) { SessionListener *old = m_listener; m_listener = listener; return old; } /************************ ProgressData implementation *****************/ ProgressData::ProgressData(int32_t &progress) : m_progress(progress), m_step(PRO_SYNC_INVALID), m_sendCounts(0), m_internalMode(INTERNAL_NONE) { /** * init default units of each step */ float totalUnits = 0.0; for(int i = 0; i < PRO_SYNC_TOTAL; i++) { float units = getDefaultUnits((ProgressStep)i); m_syncUnits[i] = units; totalUnits += units; } m_propOfUnit = 1.0 / totalUnits; /** * init default sync step proportions. each step stores proportions of * its previous steps and itself. */ m_syncProp[0] = 0; for(int i = 1; i < PRO_SYNC_TOTAL - 1; i++) { m_syncProp[i] = m_syncProp[i - 1] + m_syncUnits[i] / totalUnits; } m_syncProp[PRO_SYNC_TOTAL - 1] = 1.0; } void ProgressData::setStep(ProgressStep step) { if(m_step != step) { /** if state is changed, progress is set as the end of current step*/ m_progress = 100.0 * m_syncProp[(int)m_step]; m_step = step; ///< change to new state m_sendCounts = 0; ///< clear send/receive counts m_source = ""; ///< clear source } } void ProgressData::sendStart() { checkInternalMode(); m_sendCounts++; /* self adapts. If a new send and not default, we need re-calculate proportions */ if(m_sendCounts > MSG_SEND_RECEIVE_TIMES) { m_syncUnits[(int)m_step] += 1; recalc(); } /** * If in the send operation of PRO_SYNC_UNINIT, it often takes extra time * to send message due to items handling */ if(m_step == PRO_SYNC_UNINIT && m_syncUnits[(int)m_step] != MSG_SEND_RECEIVE_TIMES) { updateProg(DATA_PREPARE_RATIO); } } void ProgressData::receiveEnd() { /** * often receiveEnd is the last operation of each step by default. * If more send/receive, then we need expand proportion of current * step and re-calc them */ updateProg(m_syncUnits[(int)m_step]); } void ProgressData::addSyncMode(SyncMode mode) { switch(mode) { case SYNC_TWO_WAY: case SYNC_SLOW: m_internalMode |= INTERNAL_TWO_WAY; break; case SYNC_ONE_WAY_FROM_CLIENT: case SYNC_REFRESH_FROM_CLIENT: m_internalMode |= INTERNAL_ONLY_TO_CLIENT; break; case SYNC_ONE_WAY_FROM_SERVER: case SYNC_REFRESH_FROM_SERVER: m_internalMode |= INTERNAL_ONLY_TO_SERVER; break; default: ; }; } void ProgressData::itemPrepare() { checkInternalMode(); /** * only the first PEV_ITEMPREPARE event takes some time * due to data access, other events don't according to * profiling data */ if(m_source.empty()) { m_source = "source"; ///< use this to check whether itemPrepare occurs updateProg(DATA_PREPARE_RATIO); } } void ProgressData::itemReceive(const string &source, int count, int total) { /** * source is used to check whether a new source is received * If the first source, we compare its total number and default number * then re-calc sync units */ if(m_source.empty()) { m_source = source; if(total != 0) { m_syncUnits[PRO_SYNC_UNINIT] += ONEITEM_RECEIVE_RATIO * (total - DEFAULT_ITEMS); recalc(); } /** if another new source, add them into sync units */ } else if(m_source != source){ m_source = source; if(total != 0) { m_syncUnits[PRO_SYNC_UNINIT] += ONEITEM_RECEIVE_RATIO * total; recalc(); } } updateProg(ONEITEM_RECEIVE_RATIO); } void ProgressData::updateProg(float ratio) { m_progress += m_propOfUnit * 100 * ratio; m_syncUnits[(int)m_step] -= ratio; } /** dynamically adapt the proportion of each step by their current units */ void ProgressData::recalc() { float units = getRemainTotalUnits(); if(std::abs(units) < std::numeric_limits::epsilon()) { m_propOfUnit = 0.0; } else { m_propOfUnit = ( 100.0 - m_progress ) / (100.0 * units); } if(m_step != PRO_SYNC_TOTAL -1 ) { m_syncProp[(int)m_step] = m_progress / 100.0 + m_syncUnits[(int)m_step] * m_propOfUnit; for(int i = ((int)m_step) + 1; i < PRO_SYNC_TOTAL - 1; i++) { m_syncProp[i] = m_syncProp[i - 1] + m_syncUnits[i] * m_propOfUnit; } } } void ProgressData::checkInternalMode() { if(!m_internalMode) { return; } else if(m_internalMode & INTERNAL_TWO_WAY) { // don't adjust } else if(m_internalMode & INTERNAL_ONLY_TO_CLIENT) { // only to client, remove units of prepare and send m_syncUnits[PRO_SYNC_DATA] -= (ONEITEM_RECEIVE_RATIO * DEFAULT_ITEMS + DATA_PREPARE_RATIO); recalc(); } else if(m_internalMode & INTERNAL_ONLY_TO_SERVER) { // only to server, remove units of receive m_syncUnits[PRO_SYNC_UNINIT] -= (ONEITEM_RECEIVE_RATIO * DEFAULT_ITEMS + DATA_PREPARE_RATIO); recalc(); } m_internalMode = INTERNAL_NONE; } float ProgressData::getRemainTotalUnits() { float total = 0.0; for(int i = (int)m_step; i < PRO_SYNC_TOTAL; i++) { total += m_syncUnits[i]; } return total; } float ProgressData::getDefaultUnits(ProgressStep step) { switch(step) { case PRO_SYNC_PREPARE: return PRO_SYNC_PREPARE_RATIO; case PRO_SYNC_INIT: return CONN_SETUP_RATIO + MSG_SEND_RECEIVE_TIMES; case PRO_SYNC_DATA: return ONEITEM_SEND_RATIO * DEFAULT_ITEMS + DATA_PREPARE_RATIO + MSG_SEND_RECEIVE_TIMES; case PRO_SYNC_UNINIT: return ONEITEM_RECEIVE_RATIO * DEFAULT_ITEMS + DATA_PREPARE_RATIO + MSG_SEND_RECEIVE_TIMES; default: return 0; }; } /************************ Connection implementation *****************/ void Connection::failed(const std::string &reason) { if (m_failure.empty()) { m_failure = reason; if (m_session) { m_session->setConnectionError(reason); } } if (m_state != FAILED) { abort(); } m_state = FAILED; } std::string Connection::buildDescription(const StringMap &peer) { StringMap::const_iterator desc = peer.find("description"), id = peer.find("id"), trans = peer.find("transport"), trans_desc = peer.find("transport_description"); std::string buffer; buffer.reserve(256); if (desc != peer.end()) { buffer += desc->second; } if (id != peer.end() || trans != peer.end()) { if (!buffer.empty()) { buffer += " "; } buffer += "("; if (id != peer.end()) { buffer += id->second; if (trans != peer.end()) { buffer += " via "; } } if (trans != peer.end()) { buffer += trans->second; if (trans_desc != peer.end()) { buffer += " "; buffer += trans_desc->second; } } buffer += ")"; } return buffer; } void Connection::wakeupSession() { if (m_loop) { g_main_loop_quit(m_loop); m_loop = NULL; } } void Connection::process(const Caller_t &caller, const std::pair &message, const std::string &message_type) { SE_LOG_DEBUG(NULL, NULL, "D-Bus client %s sends %lu bytes via connection %s, %s", caller.c_str(), (unsigned long)message.first, getPath(), message_type.c_str()); boost::shared_ptr client(m_server.findClient(caller)); if (!client) { throw runtime_error("unknown client"); } boost::shared_ptr myself = boost::static_pointer_cast(client->findResource(this)); if (!myself) { throw runtime_error("client does not own connection"); } // any kind of error from now on terminates the connection try { switch (m_state) { case SETUP: { std::string config; std::string peerDeviceID; bool serverMode = false; // check message type, determine whether we act // as client or server, choose config if (message_type == "HTTP Config") { // type used for testing, payload is config name config.assign(reinterpret_cast(message.second), message.first); } else if (message_type == TransportAgent::m_contentTypeServerAlertedNotificationDS) { sysync::SanPackage san; if (san.PassSan(const_cast(message.second), message.first, 2) || san.GetHeader()) { // We are very tolerant regarding the content of the message. // If it doesn't parse, try to do something useful anyway. // only for SAN 1.2, for SAN 1.0/1.1 we can not be sure // whether it is a SAN package or a normal sync pacakge if (message_type == TransportAgent::m_contentTypeServerAlertedNotificationDS) { config = "default"; SE_LOG_DEBUG(NULL, NULL, "SAN parsing failed, falling back to 'default' config"); } } else { //Server alerted notification case // Extract server ID and match it against a server // configuration. Multiple different peers might use the // same serverID ("PC Suite"), so check properties of the // of our configs first before going back to the name itself. std::string serverID = san.fServerID; SyncConfig::ConfigList servers = SyncConfig::getConfigs(); BOOST_FOREACH(const SyncConfig::ConfigList::value_type &server, servers) { SyncConfig conf(server.first); vector urls = conf.getSyncURL(); BOOST_FOREACH (const string &url, urls) { if (url == serverID) { config = server.first; break; } } if (!config.empty()) { break; } } // for Bluetooth transports match against mac address. StringMap::const_iterator id = m_peer.find("id"), trans = m_peer.find("transport"); if (trans != m_peer.end() && id != m_peer.end()) { if (trans->second == "org.openobex.obexd") { m_peerBtAddr = id->second.substr(0, id->second.find("+")); BOOST_FOREACH(const SyncConfig::ConfigList::value_type &server, servers) { SyncConfig conf(server.first); vector urls = conf.getSyncURL(); BOOST_FOREACH (string &url, urls){ url = url.substr (0, url.find("+")); SE_LOG_DEBUG (NULL, NULL, "matching against %s",url.c_str()); if (url.find ("obex-bt://") ==0 && url.substr(strlen("obex-bt://"), url.npos) == m_peerBtAddr) { config = server.first; break; } } if (!config.empty()){ break; } } } } if (config.empty()) { BOOST_FOREACH(const SyncConfig::ConfigList::value_type &server, servers) { if (server.first == serverID) { config = serverID; break; } } } // create a default configuration name if none matched if (config.empty()) { config = serverID+"_"+getCurrentTime(); SE_LOG_DEBUG(NULL, NULL, "SAN Server ID '%s' unknown, falling back to automatically created '%s' config", serverID.c_str(), config.c_str()); } SE_LOG_DEBUG(NULL, NULL, "SAN sync with config %s", config.c_str()); m_SANContent.reset (new SANContent ()); // extract number of sources int numSources = san.fNSync; int syncType; uint32_t contentType; std::string serverURI; if (!numSources) { SE_LOG_DEBUG(NULL, NULL, "SAN message with no sources, using selected modes"); // Synchronize all known sources with the default mode. if (san.GetNthSync(0, syncType, contentType, serverURI)) { SE_LOG_DEBUG(NULL, NULL, "SAN invalid header, using default modes"); } else if (syncType < SYNC_FIRST || syncType > SYNC_LAST) { SE_LOG_DEBUG(NULL, NULL, "SAN invalid sync type %d, using default modes", syncType); } else { m_syncMode = PrettyPrintSyncMode(SyncMode(syncType), true); SE_LOG_DEBUG(NULL, NULL, "SAN sync mode for all configured sources: %s", m_syncMode.c_str()); } } else { for (int sync = 1; sync <= numSources; sync++) { if (san.GetNthSync(sync, syncType, contentType, serverURI)) { SE_LOG_DEBUG(NULL, NULL, "SAN invalid sync entry #%d", sync); } else if (syncType < SYNC_FIRST || syncType > SYNC_LAST) { SE_LOG_DEBUG(NULL, NULL, "SAN invalid sync type %d for entry #%d, ignoring entry", syncType, sync); } else { std::string syncMode = PrettyPrintSyncMode(SyncMode(syncType), true); m_SANContent->m_syncType.push_back (syncMode); m_SANContent->m_serverURI.push_back (serverURI); m_SANContent->m_contentType.push_back (contentType); } } } } // TODO: use the session ID set by the server if non-null } else if (// relaxed checking for XML: ignore stuff like "; CHARSET=UTF-8" message_type.substr(0, message_type.find(';')) == TransportAgent::m_contentTypeSyncML || message_type == TransportAgent::m_contentTypeSyncWBXML) { // run a new SyncML session as server serverMode = true; if (m_peer.find("config") == m_peer.end() && !m_peer["config"].empty()) { SE_LOG_DEBUG(NULL, NULL, "ignoring pre-chosen config '%s'", m_peer["config"].c_str()); } // peek into the data to extract the locURI = device ID, // then use it to find the configuration SyncContext::SyncMLMessageInfo info; info = SyncContext::analyzeSyncMLMessage(reinterpret_cast(message.second), message.first, message_type); if (info.m_deviceID.empty()) { // TODO: proper exception throw runtime_error("could not extract LocURI=deviceID from initial message"); } BOOST_FOREACH(const SyncConfig::ConfigList::value_type &entry, SyncConfig::getConfigs()) { SyncConfig peer(entry.first); if (info.m_deviceID == peer.getRemoteDevID()) { config = entry.first; SE_LOG_INFO(NULL, NULL, "matched %s against config %s (%s)", info.toString().c_str(), entry.first.c_str(), entry.second.c_str()); break; } } if (config.empty()) { // TODO: proper exception throw runtime_error(string("no configuration found for ") + info.toString()); } // abort previous session of this client m_server.killSessions(info.m_deviceID); peerDeviceID = info.m_deviceID; } else { throw runtime_error(StringPrintf("message type '%s' not supported for starting a sync", message_type.c_str())); } // run session as client or server m_state = PROCESSING; m_session.reset(new Session(m_server, peerDeviceID, config, m_sessionID)); if (serverMode) { m_session->initServer(SharedBuffer(reinterpret_cast(message.second), message.first), message_type); } m_session->setPriority(Session::PRI_CONNECTION); m_session->setConnection(myself); // this will be reset only when the connection shuts down okay // or overwritten with the error given to us in // Connection::close() m_session->setConnectionError("closed prematurely"); m_server.enqueue(m_session); break; } case PROCESSING: throw std::runtime_error("protocol error: already processing a message"); break; case WAITING: m_incomingMsg = SharedBuffer(reinterpret_cast(message.second), message.first); m_incomingMsgType = message_type; m_state = PROCESSING; // get out of DBusTransportAgent::wait() wakeupSession(); break; case FINAL: wakeupSession(); throw std::runtime_error("protocol error: final reply sent, no further message processing possible"); case DONE: throw std::runtime_error("protocol error: connection closed, no further message processing possible"); break; case FAILED: throw std::runtime_error(m_failure); break; default: throw std::runtime_error("protocol error: unknown internal state"); break; } } catch (const std::exception &error) { failed(error.what()); throw; } catch (...) { failed("unknown exception in Connection::process"); throw; } } void Connection::close(const Caller_t &caller, bool normal, const std::string &error) { SE_LOG_DEBUG(NULL, NULL, "D-Bus client %s closes connection %s %s%s%s", caller.c_str(), getPath(), normal ? "normally" : "with error", error.empty() ? "" : ": ", error.c_str()); boost::shared_ptr client(m_server.findClient(caller)); if (!client) { throw runtime_error("unknown client"); } if (!normal || m_state != FINAL) { std::string err = error.empty() ? "connection closed unexpectedly" : error; if (m_session) { m_session->setConnectionError(err); } failed(err); } else { m_state = DONE; if (m_session) { m_session->setConnectionError(""); } } // remove reference to us from client, will destruct *this* // instance! client->detach(this); } void Connection::abort() { if (!m_abortSent) { sendAbort(); m_abortSent = true; m_state = FAILED; } } void Connection::shutdown() { // trigger removal of this connection by removing all // references to it m_server.detach(this); } Connection::Connection(DBusServer &server, const DBusConnectionPtr &conn, const std::string &sessionID, const StringMap &peer, bool must_authenticate) : DBusObjectHelper(conn.get(), std::string("/org/syncevolution/Connection/") + sessionID, "org.syncevolution.Connection", boost::bind(&DBusServer::autoTermCallback, &server)), m_server(server), m_peer(peer), m_mustAuthenticate(must_authenticate), m_state(SETUP), m_sessionID(sessionID), m_loop(NULL), sendAbort(*this, "Abort"), m_abortSent(false), reply(*this, "Reply"), m_description(buildDescription(peer)) { add(this, &Connection::process, "Process"); add(this, &Connection::close, "Close"); add(sendAbort); add(reply); m_server.autoTermRef(); } Connection::~Connection() { SE_LOG_DEBUG(NULL, NULL, "done with connection to '%s'%s%s%s", m_description.c_str(), m_state == DONE ? ", normal shutdown" : " unexpectedly", m_failure.empty() ? "" : ": ", m_failure.c_str()); try { if (m_state != DONE) { abort(); } // DBusTransportAgent waiting? Wake it up. wakeupSession(); m_session.use_count(); m_session.reset(); } catch (...) { // log errors, but do not propagate them because we are // destructing Exception::handle(); } m_server.autoTermUnref(); } void Connection::ready() { //if configuration not yet created std::string configName = m_session->getConfigName(); SyncConfig config (configName); if (!config.exists() && m_SANContent) { SE_LOG_DEBUG (NULL, NULL, "Configuration %s not exists for a runnable session in a SAN context, create it automatically", configName.c_str()); ReadOperations::Config_t from; const std::string templateName = "SyncEvolution"; // TODO: support SAN from other well known servers ReadOperations ops(templateName, m_server); ops.getConfig(true , from); if (!m_peerBtAddr.empty()){ from[""]["SyncURL"] = string ("obex-bt://") + m_peerBtAddr; } m_session->setConfig (false, false, from); } const SyncContext context (configName); std::list sources = context.getSyncSources(); if (m_SANContent && !m_SANContent->m_syncType.empty()) { // check what the server wants us to synchronize // and only synchronize that m_syncMode = "disabled"; for (size_t sync=0; syncm_syncType.size(); sync++) { std::string syncMode = m_SANContent->m_syncType[sync]; std::string serverURI = m_SANContent->m_serverURI[sync]; //uint32_t contentType = m_SANContent->m_contentType[sync]; bool found = false; BOOST_FOREACH(const std::string &source, sources) { boost::shared_ptr sourceConfig(context.getSyncSourceConfig(source)); // prefix match because the local // configuration might contain // additional parameters (like date // range selection for events) if (boost::starts_with(sourceConfig->getURI(), serverURI)) { SE_LOG_DEBUG(NULL, NULL, "SAN entry #%d = source %s with mode %s", (int)sync, source.c_str(), syncMode.c_str()); m_sourceModes[source] = syncMode; found = true; break; } } if (!found) { SE_LOG_DEBUG(NULL, NULL, "SAN entry #%d with mode %s ignored because Server URI %s is unknown", (int)sync, syncMode.c_str(), serverURI.c_str()); } } if (m_sourceModes.empty()) { SE_LOG_DEBUG(NULL, NULL, "SAN message with no known entries, falling back to default"); m_syncMode = ""; } } if (m_SANContent) { m_session->setRemoteInitiated(true); } // proceed with sync now that our session is ready m_session->sync(m_syncMode, m_sourceModes); } /****************** DBusTransportAgent implementation **************/ DBusTransportAgent::DBusTransportAgent(GMainLoop *loop, Session &session, boost::weak_ptr connection) : m_loop(loop), m_session(session), m_connection(connection), m_callback(NULL), m_eventTriggered(false), m_waiting(false) { } DBusTransportAgent::~DBusTransportAgent() { boost::shared_ptr connection = m_connection.lock(); if (connection) { connection->shutdown(); } } void DBusTransportAgent::send(const char *data, size_t len) { boost::shared_ptr connection = m_connection.lock(); if (!connection) { SE_THROW_EXCEPTION(TransportException, "D-Bus peer has disconnected"); } if (connection->m_state != Connection::PROCESSING) { SE_THROW_EXCEPTION(TransportException, "cannot send to our D-Bus peer"); } // Change state in advance. If we fail while replying, then all // further resends will fail with the error above. connection->m_state = Connection::WAITING; connection->m_incomingMsg = SharedBuffer(); // setup regular callback if (m_callback) { m_eventSource = g_timeout_add_seconds(m_callbackInterval, timeoutCallback, static_cast(this)); } m_eventTriggered = false; // TODO: turn D-Bus exceptions into transport exceptions StringMap meta; meta["URL"] = m_url; connection->reply(std::make_pair(len, reinterpret_cast(data)), m_type, meta, false, connection->m_sessionID); } void DBusTransportAgent::shutdown() { boost::shared_ptr connection = m_connection.lock(); if (!connection) { SE_THROW_EXCEPTION(TransportException, "D-Bus peer has disconnected"); } if (connection->m_state != Connection::FAILED) { // send final, empty message and wait for close connection->m_state = Connection::FINAL; connection->reply(std::pair(0, 0), "", StringMap(), true, connection->m_sessionID); } } gboolean DBusTransportAgent::timeoutCallback(gpointer transport) { DBusTransportAgent *me = static_cast(transport); me->m_callback(me->m_callbackData); // TODO: check or remove return code from callback?! me->m_eventTriggered = true; if (me->m_waiting) { g_main_loop_quit(me->m_loop); } return false; } void DBusTransportAgent::doWait(boost::shared_ptr &connection) { // let Connection wake us up when it has a reply or // when it closes down connection->m_loop = m_loop; // release our reference so that the Connection instance can // be destructed when requested by the D-Bus peer connection.reset(); // now wait m_waiting = true; g_main_loop_run(m_loop); m_waiting = false; } DBusTransportAgent::Status DBusTransportAgent::wait(bool noReply) { boost::shared_ptr connection = m_connection.lock(); if (!connection) { SE_THROW_EXCEPTION(TransportException, "D-Bus peer has disconnected"); } switch (connection->m_state) { case Connection::PROCESSING: m_incomingMsg = connection->m_incomingMsg; m_incomingMsgType = connection->m_incomingMsgType; return GOT_REPLY; break; case Connection::FINAL: if (m_eventTriggered) { return TIME_OUT; } doWait(connection); // if the connection is still available, then keep waiting connection = m_connection.lock(); if (connection) { return ACTIVE; } else if (m_session.getConnectionError().empty()) { return INACTIVE; } else { SE_THROW_EXCEPTION(TransportException, m_session.getConnectionError()); return FAILED; } break; case Connection::WAITING: if (noReply) { // message is sent as far as we know, so return return INACTIVE; } if (m_eventTriggered) { return TIME_OUT; } doWait(connection); // tell caller to check again return ACTIVE; break; case Connection::DONE: if (!noReply) { SE_THROW_EXCEPTION(TransportException, "internal error: transport has shut down, can no longer receive reply"); } return CLOSED; default: SE_THROW_EXCEPTION(TransportException, "internal error: send() on connection which is not ready"); break; } return FAILED; } void DBusTransportAgent::getReply(const char *&data, size_t &len, std::string &contentType) { data = m_incomingMsg.get(); len = m_incomingMsg.size(); contentType = m_incomingMsgType; } /********************* PresenceStatus implementation ****************/ void PresenceStatus::init(){ //initialize the configured peer list if (!m_initiated) { SyncConfig::ConfigList list = SyncConfig::getConfigs(); BOOST_FOREACH(const SyncConfig::ConfigList::value_type &server, list) { SyncConfig config (server.first); vector urls = config.getSyncURL(); m_peers[server.first].clear(); BOOST_FOREACH (const string &url, urls) { m_peers[server.first].push_back(make_pair(url,MIGHTWORK)); } } m_initiated = true; } } /* Implement DBusServer::checkPresence*/ void PresenceStatus::checkPresence (const string &peer, string& status, std::vector &transport) { if (!m_initiated) { //might triggered by updateConfigPeers init(); } string peerName = SyncConfig::normalizeConfigString (peer); vector< pair > mytransports = m_peers[peerName]; if (mytransports.empty()) { //wrong config name? status = status2string(NOTRANSPORT); transport.clear(); return; } PeerStatus mystatus = MIGHTWORK; transport.clear(); //only if all transports are unavailable can we declare the peer //status as unavailable BOOST_FOREACH (PeerStatusPair &mytransport, mytransports) { if (mytransport.second == MIGHTWORK) { transport.push_back (mytransport.first); } } if (transport.empty()) { mystatus = NOTRANSPORT; } status = status2string(mystatus); } void PresenceStatus::updateConfigPeers (const std::string &peer, const ReadOperations::Config_t &config) { ReadOperations::Config_t::const_iterator iter = config.find (""); if (iter != config.end()) { //As a simple approach, just reinitialize the whole STATUSMAP //it will cause later updatePresenceStatus resend all signals //and a reload in checkPresence m_initiated = false; } } void PresenceStatus::updatePresenceStatus (bool newStatus, PresenceStatus::TransportType type) { if (type == PresenceStatus::HTTP_TRANSPORT) { updatePresenceStatus (newStatus, m_btPresence); } else if (type == PresenceStatus::BT_TRANSPORT) { updatePresenceStatus (m_httpPresence, newStatus); }else { } } void PresenceStatus::updatePresenceStatus (bool httpPresence, bool btPresence) { bool httpChanged = (m_httpPresence != httpPresence); bool btChanged = (m_btPresence != btPresence); m_httpPresence = httpPresence; m_btPresence = btPresence; if(httpChanged) { m_httpTimer.reset(); } if(btChanged) { m_btTimer.reset(); } if (m_initiated && !httpChanged && !btChanged) { //nothing changed return; } //initialize the configured peer list bool initiated = m_initiated; if (!m_initiated) { init(); } //iterate all configured peers and fire singals BOOST_FOREACH (StatusPair &peer, m_peers) { //iterate all possible transports //TODO One peer might got more than one signals, avoid this std::vector > &transports = peer.second; BOOST_FOREACH (PeerStatusPair &entry, transports) { string url = entry.first; if (boost::starts_with (url, "http") && (httpChanged || !initiated)) { entry.second = m_httpPresence ? MIGHTWORK: NOTRANSPORT; m_server.emitPresence (peer.first, status2string (entry.second), entry.first); SE_LOG_DEBUG(NULL, NULL, "http presence signal %s,%s,%s", peer.first.c_str(), status2string (entry.second).c_str(), entry.first.c_str()); } else if (boost::starts_with (url, "obex-bt") && (btChanged || !initiated)) { entry.second = m_btPresence ? MIGHTWORK: NOTRANSPORT; m_server.emitPresence (peer.first, status2string (entry.second), entry.first); SE_LOG_DEBUG(NULL, NULL, "bluetooth presence signal %s,%s,%s", peer.first.c_str(), status2string (entry.second).c_str(), entry.first.c_str()); } } } } /********************** Connman Client implementation **************/ ConnmanClient::ConnmanClient(DBusServer &server): m_server(server), m_propertyChanged(*this, "PropertyChanged") { const char *connmanTest = getenv ("DBUS_TEST_CONNMAN"); m_connmanConn = b_dbus_setup_bus (connmanTest ? DBUS_BUS_SESSION: DBUS_BUS_SYSTEM, NULL, true, NULL); if (m_connmanConn){ typedef std::map > > PropDict; DBusClientCall1 getProp(*this,"GetProperties"); getProp (boost::bind(&ConnmanClient::getPropCb, this, _1, _2)); m_propertyChanged.activate(boost::bind(&ConnmanClient::propertyChanged, this, _1, _2)); }else{ SE_LOG_ERROR (NULL, NULL, "DBus connection setup for connman failed"); } } void ConnmanClient::getPropCb (const std::map > >& props, const string &error){ if (!error.empty()) { if (error == "org.freedesktop.DBus.Error.ServiceUnknown") { // ensure there is still first set of singal set in case of no // connman available m_server.getPresenceStatus().updatePresenceStatus (true, true); SE_LOG_DEBUG (NULL, NULL, "No connman service available %s", error.c_str()); return; } SE_LOG_DEBUG (NULL, NULL, "error in connmanCallback %s", error.c_str()); return; } typedef std::pair > > element; bool httpPresence = false, btPresence = false; BOOST_FOREACH (element entry, props) { //match connected for HTTP based peers (wifi/wimax/ethernet) if (entry.first == "ConnectedTechnologies") { std::vector connected = boost::get > (entry.second); BOOST_FOREACH (std::string tech, connected) { if (boost::iequals (tech, "wifi") || boost::iequals (tech, "ethernet") || boost::iequals (tech, "wimax")) { httpPresence = true; break; } } } else if (entry.first == "AvailableTechnologies") { std::vector enabled = boost::get > (entry.second); BOOST_FOREACH (std::string tech, enabled){ if (boost::iequals (tech, "bluetooth")) { btPresence = true; break; } } } else { continue; } } //now delivering the signals m_server.getPresenceStatus().updatePresenceStatus (httpPresence, btPresence); } void ConnmanClient::propertyChanged(const string &name, const boost::variant, string> &prop) { bool httpPresence=false, btPresence=false; bool httpChanged=false, btChanged=false; if (boost::iequals(name, "ConnectedTechnologies")) { httpChanged=true; vector connected = boost::get >(prop); BOOST_FOREACH (std::string tech, connected) { if (boost::iequals (tech, "wifi") || boost::iequals (tech, "ethernet") || boost::iequals (tech, "wimax")) { httpPresence=true; break; } } } else if (boost::iequals (name, "AvailableTechnologies")){ btChanged=true; vector enabled = boost::get >(prop); BOOST_FOREACH (std::string tech, enabled){ if (boost::iequals (tech, "bluetooth")) { btPresence = true; break; } } } if(httpChanged) { m_server.getPresenceStatus().updatePresenceStatus (httpPresence, PresenceStatus::HTTP_TRANSPORT); } else if (btChanged) { m_server.getPresenceStatus().updatePresenceStatus (btPresence, PresenceStatus::BT_TRANSPORT); } else { } } /********************** DBusServer implementation ******************/ void DBusServer::clientGone(Client *c) { for(Clients_t::iterator it = m_clients.begin(); it != m_clients.end(); ++it) { if (it->second.get() == c) { SE_LOG_DEBUG(NULL, NULL, "D-Bus client %s has disconnected", c->m_ID.c_str()); m_clients.erase(it); return; } } // remove the client if it attaches the dbus server detachClientRefs(c->m_ID, true); SE_LOG_DEBUG(NULL, NULL, "unknown client has disconnected?!"); } std::string DBusServer::getNextSession() { // Make the session ID somewhat random. This protects to // some extend against injecting unwanted messages into the // communication. m_lastSession++; if (!m_lastSession) { m_lastSession++; } return StringPrintf("%u%u", rand(), m_lastSession); } void DBusServer::attachClient(const Caller_t &caller, const boost::shared_ptr &watch) { boost::shared_ptr client = addClient(getConnection(), caller, watch); std::list >::iterator it; for(it = m_attachedClients.begin(); it != m_attachedClients.end(); ++it) { if (it->first == caller) { break; } } autoTermRef(); // if not attach before, then create it if(it == m_attachedClients.end()) { m_attachedClients.push_back(std::pair(caller, 1)); watch->setCallback(boost::bind(&DBusServer::clientGone, this, client.get())); } else { it->second++; } } void DBusServer::detachClient(const Caller_t &caller) { detachClientRefs(caller, false); } void DBusServer::detachClientRefs(const Caller_t &caller, bool allRefs) { std::list >::iterator it; for(it = m_attachedClients.begin(); it != m_attachedClients.end(); ++it) { if (it->first == caller) { if(allRefs) { autoTermUnref(it->second); m_attachedClients.erase(it); } else if(--it->second == 0) { autoTermUnref(); m_attachedClients.erase(it); } else { autoTermUnref(); } break; } } } void DBusServer::connect(const Caller_t &caller, const boost::shared_ptr &watch, const StringMap &peer, bool must_authenticate, const std::string &session, DBusObject_t &object) { if (!session.empty()) { // reconnecting to old connection is not implemented yet throw std::runtime_error("not implemented"); } std::string new_session = getNextSession(); boost::shared_ptr c(new Connection(*this, getConnection(), new_session, peer, must_authenticate)); SE_LOG_DEBUG(NULL, NULL, "connecting D-Bus client %s with connection %s '%s'", caller.c_str(), c->getPath(), c->m_description.c_str()); boost::shared_ptr client = addClient(getConnection(), caller, watch); client->attach(c); c->activate(); object = c->getPath(); } void DBusServer::startSession(const Caller_t &caller, const boost::shared_ptr &watch, const std::string &server, DBusObject_t &object) { boost::shared_ptr client = addClient(getConnection(), caller, watch); std::string new_session = getNextSession(); boost::shared_ptr session(new Session(*this, "is this a client or server session?", server, new_session)); client->attach(session); session->activate(); enqueue(session); object = session->getPath(); } void DBusServer::checkPresence(const std::string &server, std::string &status, std::vector &transports) { return m_presence.checkPresence(server, status, transports); } void DBusServer::getSessions(std::vector &sessions) { sessions.reserve(m_workQueue.size() + 1); if (m_activeSession) { sessions.push_back(m_activeSession->getPath()); } BOOST_FOREACH(boost::weak_ptr &session, m_workQueue) { boost::shared_ptr s = session.lock(); if (s) { sessions.push_back(s->getPath()); } } } DBusServer::DBusServer(GMainLoop *loop, const DBusConnectionPtr &conn, int duration) : DBusObjectHelper(conn.get(), "/org/syncevolution/Server", "org.syncevolution.Server", boost::bind(&DBusServer::autoTermCallback, this)), m_loop(loop), m_lastSession(time(NULL)), m_activeSession(NULL), m_lastInfoReq(0), m_bluezManager(*this), sessionChanged(*this, "SessionChanged"), presence(*this, "Presence"), templatesChanged(*this, "TemplatesChanged"), infoRequest(*this, "InfoRequest"), logOutput(*this, "LogOutput"), m_presence(*this), m_connman(*this), m_autoSync(*this), m_autoTerm(m_autoSync.preventTerm() ? -1 : duration), //if there is any task in auto sync, prevent auto termination m_parentLogger(LoggerBase::instance()) { struct timeval tv; gettimeofday(&tv, NULL); srand(tv.tv_usec); add(this, &DBusServer::attachClient, "Attach"); add(this, &DBusServer::detachClient, "Detach"); add(this, &DBusServer::connect, "Connect"); add(this, &DBusServer::startSession, "StartSession"); add(this, &DBusServer::getConfigs, "GetConfigs"); add(this, &DBusServer::getConfig, "GetConfig"); add(this, &DBusServer::getReports, "GetReports"); add(this, &DBusServer::checkSource, "CheckSource"); add(this, &DBusServer::getDatabases, "GetDatabases"); add(this, &DBusServer::checkPresence, "CheckPresence"); add(this, &DBusServer::getSessions, "GetSessions"); add(this, &DBusServer::infoResponse, "InfoResponse"); add(sessionChanged); add(templatesChanged); add(presence); add(infoRequest); add(logOutput); LoggerBase::pushLogger(this); setLevel(LoggerBase::DEBUG); } DBusServer::~DBusServer() { // make sure all other objects are gone before destructing ourselves m_syncSession.reset(); m_workQueue.clear(); m_clients.clear(); m_attachedClients.clear(); LoggerBase::popLogger(); } void DBusServer::run() { while (!shutdownRequested) { if (!m_activeSession || !m_activeSession->readyToRun()) { g_main_loop_run(m_loop); } if (m_activeSession && m_activeSession->readyToRun()) { // this session must be owned by someone, otherwise // it would not be set as active session boost::shared_ptr session = m_activeSessionRef.lock(); if (!session) { throw runtime_error("internal error: session no longer available"); } try { // ensure that the session doesn't go away m_syncSession.swap(session); m_activeSession->run(); } catch (const std::exception &ex) { SE_LOG_ERROR(NULL, NULL, "%s", ex.what()); } catch (...) { SE_LOG_ERROR(NULL, NULL, "unknown error"); } session.swap(m_syncSession); dequeue(session.get()); } if (m_autoSync.hasTask()) { // if there is at least one pending task and no session is created for auto sync, // pick one task and create a session m_autoSync.startTask(); } // Make sure check whether m_activeSession is owned by autosync // Otherwise activeSession is owned by AutoSyncManager but it never // be ready to run. Because methods of Session, like 'sync', are able to be // called when it is active. if (m_autoSync.hasActiveSession()) { // if the autosync is the active session, then invoke 'sync' // to make it ready to run m_autoSync.prepare(); } } } /** * look up client by its ID */ boost::shared_ptr DBusServer::findClient(const Caller_t &ID) { for(Clients_t::iterator it = m_clients.begin(); it != m_clients.end(); ++it) { if (it->second->m_ID == ID) { return it->second; } } return boost::shared_ptr(); } boost::shared_ptr DBusServer::addClient(const DBusConnectionPtr &conn, const Caller_t &ID, const boost::shared_ptr &watch) { boost::shared_ptr client(findClient(ID)); if (client) { return client; } client.reset(new Client(ID)); // add to our list *before* checking that peer exists, so // that clientGone() can remove it if the check fails m_clients.push_back(std::make_pair(watch, client)); watch->setCallback(boost::bind(&DBusServer::clientGone, this, client.get())); return client; } void DBusServer::detach(Resource *resource) { BOOST_FOREACH(const Clients_t::value_type &client_entry, m_clients) { client_entry.second->detachAll(resource); } } void DBusServer::enqueue(const boost::shared_ptr &session) { WorkQueue_t::iterator it = m_workQueue.end(); while (it != m_workQueue.begin()) { --it; if (it->lock()->getPriority() <= session->getPriority()) { ++it; break; } } m_workQueue.insert(it, session); checkQueue(); } int DBusServer::killSessions(const std::string &peerDeviceID) { int count = 0; WorkQueue_t::iterator it = m_workQueue.begin(); while (it != m_workQueue.end()) { boost::shared_ptr session = it->lock(); if (session && session->getPeerDeviceID() == peerDeviceID) { SE_LOG_DEBUG(NULL, NULL, "removing pending session %s because it matches deviceID %s", session->getSessionID().c_str(), peerDeviceID.c_str()); // remove session and its corresponding connection boost::shared_ptr c = session->getConnection().lock(); if (c) { c->shutdown(); } it = m_workQueue.erase(it); count++; } else { ++it; } } if (m_activeSession && m_activeSession->getPeerDeviceID() == peerDeviceID) { SE_LOG_DEBUG(NULL, NULL, "aborting active session %s because it matches deviceID %s", m_activeSession->getSessionID().c_str(), peerDeviceID.c_str()); try { // abort, even if not necessary right now m_activeSession->abort(); } catch (...) { // TODO: catch only that exception which indicates // incorrect use of the function } dequeue(m_activeSession); count++; } return count; } void DBusServer::dequeue(Session *session) { if (m_syncSession.get() == session) { // This is the running sync session. // It's not in the work queue and we have to // keep it active, so nothing to do. return; } for (WorkQueue_t::iterator it = m_workQueue.begin(); it != m_workQueue.end(); ++it) { if (it->lock().get() == session) { // remove from queue m_workQueue.erase(it); // session was idle, so nothing else to do return; } } if (m_activeSession == session) { // The session is releasing the lock, so someone else might // run now. session->setActive(false); sessionChanged(session->getPath(), false); m_activeSession = NULL; m_activeSessionRef.reset(); checkQueue(); return; } } void DBusServer::checkQueue() { if (m_activeSession) { // still busy return; } while (!m_workQueue.empty()) { boost::shared_ptr session = m_workQueue.front().lock(); m_workQueue.pop_front(); if (session) { // activate the session m_activeSession = session.get(); m_activeSessionRef = session; session->setActive(true); sessionChanged(session->getPath(), true); //if the active session is changed, give a chance to quit the main loop //and make it ready to run if it is owned by AutoSyncManager. //Otherwise, server might be blocked. g_main_loop_quit(m_loop); return; } } } void DBusServer::infoResponse(const Caller_t &caller, const std::string &id, const std::string &state, const std::map &response) { InfoReqMap::iterator it = m_infoReqMap.find(id); // if not found, ignore if(it != m_infoReqMap.end()) { boost::shared_ptr infoReq = it->second.lock(); infoReq->setResponse(caller, state, response); } } boost::shared_ptr DBusServer::createInfoReq(const string &type, const std::map ¶meters, const Session *session) { boost::shared_ptr infoReq(new InfoReq(*this, type, parameters, session)); boost::weak_ptr item(infoReq) ; m_infoReqMap.insert(pair >(infoReq->getId(), item)); return infoReq; } std::string DBusServer::getNextInfoReq() { return StringPrintf("%u", ++m_lastInfoReq); } void DBusServer::emitInfoReq(const InfoReq &req) { infoRequest(req.getId(), req.getSessionPath(), req.getInfoStateStr(), req.getHandler(), req.getType(), req.getParam()); } void DBusServer::removeInfoReq(const InfoReq &req) { // remove InfoRequest from hash map InfoReqMap::iterator it = m_infoReqMap.find(req.getId()); if(it != m_infoReqMap.end()) { m_infoReqMap.erase(it); } } void DBusServer::getDeviceList(SyncConfig::DeviceList &devices) { //wait bluez or other device managers while(!m_bluezManager.isDone()) { g_main_loop_run(m_loop); } devices.clear(); devices = m_syncDevices; } void DBusServer::addPeerTempl(const string &templName, const boost::shared_ptr peerTempl) { std::string lower = templName; boost::to_lower(lower); m_matchedTempls.insert(MatchedTemplates::value_type(lower, peerTempl)); } boost::shared_ptr DBusServer::getPeerTempl(const string &peer) { std::string lower = peer; boost::to_lower(lower); MatchedTemplates::iterator it = m_matchedTempls.find(lower); if(it != m_matchedTempls.end()) { return it->second; } else { return boost::shared_ptr(); } } bool DBusServer::getDevice(const string &deviceId, SyncConfig::DeviceDescription &device) { SyncConfig::DeviceList::iterator syncDevIt; for(syncDevIt = m_syncDevices.begin(); syncDevIt != m_syncDevices.end(); ++syncDevIt) { if(boost::equals(syncDevIt->m_deviceId, deviceId)) { device = *syncDevIt; return true; } } return false; } void DBusServer::addDevice(const SyncConfig::DeviceDescription &device) { SyncConfig::DeviceList::iterator it; for(it = m_syncDevices.begin(); it != m_syncDevices.end(); ++it) { if(boost::iequals(it->m_deviceId, device.m_deviceId)) { break; } } if(it == m_syncDevices.end()) { m_syncDevices.push_back(device); templatesChanged(); } } void DBusServer::removeDevice(const string &deviceId) { SyncConfig::DeviceList::iterator syncDevIt; for(syncDevIt = m_syncDevices.begin(); syncDevIt != m_syncDevices.end(); ++syncDevIt) { if(boost::equals(syncDevIt->m_deviceId, deviceId)) { m_syncDevices.erase(syncDevIt); templatesChanged(); break; } } } void DBusServer::updateDevice(const string &deviceId, const SyncConfig::DeviceDescription &device) { SyncConfig::DeviceList::iterator it; for(it = m_syncDevices.begin(); it != m_syncDevices.end(); ++it) { if(boost::iequals(it->m_deviceId, deviceId)) { (*it) = device; templatesChanged(); break; } } } void DBusServer::messagev(Level level, const char *prefix, const char *file, int line, const char *function, const char *format, va_list args) { // iterating over args in messagev() is destructive, must make a copy first va_list argsCopy; va_copy(argsCopy, args); m_parentLogger.messagev(level, prefix, file, line, function, format, args); string log = StringPrintfV(format, argsCopy); va_end(argsCopy); // prefix is used to set session path // for general server output, the object path field is dbus server // the object path can't be empty for object paths prevent using empty string. string strLevel = Logger::levelToStr(level); if(m_activeSession) { logOutput(m_activeSession->getPath(), strLevel, log); } else { logOutput(getPath(), strLevel, log); } } /********************** InfoReq implementation ******************/ InfoReq::InfoReq(DBusServer &server, const string &type, const InfoMap ¶meters, const Session *session, uint32_t timeout) : m_server(server), m_session(session), m_infoState(IN_REQ), m_status(ST_RUN), m_type(type), m_param(parameters), m_timeout(timeout), m_timer(m_timeout * 1000) { m_id = m_server.getNextInfoReq(); m_server.emitInfoReq(*this); m_param.clear(); } InfoReq::~InfoReq() { m_handler = ""; done(); m_server.removeInfoReq(*this); } InfoReq::Status InfoReq::check() { if(m_status == ST_RUN) { // give an opportunity to poll the sources on the main context g_main_context_iteration(g_main_loop_get_context(m_server.getLoop()), false); checkTimeout(); } return m_status; } bool InfoReq::getResponse(InfoMap &response) { if (m_status == ST_OK) { response = m_response; return true; } return false; } InfoReq::Status InfoReq::wait(InfoMap &response, uint32_t interval) { // give a chance to check whether it has been timeout check(); if(m_status == ST_RUN) { guint checkSource = g_timeout_add_seconds(interval, (GSourceFunc) checkCallback, static_cast(this)); while(m_status == ST_RUN) { g_main_context_iteration(g_main_loop_get_context(m_server.getLoop()), true); } // if the source is not removed if(m_status != ST_TIMEOUT && m_status != ST_CANCEL) { g_source_remove(checkSource); } } if (m_status == ST_OK) { response = m_response; } return m_status; } void InfoReq::cancel() { if(m_status == ST_RUN) { m_handler = ""; done(); m_status = ST_CANCEL; } } string InfoReq::statusToString(Status status) { switch(status) { case ST_RUN: return "running"; case ST_OK: return "ok"; case ST_CANCEL: return "cancelled"; case ST_TIMEOUT: return "timeout"; default: return ""; }; } string InfoReq::infoStateToString(InfoState state) { switch(state) { case IN_REQ: return "request"; case IN_WAIT: return "waiting"; case IN_DONE: return "done"; default: return ""; } } gboolean InfoReq::checkCallback(gpointer data) { // TODO: check abort and suspend(MB#8730) // if InfoRequest("request") is sent and waiting for InfoResponse("working"), // add a timeout mechanism InfoReq *req = static_cast(data); if (req->checkTimeout()) { return FALSE; } return TRUE; } bool InfoReq::checkTimeout() { // if waiting for client response, check time out if(m_status == ST_RUN) { if (m_timer.timeout()) { m_status = ST_TIMEOUT; return true; } } return false; } void InfoReq::setResponse(const Caller_t &caller, const string &state, const InfoMap &response) { if(m_status != ST_RUN) { return; } else if(m_infoState == IN_REQ && state == "working") { m_handler = caller; m_infoState = IN_WAIT; m_server.emitInfoReq(*this); //reset the timer, used to check timeout m_timer.reset(); } else if(m_infoState == IN_WAIT && state == "response") { m_response = response; m_handler = caller; done(); m_status = ST_OK; } } void InfoReq::done() { if (m_infoState != IN_DONE) { m_infoState = IN_DONE; m_server.emitInfoReq(*this); } } /********************** BluezManager implementation ******************/ BluezManager::BluezManager(DBusServer &server) : m_server(server), m_adapterChanged(*this, "DefaultAdapterChanged") { m_bluezConn = b_dbus_setup_bus(DBUS_BUS_SYSTEM, NULL, true, NULL); if(m_bluezConn) { m_done = false; DBusClientCall1 getAdapter(*this, "DefaultAdapter"); getAdapter(boost::bind(&BluezManager::defaultAdapterCb, this, _1, _2 )); m_adapterChanged.activate(boost::bind(&BluezManager::defaultAdapterChanged, this, _1)); } else { m_done = true; } } void BluezManager::defaultAdapterChanged(const DBusObject_t &adapter) { m_done = false; //remove devices that belong to this original adapter if(m_adapter) { BOOST_FOREACH(boost::shared_ptr &device, m_adapter->getDevices()) { m_server.removeDevice(device->getMac()); } } string error; defaultAdapterCb(adapter, error); } void BluezManager::defaultAdapterCb(const DBusObject_t &adapter, const string &error) { if(!error.empty()) { SE_LOG_DEBUG (NULL, NULL, "Error in calling DefaultAdapter of Interface org.bluez.Manager: %s", error.c_str()); m_done = true; return; } m_adapter.reset(new BluezAdapter(*this, adapter)); } BluezManager::BluezAdapter::BluezAdapter(BluezManager &manager, const string &path) : m_manager(manager), m_path(path), m_devNo(0), m_devReplies(0), m_deviceRemoved(*this, "DeviceRemoved"), m_deviceAdded(*this, "DeviceCreated") { DBusClientCall1 > listDevices(*this, "ListDevices"); listDevices(boost::bind(&BluezAdapter::listDevicesCb, this, _1, _2)); m_deviceRemoved.activate(boost::bind(&BluezAdapter::deviceRemoved, this, _1)); m_deviceAdded.activate(boost::bind(&BluezAdapter::deviceCreated, this, _1)); } void BluezManager::BluezAdapter::listDevicesCb(const std::vector &devices, const string &error) { if(!error.empty()) { SE_LOG_DEBUG (NULL, NULL, "Error in calling ListDevices of Interface org.bluez.Adapter: %s", error.c_str()); checkDone(true); return; } m_devNo = devices.size(); BOOST_FOREACH(const DBusObject_t &device, devices) { boost::shared_ptr bluezDevice(new BluezDevice(*this, device)); m_devices.push_back(bluezDevice); } checkDone(); } void BluezManager::BluezAdapter::deviceRemoved(const DBusObject_t &object) { string address; std::vector >::iterator devIt; for(devIt = m_devices.begin(); devIt != m_devices.end(); ++devIt) { if(boost::equals((*devIt)->getPath(), object)) { address = (*devIt)->m_mac; if((*devIt)->m_reply) { m_devReplies--; } m_devNo--; m_devices.erase(devIt); break; } } m_manager.m_server.removeDevice(address); } void BluezManager::BluezAdapter::deviceCreated(const DBusObject_t &object) { m_devNo++; boost::shared_ptr bluezDevice(new BluezDevice(*this, object)); m_devices.push_back(bluezDevice); } BluezManager::BluezDevice::BluezDevice (BluezAdapter &adapter, const string &path) : m_adapter(adapter), m_path(path), m_reply(false), m_propertyChanged(*this, "PropertyChanged") { DBusClientCall1 getProperties(*this, "GetProperties"); getProperties(boost::bind(&BluezDevice::getPropertiesCb, this, _1, _2)); m_propertyChanged.activate(boost::bind(&BluezDevice::propertyChanged, this, _1, _2)); } void BluezManager::BluezDevice::checkSyncService(const std::vector &uuids) { static const char * SYNCML_CLIENT_UUID = "00000002-0000-1000-8000-0002ee000002"; bool hasSyncService = false; DBusServer &server = m_adapter.m_manager.m_server; BOOST_FOREACH(const string &uuid, uuids) { //if the device has sync service, add it to the device list if(boost::iequals(uuid, SYNCML_CLIENT_UUID)) { hasSyncService = true; if(!m_mac.empty()) { server.addDevice(SyncConfig::DeviceDescription(m_mac, m_name, SyncConfig::MATCH_FOR_SERVER_MODE)); } break; } } // if sync service is not available now, possible to remove device if(!hasSyncService && !m_mac.empty()) { server.removeDevice(m_mac); } } void BluezManager::BluezDevice::getPropertiesCb(const PropDict &props, const string &error) { m_adapter.m_devReplies++; m_reply = true; if(!error.empty()) { SE_LOG_DEBUG (NULL, NULL, "Error in calling GetProperties of Interface org.bluez.Device: %s", error.c_str()); } else { PropDict::const_iterator it = props.find("Name"); if(it != props.end()) { m_name = boost::get(it->second); } it = props.find("Address"); if(it != props.end()) { m_mac = boost::get(it->second); } PropDict::const_iterator uuids = props.find("UUIDs"); if(uuids != props.end()) { const std::vector uuidVec = boost::get >(uuids->second); checkSyncService(uuidVec); } } m_adapter.checkDone(); } void BluezManager::BluezDevice::propertyChanged(const string &name, const boost::variant, string> &prop) { DBusServer &server = m_adapter.m_manager.m_server; if(boost::iequals(name, "Name")) { m_name = boost::get(prop); SyncConfig::DeviceDescription device; if(server.getDevice(m_mac, device)) { device.m_fingerprint = m_name; server.updateDevice(m_mac, device); } } else if(boost::iequals(name, "UUIDs")) { const std::vector uuidVec = boost::get >(prop); checkSyncService(uuidVec); } else if(boost::iequals(name, "Address")) { string mac = boost::get(prop); SyncConfig::DeviceDescription device; if(server.getDevice(m_mac, device)) { device.m_deviceId = mac; server.updateDevice(m_mac, device); } m_mac = mac; } } /************************ AutoSyncManager ******************/ void AutoSyncManager::init() { m_peerMap.clear(); SyncConfig::ConfigList list = SyncConfig::getConfigs(); BOOST_FOREACH(const SyncConfig::ConfigList::value_type &server, list) { initConfig(server.first); } } void AutoSyncManager::initConfig(const string &configName) { SyncConfig config (configName); if(!config.exists()) { return; } vector urls = config.getSyncURL(); string autoSync = config.getAutoSync(); //enable http and bt? bool http = false, bt = false; if(autoSync.empty() || boost::iequals(autoSync, "0") || boost::iequals(autoSync, "f")) { http = false; bt = false; } else if(boost::iequals(autoSync, "1") || boost::iequals(autoSync, "t")) { http = true; bt = true; } else { vector options; boost::split(options, autoSync, boost::is_any_of(",")); BOOST_FOREACH(string op, options) { if(boost::iequals(op, "http")) { http = true; } else if(boost::iequals(op, "obex-bt")) { bt = true; } } } unsigned int interval = config.getAutoSyncInterval(); unsigned int duration = config.getAutoSyncDelay(); BOOST_FOREACH(string url, urls) { if((boost::istarts_with(url, "http") && http) || (boost::istarts_with(url, "obex-bt") && bt)) { AutoSyncTask syncTask(configName, duration, url); PeerMap::iterator it = m_peerMap.find(interval); if(it != m_peerMap.end()) { it->second->push_back(syncTask); } else { boost::shared_ptr list(new AutoSyncTaskList(*this, interval)); list->push_back(syncTask); list->createTimeoutSource(); m_peerMap.insert(std::make_pair(interval, list)); } } } } void AutoSyncManager::remove(const string &configName) { //wipe out tasks in the m_peerMap PeerMap::iterator it = m_peerMap.begin(); while(it != m_peerMap.end()) { boost::shared_ptr &list = it->second; AutoSyncTaskList::iterator taskIt = list->begin(); while(taskIt != list->end()) { if(boost::iequals(taskIt->m_peer, configName)) { taskIt = list->erase(taskIt); } else { ++taskIt; } } //if list is empty, remove the list from map if(list->empty()) { PeerMap::iterator erased = it++; m_peerMap.erase(erased); } else { ++it; } } //wipe out scheduled tasks in the working queue based on configName list::iterator qit = m_workQueue.begin(); while(qit != m_workQueue.end()) { if(boost::iequals(qit->m_peer, configName)) { qit = m_workQueue.erase(qit); } else { ++qit; } } } void AutoSyncManager::update(const string &configName) { // remove task from m_peerMap and tasks in the working queue for this config remove(configName); // re-load the config and re-init peer map initConfig(configName); //don't clear if the task is running if(m_session && !hasActiveSession() && boost::iequals(m_session->getConfigName(), configName)) { m_server.dequeue(m_session.get()); m_session.reset(); m_activeTask.reset(); startTask(); } } void AutoSyncManager::scheduleAll() { BOOST_FOREACH(PeerMap::value_type &elem, m_peerMap) { elem.second->scheduleTaskList(); } } bool AutoSyncManager::addTask(const AutoSyncTask &syncTask) { if(taskLikelyToRun(syncTask)) { m_workQueue.push_back(syncTask); return true; } return false; } bool AutoSyncManager::findTask(const AutoSyncTask &syncTask) { if(m_activeTask && *m_activeTask == syncTask) { return true; } BOOST_FOREACH(const AutoSyncTask &task, m_workQueue) { if(task == syncTask) { return true; } } return false; } bool AutoSyncManager::taskLikelyToRun(const AutoSyncTask &syncTask) { PresenceStatus &status = m_server.getPresenceStatus(); // avoid doing any checking of task list if http and bt presence are false if(!status.getHttpPresence() && !status.getBtPresence()) { return false; } if(boost::istarts_with(syncTask.m_url, "http") && status.getHttpPresence()) { // don't add duplicate tasks if(!findTask(syncTask)) { Timer& timer = status.getHttpTimer(); // if the time peer have been around is longer than 'autoSyncDelay', // then return true if (timer.timeout(syncTask.m_delay * 1000 /* seconds to milliseconds */)) { return true; } } } else if (boost::istarts_with(syncTask.m_url, "obex-bt") && status.getBtPresence()) { // don't add duplicate tasks if(!findTask(syncTask)) { return true; } } return false; } void AutoSyncManager::startTask() { // get the front task and run a sync // if there has been a session for the front task, do nothing if(hasTask() && !m_session) { m_activeTask.reset(new AutoSyncTask(m_workQueue.front())); m_workQueue.pop_front(); string newSession = m_server.getNextSession(); m_session.reset(new Session(m_server, "", m_activeTask->m_peer, newSession)); m_session->setPriority(Session::PRI_AUTOSYNC); m_session->addListener(this); m_server.enqueue(m_session); } } bool AutoSyncManager::hasActiveSession() { return m_session && m_session->getActive(); } void AutoSyncManager::prepare() { if(m_session && m_session->getActive()) { // now a config may contain many urls, so replace it with our own temporarily // otherwise it only picks the first one ReadOperations::Config_t config; StringMap stringMap; stringMap["syncURL"] = m_activeTask->m_url; config[""] = stringMap; m_session->setConfig(true, true, config); string mode; Session::SourceModes_t sourceModes; m_session->sync(mode, sourceModes); } } void AutoSyncManager::syncSuccessStart() { m_syncSuccessStart = true; SE_LOG_INFO(NULL, NULL,"Automatic sync for '%s' has been successfully started.\n", m_activeTask->m_peer.c_str()); #ifdef HAS_NOTIFY string summary = StringPrintf(_("%s is syncing"), m_activeTask->m_peer.c_str()); string body = StringPrintf(_("We have just started to sync your computer with the %s sync service."), m_activeTask->m_peer.c_str()); //TODO: set config information for 'sync-ui' m_notify.send(summary.c_str(), body.c_str()); #endif } void AutoSyncManager::syncDone(SyncMLStatus status) { SE_LOG_INFO(NULL, NULL,"Automatic sync for '%s' has been done.\n", m_activeTask->m_peer.c_str()); #ifdef HAS_NOTIFY // send a notification to notification server string summary, body; if(m_syncSuccessStart && status == STATUS_OK) { // if sync is successfully started and done summary = StringPrintf(_("%s sync complete"), m_activeTask->m_peer.c_str()); body = StringPrintf(_("We have just finished syncing your computer with the %s sync service."), m_activeTask->m_peer.c_str()); //TODO: set config information for 'sync-ui' m_notify.send(summary.c_str(), body.c_str()); } else if(m_syncSuccessStart || (!m_syncSuccessStart && status == STATUS_FATAL)) { //if sync is successfully started and has errors, or not started successful with a fatal problem summary = StringPrintf(_("Sync problem.")); body = StringPrintf(_("Sorry, there's a problem with your sync that you need to attend to.")); //TODO: set config information for 'sync-ui' m_notify.send(summary.c_str(), body.c_str()); } #endif m_session.reset(); m_activeTask.reset(); m_syncSuccessStart = false; } #ifdef HAS_NOTIFY AutoSyncManager::Notification::Notification() { bindtextdomain (GETTEXT_PACKAGE, SYNCEVOLUTION_LOCALEDIR); bind_textdomain_codeset (GETTEXT_PACKAGE, "UTF-8"); textdomain (GETTEXT_PACKAGE); m_init = notify_init("SyncEvolution"); m_actions = false; m_notification = NULL; // check whether 'actions' are supported by notification server if(m_init) { GList *list = notify_get_server_caps(); if(list) { for(; list != NULL; list = list->next) { if(boost::iequals((char *)list->data, "actions")) { m_actions = true; } } } } } AutoSyncManager::Notification::~Notification() { if(m_init) { notify_uninit(); } } void AutoSyncManager::Notification::notifyAction(NotifyNotification *notify, gchar *action, gpointer userData) { if(boost::iequals("view", action)) { pid_t pid; if((pid = fork()) == 0) { //search sync-ui from $PATH if(execlp("sync-ui", "sync-ui", (const char*)0) < 0) { exit(0); } } } //if dismiss, ignore } void AutoSyncManager::Notification::send(const char *summary, const char *body, const char *viewParams) { if(!m_init) return; if(m_notification) { notify_notification_clear_actions(m_notification); notify_notification_close(m_notification, NULL); } m_notification = notify_notification_new(summary, body, NULL, NULL); //if actions are not supported, don't add actions //An example is Ubuntu Notify OSD. It uses an alert box //instead of a bubble when a notification is appended with actions. //the alert box won't be closed until user inputs. //so disable it in case of no support of actions if(m_actions) { notify_notification_add_action(m_notification, "view", _("View"), notifyAction, (gpointer)viewParams, NULL); // Use "default" as ID because that is what mutter-moblin // recognizes: it then skips the action instead of adding it // in addition to its own "Dismiss" button (always added). notify_notification_add_action(m_notification, "default", _("Dismiss"), notifyAction, (gpointer)viewParams, NULL); } notify_notification_show(m_notification, NULL); } #endif void AutoSyncManager::AutoSyncTaskList::createTimeoutSource() { //if interval is 0, only run auto sync when changes are detected. if(m_interval) { m_source = g_timeout_add_seconds(m_interval, taskListTimeoutCb, static_cast(this)); } } gboolean AutoSyncManager::AutoSyncTaskList::taskListTimeoutCb(gpointer data) { AutoSyncTaskList *list = static_cast(data); list->scheduleTaskList(); return TRUE; } void AutoSyncManager::AutoSyncTaskList::scheduleTaskList() { BOOST_FOREACH(AutoSyncTask &syncTask, *this) { m_manager.addTask(syncTask); } g_main_loop_quit(m_manager.m_server.getLoop()); } /**************************** main *************************/ void niam(int sig) { shutdownRequested = true; SyncContext::handleSignal(sig); g_main_loop_quit (loop); } static bool parseDuration(int &duration, const char* value) { if(value == NULL) { return false; } else if (boost::iequals(value, "unlimited")) { duration = -1; return true; } else if ((duration = atoi(value)) > 0) { return true; } else { return false; } } int main(int argc, char **argv) { int duration = 600; int opt = 1; while(opt < argc) { if(argv[opt][0] != '-') { break; } if (boost::iequals(argv[opt], "--duration") || boost::iequals(argv[opt], "-d")) { opt++; if(!parseDuration(duration, opt== argc ? NULL : argv[opt])) { std::cout << argv[opt-1] << ": unknown parameter value or not set" << std::endl; return false; } } else { std::cout << argv[opt] << ": unknown parameter" << std::endl; return false; } opt++; } try { g_type_init(); g_thread_init(NULL); g_set_application_name("SyncEvolution"); // Initializing a potential use of EDS early is necessary for // libsynthesis when compiled with // --enable-evolution-compatibility: in that mode libical will // only be found by libsynthesis after EDSAbiWrapperInit() // pulls it into the process by loading libecal. EDSAbiWrapperInit(); loop = g_main_loop_new (NULL, FALSE); setvbuf(stderr, NULL, _IONBF, 0); setvbuf(stdout, NULL, _IONBF, 0); signal(SIGTERM, niam); signal(SIGINT, niam); LogRedirect redirect(true); redirectPtr = &redirect; // make daemon less chatty - long term this should be a command line option LoggerBase::instance().setLevel(LoggerBase::INFO); DBusErrorCXX err; DBusConnectionPtr conn = b_dbus_setup_bus(DBUS_BUS_SESSION, "org.syncevolution", true, &err); if (!conn) { err.throwFailure("b_dbus_setup_bus()", " failed - server already running?"); } DBusServer server(loop, conn, duration); server.activate(); SE_LOG_INFO(NULL, NULL, "%s: ready to run", argv[0]); server.run(); return 0; } catch ( const std::exception &ex ) { SE_LOG_ERROR(NULL, NULL, "%s", ex.what()); } catch (...) { SE_LOG_ERROR(NULL, NULL, "unknown error"); } return 1; }