assistantSyncPtUpdateMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2008 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: assistantSyncPtUpdateMsg.h,v $ $Revision: 1.2 $ $State: Exp $
*********************************************************************/

#ifndef DtAssistantSyncPtUpdateMsg_H_
#define DtAssistantSyncPtUpdateMsg_H_


#include <vlutil/vlString.h>
#include <vlutil/vlUtil.h>

#include "assistantMsg.h"
#include "federationInfo.h"
#include "netAssistantSyncPtUpdateMsg.h"

class DtRtiAssistantServer;
class DtRtiAssistantPeer;
class DtAssistantSyncPtUpdateMsg;

typedef void (*DtAssistantSyncPtUpdateCb)(const DtAssistantSyncPtUpdateMsg& inter, void* usr);

class DT_DLL_ASSISTANT DtAssistantSyncPtUpdateMsg : public DtAssistantMsg
{
public:

   DtAssistantSyncPtUpdateMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtAssistantSyncPtUpdateMsg(const DtNetAssistantSyncPtUpdateMsg* netRepMsg,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtAssistantSyncPtUpdateMsg();

   virtual DtAssistantMsg* clone(bool copy = true) const;

   virtual bool isRemoval() const;

   virtual void setIsRemoval( bool remove );

   virtual void getPendingAndAchieved( DtPendingAchievedPair& pendAchieve ) const;

   virtual void setPendingAndAchieved( const DtPendingAchievedPair& pendAchieve );

   virtual MAKRti::DtString federationName() const;

   virtual void setFederationName( const MAKRti::DtString& name );

   virtual MAKRti::DtString syncPtName() const;

   virtual void setSyncPtName( const MAKRti::DtString& name );

   virtual void printData() const;

public:

   static DtAssistantMsg* create(const DtNetAssistantMsgHeader* initial,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   static DtAssistantMsg* create(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   static void addCallback(DtRtiAssistantServer* conn,
      DtAssistantSyncPtUpdateCb cb, void* usr);
   static void removeCallback(DtRtiAssistantServer* conn,
      DtAssistantSyncPtUpdateCb cb, void* usr);

   static void addCallback(DtRtiAssistantPeer* conn, 
      DtAssistantSyncPtUpdateCb cb, void* usr);
   static void removeCallback(DtRtiAssistantPeer* conn, 
      DtAssistantSyncPtUpdateCb cb, void* usr);
      
protected:

   virtual DtNetAssistantSyncPtUpdateMsg* netAssistantSyncPtUpdateMsg();
   virtual const DtNetAssistantSyncPtUpdateMsg* netAssistantSyncPtUpdateMsg() const;

   virtual DtAssistantMsgKind internalMsgKind();

   virtual int minSize() const;

   virtual void setNumPending( unsigned num );
   virtual unsigned numPending() const;

   virtual const DtNetU32* pendingPtr() const;
   virtual DtNetU32* pendingPtr();

   virtual void setNumAchieved( unsigned num );
   virtual unsigned numAchieved() const;

   virtual const DtNetU32* achievedPtr() const;
   virtual DtNetU32* achievedPtr();

   virtual void setFederationNameSize( unsigned size );
   virtual unsigned federationNameSize() const;

   virtual const char* federationNamePtr() const;
   virtual char* federationNamePtr();

   virtual void setSyncPtNameSize( unsigned size );
   virtual unsigned syncPtNameSize() const;

   virtual const char* syncPtNamePtr() const;
   virtual char* syncPtNamePtr();

};

#endif