async_context.hpp

Go to the documentation of this file.

// Copyright 2025 Kevin Exton
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#pragma once
#ifndef CPPNET_ASYNC_CONTEXT_HPP
#define CPPNET_ASYNC_CONTEXT_HPP
#include "net/detail/immovable.hpp"
#include "net/timers/timers.hpp"
 
#include <exec/async_scope.hpp>
#include <io/io.hpp>
 
#include <atomic>
#include <cstdint>
namespace net::service {
 
struct async_context : detail::immovable {
  using async_scope = exec::async_scope;
  using multiplexer_type = io::execution::poll_multiplexer;
  using triggers = io::execution::basic_triggers<multiplexer_type>;
  using socket_dialog = triggers::socket_dialog;
  using socket_type = io::socket::native_socket_type;
  using signal_mask = std::uint64_t;
  using interrupt_source = timers::socketpair_interrupt_source_t;
  using timers_type = timers::timers<interrupt_source>;
  using clock = std::chrono::steady_clock;
  using duration = std::chrono::milliseconds;
 
  enum signals : std::uint8_t { terminate = 0, user1, END };
  enum context_states : std::uint8_t { PENDING = 0, STARTED, STOPPED };
 
  timers_type timers;
  async_scope scope;
  triggers poller;
  std::atomic<signal_mask> sigmask;
  std::atomic<context_states> state{PENDING};
 
  inline auto signal(int signum) -> void;
 
  inline auto interrupt() const noexcept -> void;
 
  template <typename Fn>
    requires std::is_invocable_r_v<bool, Fn>
  auto isr(const socket_dialog &socket, Fn routine) -> void;
 
  inline auto run() -> void;
};
 
} // namespace net::service
 
#include "impl/async_context_impl.hpp" // IWYU pragma: export
 
#endif // CPPNET_ASYNC_CONTEXT_HPP