assistantAwaitingFwsMsg.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2010 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: assistantAwaitingFwsMsg.h,v $ $Revision: 1.6 $ $State: Exp $
*********************************************************************/

#ifndef DtAssistantAwaitingForwardersMsg_H_
#define DtAssistantAwaitingForwardersMsg_H_


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

#include "assistantMsg.h"
#include "federationInfo.h"
#include "netAssistantAwaitingFwsMsg.h"
#include "rtiAssistantForwarderClient.h"
#include "rtiVersion.h"

class DtRtiAssistantServer;
class DtRtiAssistantClient;
class DtAssistantAwaitingForwardersMsg;

typedef void (*DtAssistantAwaitingForwardersCb)(const DtAssistantAwaitingForwardersMsg& inter, void* usr);

class DT_DLL_ASSISTANT DtAssistantAwaitingForwardersMsg : public DtAssistantMsg
{
public:

   DtAssistantAwaitingForwardersMsg(DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   DtAssistantAwaitingForwardersMsg(const DtNetAssistantAwaitingForwardersMsg* netRepMsg,
      DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

   virtual ~DtAssistantAwaitingForwardersMsg();

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

public:

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

   static DtAssistantMsg* create(MAKRti::DtBufferPtr buffer = DtUSE_INTERNAL_BUFFER);

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

   static void addCallback(DtRtiAssistantClient* conn, 
      DtAssistantAwaitingForwardersCb cb, void* usr);
   static void removeCallback(DtRtiAssistantClient* conn, 
      DtAssistantAwaitingForwardersCb cb, void* usr);
   
   void getForwarders(DtNeededFwConnMap& fws) const;

   void setForwarders(const DtNeededFwConnMap& fws);

   bool isWaitingForForwarders() const;

   void setIsWaitingForForwarders(bool isWaiting);

   unsigned int numForwarders() const;
      
protected:

   virtual DtNetAssistantAwaitingForwardersMsg* netAssistantAwaitingForwardersMsg();
   virtual const DtNetAssistantAwaitingForwardersMsg* netAssistantAwaitingForwardersMsg() const;

   virtual DtAssistantMsgKind internalMsgKind();

   virtual int minSize() const;

   virtual const DtNetU128* forwarderAddrsPtr() const;
   virtual DtNetU128* forwarderAddrsPtr();

   virtual const DtNetU16* forwarderPortsPtr() const;
   virtual DtNetU16* forwarderPortsPtr();

   virtual unsigned int forwarderNamesSize() const;
   virtual void setForwarderNamesSize(unsigned int size);

   virtual const char* forwarderNamesPtr() const;
   virtual char* forwarderNamesPtr();

   const DtNetU8* forwarderConnectedPtr() const;
   DtNetU8* forwarderConnectedPtr();
};

#endif