X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fsyncableobject.h;h=fda437f38ba008b556aa71f88377e9175a9be8e2;hp=482470a51ae3d41170031f5706f21bc44e830373;hb=62b7bed21f011037a34d7a4ea797d79fbdeff687;hpb=1b680d1e84bff6c2e6f64dfbda72cb91efa48125 diff --git a/src/common/syncableobject.h b/src/common/syncableobject.h index 482470a5..fda437f3 100644 --- a/src/common/syncableobject.h +++ b/src/common/syncableobject.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-08 by the Quassel IRC Team * + * Copyright (C) 2005-09 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -18,20 +18,25 @@ * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * ***************************************************************************/ -#ifndef _SYNCABLEOBJECT_H_ -#define _SYNCABLEOBJECT_H_ +#ifndef SYNCABLEOBJECT_H +#define SYNCABLEOBJECT_H #include #include #include #include +#include "signalproxy.h" + class SyncableObject : public QObject { + SYNCABLE_OBJECT Q_OBJECT public: SyncableObject(QObject *parent = 0); + SyncableObject(const QString &objectName, QObject *parent = 0); SyncableObject(const SyncableObject &other, QObject *parent = 0); + ~SyncableObject(); //! Stores the object's state into a QVariantMap. /** The default implementation takes dynamic properties as well as getters that have @@ -61,25 +66,49 @@ public: public slots: virtual void setInitialized(); void requestUpdate(const QVariantMap &properties); - void update(const QVariantMap &properties); + virtual void update(const QVariantMap &properties); protected: + void sync_call__(SignalProxy::ProxyMode modeType, const char *funcname, ...) const; + void renameObject(const QString &newName); SyncableObject &operator=(const SyncableObject &other); signals: void initDone(); void updatedRemotely(); - void updated(const QVariantMap &properties); - void updateRequested(const QVariantMap &properties); - void objectRenamed(QString newName, QString oldName); + void updated(); private: + void synchronize(SignalProxy *proxy); + void stopSynchronize(SignalProxy *proxy); + bool setInitValue(const QString &property, const QVariant &value); bool _initialized; bool _allowClientUpdates; + QList _signalProxies; + + friend class SignalProxy; }; +#define SYNCABLE_OBJECT static const int _classNameOffset__; +#define INIT_SYNCABLE_OBJECT(x) const int x ::_classNameOffset__ = QByteArray(staticMetaObject.className()).length() + 2; + +#ifdef Q_WS_WIN +# define SYNC(...) sync_call__(SignalProxy::Server, (__FUNCTION__ + _classNameOffset__), __VA_ARGS__); +# define REQUEST(...) sync_call__(SignalProxy::Client, (__FUNCTION__ + _classNameOffset__) , __VA_ARGS__); +#else +# define SYNC(...) sync_call__(SignalProxy::Server, __func__, __VA_ARGS__); +# define REQUEST(...) sync_call__(SignalProxy::Client, __func__, __VA_ARGS__); +#endif //Q_WS_WIN + +#define SYNC_OTHER(x, ...) sync_call__(SignalProxy::Server, #x, __VA_ARGS__); +#define REQUEST_OTHER(x, ...) sync_call__(SignalProxy::Client, #x, __VA_ARGS__); + + +#define ARG(x) const_cast(reinterpret_cast(&x)) +#define NO_ARG 0 + #endif