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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
/****************************************************************************
* *
* OpenNI 1.x Alpha *
* Copyright (C) 2011 PrimeSense Ltd. *
* *
* This file is part of OpenNI. *
* *
* OpenNI is free software: you can redistribute it and/or modify *
* it under the terms of the GNU Lesser General Public License as published *
* by the Free Software Foundation, either version 3 of the License, or *
* (at your option) any later version. *
* *
* OpenNI is distributed in the hope that it will be useful, *
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
* GNU Lesser General Public License for more details. *
* *
* You should have received a copy of the GNU Lesser General Public License *
* along with OpenNI. If not, see <http://www.gnu.org/licenses/>. *
* *
****************************************************************************/
#ifndef __XN_PLAYER_IMPL_H__
#define __XN_PLAYER_IMPL_H__
#include "XnStatus.h"
#include "XnInternalTypes.h"
#include <XnModuleInterface.h>
#include <XnStringsHashT.h>
#include <XnTypes.h>
#include <XnOS.h>
namespace xn
{
class PlayerImpl : public NodePrivateData
{
public:
PlayerImpl();
virtual ~PlayerImpl();
XnStatus Init(XnNodeHandle hPlayer);
virtual void BeforeNodeDestroy();
XnStatus SetSource(XnRecordMedium sourceType, const XnChar* strSource);
XnStatus GetSource(XnRecordMedium &sourceType, XnChar* strSource, XnUInt32 nBufSize);
void Destroy();
XnStatus EnumerateNodes(XnNodeInfoList** ppList);
XnStatus SetPlaybackSpeed(XnDouble dSpeed);
XnDouble GetPlaybackSpeed();
void TriggerPlayback();
XnStatus ReadNext();
XnStatus SeekToTimestamp(XnInt64 nTimeOffset, XnPlayerSeekOrigin origin);
XnStatus SeekToFrame(const XnChar* strNodeName, XnInt32 nFrameOffset, XnPlayerSeekOrigin origin);
private:
XnModulePlayerInterface& ModulePlayer();
XnModuleNodeHandle ModuleHandle();
void ResetTimeReference();
static XnStatus XN_CALLBACK_TYPE OpenFile(void* pCookie);
static XnStatus XN_CALLBACK_TYPE ReadFile(void* pCookie, void *pBuffer, XnUInt32 nSize, XnUInt32 *pnBytesRead);
static XnStatus XN_CALLBACK_TYPE SeekFile (void* pCookie, XnOSSeekType seekType, const XnInt32 nOffset);
static XnStatus XN_CALLBACK_TYPE SeekFile64(void* pCookie, XnOSSeekType seekType, const XnInt64 nOffset);
static XnUInt32 XN_CALLBACK_TYPE TellFile (void* pCookie);
static XnUInt64 XN_CALLBACK_TYPE TellFile64(void* pCookie);
static void XN_CALLBACK_TYPE CloseFile(void *pCookie);
XnStatus OpenFileImpl();
XnStatus ReadFileImpl(void *pData, XnUInt32 nSize, XnUInt32& nBytesRead);
XnStatus SeekFileImpl (XnOSSeekType seekType, XnInt32 nOffset);
XnStatus SeekFile64Impl(XnOSSeekType seekType, XnInt64 nOffset);
XnUInt32 TellFileImpl ();
XnUInt64 TellFile64Impl();
void CloseFileImpl();
//Node notifications
static XnStatus XN_CALLBACK_TYPE OnNodeAdded(void* pCookie, const XnChar* strNodeName,
XnProductionNodeType type, XnCodecID compression);
static XnStatus XN_CALLBACK_TYPE OnNodeRemoved(void* pCookie, const XnChar* strNodeName);
static XnStatus XN_CALLBACK_TYPE OnNodeIntPropChanged(void* pCookie, const XnChar* strNodeName,
const XnChar* strPropName, XnUInt64 nValue);
static XnStatus XN_CALLBACK_TYPE OnNodeRealPropChanged(void* pCookie, const XnChar* strNodeName,
const XnChar* strPropName, XnDouble dValue);
static XnStatus XN_CALLBACK_TYPE OnNodeStringPropChanged(void* pCookie, const XnChar* strNodeName,
const XnChar* strPropName, const XnChar* strValue);
static XnStatus XN_CALLBACK_TYPE OnNodeGeneralPropChanged(void* pCookie, const XnChar* strNodeName,
const XnChar* strPropName, XnUInt32 nBufferSize, const void* pBuffer);
static XnStatus XN_CALLBACK_TYPE OnNodeStateReady(void* pCookie, const XnChar* strNodeName);
static XnStatus XN_CALLBACK_TYPE OnNodeNewData(void* pCookie, const XnChar* strNodeName,
XnUInt64 nTimeStamp, XnUInt32 nFrame, const void* pData, XnUInt32 nSize);
XnStatus AddNode(const XnChar* strNodeName, XnProductionNodeType type, XnCodecID compression);
XnStatus RemoveNode(const XnChar* strNodeName);
XnStatus SetNodeIntProp(const XnChar* strNodeName, const XnChar* strPropName, XnUInt64 nValue);
XnStatus SetNodeRealProp(const XnChar* strNodeName, const XnChar* strPropName, XnDouble dValue);
XnStatus SetNodeStringProp(const XnChar* strNodeName, const XnChar* strPropName, const XnChar* strValue);
XnStatus SetNodeGeneralProp(const XnChar* strNodeName, const XnChar* strPropName, XnUInt32 nBufferSize, const void* pBuffer);
XnStatus SetNodeNewData(const XnChar* strNodeName, XnUInt64 nTimeStamp, XnUInt32 nFrame, const void* pData, XnUInt32 nSize);
XnStatus SetNodeStateReady(const XnChar* strNodeName);
void OnEndOfFileReached();
static void XN_CALLBACK_TYPE EndOfFileReachedCallback(void* pCookie);
void PlaybackThread();
static XN_THREAD_PROC PlaybackThread(XN_THREAD_PARAM pThreadParam);
typedef struct PlayedNodeInfo
{
XnNodeHandle hNode;
XnLockHandle hLock;
} PlayedNodeInfo;
typedef XnStringsHashT<PlayedNodeInfo> PlayedNodesHash;
static XnPlayerInputStreamInterface s_fileInputStream;
static XnNodeNotifications s_nodeNotifications;
XnNodeHandle m_hPlayer;
XnBool m_bIsFileOpen;
XN_FILE_HANDLE m_hInFile;
XnChar m_strSource[XN_FILE_MAX_PATH];
XnRecordMedium m_sourceType;
PlayedNodesHash m_playedNodes;
XnDouble m_dPlaybackSpeed;
XnUInt64 m_nStartTimestamp;
XnUInt64 m_nStartTime;
XnBool m_bHasTimeReference;
XN_THREAD_HANDLE m_hPlaybackThread;
XN_EVENT_HANDLE m_hPlaybackEvent;
XN_CRITICAL_SECTION_HANDLE m_hPlaybackLock;
XnBool m_bPlaybackThreadShutdown;
};
}
#endif //__XN_PLAYER_IMPL_H__
|
