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
|
#ifndef __SOCKETCONNECTIONFACTORY_H__
#define __SOCKETCONNECTIONFACTORY_H__
#include "IConnectionFactory.h"
#include "XnSyncSocketConnection.h"
#include "XnSyncServerSocketConnection.h"
#include <XnArray.h>
namespace xn
{
class SocketConnectionFactory: public IConnectionFactory
{
public:
enum Type {TYPE_CLIENT, TYPE_SERVER};
SocketConnectionFactory(Type type);
virtual ~SocketConnectionFactory();
virtual XnStatus Init(const XnChar* strConnString);
virtual void Shutdown();
virtual XnBool IsInitialized() const;
virtual XnUInt16 GetNumInputDataConnections() const;
virtual XnUInt16 GetNumOutputDataConnections() const;
/** The pointer returned by GetControlConnection() belongs to the connection factory and
must not be deleted by caller. **/
virtual XnStatus GetControlConnection(ISyncIOConnection*& pConnection);
// nID is used for server, as the server has several output connections.
virtual XnStatus CreateOutputDataConnection(XnUInt16 nID, IOutputConnection*& pConnection);
// nID is used for client, as the client has several output connections.
virtual XnStatus CreateInputDataConnection(XnUInt16 nID, IAsyncInputConnection*& pConnection);
static XnStatus AddEnumerationTarget(const XnChar* strConnString);
static XnStatus EnumerateConnStrings(XnUInt16 nProductID, XnConnectionString*& astrConnStrings, XnUInt32& nCount);
static void FreeConnStringsList(XnConnectionString* astrConnStrings);
static const XnUInt16 DATA_OUT_MAX_PACKET_SIZE;
static const XnUInt16 DATA_IN_MAX_PACKET_SIZE;
private:
static const XnUInt16 CONTROL_MAX_PACKET_SIZE;
static XnStatus ParseConnectionString(const XnChar* strConnString, XnChar* strIP, XnUInt32 nIPBufSize, XnUInt16& nPort);
static XnStatus EncodeConnectionString(XnChar* strConnString, XnUInt32 nBufferSize, const XnChar* strIP, XnUInt16 nPort);
// patch: we need to define a struct to keep in XnArray (XnArray cannot work directly with XnConnectionString)
typedef struct ConnectionStringStruct
{
XnConnectionString m_strConn;
} ConnectionStringStruct;
static const XnUInt16 NUM_SERVER_TO_CLIENT_DATA_CONNECTIONS;
static xnl::Array<SyncSocketConnection> s_controlConnections;
static XnStatus GetControlConnectionImpl(const XnChar* strIP, XnUInt16 nPort, SyncSocketConnection*& pControlConnection);
static XnStatus TryAndAddEnumerationTarget(xnl::Array<ConnectionStringStruct>& result, const XnChar* strConnString);
static XnStatus AddConfigFileTarget(xnl::Array<ConnectionStringStruct>& result, XnUInt16 nProductID);
// The client implementation returns ISyncIOConnection object that could not be deleted (return from s_controlConnections),
// I want the behavior to be consistent for both client and server.
SyncServerSocketListener m_serverListener;
Type m_type;
XnChar m_strIP[XN_FILE_MAX_PATH];
XnUInt16 m_nControlPort;
XnUInt16 m_nDataOutPort;
XnUInt16 m_nDataInBasePort;
XnBool m_bInitialized;
static xnl::Array<ConnectionStringStruct> s_enumerationTargets;
};
}
#endif // __SOCKETCONNECTIONFACTORY_H__
|
