ZGDatabasePeerSession.h

Go to the documentation of this file.

#ifndef ZGDatabasePeerSession_h
#define ZGDatabasePeerSession_h

#include "zg/ZGPeerSession.h"
#include "zg/IDatabaseObject.h"

namespace zg
{

class ZGDatabasePeerSession : public ZGPeerSession
{
public:
   ZGDatabasePeerSession(const ZGPeerSettings & peerSettings);

   virtual status_t AttachedToServer();

   IDatabaseObject * GetDatabaseObject(uint32 whichDatabase) {return _databaseObjects[whichDatabase]();}

   const IDatabaseObject * GetDatabaseObject(uint32 whichDatabase) const {return _databaseObjects[whichDatabase]();}

protected:
   virtual IDatabaseObjectRef CreateDatabaseObject(uint32 whichDatabase) = 0;

   // ZGPeerSession API implementation
   virtual void ResetLocalDatabaseToDefault(uint32 whichDatabase, uint32 & dbChecksum);
   virtual ConstMessageRef SeniorUpdateLocalDatabase(uint32 whichDatabase, uint32 & dbChecksum, const ConstMessageRef & seniorDoMsg);
   virtual status_t JuniorUpdateLocalDatabase(uint32 whichDatabase, uint32 & dbChecksum, const ConstMessageRef & juniorDoMsg);
   virtual MessageRef SaveLocalDatabaseToMessage(uint32 whichDatabase) const;
   virtual status_t SetLocalDatabaseFromMessage(uint32 whichDatabase, uint32 & dbChecksum, const ConstMessageRef & newDBStateMsg);
   virtual uint32 CalculateLocalDatabaseChecksum(uint32 whichDatabase) const;
   virtual String GetLocalDatabaseContentsAsString(uint32 whichDatabase) const;

private:
   Queue<IDatabaseObjectRef> _databaseObjects;
};
DECLARE_REFTYPES(ZGDatabasePeerSession);

};  // end namespace zg

#endif