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
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
|
/****************************************************************************
* *
* 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 __PLAYER_NODE_H__
#define __PLAYER_NODE_H__
#include <XnModuleCppInterface.h>
#include <XnCppWrapper.h>
#include <XnTypes.h>
#include <XnEventT.h>
#include <XnStringsHashT.h>
#include "DataRecords.h"
#include <XnCodecIDs.h>
class PlayerNode : public xn::ModulePlayer
{
public:
PlayerNode(xn::Context &context, const XnChar* strName);
virtual ~PlayerNode();
//public functions
virtual XnStatus Init();
virtual XnStatus Destroy();
//xn::ModulePlayer implementation
virtual XnStatus SetInputStream(void* pStreamCookie, XnPlayerInputStreamInterface* pStream);
virtual XnStatus ReadNext();
virtual XnStatus SetNodeNotifications(void* pNotificationsCookie, XnNodeNotifications* pNodeNotifications);
virtual XnStatus SetRepeat(XnBool bRepeat);
virtual XnStatus SeekToTimeStamp(XnInt64 nTimeOffset, XnPlayerSeekOrigin origin);
virtual XnStatus SeekToFrame(const XnChar* strNodeName, XnInt32 nFrameOffset, XnPlayerSeekOrigin origin);
virtual XnStatus TellTimestamp(XnUInt64& nTimestamp);
virtual XnStatus TellFrame(const XnChar* strNodeName, XnUInt32& nFrameNumber);
virtual XnUInt32 GetNumFrames(const XnChar* strNodeName, XnUInt32& nFrames);
virtual const XnChar* GetSupportedFormat();
virtual XnBool IsEOF();
virtual XnStatus RegisterToEndOfFileReached(XnModuleStateChangedHandler handler, void* pCookie, XnCallbackHandle& hCallback);
virtual void UnregisterFromEndOfFileReached(XnCallbackHandle hCallback);
private:
struct RecordUndoInfo
{
RecordUndoInfo() { Reset(); }
void Reset() { nRecordPos = 0; nUndoRecordPos = 0; }
XnUInt64 nRecordPos;
XnUInt64 nUndoRecordPos;
};
typedef XnStringsHashT<RecordUndoInfo> RecordUndoInfoMap;
struct PlayerNodeInfo
{
PlayerNodeInfo();
~PlayerNodeInfo();
void Reset();
XnBool bValid;
XnChar strName[XN_MAX_NAME_LENGTH];
XnUInt64 nLastDataPos;
XnCodecID compression;
XnUInt32 nFrames;
XnUInt32 nCurFrame;
XnUInt64 nMaxTimeStamp;
XnBool bStateReady;
XnBool bIsGenerator;
xn::Codec codec;
RecordUndoInfoMap recordUndoInfoMap;
RecordUndoInfo newDataUndoInfo;
DataIndexEntry* pDataIndex;
};
XnStatus ProcessRecord(XnBool bProcessPayload);
XnStatus SeekToTimeStampAbsolute(XnUInt64 nDestTimeStamp);
XnStatus SeekToTimeStampRelative(XnInt64 nOffset);
XnStatus UndoRecord(PlayerNode::RecordUndoInfo& undoInfo, XnUInt64 nDestPos, XnBool& nUndone);
XnStatus SeekToFrameAbsolute(XnUInt32 nNodeID, XnUInt32 nFrameNumber);
XnStatus ProcessEachNodeLastData(XnUInt32 nIDToProcessLast);
XnStatus OpenStream();
XnStatus Read(void* pData, XnUInt32 nSize, XnUInt32& nBytesRead);
XnStatus ReadRecordHeader(Record& record);
XnStatus ReadRecordFields(Record& record);
//ReadRecord reads just the fields of the record, not the payload.
XnStatus ReadRecord(Record& record);
XnStatus SeekStream(XnOSSeekType seekType, XnInt64 nOffset);
XnUInt64 TellStream();
XnStatus CloseStream();
XnStatus HandleRecord(Record& record, XnBool bHandleRecord);
XnStatus HandleNodeAddedImpl(XnUInt32 nNodeID, XnProductionNodeType type, const XnChar* strName, XnCodecID compression, XnUInt32 nNumberOfFrames, XnUInt64 nMinTimestamp, XnUInt64 nMaxTimestamp);
XnStatus HandleNodeAddedRecord(NodeAddedRecord record);
XnStatus HandleGeneralPropRecord(GeneralPropRecord record);
XnStatus HandleIntPropRecord(IntPropRecord record);
XnStatus HandleRealPropRecord(RealPropRecord record);
XnStatus HandleStringPropRecord(StringPropRecord record);
XnStatus HandleNodeRemovedRecord(NodeRemovedRecord record);
XnStatus HandleNodeStateReadyRecord(NodeStateReadyRecord record);
XnStatus HandleNodeDataBeginRecord(NodeDataBeginRecord record);
XnStatus HandleNewDataRecord(NewDataRecordHeader record, XnBool bHandleRecord);
XnStatus HandleDataIndexRecord(DataIndexRecordHeader record, XnBool bReadPayload);
XnStatus HandleEndRecord(EndRecord record);
XnStatus Rewind();
XnStatus ProcessUntilFirstData();
PlayerNodeInfo* GetPlayerNodeInfo(XnUInt32 nNodeID);
XnStatus RemovePlayerNodeInfo(XnUInt32 nNodeID);
XnUInt32 GetPlayerNodeIDByName(const XnChar* strNodeName);
PlayerNodeInfo* GetPlayerNodeInfoByName(const XnChar* strNodeName);
XnStatus SaveRecordUndoInfo(PlayerNodeInfo* pPlayerNodeInfo, const XnChar* strPropName, XnUInt64 nRecordPos, XnUInt64 nUndoRecordPos);
XnStatus GetRecordUndoInfo(PlayerNodeInfo* pPlayerNodeInfo, const XnChar* strPropName, XnUInt64& nRecordPos, XnUInt64& nUndoRecordPos);
XnStatus SkipRecordPayload(Record record);
XnStatus SeekToRecordByType(XnUInt32 nNodeID, RecordType type);
DataIndexEntry* FindTimestampInDataIndex(XnUInt32 nNodeID, XnUInt64 nTimestamp);
DataIndexEntry** GetSeekLocationsFromDataIndex(XnUInt32 nNodeID, XnUInt32 nDestFrame);
XnNodeHandle GetSelfNodeHandle();
// BC functions
XnStatus HandleNodeAdded_1_0_0_5_Record(NodeAdded_1_0_0_5_Record record);
XnStatus HandleNodeAdded_1_0_0_4_Record(NodeAdded_1_0_0_4_Record record);
static const XnUInt64 DATA_MAX_SIZE;
static const XnUInt64 RECORD_MAX_SIZE;
static const XnVersion OLDEST_SUPPORTED_FILE_FORMAT_VERSION;
static const XnVersion FIRST_FILESIZE64BIT_FILE_FORMAT_VERSION;
XnVersion m_fileVersion;
XnChar m_strName[XN_MAX_NAME_LENGTH];
XnBool m_bOpen;
XnBool m_bIs32bitFileFormat;
XnUInt8* m_pRecordBuffer;
XnUInt8* m_pUncompressedData;
void* m_pStreamCookie;
XnPlayerInputStreamInterface* m_pInputStream;
void* m_pNotificationsCookie;
XnNodeNotifications* m_pNodeNotifications;
XnBool m_bRepeat;
XnBool m_bDataBegun;
XnBool m_bEOF;
XnUInt64 m_nTimeStamp;
XnUInt64 m_nGlobalMaxTimeStamp;
XnEventNoArgs m_eofReachedEvent;
PlayerNodeInfo* m_pNodeInfoMap;
XnUInt32 m_nMaxNodes;
xn::Context m_context;
XnNodeHandle m_hSelf;
DataIndexEntry** m_aSeekTempArray;
};
#endif //__PLAYER_NODE_H__
|
