/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_6_2_7/src/EventFilter/StorageManager/interface/DiscardManager.h

Go to the documentation of this file.

// $Id: DiscardManager.h,v 1.7 2011/04/07 08:02:03 mommsen Exp $

#ifndef EventFilter_StorageManager_DiscardManager_h
#define EventFilter_StorageManager_DiscardManager_h

#include "xdaq/ApplicationContext.h"
#include "xdaq/ApplicationDescriptor.h"
#include "toolbox/mem/Pool.h"

#include "boost/shared_ptr.hpp"

#include <map>
#include <string>
#include <utility>


namespace stor {

  class DataSenderMonitorCollection;
  class FUProxy;
  class I2OChain;


  class DiscardManager
  {
  public:

    typedef std::pair<std::string, unsigned int> HLTSenderKey;
    typedef boost::shared_ptr<FUProxy> FUProxyPtr;
    typedef std::map< HLTSenderKey, boost::shared_ptr<FUProxy> > FUProxyMap;

    DiscardManager
    (
      xdaq::ApplicationContext*,
      xdaq::ApplicationDescriptor*,
      DataSenderMonitorCollection&
    );

    void configure();

    bool sendDiscardMessage(I2OChain const&);

  private:

    FUProxyPtr getProxyFromCache
    (
      std::string const& hltClassName,
      unsigned int const& hltInstance
    );
    
    FUProxyPtr makeNewFUProxy
    (
      std::string const& hltClassName,
      unsigned int const& hltInstance
    );

    xdaq::ApplicationContext* appContext_;
    xdaq::ApplicationDescriptor* appDescriptor_;
    toolbox::mem::Pool* msgPool_;

    FUProxyMap proxyCache_;

    DataSenderMonitorCollection& dataSenderMonCollection_;
  };

  typedef boost::shared_ptr<DiscardManager> DiscardManagerPtr;

} // namespace stor

#endif // EventFilter_StorageManager_DiscardManager_h