/data/refman/pasoursint/CMSSW_4_1_8_patch13/src/EventFilter/SMProxyServer/src/EventMsg.cc

Go to the documentation of this file.

// $Id: EventMsg.cc,v 1.1.4.2 2011/03/07 12:01:12 mommsen Exp $

#include "EventFilter/SMProxyServer/interface/EventMsg.h"


namespace smproxy
{

  EventMsg::EventMsg() :
  faulty_(true)
  {}
  
  
  EventMsg::EventMsg(const EventMsgView& eventMsgView) :
  faulty_(false)
  {
    buf_.reset( new EventMsgBuffer(eventMsgView.size()) );
    std::copy(
      eventMsgView.startAddress(),
      eventMsgView.startAddress()+eventMsgView.size(),
      &(*buf_)[0]
    );
  }
  
  
  void EventMsg::tagForEventConsumers(const stor::QueueIDs& queueIDs)
  {
    queueIDs_ = queueIDs;
  }
  
  
  const stor::QueueIDs& EventMsg::getEventConsumerTags() const
  {
    return queueIDs_;
  }
  
  
  size_t EventMsg::memoryUsed() const
  {
    return sizeof(buf_);
  }
  
  
  unsigned long EventMsg::totalDataSize() const
  {
    return buf_->size();
  }
  
  
  unsigned char* EventMsg::dataLocation() const
  {
    return &(*buf_)[0];
  }
  
  
  bool EventMsg::empty() const
  {
    return (buf_.get() == 0);
  }


  bool EventMsg::faulty() const
  {
    return faulty_;
  }

} // namespace smproxy