MAK Data Logger API Documentation for DIS
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
lgrRecordDriver.h
Go to the documentation of this file.
1 /******************************************************************************
2 ** Copyright (c) 1992-2010 VT MAK
3 ** All rights reserved.
4 ******************************************************************************/
5 
9 
10 #ifndef lgrRecordDriver_H_
11 #define lgrRecordDriver_H_
12 
13 #include <lgrCore/lgrDriver.h>
14 #include <lgrUtil/absoluteTime.h>
15 #include <lgrCore/messageBuffer.h>
16 #include <vlutil/vlRunnable.h>
17 
18 class DtThread;
19 
20 namespace MAKLogger
21 {
22  class DtCheckpointPolicy;
23  class DtLgrClock;
24  class DtLgrContinuousClock;
25  class DtLgrFileInput;
26  class DtLgrFileOutput;
27  class DtLgrPlaybackDriver;
28  class DtLgrRecordCommandFactory;
29  class DtLgrRecordInterface;
30  class DtMessagePipeline;
31  class DtThreadedObject;
32  class DtLgrRecordMediaStream;
33 
37  class DT_DLL_LGRCORE DtLgrRecordDriver : public DtLgrCommandHandler
38  {
39  public:
40  typedef DtLgrRecordCommandFactory Factory;
41  typedef DtLgrRecordInterface Interface;
42 
43  DT_VIRTUAL_CTR(DtLgrRecordDriver,(DtLgrSystemDriver&))
44 
45  virtual ~DtLgrRecordDriver();
46 
48  virtual void tick();
49 
50  virtual bool releasePipeline();
51  virtual bool getPipeline();
52  virtual bool hasPipeline() const;
53 
54  virtual bool isFileOpen() const;
55  virtual bool isFileEmpty() const;
56 
57  virtual bool isRecording() const;
58  virtual bool isPaused() const;
59 
61  virtual bool pauseOnRecordAs() const;
62 
64  virtual int checkpointPolicyId() const;
65 
67  virtual int checkpointCount() const;
68 
70  virtual int checkpointSize() const;
71 
73  virtual DtAbsoluteTime checkpointTime() const;
74 
76  bool interactionsCheckpointed() const;
77 
80  virtual const DtString& filename() const;
81 
86  virtual DtCheckpointPolicy* duplicateCheckpointPolicy() const;
87 
89  virtual bool recordToMultipleFiles() const;
90 
92  virtual double multipleFileDuration() const;
93 
95  virtual const DtString& multipleFileNamingConvention() const;
96 
98  virtual const DtLgrFileOutput* currentOutput() const;
99 
101  virtual void addTemporaryTrackedEntity(const DtString& name);
102 
104  virtual const DtString& streamPipeline() const;
105 
107  virtual const DtString& streamConfiguration() const;
108 
109  const DtString& selectedMediaStreamConfigurations() const;
110 
112  bool isRecordingMediaStream() const;
113 
115  bool mediaRecordByDefault() const;
116 
118  int mediaRecordPort() const;
119 
121  virtual void stopAllThreads();
122 
124  virtual void stopThread( DtLgrCommandThread* commandThread );
125 
126  protected:
127 
129  virtual DtLgrPlaybackDriver* getPlaybackDriver(bool checkForFileOpen) const;
130 
132  virtual void setCheckpointPolicy(DtCheckpointPolicy* policy);
133 
135  virtual void tickNormalRecording();
136 
140  virtual void tickRecordToMultipleFiles(double multipleFileDuration, bool final = false);
141 
142  virtual void configurePipeline();
143 
145  virtual void activateIdleListening();
146 
147  virtual bool doNewFile(DtString filename, DtString description, bool overwrite);
148  virtual bool doRecord(bool multipleFiles);
149  virtual bool doStop();
150  virtual bool doPause();
151  virtual bool doUnpause();
152 
154  virtual DtString multipleFileName() const;
155 
160  virtual DtString multiFileDescription(bool final);
161 
164  virtual void createMediaPipeline(const DtString& pipelineConfigurations,
165  const DtString tapeFilePath, int port);
166 
168 
169  DtResponse newFile(const DtCommand& command);
170  DtResponse closeFile(const DtCommand& command);
171  DtResponse cancelRecording(const DtCommand& command);
172  DtResponse record(const DtCommand& command);
173  DtResponse pause(const DtCommand& command);
174  DtResponse unpause(const DtCommand& command);
175  DtResponse stop(const DtCommand& command);
176  DtResponse stopCondition(const DtCommand& command);
177  DtResponse stopDuration(const DtCommand& command);
178  DtResponse stopSize(const DtCommand& command);
179  DtResponse setCheckpointParameters(const DtCommand& command);
180  DtResponse setPauseOnRecordAs(const DtCommand& command);
181  DtResponse saveRecordedData(const DtCommand& command);
182  DtResponse saveRecordedDataFinished(const DtCommand& command);
183  DtResponse setRecordToMultipleFilesSettings(const DtCommand& command);
184  DtResponse startRecordToMultipleFiles(const DtCommand& command);
185  DtResponse setMediaRecordFromStreamConfiguration( const DtCommand& command );
186  DtResponse setMediaRecordFromStreamPipeline(const DtCommand& command);
187  DtResponse setIsRecordingMediaStream(const DtCommand& command);
188  DtResponse setMediaRecordByDefault(const DtCommand& command);
189  DtResponse setMediaRecordStreamParameters(const DtCommand& command);
191 
192  protected:
193 
194  class DumpCurrentRecordingThread : public DtRunnable
195  {
196  public:
197  DumpCurrentRecordingThread( MAKLogger::DtLgrSystemDriver* driver, DtString newFileName,
198  DtString description, DtLgrFileInput* input, DtLgrFileOutput* output,
199  int packetOperationCount, double fixedDuration,DtRelativeTime offset);
200 
201  virtual ~DumpCurrentRecordingThread();
202 
203  virtual void run();
204 
205  protected:
206  DtCommandInterface* myInterface;
207  DtString myFilename;
208  DtString myDescription;
209  DtLgrFileInput* myInputFile;
210  DtLgrFileOutput* myOutput;
211  int myPacketOperationCount;
212  DtRelativeTime myFixedDuration;
213  DtRelativeTime myOffset;
214  };
215 
216  DtString myFileName;
217  DtString myDescription;
218  DtLgrFileOutput* myFileOutput;
219  DtLgrSystemDriver* myDriver;
220  DtMessagePipeline* myPipeline;
221 
223  DtCheckpointPolicy* myCheckpointPolicy;
224  int myCheckpointPolicyId;
225  int myCheckpointPolicyCount;
226  int myCheckpointPolicySize;
227  DtAbsoluteTime myCheckpointPolicyTime;
228  bool myCheckpointInteractions;
229 
230  DtLgrContinuousClock* myRecordingClock;
231  DtLgrClock* myOriginalClock;
232  DtAbsoluteTime myCurrentTime;
233 
234  bool myRecordingFlag;
235  bool myPausedFlag;
236  bool myPauseOnRecordAsFlag;
237  bool myFileEmptyFlag;
238  int myStopCondition;
239  bool myStopConditionClose;
240  DtRelativeTime myStopDuration;
241  DtU64 myStopSize;
242  int myPacketOperationCount;
243  bool mySavingRecordingData;
244  DtThreadedObject* myDumpThread;
245 
246  bool myRecordToMultipleFiles;
247  double myMultipleFileDuration;
248  double myLastMultipleFileEndTime;
249  DtString myMultipleFileNamingConvention;
250  DtAbsoluteTime myTimeToSaveMultipleFiles;
251  int myMultipleFileIndex;
252  DtFilePosition myNextSavePosition;
253  DtMessageBuffer* myCompleteState;
254 
256  DtMessageBuffer myPauseTimeSnapshot;
257 
258  DtString myStreamConfiguration;
259  DtString myStreamPipeline;
260  std::set<DtLgrRecordMediaStream*> myRecordStreams;
261  bool myIsRecordingMediaStream;
262  int myMediaRecordPort;
263  bool myMediaRecordByDefault;
264  };
265 
266 }
267 
268 #endif
Document ID: Generated on Tue Aug 1 09:00:26 EDT 2017 from SVN revision 179128
Copyright © 2017 VT MÄK. All Rights Reserved (www.mak.com)