1

#ifndef NETWORK_SESSION_HH

     2

#define NETWORK_SESSION_HH

     3

     4

#include <map>

     5

     6

// forward-declare

     7

class NetworkSession;

     8

     9

/*

    10

 * Used to separate packets, ID zero is reserved for NetworkSession use

    11

 */

    12

typedef uint16_t NetworkChannelID;

    13

    14

#include "NetworkTCP.hh"

    15

#include "NetworkUDP.hh"

    16

#include "NetworkNode.hh"

    17

    18

class NetworkSession {

    19

    friend class NetworkNode;

    20

    21

    private:

    22

        uint64_t magic;

    23

        NetworkTCPServer *tcp_srv;

    24

        NetworkUDP *udp_srv, *udp_client;

    25

    26

        CL_SlotContainer slots;

    27

    28

        std::map<NetworkAddress, NetworkNode*> nodes;

    29

        std::map<NetworkChannelID, CL_Signal_v2<NetworkPacket&, NetworkNode *> > _map_sig_chan_message;

    30

    31

    public:

    32

        NetworkSession (uint64_t magic);

    33

    34

        void listen (const NetworkAddress &addr);

    35

        NetworkNode* connect (const NetworkAddress &addr);

    36

    37

    protected:

    38

        virtual NetworkNode *build_node (NetworkTCPTransport *tcp, NetworkUDP *udp, const NetworkAddress &addr, enum NetworkNodeType type);

    39

    40

        void handle_disconnect (NetworkNode *node);

    41

        void handle_message (NetworkPacket &pkt, NetworkNode *node);

    42

    43

    private:

    44

        void on_tcp_client (NetworkTCPTransport *client);

    45

        void on_udp_packet (NetworkPacket &pkt, const NetworkAddress &addr);

    46

    47

        CL_Signal_v1<NetworkNode*> _sig_node_connected;

    48

    49

    public:

    50

        void send_all (NetworkChannelID channel_id, const NetworkPacket &pkt, bool reliable = true);

    51

        void send_all_except (NetworkChannelID channel_id, const NetworkPacket &pkt, const NetworkNode *node, bool reliable = true);

    52

    53

        CL_Signal_v1<NetworkNode*>& sig_node_connected (void) { return _sig_node_connected; }

    54

        CL_Signal_v2<NetworkPacket&, NetworkNode *>& sig_chan_message (NetworkChannelID cid) { return _map_sig_chan_message[cid]; }

    55

};

    56

    57

#endif /* NETWORK_SESSION_HH */