request_queue_impl_1q.hpp

Go to the documentation of this file.

/***************************************************************************
 *  foxxll/io/request_queue_impl_1q.hpp
 *
 *  Part of FOXXLL. See http://foxxll.org
 *
 *  Copyright (C) 2002 Roman Dementiev <[email protected]>
 *  Copyright (C) 2008-2009 Andreas Beckmann <[email protected]>
 *  Copyright (C) 2009 Johannes Singler <[email protected]>
 *
 *  Distributed under the Boost Software License, Version 1.0.
 *  (See accompanying file LICENSE_1_0.txt or copy at
 *  http://www.boost.org/LICENSE_1_0.txt)
 **************************************************************************/

#ifndef FOXXLL_IO_REQUEST_QUEUE_IMPL_1Q_HEADER
#define FOXXLL_IO_REQUEST_QUEUE_IMPL_1Q_HEADER

#include <list>
#include <mutex>

#include <tlx/unused.hpp>

#include <foxxll/io/request_queue_impl_worker.hpp>

namespace foxxll {

//! \addtogroup foxxll_reqlayer
//! \{

//! Implementation of a local request queue having only one queue for both read
//! and write requests, thus having only one thread.
class request_queue_impl_1q : public request_queue_impl_worker
{
private:
    using self = request_queue_impl_1q;
    using queue_type = std::list<request_ptr>;

    std::mutex queue_mutex_;
    queue_type queue_;

    shared_state<thread_state> thread_state_;
    std::thread thread_;
    tlx::semaphore sem_;

    static const priority_op priority_op_ = WRITE;

    static void * worker(void* arg);

public:
    // \param n max number of requests simultaneously submitted to disk
    explicit request_queue_impl_1q(int n = 1);

    // in a multi-threaded setup this does not work as intended
    // also there were race conditions possible
    // and actually an old value was never restored once a new one was set ...
    // so just disable it and all it's nice implications
    void set_priority_op(const priority_op& op) final;

    void add_request(request_ptr& req) final;
    bool cancel_request(request_ptr& req) final;
    ~request_queue_impl_1q();
};

//! \}

} // namespace foxxll

#endif // !FOXXLL_IO_REQUEST_QUEUE_IMPL_1Q_HEADER

/**************************************************************************/