IfTcp.hxx

Go to the documentation of this file.

 
#ifndef _OPENLCB_IFTCP_HXX_
#define _OPENLCB_IFTCP_HXX_
 
#include "openlcb/If.hxx"
#include "utils/Hub.hxx"
 
namespace openlcb
{
 
struct TcpMessage
{
    NodeHandle dst;
    string data;
};
 
class ClockBaseSequenceNumberGenerator;
class TcpSendFlow;
class TcpRecvFlow;
 
class IfTcp : public If
{
public:
    IfTcp(NodeID gateway_node_id, HubFlow *device, int local_nodes_count);
 
    ~IfTcp();
 
    void add_owned_flow(Executable *e) override;
    void add_owned_flow(Destructable *e)
    {
        ownedFlows_.emplace_back(e);
    }
    void delete_owned_flow(Destructable *d);
    void delete_local_node(Node *node) override;
    bool matching_node(NodeHandle expected, NodeHandle actual) override;
 
    void add_network_fd(int fd, Notifiable *on_error = nullptr);
 
    NodeID get_default_node_id() override;
 
private:
    HubFlow *device_;
    std::vector<std::unique_ptr<Destructable>> ownedFlows_;
    ClockBaseSequenceNumberGenerator *seq_;
    TcpSendFlow *sendFlow_;
    TcpRecvFlow *recvFlow_;
};
 
} // namespace openlcb
 
#endif // _OPENLCB_IFTCP_HXX_