rtiExecHandshakeProcessor.h

Go to the documentation of this file.

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

#ifndef DtRtiExecHandshakeProcessor_H_
#define DtRtiExecHandshakeProcessor_H_

#include "forwarderNode.h"
#include "execHandshakeMsg.h"
#include "routeMap.h"
#include "rtiMsConfig.h"

#include <vlutil/vlUtil.h>
#include <map>
#include <set>

class DtRtiExecHandshakeFilter;
class DtRtiExecHandshakeMsg;
template< typename ParentType > class DtRtiExecConnectionFilter;
class DtRtiExecConnectMsg;
class DtRtiExecDisconnectMsg;

class DT_DLL_FORWARDER DtRtiExecHandshakeProcessor
{
public:
   typedef bool (DtRtiExecHandshakeProcessor::* HandshakeMsgHandlerMemberCb)(
      const DtInetAddrAndPort& src, const DtRtiExecHandshakeMsg& msg  );
   typedef bool (DtRtiExecHandshakeProcessor::* DestinationProcessingMemberCb)(
      const DtInetAddrAndPort& src, DtForwarderPort::DtAddressPortList& destinations );

   DtRtiExecHandshakeProcessor( DtBoost::shared_ptr<DtForwarderNode> parent );
   
   virtual ~DtRtiExecHandshakeProcessor();

   virtual bool gotMsgToLanPort( const DtInetAddrAndPort& src,
      const DtRtiExecHandshakeMsg& msg );
   
   virtual bool gotMsgToOutPort( const DtInetAddrAndPort& src,
      const DtRtiExecHandshakeMsg& msg );
   
   virtual bool gotRtiExecConnect( const DtInetAddrAndPort& src,
      const DtRtiExecConnectMsg& msg );

   virtual bool gotRtiExecDisconnect( const DtInetAddrAndPort& src,
      const DtRtiExecDisconnectMsg& msg );

   virtual bool processExecHandshakeDestinations ( const DtInetAddrAndPort& src,
      DtForwarderPort::DtAddressPortList& destinations );

   virtual bool ignoreExecHandshakeDestinations ( const DtInetAddrAndPort& src, 
      DtForwarderPort::DtAddressPortList& destinations );

   virtual bool ignoreExecConnectDestinations ( const DtInetAddrAndPort& src,
      DtForwarderPort::DtAddressPortList& destinations );

   virtual bool isLocalGroupMember( const DtInetAddrAndPort& addr );
   virtual DtInetAddrAndPort locateGroupPortal( const DtInetAddrAndPort& addr );

   virtual DtInetAddrAndPort localNodeAddress();

public:

   static int lostConnection( const MAKRti::DtString& connName, const MAKRti::DtString& hostName,
      unsigned int connID, const std::pair<DtInetAddrAndPort, DtInetAddrAndPort>& connAddr, void* usr);

protected:

   virtual int lostConnection( const MAKRti::DtString& connName, const MAKRti::DtString& hostName,
      unsigned int connID, const std::pair<DtInetAddrAndPort, DtInetAddrAndPort>& connAddr);
   
   virtual void sendResponseMsg( DtRtiExecHandshakeMsg::DtHandshakeStatus status,
      DtHandle src, DtHandle dest, const MAKRti::DtString& hostName, bool fullyCompliant,
      const DtInetAddrAndPort* addr = 0 );

   virtual bool processInToOutMsg( const DtInetAddrAndPort& src,
      const DtRtiExecHandshakeMsg& msg );
   
   virtual bool processLanToOutMsg( const DtInetAddrAndPort& src,
      const DtRtiExecHandshakeMsg& msg );

   
protected:

   class PendingRequest;
   typedef std::set< unsigned int >                 DtConnIdList;
   typedef std::map< unsigned int, PendingRequest > DtConnIdToRequestMap;

   class PendingRequest
   {
   public:
      typedef std::set< unsigned int >              DtConnIdList;
      
      PendingRequest() :
         currentStatus( DtRtiExecHandshakeMsg::HsResponseGranted ),
         destinationHandle( 0 ),
         sourceHandle( 0 ),
         sourceAddress(),
         pendingOutResponses(),
         pendingLanResponses() {}
         
      PendingRequest( const DtInetAddrAndPort& src, DtHandle destHandle,
                      DtHandle srcHandle,
                      const DtRouteMap::DtAddressPortList& expectedOutResponses,
                      const DtConnIdList& expectedLanResponses ) :
         currentStatus( DtRtiExecHandshakeMsg::HsResponseGranted ),
         destinationHandle( destHandle ),
         sourceHandle( srcHandle ),
         sourceAddress( src ),
         pendingOutResponses( expectedOutResponses ),
         pendingLanResponses( expectedLanResponses ) {}
         
      DtRtiExecHandshakeMsg::DtHandshakeStatus currentStatus;
      DtHandle                                 destinationHandle;
      DtHandle                                 sourceHandle;
      DtInetAddrAndPort                        sourceAddress;
      DtRouteMap::DtAddressPortList            pendingOutResponses;
      DtConnIdList                             pendingLanResponses;
   };


protected:

   DtBoost::shared_ptr<DtForwarderNode>  myParent;
   DtRtiExecHandshakeFilter*  myMsgToLanFilter;
   DtRtiExecHandshakeFilter*  myMsgToOutFilter;
   DtRtiExecConnectionFilter<DtRtiExecHandshakeProcessor>* myRtiExecConnectionFilter;

   DtConnIdList               myLocalRtiExecConnIds;

   DtConnIdToRequestMap       myPendingRequests;

   unsigned long myConnectionIdOfLocalRtiExec;
   bool myHaveConnectionIdOfLocalRtiExec;
   
};

#endif