io_context.h

Go to the documentation of this file.

/* Diagnostic Client library
* Copyright (C) 2024  Avijit Dey
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
#ifndef DIAG_CLIENT_LIB_LIB_BOOST_SUPPORT_SOCKET_IO_CONTEXT_H_
#define DIAG_CLIENT_LIB_LIB_BOOST_SUPPORT_SOCKET_IO_CONTEXT_H_
 
#include <boost/asio.hpp>
#include <string_view>
 
#include "utility/thread.h"
 
namespace boost_support {
namespace socket {
 
class IoContext final {
 public:
  using Context = boost::asio::io_context;
 
 public:
  IoContext() noexcept;
 
  IoContext(std::string_view context_name) noexcept;
 
  IoContext(const IoContext &other) noexcept = delete;
  IoContext &operator=(const IoContext &other) noexcept = delete;
 
  IoContext(IoContext &&other) noexcept = delete;
  IoContext &operator=(IoContext &&other) noexcept = delete;
 
  ~IoContext() noexcept;
 
  void Initialize() noexcept;
 
  void DeInitialize() noexcept;
 
  Context &GetContext() noexcept;
 
 private:
  Context io_context_;
 
  std::atomic_bool exit_request_;
 
  std::atomic_bool running_;
 
  std::condition_variable cond_var_;
 
  std::string context_name_;
 
  utility::thread::Thread thread_;
 
  std::mutex mutex_;
};
}  // namespace socket
}  // namespace boost_support
#endif  // DIAG_CLIENT_LIB_LIB_BOOST_SUPPORT_SOCKET_IO_CONTEXT_H_