---

edmtest::TestConsumer Class Reference

#include <IOPool/Streamer/src/TestConsumer.h>

List of all members.

Public Member Functions
void	bufferReady ()
void	sendRegistry (void *buf, int len)
void	stop ()
	TestConsumer (edm::ParameterSet const &ps, edm::EventBuffer *buf)
	~TestConsumer ()
Private Attributes
edm::EventBuffer *	bufs_
Worker *	worker_

---

Detailed Description

Definition at line 11 of file TestConsumer.h.

---

Constructor & Destructor Documentation

edmtest::TestConsumer::TestConsumer	(	edm::ParameterSet const &	ps,
		edm::EventBuffer *	buf
	)

Definition at line 96 of file TestConsumer.cc.

00097                                                  :
00098     worker_(new Worker(ps.getParameter<std::string>("fileName"),
00099                        ps.getUntrackedParameter<int>("numPerFile",1<<31))),
00100     bufs_(buf)
00101   {
00102     // first write out all the product registry data into the front
00103     // of the output file (in text format)
00104   }
  

edmtest::TestConsumer::~TestConsumer

(

)

Definition at line 106 of file TestConsumer.cc.

References worker_.

  {
    delete worker_;
  }

---

Member Function Documentation

void edmtest::TestConsumer::bufferReady

(

)

Definition at line 111 of file TestConsumer.cc.

References edm::EventBuffer::OperateBuffer< T >::buffer(), bufs_, edmtest::Worker::checkCount(), edmtest::Worker::ost_, edm::EventBuffer::OperateBuffer< T >::size(), and worker_.

  {
    worker_->checkCount();

    EventBuffer::ConsumerBuffer cb(*bufs_);

    int sz = cb.size();
    worker_->ost_->write((const char*)(&sz),sizeof(int));
    worker_->ost_->write((const char*)cb.buffer(),sz);

  }

void edmtest::TestConsumer::sendRegistry	(	void *	buf,
		int	len
	)

Definition at line 129 of file TestConsumer.cc.

References edmtest::Worker::saveReg(), worker_, and edmtest::Worker::writeReg().

  {
    worker_->saveReg(buf,len);
    worker_->writeReg();
  }

void edmtest::TestConsumer::stop

(

)

Definition at line 123 of file TestConsumer.cc.

References bufs_, and edm::EventBuffer::OperateBuffer< T >::commit().

  {
    EventBuffer::ProducerBuffer pb(*bufs_);
    pb.commit();
  }

---

Member Data Documentation

edm::EventBuffer* edmtest::TestConsumer::bufs_ [private]

Definition at line 25 of file TestConsumer.h.

Referenced by bufferReady(), and stop().

Worker* edmtest::TestConsumer::worker_ [private]

Definition at line 24 of file TestConsumer.h.

Referenced by bufferReady(), sendRegistry(), and ~TestConsumer().

---

The documentation for this class was generated from the following files:

• IOPool/Streamer/src/TestConsumer.h
• IOPool/Streamer/src/TestConsumer.cc

---