synchronousFileDistributor.h

Go to the documentation of this file.

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


#ifndef DtSynchronousMultFileDistributor_H_
#define DtSynchronousMultFileDistributor_H_


#include "fileDistributor.h"


class DtSynchronousFileDistributor;
//DtFileDistributorThread creator callback signature

class DT_DLL_LRC DtSynchronousFileDistributor : public DtFileDistributor
{

public:
   
   DtSynchronousFileDistributor( const int fedEx, const MAKRti::DtString& fedExName,
      DtConnectionMgr* connMgr );

   virtual ~DtSynchronousFileDistributor();


   

public:

   virtual bool tick();

   static DtSynchronousFileDistributor* create(const int fedEx, 
                                               const MAKRti::DtString& fedExName,
                                               DtConnectionMgr* connMgr );


   virtual bool sendFedFile(const std::vector<MAKRti::DtString>& modules);

   virtual bool pullEntireFedFile(const std::vector<MAKRti::DtString>& modules);

   static void multFileReceivedCb( const DtFomModuleDistributionMsg& msg, void* usr );

   bool pushedFomModules() const;

   bool pullInProgress() const;

   void getPushedFomModules(std::vector<MAKRti::DtString>& modules);

   void multFileRequestedCb( const DtFomModuleRequestMsg& msg );

   void multFileReceivedCb( const DtFomModuleDistributionMsg& msg );

   void fileReceivedCb(const DtFomModuleDistributionMsg& msg );

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

private:

   
   //Really the string associated with the file when their contents were uploaded.
   //All files stored as tmpFiles.
   
   DtConnectionMgr*        myConnMgr;
   std::vector<MAKRti::DtString>   myReceivedPushedFomModules;

   bool myPullInProgress;
      
};

#endif  //! DtSynchronousMultFileDistributor_H_