/data/refman/pasoursint/CMSSW_5_2_9/src/EventFilter/StorageManager/interface/StorageManager.h

Go to the documentation of this file.

// $Id: StorageManager.h,v 1.61 2011/11/17 17:35:40 mommsen Exp $

#ifndef EventFilter_StorageManager_StorageManager_h
#define EventFilter_StorageManager_StorageManager_h

#include <string>

#include "boost/scoped_ptr.hpp"

#include "EventFilter/StorageManager/interface/ConsumerUtils.h"
#include "EventFilter/StorageManager/interface/SharedResources.h"
#include "EventFilter/StorageManager/interface/SMWebPageHelper.h"

#include "xdaq/Application.h"
#include "xgi/exception/Exception.h"
#include "xoap/MessageReference.h"


namespace toolbox { 
  namespace mem {
    class Reference;
  }
}

namespace xgi {
  class Input;
  class Output;
}

namespace stor {

  class DiskWriter;
  class DQMEventProcessor;
  class FragmentProcessor;


  class StorageManager: public xdaq::Application
  {

  public:
  
    StorageManager( xdaq::ApplicationStub* s );


  private:  
  
    StorageManager(StorageManager const&); // not implemented
    StorageManager& operator=(StorageManager const&); // not implemented

    void bindI2OCallbacks();

    void receiveRegistryMessage(toolbox::mem::Reference *ref);

    void receiveDataMessage(toolbox::mem::Reference *ref);

    void receiveErrorDataMessage(toolbox::mem::Reference *ref);

    void receiveDQMMessage(toolbox::mem::Reference *ref);

    void receiveEndOfLumiSectionMessage(toolbox::mem::Reference *ref);

    void bindStateMachineCallbacks();

    xoap::MessageReference handleFSMSoapMessage( xoap::MessageReference )
      throw( xoap::exception::Exception );


    void bindWebInterfaceCallbacks();

    void css(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void defaultWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void inputWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void storedDataWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void fileStatisticsWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void rbsenderWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void rbsenderDetailWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void consumerStatisticsPage( xgi::Input* in, xgi::Output* out )
      throw( xgi::exception::Exception );

    void dqmEventStatisticsWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void throughputWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void consumerListWebPage(xgi::Input *in, xgi::Output *out)
      throw (xgi::exception::Exception);

    void bindConsumerCallbacks();

    void processConsumerRegistrationRequest( xgi::Input* in, xgi::Output* out )
      throw( xgi::exception::Exception );

    void processConsumerHeaderRequest( xgi::Input* in, xgi::Output* out )
      throw( xgi::exception::Exception );

    void processConsumerEventRequest( xgi::Input* in, xgi::Output* out )
      throw( xgi::exception::Exception );
 
    void processDQMConsumerRegistrationRequest( xgi::Input* in, xgi::Output* out )
      throw( xgi::exception::Exception );

    void processDQMConsumerEventRequest( xgi::Input* in, xgi::Output* out )
      throw( xgi::exception::Exception );

    void initializeSharedResources();

    void startWorkerThreads();

    SharedResourcesPtr sharedResources_;

    boost::scoped_ptr<FragmentProcessor> fragmentProcessor_;
    boost::scoped_ptr<DiskWriter> diskWriter_;
    boost::scoped_ptr<DQMEventProcessor> dqmEventProcessor_;

    typedef ConsumerUtils<Configuration,EventQueueCollection> ConsumerUtils_t;
    boost::scoped_ptr<ConsumerUtils_t> consumerUtils_;
    boost::scoped_ptr<SMWebPageHelper> smWebPageHelper_;

  };

} // namespace stor

#endif // EventFilter_StorageManager_StorageManager_h