asynchronousFileDistributor.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2007 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: asynchronousFileDistributor.h,v $ $Revision: 1.9 $ $State: Exp $
*********************************************************************/


#ifndef DtAsyncFileDistributorRunnable_H_
#define DtAsyncFileDistributorRunnable_H_


#include "fileDistributor.h"
#include "distributorThreadEvents.h"
#include <vlutil/vlRunnable.h>
#include <vlutil/vlThread.h>
#include "vlThreadSafeQueue.h"
#include <vlutil/vlThreadSafe.h>
#include "vlThreadedObject.h"
#include "fedex.h"

class DtAsyncFileDistributorRunnable;


class DT_DLL_EXEC DtAsyncFileDistributorRunnable : public DtRunnable, public DtFileDistributor
{

public:   

   DtAsyncFileDistributorRunnable( DtFedExec* parent );

   virtual ~DtAsyncFileDistributorRunnable();


   //Event processing.

   virtual DtUniquePtr<DtDistributorThreadEvent> getNextEvent();

   virtual void postCommand( DtUniquePtr<DtFedExecDistribFunctor> cmd);

   virtual void setOnExitHandler( const DtDistributorThreadEvent& fn );

   //Register/ Unregister event calls:
   virtual void registerUploadFedFileToExecEvent( const DtDistribFunctor& fn );
   virtual void registerFedFileRequestsEvent( const DtDistribFunctor& fn );
   virtual void registerRequestedModulesArrivedEvent( const DtDistribFunctor& fn );
   virtual void registerTakeFileEvent( const DtDistribFunctor& fn );
   virtual void registerPushFedFileToFederatesEvent( const DtDistribFunctor& fn );
   virtual void registerPushFedFileToSingleFederateEvent( const DtDistribFunctor& fn );


public:

   virtual void run();
     
   static DtAsyncFileDistributorRunnable* create( DtFedExec* parent );
      
   virtual void requestFedFileUploadToExec( const unsigned long initiatingFedID,
                                                          const std::vector<DtString>* modules);
   virtual bool sendFedFile(const std::vector<DtString>& modules, DtFederateHandle recipient);

   virtual void fedFileUploaded(const DtString fileUploaded);

   void processTakeFileCmd(std::map<DtString, DtFileInformation*>);

   void processPushFedFileToAllFederates(DtString name, int size, const char* buff, unsigned long destination);
   void processFileRequested( const DtFomModuleRequestMsg& cmd );
   void processFileReceived( const DtFomModuleDistributionMsg& cmd );


   bool requestsPending() const;

private:
   DtAsyncFileDistributorRunnable();
   DtAsyncFileDistributorRunnable(const DtAsyncFileDistributorRunnable& orig);
   DtAsyncFileDistributorRunnable& operator=(const DtAsyncFileDistributorRunnable& orig);


private:

   DtFedExec*        myFedEx;

protected:

   typedef std::list<DtDistributorThreadEvent*> DtDistributorThreadEventList;

protected:
   void signalFrontEnd() const;
   bool executeCommand();
   void processInternalCommands();
   void changeCallbackEvents( const DtDistribFunctorChangeRequest& fn );
   void clearEventList( rtiMsgList& theEventList );
   bool myStopped;

protected:
   DtUniquePtr<DtFedExecDistribFunctor> mySignal;
   DtUniquePtr<DtDistributorThreadEvent> myOnExitEvent;

   DtThreadSafeQueue<DtDistributorThreadEvent> myPendingCommands;

   DtThreadSafeQueue<DtDistributorThreadEvent> myEventQueue;

   DtThreadSafeQueue<DtDistributorThreadEvent> myInternalCmdQueue;

   DtDistributorThreadEventList myRequestedModuleArrivedEvents;
   DtDistributorThreadEventList myTakeFileEvents;
   DtDistributorThreadEventList myFedFileRequestedEvents;      
   DtDistributorThreadEventList myFedFileReceivedEvents;
   DtDistributorThreadEventList myPushFedFileToAllFederatesEvents;
   DtDistributorThreadEventList myPushFedFileToSingleFederateEvents;
   DtDistributorThreadEventList myUploadRequestEvents;


   typedef std::pair< DtDistributorThreadEvent*, bool>      DtMsgFunctorIsMomMsgPair;



};

#endif