/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_6_2_5/src/EventFilter/StorageManager/interface/FragmentProcessor.h

Go to the documentation of this file.

// $Id: FragmentProcessor.h,v 1.6 2011/03/07 15:31:32 mommsen Exp $

#ifndef EventFilter_StorageManager_FragmentProcessor_h
#define EventFilter_StorageManager_FragmentProcessor_h

#include "toolbox/lang/Class.h"
#include "toolbox/task/WaitingWorkLoop.h"
#include "xdaq/Application.h"

#include "boost/date_time/posix_time/posix_time_types.hpp"
#include "boost/shared_ptr.hpp"

#include "EventFilter/StorageManager/interface/EventDistributor.h"
#include "EventFilter/StorageManager/interface/FragmentQueue.h"
#include "EventFilter/StorageManager/interface/FragmentStore.h"
#include "EventFilter/StorageManager/interface/SharedResources.h"
#include "EventFilter/StorageManager/interface/StateMachine.h"
#include "EventFilter/StorageManager/interface/WrapperNotifier.h"


namespace stor {

  class I2OChain;
  class QueueID;


  class FragmentProcessor : public toolbox::lang::Class
  {
  public:
    
    FragmentProcessor( xdaq::Application *app, SharedResourcesPtr sr );

    ~FragmentProcessor();
    
    bool processMessages(toolbox::task::WorkLoop*);

    void startWorkLoop(std::string workloopName);


  private:

    void processAllCommands();

    void processAllRegistrations();

    void processOneFragmentIfPossible();

    void processOneFragment();

    xdaq::Application*                 app_;
    SharedResourcesPtr                 sharedResources_;
    WrapperNotifier                    wrapperNotifier_;
    StateMachinePtr                    stateMachine_;
    FragmentStore                      fragmentStore_;
    EventDistributor                   eventDistributor_;

    boost::posix_time::time_duration   timeout_; // Waiting time
    bool                               actionIsActive_;

    toolbox::task::WorkLoop*           processWL_;      

  };
  
} // namespace stor

#endif // EventFilter_StorageManager_FragmentProcessor_h