BufferedIOHandler Class Reference

a IOHandler with buffer support the buffer is only for read(). write() is not supported the public functions of this class are *not* thread safe! More...

#include <buffered_io_handler.h>

Inheritance diagram for BufferedIOHandler:

Public Member Functions
	BufferedIOHandler (zmm::Ref< IOHandler > underlyingHandler, size_t bufSize, size_t maxChunkSize, size_t initialFillSize)
	get an instance of a BufferedIOHandler
virtual void	open (enum UpnpOpenFileMode mode)
	Opens a data for the web server.
virtual void	close ()
	Close/free previously opened/initialized data.
virtual int	read (char *buf, size_t length)
	Reads previously opened/initialized data sequentially.
virtual void	seek (off_t offset, int whence)
	Performs a seek on an open/initialized data.
virtual int	write (char *buf, size_t length)
	Writes to previously opened/initialized data sequentially.
void	retain ()
void	release ()
int	getRefCount ()
Static Public Member Functions
static void *	operator new (size_t size)
static void	operator delete (void *ptr)
Protected Member Functions
void	startBufferThread ()
void	stopBufferThread ()
Static Protected Member Functions
static void *	staticThreadProc (void *arg)
Protected Attributes
size_t	bufSize
size_t	initialFillSize
char *	buffer
bool	isOpen
bool	eof
bool	readError
bool	waitForInitialFillSize
bool	signalAfterEveryRead
bool	checkSocket
bool	empty
size_t	a
size_t	b
off_t	posRead
bool	seekEnabled
bool	doSeek
off_t	seekOffset
int	seekWhence
pthread_t	bufferThread
bool	threadShutdown
zmm::Ref< Cond >	cond
zmm::Ref< Mutex >	mutex
mt_atomic_t	_ref_count
Private Member Functions
virtual void	threadProc ()
Private Attributes
zmm::Ref< IOHandler >	underlyingHandler
size_t	maxChunkSize

Detailed Description

a IOHandler with buffer support the buffer is only for read(). write() is not supported the public functions of this class are *not* thread safe!

Definition at line 42 of file buffered_io_handler.h.

Constructor & Destructor Documentation

BufferedIOHandler::BufferedIOHandler	(	zmm::Ref< IOHandler >	underlyingHandler,
		size_t	bufSize,
		size_t	maxChunkSize,
		size_t	initialFillSize
	)

get an instance of a BufferedIOHandler

Parameters:

	underlyingHandler	the IOHandler from which the buffer should read
	bufSize	the size of the buffer in bytes
	maxChunkSize	the maximum size of the chunks which are read by the buffer
	initialFillSize	the number of bytes which have to be in the buffer before the first read at the very beginning or after a seek returns; 0 disables the delay

Definition at line 41 of file buffered_io_handler.cc.

References _, _Exception, and nil.

Member Function Documentation

void BufferedIOHandler::close ( ) [virtual]

Close/free previously opened/initialized data.

Reimplemented from IOHandlerBufferHelper.

Definition at line 61 of file buffered_io_handler.cc.

References underlyingHandler.

int Object::getRefCount ( ) [inherited]

Definition at line 78 of file object.cc.

References zmm::Object::_ref_count, and atomic_get().

virtual void BufferedIOHandler::open ( enum UpnpOpenFileMode mode ) [virtual]

Opens a data for the web server.

Parameters:

mode

in which the data will be opened (we only support UPNP_READ)

Todo:: Genych, ya tut che to zapamyatowal kak gawno rabotaet? kto filename poluchaet??

Reimplemented from IOHandlerBufferHelper.

void Object::operator delete ( void * ptr ) [static, inherited]

Definition at line 87 of file object.cc.

References FREE.

void * Object::operator new ( size_t size ) [static, inherited]

Definition at line 83 of file object.cc.

References MALLOC.

virtual int IOHandlerBufferHelper::read	(	char *	buf,
		size_t	length
	)			`[virtual, inherited]`

Reads previously opened/initialized data sequentially.

Parameters:

	buf	This buffer will be filled by our read functions.
	length	Number of bytes to read.

Reimplemented from IOHandler.

void Object::release ( ) [inherited]

Definition at line 66 of file object.cc.

References zmm::Object::_ref_count, atomic_dec(), and zmm::Object::mutex.

Referenced by zmm::ArrayBase::clear(), zmm::String::operator=(), DSOHash< zmm::Array< CacheObject > >::releaseData(), DSBHash< VT >::releaseData(), DSOHash< zmm::Array< CacheObject > >::remove(), zmm::ArrayBase::remove(), zmm::ArrayBase::removeUnordered(), zmm::ArrayBase::set(), zmm::ArrayBase::~ArrayBase(), DSOHash< zmm::Array< CacheObject > >::~DSOHash(), zmm::ObjectQueue< AutoscanDirectory >::~ObjectQueue(), zmm::ObjectStack< Element >::~ObjectStack(), and zmm::String::~String().

void Object::retain ( ) [inherited]

Definition at line 58 of file object.cc.

References zmm::Object::_ref_count, atomic_inc(), and zmm::Object::mutex.

Referenced by zmm::ArrayBase::append(), zmm::ObjectQueue< AutoscanDirectory >::enqueue(), zmm::ArrayBase::insert(), zmm::String::operator=(), zmm::ObjectStack< Element >::push(), DSOHash< zmm::Array< CacheObject > >::put(), DSBHash< VT >::put(), zmm::ArrayBase::set(), and zmm::String::String().

virtual void IOHandlerBufferHelper::seek	(	off_t	offset,
		int	whence
	)			`[virtual, inherited]`

Performs a seek on an open/initialized data.

Parameters:

	offset	Number of bytes to move in the buffer. For seeking forwards positive values are used, for seeking backwards - negative. Offset must be positive if origin is set to SEEK_SET
	whence	The position to move relative to. SEEK_CUR to move relative to current position, SEEK_END to move relative to the end of file, SEEK_SET to specify an absolute offset.

Reimplemented from IOHandler.

void IOHandlerBufferHelper::startBufferThread ( ) [protected, inherited]

Definition at line 201 of file io_handler_buffer_helper.cc.

References IOHandlerBufferHelper::bufferThread, NULL, and IOHandlerBufferHelper::staticThreadProc().

void * IOHandlerBufferHelper::staticThreadProc ( void * arg ) [static, protected, inherited]

Definition at line 222 of file io_handler_buffer_helper.cc.

References log_debug, NULL, and IOHandlerBufferHelper::threadProc().

Referenced by IOHandlerBufferHelper::startBufferThread().

void IOHandlerBufferHelper::stopBufferThread ( ) [protected, inherited]

Definition at line 211 of file io_handler_buffer_helper.cc.

References AUTOLOCK, AUTOUNLOCK, IOHandlerBufferHelper::bufferThread, IOHandlerBufferHelper::cond, IOHandlerBufferHelper::mutex, NULL, and IOHandlerBufferHelper::threadShutdown.

Referenced by IOHandlerBufferHelper::close().