tcp_receiver.hh

Go to the documentation of this file.

#ifndef SPONGE_LIBSPONGE_TCP_RECEIVER_HH
#define SPONGE_LIBSPONGE_TCP_RECEIVER_HH
 
#include "byte_stream.hh"
#include "stream_reassembler.hh"
#include "tcp_segment.hh"
#include "wrapping_integers.hh"
 
#include <optional>
 
 
class TCPReceiver {
    StreamReassembler _reassembler;
 
    size_t _capacity;
 
  public:
    TCPReceiver(const size_t capacity) : _reassembler(capacity), _capacity(capacity) {}
 
 
    std::optional<WrappingInt32> ackno() const;
 
    size_t window_size() const;
 
    size_t unassembled_bytes() const { return _reassembler.unassembled_bytes(); }
 
    void segment_received(const TCPSegment &seg);
 
    ByteStream &stream_out() { return _reassembler.stream_out(); }
    const ByteStream &stream_out() const { return _reassembler.stream_out(); }
};
 
#endif  // SPONGE_LIBSPONGE_TCP_RECEIVER_HH