InitMsgCollection.h

Go to the documentation of this file.

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

#ifndef EventFilter_StorageManager_InitMsgCollection_h
#define EventFilter_StorageManager_InitMsgCollection_h

#include "IOPool/Streamer/interface/InitMessage.h"

#include "boost/shared_ptr.hpp"
#include "boost/thread/thread.hpp"
#include <vector>
#include <map>
#include <string>
#include <utility>

namespace stor
{

  typedef std::vector<unsigned char> InitMsgBuffer;
  typedef boost::shared_ptr<InitMsgBuffer> InitMsgSharedPtr;

  class InitMsgCollection
  {

  public:

    InitMsgCollection();

    ~InitMsgCollection();

    bool addIfUnique(InitMsgView const& initMsgView);

    InitMsgSharedPtr getElementForOutputModule(const std::string& requestedOMLabel) const;

    InitMsgSharedPtr getLastElement() const;

    InitMsgSharedPtr getElementAt(const unsigned int index) const;
 
    void clear();

    size_t size() const;

    size_t initMsgCount(const std::string& outputModuleLabel) const;

    size_t maxMsgCount() const;

    std::string getSelectionHelpString() const;

    std::string getOutputModuleName(const uint32_t outputModuleId) const;

    static std::string stringsToText(Strings const& list,
                                     unsigned int maxCount = 0);

  private:

    void add(InitMsgView const& initMsgView);

    typedef std::pair<InitMsgSharedPtr, size_t> InitMsgPtrAndCount;
    typedef std::vector<InitMsgPtrAndCount> InitMsgList;
    InitMsgList initMsgList_;

    typedef std::map<uint32_t, std::string> OutModTable;
    OutModTable outModNameTable_;
    mutable boost::mutex listLock_;
  };
  
  typedef boost::shared_ptr<InitMsgCollection> InitMsgCollectionPtr;

} //namespace stor

#endif // EventFilter_StorageManager_InitMsgCollection_h