1

     2

#include <cassert>

     3

     4

#include "NetworkNode.hh"

     5

     6

NetworkNode::NetworkNode (NetworkSession &session, NetworkTCPTransport *tcp, NetworkUDP *udp, const NetworkAddress &address) :

     7

    session(session), tcp(tcp), udp(udp), address(address) {

     8

     9

    // connect signals

    10

    slots.connect(tcp->sig_disconnect(), this, &NetworkNode::on_disconnect);

    11

    slots.connect(tcp->sig_packet(), &session, &NetworkSession::handle_message, this);

    12

    13

}

    14

    15

NetworkNode::~NetworkNode (void) {

    16

    delete tcp;

    17

}

    18

    19

void NetworkNode::on_disconnect (void) {

    20

    // tell session

    21

    session.handle_disconnect(this);

    22

    23

    // fire signal

    24

    _sig_disconnected();

    25

    26

    // delete

    27

//    delete this;

    28

}

    29

    30

void NetworkNode::send (NetworkChannelID channel_id, const NetworkPacket &pkt, bool reliable) {

    31

    assert(channel_id > 0);

    32

    33

    // add our header

    34

    NetworkPacket pkt2;

    35

    pkt2.write_uint16(channel_id);

    36

    pkt2.write_packet(pkt);

    37

    38

    // either tcp or udp

    39

    if (reliable) {

    40

        assert(tcp);

    41

    42

        tcp->write_packet(pkt2);

    43

    44

    } else {

    45

        udp->sendto(pkt2, address);

    46

    }

    47

}

    48

    49

const NetworkAddress& NetworkNode::getRemoteAddress (void) {

    50

    return address;

    51

}