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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
#include "XnLinkOutputDataEndpoint.h"
#include "IConnectionFactory.h"
#include "IOutputConnection.h"
#include <XnOS.h>
#include <XnLog.h>
#define XN_MASK_LINK "xnLink"
namespace xn
{
LinkOutputDataEndpoint::LinkOutputDataEndpoint()
{
m_pConnection = NULL;
m_bInitialized = FALSE;
m_bConnected = FALSE;
m_nEndpointID = 0;
}
LinkOutputDataEndpoint::~LinkOutputDataEndpoint()
{
Shutdown();
}
XnStatus LinkOutputDataEndpoint::Init(XnUInt16 nEndpointID,
IConnectionFactory* pConnectionFactory)
{
XN_VALIDATE_INPUT_PTR(pConnectionFactory);
XnStatus nRetVal = XN_STATUS_OK;
if (!m_bInitialized)
{
//Create output data connection
m_nEndpointID = nEndpointID;
nRetVal = pConnectionFactory->CreateOutputDataConnection(nEndpointID, m_pConnection);
XN_IS_STATUS_OK_LOG_ERROR("Create output data connection", nRetVal);
//We are initialized :)
m_bInitialized = TRUE;
}
return XN_STATUS_OK;
}
XnBool LinkOutputDataEndpoint::IsInitialized() const
{
return m_bInitialized;
}
void LinkOutputDataEndpoint::Shutdown()
{
Disconnect();
XN_DELETE(m_pConnection);
m_pConnection = NULL;
m_bInitialized = FALSE;
}
XnStatus LinkOutputDataEndpoint::Connect()
{
XnStatus nRetVal = XN_STATUS_OK;
if (!m_bInitialized)
{
XN_LOG_ERROR_RETURN(XN_STATUS_NOT_INIT, XN_MASK_LINK, "Not initialized");
}
if (!m_bConnected)
{
//Connect
nRetVal = m_pConnection->Connect();
XN_IS_STATUS_OK_LOG_ERROR("Connect input data connection", nRetVal);
//We're connected
m_bConnected = TRUE;
}
return XN_STATUS_OK;
}
void LinkOutputDataEndpoint::Disconnect()
{
if (m_bConnected)
{
m_pConnection->Disconnect();
m_bConnected = FALSE;
}
}
XnBool LinkOutputDataEndpoint::IsConnected() const
{
return m_bConnected;
}
XnUInt16 LinkOutputDataEndpoint::GetMaxPacketSize() const
{
return m_pConnection->GetMaxPacketSize();
}
XnStatus LinkOutputDataEndpoint::SendData(const void* pData, XnUInt32 nSize)
{
return m_pConnection->Send(pData, nSize);
}
}
|
