smSocket__rti__.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2005 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: smSocket__rti__.h,v $ $Revision: 1.13 $ $State: Exp $
*********************************************************************/
#ifndef smSocket_H_
#define smSocket_H_


#include <vlutil/vlUtil.h>
#include <vlutil/vlInetAddr.h>
#include <udpMsgSocket.h>
#include "vlShmSubscribableMessageQueue__rti__.h"

#if DT_HAVE_STD_H
#include <std.h>
#endif

#include <stdio.h>
#include <sys/types.h>
#include <vector>

#ifdef DtUSE_UTILITIES_NAMESPACE
namespace DtUSE_UTILITIES_NAMESPACE
{
#endif


class DT_DLL_LRC DtSmSocket__rti__ : public DtUdpMsgSocket
{
  public:
    DtSmSocket__rti__(const char * sharename, DtBoost::shared_ptr<DtMsgHeaderReader> hdrReader);

    virtual ~DtSmSocket__rti__();

    virtual bool initializeSmQueue(DtU32 id = DtSM_INVALID_SUBSCRIBER_ID,
                                   bool forceSubscribe = false);
    virtual bool initializeSmQueue(DtU32 numBuckets, DtU32 payloadSize,
                                   DtU32 id = DtSM_INVALID_SUBSCRIBER_ID,
                                   bool forceSubscribe = false);

    virtual int sendMessage(caddr_t msg, size_t msgSize, bool deleteAfterSend,
       const DtInetAddr& notUsed = DtInetAddr::inaddrAny());

    virtual bool flush();

    virtual void openSocket(const DtInetEndpoint& dest,
       DtU32 flags = DtDefaultSockOpts, DtU16 localPort = 0,
       DtInetDevice* hostIf = NULL);
    virtual void enableBundling(size_t maxBundleSize);
    virtual void disableBundling();
    virtual void enableCompression(DtU8 compressionLevel);
    virtual void disableCompression();
    virtual bool joinMulticastGroup( const DtInetAddr& grpAddr, 
       DtInetDevice* device = NULL );
    virtual bool joinMulticastGroup( const DtInetEndpoint& grpEndpoint, 
       DtInetDevice* device = NULL );
    virtual bool dropMulticastGroup( const DtInetAddr& grpAddr, 
       DtInetDevice* device = NULL );
    virtual bool dropMulticastGroup( const DtInetEndpoint& grpEndpoint, 
       DtInetDevice* device = NULL );
    virtual bool setMcastTtlOption( DtU32 ttl );
    virtual void setRetryOnSend(unsigned int numRetries, double waitPeriod);

    virtual DtSmSubscribableMessageQueue__rti__ * msgQueue() const;
    virtual bool isOpen() const;

    virtual int   subscribe(DtU32 id = DtSM_INVALID_SUBSCRIBER_ID);
    virtual void  unsubscribe(DtU32 id);

    virtual bool  shutdownQueue(bool ruthless = false);
    virtual int   subscriberCount() const;
    
  protected:

    virtual int recv(caddr_t *buffptr, DtInetEndpoint* ep);

    MAKRti::DtString                      mySharedMemName;
    DtSmSubscribableMessageQueue__rti__ * mySmMsgQueue;

  protected:
    DtSmSocket__rti__(const DtSmSocket__rti__ &);

    DtSmSocket__rti__ &operator=(const DtSmSocket__rti__ &);

};

#ifdef DtUSE_UTILITIES_NAMESPACE
} 
#endif

#endif