FIFOStream.cxx

Go to the documentation of this file.

/*
 *  FIFOStream.cxx
 *  ers
 *
 *  Created by Matthias Wiesmann on 02.12.04.
 *  Copyright 2004 CERN. All rights reserved.
 *
 */
 
#include "ers/FIFOStream.h"
#include "ers/InvalidReferenceIssue.h"
#include "ers/NotImplemented.h"
#include "ers/Precondition.h"
#include "ers/StreamFactory.h"
 
const char* const ers::FIFOStream::FIFO_STREAM_KEY = "fifo";
 
namespace {
  ers::Stream* create_stream( const std::string& protocol, const std::string& uri ) {
    (void)uri; // to shut up the compiler
    if ( protocol == ers::FIFOStream::FIFO_STREAM_KEY ) return new ers::FIFOStream();
    return 0;
  }
  bool registered = ers::StreamFactory::instance()->register_factory(
      ers::FIFOStream::FIFO_STREAM_KEY, create_stream );
} // namespace
 
ers::FIFOStream::FIFOStream() : Stream() {}
 
ers::FIFOStream::FIFOStream( const FIFOStream& other ) : Stream( other ) {
  for ( unsigned int i = 0; i < other.m_issue_queue.size(); i++ )
  {
    Issue* cloned = other.m_issue_queue[i]->clone();
    m_issue_queue.push_back( cloned );
  } // for
} // FIFOStream
 
ers::FIFOStream::~FIFOStream() {}
 
/** Sends the issue into the stream.
 * This method should put the issue into a FIFO queue and be non blocking
 * @param i pointer to the issue to send
 * @note This method is not implemented, pending some form of common TDAQ thread library.
 */
 
void ers::FIFOStream::send( const ers::Issue* issue_ptr ) {
  ERS_PRE_CHECK_PTR( issue_ptr );
  Issue* cloned = issue_ptr->clone();
  m_issue_queue.push_back( cloned );
} // send
 
/** Blocking read into the stream.
 * @return a reference to the next Issue
 * @note This method is not implemented, pending some form of common TDAQ thread library.
 */
 
ers::Issue* ers::FIFOStream::receive() {
  if ( m_issue_queue.empty() ) return 0;
  Issue* issue = m_issue_queue[0];
  m_issue_queue.pop_front();
  return issue;
} // receive
 
void ers::FIFOStream::print_to( std::ostream& stream ) const {
  stream << ers::FIFOStream::FIFO_STREAM_KEY << ":[";
  for ( unsigned int i = 0; i < m_issue_queue.size(); i++ )
  {
    stream << m_issue_queue[i]->what();
    if ( i != m_issue_queue.size() - 1 ) { stream << ", "; } // if not last
  }                                                          // for elements
  stream << "]";
} // print_to