tcp_sender.hh

Go to the documentation of this file.

#ifndef SPONGE_LIBSPONGE_TCP_SENDER_HH
#define SPONGE_LIBSPONGE_TCP_SENDER_HH
 
#include "byte_stream.hh"
#include "tcp_config.hh"
#include "tcp_segment.hh"
#include "wrapping_integers.hh"
 
#include <functional>
#include <queue>
 
 
class TCPSender {
  private:
    WrappingInt32 _isn;
 
    std::queue<TCPSegment> _segments_out{};
 
    unsigned int _initial_retransmission_timeout;
 
    ByteStream _stream;
 
    uint64_t _next_seqno{0};
 
  public:
    TCPSender(const size_t capacity = TCPConfig::DEFAULT_CAPACITY,
              const uint16_t retx_timeout = TCPConfig::TIMEOUT_DFLT,
              const std::optional<WrappingInt32> fixed_isn = {});
 
    ByteStream &stream_in() { return _stream; }
    const ByteStream &stream_in() const { return _stream; }
 
 
    void ack_received(const WrappingInt32 ackno, const uint16_t window_size);
 
    void send_empty_segment();
 
    void fill_window();
 
    void tick(const size_t ms_since_last_tick);
 
 
    size_t bytes_in_flight() const;
 
    unsigned int consecutive_retransmissions() const;
 
    std::queue<TCPSegment> &segments_out() { return _segments_out; }
 
 
    uint64_t next_seqno_absolute() const { return _next_seqno; }
 
    WrappingInt32 next_seqno() const { return wrap(_next_seqno, _isn); }
};
 
#endif  // SPONGE_LIBSPONGE_TCP_SENDER_HH