SMProxyServer.h

Go to the documentation of this file.

// $Id: SMProxyServer.h,v 1.23 2011/03/07 15:41:54 mommsen Exp $

#ifndef EventFilter_SMProxyServer_SMProxyServer_h
#define EventFilter_SMProxyServer_SMProxyServer_h

#include "EventFilter/SMProxyServer/interface/StateMachine.h"
#include "EventFilter/SMProxyServer/interface/SMPSWebPageHelper.h"
#include "EventFilter/StorageManager/interface/ConsumerUtils.h"

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


namespace xgi {
  class Input;
  class Output;
}

namespace smproxy {

  class SMProxyServer: public xdaq::Application
  {

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

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

    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 dataRetrieverWebPage( xgi::Input* in, xgi::Output* out )
      throw( xgi::exception::Exception );

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

    void dqmEventStatisticsWebPage(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();

    StateMachinePtr stateMachine_;

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

    
    boost::scoped_ptr<SMPSWebPageHelper> smpsWebPageHelper_;

  };

} // namespace smproxy

#endif // EventFilter_SMProxyServer_SMProxyServer_h