batched_aio_reader< BatchSize > Class Template Reference

Public Member Functions
	batched_aio_reader (int fd)
void	enqueue_read_first_batch (size_t offset_bytes, size_t size_bytes, void *dest)
void	enqueue_read (size_t offset_bytes, size_t size_bytes, void *dest)
void	wait_last_read ()

Protected Member Functions
void	enqueue_next_batch ()

Protected Attributes
const int	_fd
aiocb	_batch1 [BatchSize]
aiocb	_batch2 [BatchSize]
aiocb *	_batch1_ptrs [BatchSize]
aiocb *	_batch2_ptrs [BatchSize]
aiocb **	_active_batch
aiocb **	_next_batch
size_t	_next_batch_size

Detailed Description

template<size_t BatchSize>
class batched_aio_reader< BatchSize >

Definition at line 391 of file profile_algebra_groups_read.cpp.

Constructor & Destructor Documentation

batched_aio_reader()

template<size_t BatchSize>

batched_aio_reader< BatchSize >::batched_aio_reader ( int  fd )

inline

Definition at line 394 of file profile_algebra_groups_read.cpp.

        : _fd(fd)
        , _active_batch(_batch1_ptrs)
        , _next_batch(_batch2_ptrs)
        , _next_batch_size(0)
    {
        memset(_batch1, 0, sizeof(_batch1));
        memset(_batch2, 0, sizeof(_batch2));
        for (size_t i = 0; i < BatchSize; ++i) {
            _batch1_ptrs[i] = &_batch1[i];
            _batch2_ptrs[i] = &_batch2[i];
        }
    }

Member Function Documentation

enqueue_next_batch()

template<size_t BatchSize>

void batched_aio_reader< BatchSize >::enqueue_next_batch ( )

inlineprotected

Definition at line 460 of file profile_algebra_groups_read.cpp.

    {
        int r = lio_listio(LIO_NOWAIT, _next_batch, BatchSize, nullptr);
        if (r != 0) {
            throw std::runtime_error("enqueue_batch error");
        }
    }

enqueue_read()

template<size_t BatchSize>

void batched_aio_reader< BatchSize >::enqueue_read ( size_t  offset_bytes, size_t  size_bytes, void *  dest  )

inline

Definition at line 428 of file profile_algebra_groups_read.cpp.

    {
        assert(_next_batch_size < BatchSize);
 
        aiocb *cb = _next_batch[_next_batch_size];
        cb_init(cb, _fd, offset_bytes, size_bytes, dest);
 
        ++_next_batch_size;
        if (_next_batch_size == BatchSize) {
            enqueue_next_batch();
        }
    }

Here is the call graph for this function:

enqueue_read_first_batch()

template<size_t BatchSize>

void batched_aio_reader< BatchSize >::enqueue_read_first_batch ( size_t  offset_bytes, size_t  size_bytes, void *  dest  )

inline

Definition at line 408 of file profile_algebra_groups_read.cpp.

    {
        assert(_next_batch_size < BatchSize);
 
        aiocb *cb = _next_batch[_next_batch_size];
        cb_init(cb, _fd, offset_bytes, size_bytes, dest);
 
        // When first batch is full, enqueue it and allow writing to the next
        // batch.
 
        ++_next_batch_size;
        if (_next_batch_size == BatchSize) {
            enqueue_next_batch();
 
            std::swap(_active_batch, _next_batch);
            _next_batch_size = 0;
        }
    }

Here is the call graph for this function:

wait_last_read()

template<size_t BatchSize>

void batched_aio_reader< BatchSize >::wait_last_read ( )

inline

Definition at line 441 of file profile_algebra_groups_read.cpp.

    {
        // Wait for the _active_batch
        for (size_t i = 0; i < BatchSize; ++i) {
            int r = cb_wait(_active_batch[i]);
            if (0 > r) {
                throw std::runtime_error("bad read result");
            }
            if (0 == r) {
                std::cout << "+";
            }
        }
 
        // swap pointers so it can be written into
        std::swap(_active_batch, _next_batch);
        _next_batch_size = 0;
    }

Here is the call graph for this function:

Member Data Documentation

_active_batch

template<size_t BatchSize>

aiocb** batched_aio_reader< BatchSize >::_active_batch

protected

Definition at line 473 of file profile_algebra_groups_read.cpp.

_batch1

template<size_t BatchSize>

aiocb batched_aio_reader< BatchSize >::_batch1[BatchSize]

protected

Definition at line 469 of file profile_algebra_groups_read.cpp.

_batch1_ptrs

template<size_t BatchSize>

aiocb* batched_aio_reader< BatchSize >::_batch1_ptrs[BatchSize]

protected

Definition at line 471 of file profile_algebra_groups_read.cpp.

_batch2

template<size_t BatchSize>

aiocb batched_aio_reader< BatchSize >::_batch2[BatchSize]

protected

Definition at line 470 of file profile_algebra_groups_read.cpp.

_batch2_ptrs

template<size_t BatchSize>

aiocb* batched_aio_reader< BatchSize >::_batch2_ptrs[BatchSize]

protected

Definition at line 472 of file profile_algebra_groups_read.cpp.

_fd

template<size_t BatchSize>

const int batched_aio_reader< BatchSize >::_fd

protected

Definition at line 468 of file profile_algebra_groups_read.cpp.

_next_batch

template<size_t BatchSize>

aiocb** batched_aio_reader< BatchSize >::_next_batch

protected

Definition at line 474 of file profile_algebra_groups_read.cpp.

_next_batch_size

template<size_t BatchSize>

size_t batched_aio_reader< BatchSize >::_next_batch_size

protected

Definition at line 475 of file profile_algebra_groups_read.cpp.

---

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

• /home/runner/work/libff/libff/libff/algebra/curves/profile/profile_algebra_groups_read.cpp