"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "reflector/StorageReflectSession.h" between
muscle8.20.zip and muscle8.30.zip

About: MUSCLE (Multi User Server Client Linking Environment) is a messaging server and networking API. The included server program ("muscled") lets its clients message each other, and/or store information in its serverside hierarchical database.

StorageReflectSession.h  (muscle8.20):StorageReflectSession.h  (muscle8.30)
skipping to change at line 554 skipping to change at line 554
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, PassMessageCallback) ; /** Matching nodes are sent the given message. */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, PassMessageCallback) ; /** Matching nodes are sent the given message. */
private: private:
void PushSubscriptionMessage(MessageRef & msgRef); void PushSubscriptionMessage(MessageRef & msgRef);
void SendGetDataResults(MessageRef & msg); void SendGetDataResults(MessageRef & msg);
void NodeChangedAux(DataNode & modifiedNode, const MessageRef & nodeData, Nod eChangeFlags nodeChangeFlags); void NodeChangedAux(DataNode & modifiedNode, const MessageRef & nodeData, Nod eChangeFlags nodeChangeFlags);
void UpdateDefaultMessageRoute(); void UpdateDefaultMessageRoute();
status_t RemoveParameter(const String & paramName, bool & retUpdateDefaultMes sageRoute); status_t RemoveParameter(const String & paramName, bool & retUpdateDefaultMes sageRoute);
int PassMessageCallbackAux(DataNode & node, const MessageRef & msgRef, bool m atchSelfOkay); int PassMessageCallbackAux(DataNode & node, const MessageRef & msgRef, bool m atchSelfOkay);
void TallyNodeBytes(const DataNode & n, uint32 & retNumNodes, uint32 & retNod eBytes) const; void TallyNodeBytes(const DataNode & n, uint32 & retNumNodes, uint32 & retNod eBytes) const;
DataNodeSubscribersTableRef GetDataNodeSubscribersTableFromPool(const DataNod eSubscribersTableRef & curTableRef, const String & sessionIDString, int32 delta) ; ConstDataNodeSubscribersTableRef GetDataNodeSubscribersTableFromPool(const Co nstDataNodeSubscribersTableRef & curTableRef, const String & sessionIDString, in t32 delta);
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, KickClientCallback); /** Sessions of matching nodes are EndSession()'d */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, KickClientCallback); /** Sessions of matching nodes are EndSession()'d */
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, InsertOrderedDataCal lback); /** Matching nodes have ordered data inserted into them as child nodes * / DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, InsertOrderedDataCal lback); /** Matching nodes have ordered data inserted into them as child nodes * /
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, ReorderDataCallback) ; /** Matching nodes area reordered in their parent's index */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, ReorderDataCallback) ; /** Matching nodes area reordered in their parent's index */
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, GetSubtreesCallback) ; /** Matching nodes are added in to the user Message as archived subtrees */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, GetSubtreesCallback) ; /** Matching nodes are added in to the user Message as archived subtrees */
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, GetDataCallback); /** Matching nodes are added to the (userData) Message */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, GetDataCallback); /** Matching nodes are added to the (userData) Message */
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, RemoveDataCallback); /** Matching nodes are placed in a list (userData) for later removal. */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, RemoveDataCallback); /** Matching nodes are placed in a list (userData) for later removal. */
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, DoSubscribeRefCallba ck); /** Matching nodes are ref'd or unref'd with subscribed session IDs */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, DoSubscribeRefCallba ck); /** Matching nodes are ref'd or unref'd with subscribed session IDs */
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, ChangeQueryFilterCal lback); /** Matching nodes are ref'd or unref'd depending on the QueryFilter cha nge */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, ChangeQueryFilterCal lback); /** Matching nodes are ref'd or unref'd depending on the QueryFilter cha nge */
DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, FindSessionsCallback ); /** Sessions of matching nodes are added to the given Hashtable */ DECLARE_MUSCLE_TRAVERSAL_CALLBACK(StorageReflectSession, FindSessionsCallback ); /** Sessions of matching nodes are added to the given Hashtable */
skipping to change at line 594 skipping to change at line 594
* on demand in the central-state Message. * on demand in the central-state Message.
*/ */
class StorageReflectSessionSharedData class StorageReflectSessionSharedData
{ {
public: public:
StorageReflectSessionSharedData(const DataNodeRef & root) : _root(root), _ subsDirty(false) {/* empty */} StorageReflectSessionSharedData(const DataNodeRef & root) : _root(root), _ subsDirty(false) {/* empty */}
DataNodeRef _root; DataNodeRef _root;
bool _subsDirty; bool _subsDirty;
Hashtable<uint32, DataNodeSubscribersTableRef> _cachedSubscribersTables; // cached by hash code DataNodeSubscribersTablePool _cachedSubscribersTables;
}; };
/** Sets up the global root and other shared data */ /** Sets up the global root and other shared data */
StorageReflectSessionSharedData * InitSharedData(); StorageReflectSessionSharedData * InitSharedData();
/** our current parameter set */ /** our current parameter set */
Message _parameters; Message _parameters;
/** cached to be sent when a subscription triggers */ /** cached to be sent when a subscription triggers */
MessageRef _nextSubscriptionMessage; MessageRef _nextSubscriptionMessage;
 End of changes. 2 change blocks. 
2 lines changed or deleted 2 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)