EventMsg.h

Go to the documentation of this file.

// $Id: EventMsg.h,v 1.3 2011/03/08 18:44:55 mommsen Exp $

#ifndef EventFilter_SMProxyServer_EventMsg_h
#define EventFilter_SMProxyServer_EventMsg_h

#include "EventFilter/StorageManager/interface/QueueID.h"
#include "IOPool/Streamer/interface/EventMessage.h"

#include <boost/shared_ptr.hpp>
#include <vector>

namespace smproxy {

  class EventMsg
  {
  public:
    
    EventMsg();
    EventMsg(const EventMsgView&);

    void tagForEventConsumers(const stor::QueueIDs&);

    const stor::QueueIDs& getEventConsumerTags() const;

    unsigned int droppedEventsCount() const;

    void setDroppedEventsCount(unsigned int count);

    size_t memoryUsed() const;
    
    unsigned long totalDataSize() const;

    unsigned char* dataLocation() const;

    bool empty() const;

    bool faulty() const;


  private:
    typedef std::vector<unsigned char> EventMsgBuffer;
    boost::shared_ptr<EventMsgBuffer> buf_;
    bool faulty_;
    unsigned int droppedEventsCount_;

    stor::QueueIDs queueIDs_;
  };
  
} // namespace smproxy

#endif // EventFilter_SMProxyServer_EventMsg_h 



// emacs configuration
// Local Variables: -
// mode: c++ -
// c-basic-offset: 2 -
// indent-tabs-mode: nil -
// End: -