bulkEnvironmentProcessManager.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2017 VT MAK
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include <vrfExtObjects/dllExport.h>
#include <vrfExtObjects/vrfObjectIdGenerator.h>
#include <list>

class DtBulkEnvironmentProcessPublisher;
class DtEnvironmentProcessPublisherForBulk;

typedef DtGlobalObjectDesignator (*GlobalIdChooser)(void* usr);

class DT_DLL_vrfExtObjects DtBulkEnvironmentProcessManager
{
public:

   DtBulkEnvironmentProcessManager(
      DtExerciseConn* conn, GlobalIdChooser idChooser = 0, void* idChooserUsr = 0);

   virtual ~DtBulkEnvironmentProcessManager();

   virtual void tick();

   virtual void addIndividualEnvironmentProcess(DtEnvironmentProcessPublisherForBulk* publisher);

   virtual void removeIndividualEnvironmentProcess(DtEnvironmentProcessPublisherForBulk* publisher);

   virtual void setMaxBulkRecordsSize(unsigned maxSize);

   virtual unsigned maxBulkRecordsSize() const;

   virtual void setGlobalIdChooser(GlobalIdChooser creator, void* usr);

protected:

   static DtGlobalObjectDesignator defaultGlobalIdChooser(void* usr);

   DtBulkEnvironmentProcessManager(const DtBulkEnvironmentProcessManager& orig);

   DtBulkEnvironmentProcessManager& operator=
      (const DtBulkEnvironmentProcessManager& orig);

protected:

   DtExerciseConn* myExConn;

   GlobalIdChooser myIdChooser;
   void* myIdChooserUsr;

   unsigned myMaxBulkRecordsSize;

   std::vector<DtBulkEnvironmentProcessPublisher*> myBulkPublishers;

   std::list<DtEnvironmentProcessPublisherForBulk*> myIndividualPublishers;
};