Encapsulates asynchronous buffered block writing engine. More...
#include <buf_writer.h>

Public Member Functions | |
| buffered_writer (unsigned_type write_buf_size, unsigned_type write_batch_size) | |
| Constructs an object. | |
| block_type * | get_free_block () |
| Returns free block from the internal buffer pool. | |
| block_type * | write (block_type *filled_block, const bid_type &bid) |
| Submits block for writing. | |
| void | flush () |
| Flushes not yet written buffers. | |
| virtual | ~buffered_writer () |
| Flushes not yet written buffers and frees used memory. | |
Protected Types | |
| typedef block_type::bid_type | bid_type |
|
typedef std::priority_queue < batch_entry, std::vector < batch_entry > , batch_entry_cmp > | batch_type |
Protected Attributes | |
| const unsigned_type | nwriteblocks |
| block_type * | write_buffers |
| bid_type * | write_bids |
| request_ptr * | write_reqs |
| const unsigned_type | writebatchsize |
| std::vector< int_type > | free_write_blocks |
| std::vector< int_type > | busy_write_blocks |
| batch_type | batch_write_blocks |
Encapsulates asynchronous buffered block writing engine.
buffered_writer overlaps I/Os with filling of output buffer.
| buffered_writer< block_type >::buffered_writer | ( | unsigned_type | write_buf_size, | |
| unsigned_type | write_batch_size | |||
| ) | [inline] |
Constructs an object.
| write_buf_size | number of write buffers to use | |
| write_batch_size | number of blocks to accumulate in order to flush write requests (bulk buffered writing) |
| virtual buffered_writer< block_type >::~buffered_writer | ( | ) | [inline, virtual] |
Flushes not yet written buffers and frees used memory.
| void buffered_writer< block_type >::flush | ( | ) | [inline] |
Flushes not yet written buffers.
| block_type* buffered_writer< block_type >::get_free_block | ( | ) | [inline] |
Returns free block from the internal buffer pool.
References wait_any().
Referenced by buffered_writer< block_type >::write().
| block_type* buffered_writer< block_type >::write | ( | block_type * | filled_block, | |
| const bid_type & | bid | |||
| ) | [inline] |
Submits block for writing.
| filled_block | pointer to the block |
filled_block must be value returned by get_free_block() or write() methods | bid | block identifier, a place to write data of the filled_block |
References buffered_writer< block_type >::get_free_block().
1.7.1