Connection.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: Deutsches Elektronen-Synchrotron DESY, MSK, ChimeraTK Project <chimeratk-support@desy.de>
// SPDX-License-Identifier: LGPL-3.0-or-later
#pragma once
 
#include <boost/array.hpp>
#include <boost/asio.hpp>
#include <boost/asio/buffer.hpp>
#include <boost/asio/deadline_timer.hpp>
#include <boost/make_shared.hpp>
#include <boost/shared_ptr.hpp>
 
#include <chrono>
#include <memory>
#include <thread>
#include <vector>
 
namespace ChimeraTK::Rebot {
 
  class Connection {
   public:
    Connection(std::string address, std::string port, uint32_t connectionTimeout_sec);
 
    void open();
 
    void close();
 
    std::vector<uint32_t> read(uint32_t numWordsToRead);
 
    void write(const std::vector<uint32_t>& data);
 
    bool isOpen();
 
   private:
    std::string address_;
    const std::string port_;
    boost::asio::io_context ioContext_;
    boost::asio::ip::tcp::socket s_;
    boost::asio::deadline_timer disconnectTimer_;
    boost::asio::deadline_timer::duration_type connectionTimeout_;
 
    std::mutex _closeMutex; // prevent concurrent close from the backend and the connection timeout
 
    void disconnectionTimerStart();
    void disconnectionTimerCancel(const boost::system::error_code& ec);
  };
} // namespace ChimeraTK::Rebot