---

DQMEventServer.h

Go to the documentation of this file.

#ifndef STOR_DQMEVENT_SERVER_H
#define STOR_DQMEVENT_SERVER_H

#include <sys/time.h>
#include <string>
#include <vector>
#include "IOPool/Streamer/interface/MsgTools.h"
#include "IOPool/Streamer/interface/DQMEventMessage.h"
#include "EventFilter/StorageManager/interface/DQMConsumerPipe.h"
#include "boost/shared_ptr.hpp"
#include "boost/thread/mutex.hpp"
#include "boost/thread/thread.hpp"

namespace stor
{
  class DQMEventServer
  {
  public:
    DQMEventServer(double maximumRate);
    ~DQMEventServer();

    void addConsumer(boost::shared_ptr<DQMConsumerPipe> consumer);
    boost::shared_ptr<DQMConsumerPipe> getConsumer(uint32 consumerId);
    void processDQMEvent(const DQMEventMsgView &eventView);
    boost::shared_ptr< std::vector<char> > getDQMEvent(uint32 consumerId);
    void clearQueue();
    std::map< uint32, boost::shared_ptr<DQMConsumerPipe> > getConsumerTable()
    { return(consumerTable);}

  private:

    // data members for handling a maximum rate of accepted events
    static const double MAX_ACCEPT_INTERVAL;
    double minTimeBetweenEvents_;  // seconds
    struct timeval lastAcceptedEventTime_;

    // data members for deciding when to check for disconnected consumers
    int disconnectedConsumerTestCounter_;

    // consumer lists
    std::map< uint32, boost::shared_ptr<DQMConsumerPipe> > consumerTable;
    //std::vector<boost::shared_ptr<DQMConsumerPipe>> vipConsumerList;
  };
}

#endif

---