smConnection.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2005 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: smConnection.h,v $ $Revision: 1.10 $ $State: Exp $
*********************************************************************/


#ifndef DtSmRtiConnection_H_
#define DtSmRtiConnection_H_ 1

#include <vlutil/vlString.h>
#include <vlutil/vlTime.h>
#include <list>
#include <assert.h>
#include "connection.h"
#include "rtiSmSocket.h"
#include <vlutil/vlFedTarget.h>

class DT_DLL_LRC DtSmRtiConnection : public DtRtiConnection
{
public:

   DtSmRtiConnection(DtRtiSmSocket * socket);

   virtual ~DtSmRtiConnection();

   virtual int send(const DtRtiMsg& msg,
      const MAKRti::DtInetAddr& addr = MAKRti::DtInetAddr::inaddrAny());

   virtual int send(const DtRtiMsg& msg, MAKRti::DtTransportType transport, 
                    const MAKRti::DtInetAddr& addr = MAKRti::DtInetAddr::inaddrAny(),
                    unsigned int priority = 0);

   virtual bool flush();

   virtual int getMessageNetInfo(MAKRti::DtInetAddr *addr, MAKRti::DtTransportType *trans,
                                 DtU32 *priority = NULL);

   virtual bool isReliable();

   virtual int waitForMessages(MAKRti::DtTime waitTime = 0.0);

   virtual int waitUntilFull(MAKRti::DtTime waitTime = 0.0);

   virtual bool sm_shutdown(bool ruthless = false);

   virtual int subscriberCount() const;

protected:
                 
   DtRtiSmSocket *mySmSocket;

   typedef std::list< DtRtiMsg* > DtOutboundPendingList;
   DtOutboundPendingList myObPendingMessages;

};

#endif