gsConnection.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2001, 2006 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: gsConnection.h,v $ $Revision: 1.11 $ $State: Exp $
*********************************************************************/

#ifndef DtGsRtiConnection_H_
#define DtGsRtiConnection_H_ 1


#include "connection.h"

class DtUdpMsgSocket;

class DT_DLL_LRC DtGsRtiConnection : public DtRtiConnection
{
public:

   DtGsRtiConnection(DtUdpMsgSocket *skt, const MAKRti::DtInetAddr& destAddr);

   virtual ~DtGsRtiConnection();

private:

   DtGsRtiConnection(const DtGsRtiConnection&);

   DtGsRtiConnection& operator=(const DtGsRtiConnection &);

public:
   virtual int send(const DtRtiMsg& msg, const MAKRti::DtInetAddr& destaddr);

   virtual void removeAllRemoteSites();
   
   virtual void addRemoteSite(const MAKRti::DtInetAddr& addr);
   virtual void removeRemoteSite(const MAKRti::DtInetAddr& addr);
      
protected:
   
   virtual int sendToAllRemoteSites(
      caddr_t pkt, size_t size, const MAKRti::DtInetAddr& dwSkipAddr = MAKRti::DtInetAddr::inaddrAny());

   std::set<MAKRti::DtInetAddr> myRemoteSites;

   MAKRti::DtInetAddr   myDestAddr;
   DtUdpMsgSocket* myGroupSocket;

};

#endif