fd_adapter.hh

Go to the documentation of this file.

#ifndef SPONGE_LIBSPONGE_FD_ADAPTER_HH
#define SPONGE_LIBSPONGE_FD_ADAPTER_HH
 
#include "file_descriptor.hh"
#include "lossy_fd_adapter.hh"
#include "socket.hh"
#include "tcp_config.hh"
#include "tcp_header.hh"
#include "tcp_segment.hh"
 
#include <optional>
#include <utility>
 
class FdAdapterBase {
  private:
    FdAdapterConfig _cfg{};  
    bool _listen = false;    
 
  protected:
    FdAdapterConfig &config_mutable() { return _cfg; }
 
  public:
    void set_listening(const bool l) { _listen = l; }
 
    bool listening() const { return _listen; }
 
    const FdAdapterConfig &config() const { return _cfg; }
 
    FdAdapterConfig &config_mut() { return _cfg; }
 
    void tick(const size_t) {}
};
 
class TCPOverUDPSocketAdapter : public FdAdapterBase {
  private:
    UDPSocket _sock;
 
  public:
    explicit TCPOverUDPSocketAdapter(UDPSocket &&sock) : _sock(std::move(sock)) {}
 
    std::optional<TCPSegment> read();
 
    void write(TCPSegment &seg);
 
    operator UDPSocket &() { return _sock; }
 
    operator const UDPSocket &() const { return _sock; }
};
 
using LossyTCPOverUDPSocketAdapter = LossyFdAdapter<TCPOverUDPSocketAdapter>;
 
#endif  // SPONGE_LIBSPONGE_FD_ADAPTER_HH