Thrill  0.1
Public Member Functions | Private Types | Static Private Member Functions | Private Attributes | Static Private Attributes | List of all members
request_queue_impl_qwqr Class Referencefinal
Thrill Layers » foxxll - A C++ Library for Asynchronous I/O and Block Management » I/O Primitives Layer » I/O Requests and Queues

Detailed Description

Implementation of a local request queue having two queues, one for read and one for write requests, thus having two threads. This is the default implementation.

Definition at line 34 of file request_queue_impl_qwqr.hpp.

+ Inheritance diagram for request_queue_impl_qwqr:
+ Collaboration diagram for request_queue_impl_qwqr:

#include <request_queue_impl_qwqr.hpp>

Public Member Functions

 request_queue_impl_qwqr (int n=1)
 
 ~request_queue_impl_qwqr ()
 
void add_request (request_ptr &req) final
 
bool cancel_request (request_ptr &req) final
 
void set_priority_op (const priority_op &op) final
 
- Public Member Functions inherited from request_queue
 request_queue ()=default
 
 request_queue (const request_queue &)=delete
 non-copyable: delete copy-constructor More...
 
 request_queue (request_queue &&)=default
 move-constructor: default More...
 
virtual ~request_queue ()
 
request_queue & operator= (const request_queue &)=delete
 non-copyable: delete assignment operator More...
 
request_queue & operator= (request_queue &&)=default
 move-assignment operator: default More...
 

Private Types

using queue_type = std::list< request_ptr >
 
using self = request_queue_impl_qwqr
 

Static Private Member Functions

static void * worker (void *arg)
 

Private Attributes

std::mutex read_mutex_
 
queue_type read_queue_
 
tlx::semaphore sem_
 
std::thread thread_
 
shared_state< thread_state > thread_state_
 
std::mutex write_mutex_
 
queue_type write_queue_
 

Static Private Attributes

static constexpr bool debug = false
 
static const priority_op priority_op_ = WRITE
 

Additional Inherited Members

- Public Types inherited from request_queue
enum  priority_op { READ, WRITE, NONE }
 
- Protected Types inherited from request_queue_impl_worker
enum  thread_state { NOT_RUNNING, RUNNING, TERMINATING, TERMINATED }
 
- Protected Member Functions inherited from request_queue_impl_worker
void start_thread (void *(*worker)(void *), void *arg, std::thread &t, shared_state< thread_state > &s)
 
void stop_thread (std::thread &t, shared_state< thread_state > &s, tlx::semaphore &sem)
 

Member Typedef Documentation

◆ queue_type

using queue_type = std::list<request_ptr>
private

Definition at line 40 of file request_queue_impl_qwqr.hpp.

◆ self

using self = request_queue_impl_qwqr
private

Definition at line 39 of file request_queue_impl_qwqr.hpp.

Constructor & Destructor Documentation

◆ request_queue_impl_qwqr()

request_queue_impl_qwqr ( int  n = 1)
explicit

Definition at line 48 of file request_queue_impl_qwqr.cpp.

References request_queue_impl_worker::start_thread(), request_queue_impl_qwqr::thread_, request_queue_impl_qwqr::thread_state_, tlx::unused(), and request_queue_impl_qwqr::worker().

◆ ~request_queue_impl_qwqr()

~request_queue_impl_qwqr ( )

Definition at line 150 of file request_queue_impl_qwqr.cpp.

References request_queue_impl_qwqr::sem_, request_queue_impl_worker::stop_thread(), request_queue_impl_qwqr::thread_, and request_queue_impl_qwqr::thread_state_.

Member Function Documentation

◆ add_request()

void add_request ( request_ptr &  req)
finalvirtual

Implements request_queue.

Definition at line 61 of file request_queue_impl_qwqr.cpp.

References CountingPtr< Type, Deleter >::empty(), FOXXLL_THROW_INVALID_ARGUMENT, CountingPtr< Type, Deleter >::get(), request_interface::READ, request_queue_impl_qwqr::read_mutex_, request_queue_impl_qwqr::read_queue_, request_queue_impl_worker::RUNNING, request_queue_impl_qwqr::sem_, Semaphore::signal(), request_queue_impl_qwqr::thread_state_, TLX_LOG1, request_queue_impl_qwqr::write_mutex_, and request_queue_impl_qwqr::write_queue_.

◆ cancel_request()

bool cancel_request ( request_ptr &  req)
finalvirtual

Implements request_queue.

Definition at line 110 of file request_queue_impl_qwqr.cpp.

References CountingPtr< Type, Deleter >::empty(), FOXXLL_THROW_INVALID_ARGUMENT, CountingPtr< Type, Deleter >::get(), request_interface::READ, request_queue_impl_qwqr::read_mutex_, request_queue_impl_qwqr::read_queue_, request_queue_impl_worker::RUNNING, request_queue_impl_qwqr::sem_, request_queue_impl_qwqr::thread_state_, TLX_LOG1, Semaphore::wait(), request_queue_impl_qwqr::write_mutex_, and request_queue_impl_qwqr::write_queue_.

◆ set_priority_op()

void set_priority_op ( const priority_op &  op)
finalvirtual

Reimplemented from request_queue.

Definition at line 55 of file request_queue_impl_qwqr.cpp.

References tlx::unused().

◆ worker()

void * worker ( void *  arg)
staticprivate

Definition at line 155 of file request_queue_impl_qwqr.cpp.

References CountingPtr< Type, Deleter >::get(), request_queue::NONE, request_queue::READ, request_queue_impl_qwqr::sem_, request_queue_impl_worker::TERMINATED, request_queue_impl_worker::TERMINATING, TLX_LOG, Semaphore::wait(), and request_queue::WRITE.

Referenced by request_queue_impl_qwqr::request_queue_impl_qwqr().

Member Data Documentation

◆ debug

constexpr bool debug = false
staticprivate

Definition at line 36 of file request_queue_impl_qwqr.hpp.

◆ priority_op_

const priority_op priority_op_ = WRITE
staticprivate

Definition at line 51 of file request_queue_impl_qwqr.hpp.

◆ read_mutex_

std::mutex read_mutex_
private

Definition at line 43 of file request_queue_impl_qwqr.hpp.

Referenced by request_queue_impl_qwqr::add_request(), and request_queue_impl_qwqr::cancel_request().

◆ read_queue_

queue_type read_queue_
private

Definition at line 45 of file request_queue_impl_qwqr.hpp.

Referenced by request_queue_impl_qwqr::add_request(), and request_queue_impl_qwqr::cancel_request().

◆ sem_

tlx::semaphore sem_
private

Definition at line 49 of file request_queue_impl_qwqr.hpp.

Referenced by request_queue_impl_qwqr::add_request(), request_queue_impl_qwqr::cancel_request(), request_queue_impl_qwqr::worker(), and request_queue_impl_qwqr::~request_queue_impl_qwqr().

◆ thread_

std::thread thread_
private

Definition at line 48 of file request_queue_impl_qwqr.hpp.

Referenced by request_queue_impl_qwqr::request_queue_impl_qwqr(), and request_queue_impl_qwqr::~request_queue_impl_qwqr().

◆ thread_state_

shared_state<thread_state> thread_state_
private

Definition at line 47 of file request_queue_impl_qwqr.hpp.

Referenced by request_queue_impl_qwqr::add_request(), request_queue_impl_qwqr::cancel_request(), request_queue_impl_qwqr::request_queue_impl_qwqr(), and request_queue_impl_qwqr::~request_queue_impl_qwqr().

◆ write_mutex_

std::mutex write_mutex_
private

Definition at line 42 of file request_queue_impl_qwqr.hpp.

Referenced by request_queue_impl_qwqr::add_request(), and request_queue_impl_qwqr::cancel_request().

◆ write_queue_

queue_type write_queue_
private

Definition at line 44 of file request_queue_impl_qwqr.hpp.

Referenced by request_queue_impl_qwqr::add_request(), and request_queue_impl_qwqr::cancel_request().

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