Sirikata::BatchedBuffer Class Reference

#include <BatchedBuffer.hpp>

Collaboration diagram for Sirikata::BatchedBuffer:

List of all members.

Classes
struct	IOVec
Public Member Functions
	BatchedBuffer ()
void	write (const IOVec *iov, uint32 iovcnt)
void	flush ()
void	store (FILE *os)
bool	empty ()
Private Types
typedef Batch< uint8 >	ByteBatch
Private Member Functions
void	write (const void *buf, uint32 nbytes)
Private Attributes
boost::recursive_mutex	mMutex
ByteBatch *	filling
std::deque< ByteBatch * >	batches

---

Member Typedef Documentation

typedef Batch<uint8> Sirikata::BatchedBuffer::ByteBatch [private]

---

Constructor & Destructor Documentation

Sirikata::BatchedBuffer::BatchedBuffer

(

)

---

Member Function Documentation

bool Sirikata::BatchedBuffer::empty

(

)

References batches, filling, and mMutex.

Referenced by Sirikata::Trace::Trace::storageThread().

void Sirikata::BatchedBuffer::flush

(

)

References batches, filling, and mMutex.

Referenced by Sirikata::Trace::Trace::shutdown(), and write().

void Sirikata::BatchedBuffer::store

(

FILE *

os

)

References batches, Sirikata::Batch< T >::items, mMutex, and Sirikata::Batch< T >::size.

Referenced by Sirikata::Trace::Trace::storageThread().

void Sirikata::BatchedBuffer::write	(	const IOVec *	iov,
		uint32	iovcnt
	)

References mMutex.

Referenced by Sirikata::Trace::Trace::writeRecord().

void Sirikata::BatchedBuffer::write	(	const void *	buf,
		uint32	nbytes
	)		[private]

References Sirikata::Batch< T >::avail(), filling, flush(), Sirikata::Batch< T >::full(), Sirikata::Batch< T >::items, mMutex, and Sirikata::Batch< T >::size.

---

Member Data Documentation

std::deque<ByteBatch*> Sirikata::BatchedBuffer::batches [private]

Referenced by empty(), flush(), and store().

ByteBatch* Sirikata::BatchedBuffer::filling [private]

Referenced by empty(), flush(), and write().

boost::recursive_mutex Sirikata::BatchedBuffer::mMutex [private]

Referenced by empty(), flush(), store(), and write().

---

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

• libcore/include/sirikata/core/trace/BatchedBuffer.hpp
• libcore/src/trace/BatchedBuffer.cpp