ORE Studio 0.0.4
Loading...
Searching...
No Matches
heartbeat_service.hpp
1/* -*- mode: c++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*-
2 *
3 * Copyright (C) 2025 Marco Craveiro <marco.craveiro@gmail.com>
4 *
5 * This program is free software; you can redistribute it and/or modify it under
6 * the terms of the GNU General Public License as published by the Free Software
7 * Foundation; either version 3 of the License, or (at your option) any later
8 * version.
9 *
10 * This program is distributed in the hope that it will be useful, but WITHOUT
11 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
12 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
13 * details.
14 *
15 * You should have received a copy of the GNU General Public License along with
16 * this program; if not, write to the Free Software Foundation, Inc., 51
17 * Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
18 *
19 */
20#ifndef ORES_COMMS_SERVICE_HEARTBEAT_SERVICE_HPP
21#define ORES_COMMS_SERVICE_HEARTBEAT_SERVICE_HPP
22
23#include <cstdint>
24#include <boost/asio/awaitable.hpp>
25#include "ores.utility/log/make_logger.hpp"
26
27namespace ores::comms::net { class connection; }
28
29namespace ores::comms::service {
30
38class heartbeat_service final {
39private:
40 inline static std::string_view logger_name =
41 "ores.comms.service.heartbeat_service";
42
43 static auto& lg() {
44 using namespace ores::utility::log;
45 static auto instance = make_logger(logger_name);
46 return instance;
47 }
48
49public:
57 static boost::asio::awaitable<void> handle_ping(
58 net::connection& conn,
59 std::uint32_t sequence,
60 std::uint32_t correlation_id);
61};
62
63}
64
65#endif
Contains the networking elements of the comms library.
Definition client.hpp:42
Implements logging for ORE Studio.
Definition lifecycle_manager.hpp:30
SSL connection wrapper for frame-based communication.
Definition connection.hpp:36
Service for handling heartbeat (ping/pong) protocol on the server.
Definition heartbeat_service.hpp:38
static boost::asio::awaitable< void > handle_ping(net::connection &conn, std::uint32_t sequence, std::uint32_t correlation_id)
Handle incoming ping from client and send pong response.
Definition heartbeat_service.cpp:31