|
33
|
1 |
#ifndef NETWORK_SESSION_HH
|
|
|
2 |
#define NETWORK_SESSION_HH
|
|
|
3 |
|
|
37
|
4 |
#include <map>
|
|
|
5 |
|
|
36
|
6 |
// forward-declare
|
|
|
7 |
class NetworkSession;
|
|
33
|
8 |
|
|
|
9 |
/*
|
|
|
10 |
* Used to separate packets, ID zero is reserved for NetworkSession use
|
|
|
11 |
*/
|
|
|
12 |
typedef uint16_t NetworkChannelID;
|
|
|
13 |
|
|
36
|
14 |
#include "NetworkTCP.hh"
|
|
|
15 |
#include "NetworkUDP.hh"
|
|
|
16 |
#include "NetworkNode.hh"
|
|
|
17 |
|
|
37
|
18 |
class NetworkSession {
|
|
|
19 |
friend class NetworkNode;
|
|
36
|
20 |
|
|
33
|
21 |
private:
|
|
36
|
22 |
uint64_t magic;
|
|
33
|
23 |
NetworkTCPServer *tcp_srv;
|
|
|
24 |
NetworkUDP *udp_srv, *udp_client;
|
|
|
25 |
|
|
|
26 |
CL_SlotContainer slots;
|
|
|
27 |
|
|
|
28 |
std::map<NetworkAddress, NetworkNode*> nodes;
|
|
36
|
29 |
std::map<NetworkChannelID, CL_Signal_v2<NetworkPacket&, NetworkNode *> > _map_sig_chan_message;
|
|
33
|
30 |
|
|
|
31 |
public:
|
|
36
|
32 |
NetworkSession (uint64_t magic);
|
|
33
|
33 |
|
|
|
34 |
void listen (const NetworkAddress &addr);
|
|
|
35 |
NetworkNode* connect (const NetworkAddress &addr);
|
|
36
|
36 |
|
|
|
37 |
protected:
|
|
|
38 |
virtual NetworkNode *build_node (NetworkTCPTransport *tcp, NetworkUDP *udp, const NetworkAddress &addr, enum NetworkNodeType type);
|
|
37
|
39 |
|
|
|
40 |
void handle_disconnect (NetworkNode *node);
|
|
33
|
41 |
|
|
|
42 |
private:
|
|
36
|
43 |
void on_tcp_client (NetworkTCPTransport *client);
|
|
33
|
44 |
|
|
34
|
45 |
CL_Signal_v1<NetworkNode*> _sig_node_connected;
|
|
|
46 |
|
|
33
|
47 |
public:
|
|
|
48 |
void send_all (NetworkChannelID channel_id, const NetworkPacket &pkt, bool reliable = true);
|
|
|
49 |
void send_all_except (NetworkChannelID channel_id, const NetworkPacket &pkt, const NetworkNode *node, bool reliable = true);
|
|
|
50 |
|
|
36
|
51 |
CL_Signal_v1<NetworkNode*>& sig_node_connected (void) { return _sig_node_connected; }
|
|
|
52 |
CL_Signal_v2<NetworkPacket&, NetworkNode *>& sig_chan_message (NetworkChannelID cid) { return _map_sig_chan_message[cid]; }
|
|
33
|
53 |
};
|
|
|
54 |
|
|
|
55 |
#endif /* NETWORK_SESSION_HH */
|