fd_adapter.cc

Go to the documentation of this file.

#include "fd_adapter.hh"
 
#include <iostream>
#include <stdexcept>
#include <utility>
 
using namespace std;
 
optional<TCPSegment> TCPOverUDPSocketAdapter::read() {
    auto datagram = _sock.recv();
 
    // is it for us?
    if (not listening() and (datagram.source_address != config().destination)) {
        return {};
    }
 
    // is the payload a valid TCP segment?
    TCPSegment seg;
    if (ParseResult::NoError != seg.parse(move(datagram.payload), 0)) {
        return {};
    }
 
    // should we target this source in all future replies?
    if (listening()) {
        if (seg.header().syn and not seg.header().rst) {
            config_mutable().destination = datagram.source_address;
            set_listening(false);
        } else {
            return {};
        }
    }
 
    return seg;
}
 
void TCPOverUDPSocketAdapter::write(TCPSegment &seg) {
    seg.header().sport = config().source.port();
    seg.header().dport = config().destination.port();
    _sock.sendto(config().destination, seg.serialize(0));
}
 
template class LossyFdAdapter<TCPOverUDPSocketAdapter>;