blob: 59acdc0e772bbbd9a73d98a0333e5d0cd33fe6f2 (
plain) (
blame)
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
76
77
78
79
80
81
82
83
84
85
86
|
// LuaServerHandle.h
// Declares the cLuaServerHandle class wrapping the cServerHandle functionality for Lua API
#pragma once
#include "../OSSupport/Network.h"
#include "LuaState.h"
// fwd:
class cLuaTCPLink;
typedef std::shared_ptr<cLuaTCPLink> cLuaTCPLinkPtr;
typedef std::vector<cLuaTCPLinkPtr> cLuaTCPLinkPtrs;
class cLuaServerHandle;
typedef std::shared_ptr<cLuaServerHandle> cLuaServerHandlePtr;
class cLuaServerHandle:
public cNetwork::cListenCallbacks
{
public:
/** Creates a new instance of the server handle,
wrapping the (listen-) callbacks that are in the specified table. */
cLuaServerHandle(UInt16 a_Port, cLuaState::cTableRefPtr && a_Callbacks);
virtual ~cLuaServerHandle() override;
/** Called by cNetwork::Listen()'s binding.
Sets the server handle around which this instance is wrapped, and a self SharedPtr for link management. */
void SetServerHandle(cServerHandlePtr a_ServerHandle, cLuaServerHandlePtr a_Self);
/** Terminates all connections and closes the listening socket. */
void Close(void);
/** Returns true if the server is currently listening. */
bool IsListening(void);
/** Removes the link from the list of links that the server is currently tracking. */
void RemoveLink(cLuaTCPLink * a_Link);
/** Called when Lua garbage-collects the object.
Releases the internal SharedPtr to self, so that the instance may be deallocated. */
void Release(void);
protected:
/** The Lua table that holds the callbacks to be invoked. */
cLuaState::cTableRefPtr m_Callbacks;
/** The port on which the server is listening.
Used mainly for better error reporting. */
UInt16 m_Port;
/** The cServerHandle around which this instance is wrapped. */
cServerHandlePtr m_ServerHandle;
/** Protects m_Connections against multithreaded access. */
cCriticalSection m_CSConnections;
/** All connections that are currently active in this server.
Protected by m_CSConnections. */
cLuaTCPLinkPtrs m_Connections;
/** SharedPtr to self, given out to newly created links. */
cLuaServerHandlePtr m_Self;
// cNetwork::cListenCallbacks overrides:
virtual cTCPLink::cCallbacksPtr OnIncomingConnection(const AString & a_RemoteIPAddress, UInt16 a_RemotePort) override;
virtual void OnAccepted(cTCPLink & a_Link) override;
virtual void OnError(int a_ErrorCode, const AString & a_ErrorMsg) override;
};
|
