include/vrfcgf/cgfDispatcher.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2002 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: cgfDispatcher.h,v $ $Revision: 1.31 $ $State: Exp $
*******************************************************************************/

#ifndef DtCgfDispatcher_H_
#define DtCgfDispatcher_H_



#include <vrfExtProtocol/msgTypes.h>
#include "vrfMsgTransport/vrfMsgIf.h"
#include "vrfmsgs/ifLoadScen.h"
#include "vrfmsgs/ifSaveScen.h"
#include "vrfmsgs/ifCloseScen.h"
#include "vrfmsgs/ifControl.h"
#include "vrfcgf/cgf.h"
#include <vlutil/vlFilename.h>
#include "vrfutil/compressedFileTransport.h"
#include <vl/startInter.h>
#include <vl/stopInter.h>
class DtIfControlMsg;
class DtTimer;

#include "vrfcgf/vrfcgfDefines.h"
class DT_DLL_vrfcgf DtCgfDispatcher
{
public:
   DtCgfDispatcher(DtCgf* cgf,
      DtVrfMessageInterface* messageIf,
      int receivePort = 8000);

   virtual ~DtCgfDispatcher();

   virtual void closeScenario(DtIfCloseScenario* msg);
   virtual void loadScenario(DtIfLoadScenario* msg);
   virtual void saveScenario(DtIfSaveScenario* msg, 
      const DtSimulationAddress& requester);

   virtual void controlScenario(DtIfControl* msgData, 
      const DtSimulationAddress& sender);

   virtual void setEnableResourceMonitor(bool b);

   virtual void tick();

   virtual void setTimeToQuit(bool yesNo);
   virtual bool timeToQuit() const;

   virtual DtVrfMessageInterface* messageInterface() const;

   virtual DtCgf* cgf() const;

   virtual int port() const;

   virtual const DtFilename& tempDirectory();
   virtual void setTempDirectory(const DtFilename& f);

   virtual void cleanupSockets();

   virtual unsigned int simMgmtPduProcessLevel() const;
   virtual void setSimMgmtPduProcessLevel(unsigned int level);

   virtual void processCapableTaskAndSetQuery(DtSimMessage* msg);
   virtual void processDIGuyAppearAndAniamtionsQuery(DtSimMessage* msg);

public:
   
   static void processMessageCb(DtSimMessage* msg, void* usr);

   static void startResumeSimCb(DtStartResumeInteraction* msg, void* usr);

   static void stopFreezeSimCb(DtStopFreezeInteraction* msg, void* usr);

   static void receiveFileCb(const DtFilename& f, void* usr);

   static void runDurationCompleteCallback(DtTimer* timer);

protected:
   virtual bool shouldTryReload(const DtScenario& scenario);

   virtual void pause();

   virtual void run();

   virtual void rewind();

   virtual void step(const DtSimulationAddress& sender);

   virtual void runForDuration(double duration, const DtSimulationAddress& sender);

protected:

   int myPort;
   bool myTimeToQuit;
   DtCgf* myCgf;
   DtVrfMessageInterface* myMessageIf;
   DtFilename myDir;
   DtCompressedFileTransporter myTransporter;

   DtIfLoadScenario* myPendingLoadScenario;
   unsigned int mySimMgmtPduProcessLevel;
};

#endif