Pol::Clib::ThreadedOFStreamWriter Class Reference

#include <streamsaver.h>

Inheritance diagram for Pol::Clib::ThreadedOFStreamWriter:

Public Member Functions
	ThreadedOFStreamWriter ()
	ofstream implementation with worker thread for file io More...
	ThreadedOFStreamWriter (std::ofstream *stream)
virtual	~ThreadedOFStreamWriter ()
virtual void	flush () POL_OVERRIDE
virtual void	flush_file () POL_OVERRIDE
virtual void	init (const std::string &filepath) POL_OVERRIDE
Public Member Functions inherited from Pol::Clib::StreamWriter
	StreamWriter ()
	BaseClass implements only writer operator logic. More...
virtual	~StreamWriter ()
fmt::Writer &	operator() ()

Private Types
typedef message_queue< WriterPtr >	writer_queue
typedef std::unique_ptr< fmt::Writer >	WriterPtr

Private Member Functions
void	start_worker ()

Private Attributes
writer_queue	_msg_queue
std::ofstream *	_stream
std::string	_stream_name
std::list< WriterPtr >	_writers_hold
std::thread	_writethread

Additional Inherited Members
Protected Attributes inherited from Pol::Clib::StreamWriter
std::unique_ptr< fmt::Writer >	_writer

Detailed Description

Definition at line 78 of file streamsaver.h.

Member Typedef Documentation

typedef message_queue<WriterPtr> Pol::Clib::ThreadedOFStreamWriter::writer_queue

private

Definition at line 81 of file streamsaver.h.

typedef std::unique_ptr<fmt::Writer> Pol::Clib::ThreadedOFStreamWriter::WriterPtr

private

Definition at line 80 of file streamsaver.h.

Constructor & Destructor Documentation

Pol::Clib::ThreadedOFStreamWriter::ThreadedOFStreamWriter

(

)

ofstream implementation with worker thread for file io

Definition at line 121 of file streamsaver.cpp.

References start_worker().

Pol::Clib::ThreadedOFStreamWriter::ThreadedOFStreamWriter

(

std::ofstream *

stream

)

Definition at line 127 of file streamsaver.cpp.

References start_worker().

Pol::Clib::ThreadedOFStreamWriter::~ThreadedOFStreamWriter ( )

virtual

Definition at line 168 of file streamsaver.cpp.

References flush_file().

Member Function Documentation

void Pol::Clib::ThreadedOFStreamWriter::flush ( )

virtual

Implements Pol::Clib::StreamWriter.

Definition at line 180 of file streamsaver.cpp.

References _msg_queue, Pol::Clib::StreamWriter::_writer, _writers_hold, and Pol::Clib::message_queue< Message >::push().

Referenced by flush_file().

void Pol::Clib::ThreadedOFStreamWriter::flush_file ( )

virtual

Implements Pol::Clib::StreamWriter.

Definition at line 193 of file streamsaver.cpp.

References _msg_queue, _stream, _writers_hold, _writethread, Pol::Clib::message_queue< Message >::cancel(), flush(), and Pol::Clib::message_queue< Message >::push().

Referenced by ~ThreadedOFStreamWriter().

void Pol::Clib::ThreadedOFStreamWriter::init ( const std::string &  filepath )

virtual

Implements Pol::Clib::StreamWriter.

Definition at line 173 of file streamsaver.cpp.

References _stream, and _stream_name.

void Pol::Clib::ThreadedOFStreamWriter::start_worker ( )

private

Definition at line 137 of file streamsaver.cpp.

References _msg_queue, _stream, _writethread, Pol::Clib::message_queue< Message >::pop_remaining(), and Pol::Clib::message_queue< Message >::pop_wait().

Referenced by ThreadedOFStreamWriter().

Member Data Documentation

writer_queue Pol::Clib::ThreadedOFStreamWriter::_msg_queue

private

Definition at line 94 of file streamsaver.h.

Referenced by flush(), flush_file(), and start_worker().

std::ofstream* Pol::Clib::ThreadedOFStreamWriter::_stream

private

Definition at line 93 of file streamsaver.h.

Referenced by flush_file(), init(), and start_worker().

std::string Pol::Clib::ThreadedOFStreamWriter::_stream_name

private

Definition at line 97 of file streamsaver.h.

Referenced by init().

std::list<WriterPtr> Pol::Clib::ThreadedOFStreamWriter::_writers_hold

private

Definition at line 96 of file streamsaver.h.

Referenced by flush(), and flush_file().

std::thread Pol::Clib::ThreadedOFStreamWriter::_writethread

private

Definition at line 95 of file streamsaver.h.

Referenced by flush_file(), and start_worker().

---

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

• clib/streamsaver.h
• clib/streamsaver.cpp