1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
#ifndef _UDPLISTENER
#define _UDPLISTENER
#include <boost/noncopyable.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/weak_ptr.hpp>
#include <boost/asio/ip/udp.hpp>
#include <list>
#include <queue>
namespace netcode
{
class UDPConnection;
/**
@brief Class for handling Connections on an UDPSocket
Use this class if you want to use a UDPSocket to connect to more than one other clients. You can Listen for new connections, initiate new ones and send/recieve data to/from them.
@author Karl-Robert Ernst
*/
class UDPListener : boost::noncopyable
{
public:
/**
@brief Open a socket and make it ready for listening
*/
UDPListener(int port);
/**
@brief close the socket and DELETE all connections
*/
~UDPListener();
/**
@brief Run this from time to time
This does: recieve data from the socket and hand it to the associated UDPConnection, or open a new UDPConnection. It also Updates all of its connections
*/
void Update();
/**
@brief Initiate a connection
Make a new connection to address:port. It will be pushed back in conn
*/
boost::shared_ptr<UDPConnection> SpawnConnection(const std::string& address, const unsigned port);
/**
@brief Set if we are going to accept new connections or drop all data from unconnected addresses
*/
bool Listen(const bool state);
bool Listen() const;
bool HasIncomingConnections() const;
boost::weak_ptr<UDPConnection> PreviewConnection();
boost::shared_ptr<UDPConnection> AcceptConnection();
void RejectConnection();
private:
/**
@brief Do we accept packets from unknown sources?
If true, we will create a new connection, if false, it get dropped
*/
bool acceptNewConnections;
/// Our socket
typedef boost::shared_ptr<boost::asio::ip::udp::socket> SocketPtr;
SocketPtr mySocket;
/// all connections
std::list< boost::weak_ptr< UDPConnection> > conn;
std::queue< boost::shared_ptr<UDPConnection> > waiting;
};
}
#endif
|
