ers::FIFOStream Class Reference

Queue stream. More...

#include <FIFOStream.h>

Inheritance diagram for ers::FIFOStream:

List of all members.

Public Member Functions
	FIFOStream ()
	FIFOStream (const FIFOStream &other)
	~FIFOStream ()
virtual void	send (const Issue *i)
virtual Issue *	receive ()
virtual void	print_to (std::ostream &stream) const
	operator std::string () const
Static Public Attributes
static const char *const	FIFO_STREAM_KEY = "fifo"
static const char *const	NULL_STREAM_KEY = "null"
Protected Attributes
std::deque< Issue * >	m_issue_queue

---

Detailed Description

Queue stream.

This streams is used to transmit Issues inside a process.

Author:

Matthias Wiesmann

Version:

1.0

Note:

This stream is not thread safe - it cannot depend on thread library.

Definition at line 22 of file FIFOStream.h.

---

Constructor & Destructor Documentation

ers::FIFOStream::FIFOStream

(

)

Definition at line 28 of file FIFOStream.cxx.

: Stream() {} 

ers::FIFOStream::FIFOStream

(

const FIFOStream &

other

)

Definition at line 30 of file FIFOStream.cxx.

References genRecEmupikp::i, m_issue_queue, and EvtCyclic3::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

(

)

Definition at line 37 of file FIFOStream.cxx.

{}

---

Member Function Documentation

ers::Stream::operator std::string

(

)

const [inherited]

Definition at line 35 of file Stream.cxx.

References ers::Stream::print_to().

                                    {
    std::ostringstream stream ; 
    print_to(stream); 
    return stream.str(); 
} // to string 

void ers::FIFOStream::print_to

(

std::ostream &

stream

)

const [virtual]

Reimplemented from ers::Stream.

Definition at line 63 of file FIFOStream.cxx.

References FIFO_STREAM_KEY, genRecEmupikp::i, and m_issue_queue.

                                                     {
    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

ers::Issue * ers::FIFOStream::receive

(

)

[virtual]

Blocking read into the stream.

Returns:

a reference to the next Issue

Note:

This method is not implemented, pending some form of common TDAQ thread library.

Reimplemented from ers::Stream.

Definition at line 56 of file FIFOStream.cxx.

References m_issue_queue.

                                 {
    if (m_issue_queue.empty()) return 0 ; 
    Issue *issue = m_issue_queue[0] ; 
    m_issue_queue.pop_front();
    return issue ; 
} // receive

void ers::FIFOStream::send

(

const Issue *

i

)

[virtual]

Sends the issue into the stream. This method should put the issue into a FIFO queue and be non blocking

Parameters:

i

pointer to the issue to send

Note:

This method is not implemented, pending some form of common TDAQ thread library.

Reimplemented from ers::Stream.

Definition at line 45 of file FIFOStream.cxx.

References ers::Issue::clone(), ERS_PRE_CHECK_PTR, and m_issue_queue.

                                                  {
    ERS_PRE_CHECK_PTR(issue_ptr); 
    Issue *cloned = issue_ptr->clone();
    m_issue_queue.push_back(cloned); 
} // send

---

Member Data Documentation

const char *const ers::FIFOStream::FIFO_STREAM_KEY = "fifo" [static]

Key for FIFO stream

Definition at line 27 of file FIFOStream.h.

Referenced by create_stream(), and print_to().

std::deque<Issue*> ers::FIFOStream::m_issue_queue [protected]

Definition at line 25 of file FIFOStream.h.

Referenced by FIFOStream(), print_to(), receive(), and send().

const char *const ers::Stream::NULL_STREAM_KEY = "null" [static, inherited]

Key for discard stream

Definition at line 39 of file Stream.h.

Referenced by create_stream(), and ers::Stream::print_to().

---