diff options
Diffstat (limited to 'orkbasecxx')
| -rw-r--r-- | orkbasecxx/Config.cpp | 2 | ||||
| -rw-r--r-- | orkbasecxx/Config.h | 3 | ||||
| -rw-r--r-- | orkbasecxx/Reporting.cpp | 10 |
3 files changed, 15 insertions, 0 deletions
diff --git a/orkbasecxx/Config.cpp b/orkbasecxx/Config.cpp index d57716d..24d4391 100644 --- a/orkbasecxx/Config.cpp +++ b/orkbasecxx/Config.cpp @@ -67,6 +67,7 @@ Config::Config() m_commandLineServerPort = COMMAND_LINE_SERVER_PORT_DEFAULT; m_httpServerPort = HTTP_SERVER_PORT_DEFAULT; + m_lookBackRecording = LOOKBACK_RECORDING_DEFAULT; } void Config::Define(Serializer* s) @@ -134,6 +135,7 @@ void Config::Define(Serializer* s) s->StringValue(REMOTE_PROCESSING_SERVICE_NAME_PARAM, m_remoteProcessingServiceName); s->IntValue(COMMAND_LINE_SERVER_PORT_PARAM, m_commandLineServerPort); s->IntValue(HTTP_SERVER_PORT_PARAM, m_httpServerPort); + s->BoolValue(LOOKBACK_RECORDING_PARAM, m_lookBackRecording); } void Config::Validate() diff --git a/orkbasecxx/Config.h b/orkbasecxx/Config.h index 9290815..ed9deb9 100644 --- a/orkbasecxx/Config.h +++ b/orkbasecxx/Config.h @@ -96,6 +96,8 @@ #define COMMAND_LINE_SERVER_PORT_DEFAULT 59130 #define HTTP_SERVER_PORT_PARAM "HttpServerPort" #define HTTP_SERVER_PORT_DEFAULT 59140 +#define LOOKBACK_RECORDING_PARAM "LookBackRecording" +#define LOOKBACK_RECORDING_DEFAULT true class DLL_IMPORT_EXPORT_ORKBASE Config : public Object { @@ -151,6 +153,7 @@ public: CStdString m_remoteProcessingServiceName; int m_commandLineServerPort; int m_httpServerPort; + bool m_lookBackRecording; private: log4cxx::LoggerPtr m_log; diff --git a/orkbasecxx/Reporting.cpp b/orkbasecxx/Reporting.cpp index 9aa053d..91ca42a 100644 --- a/orkbasecxx/Reporting.cpp +++ b/orkbasecxx/Reporting.cpp @@ -21,6 +21,7 @@ #include "messages/TapeMsg.h" #include "OrkClient.h" #include "Daemon.h" +#include "CapturePluginProxy.h" TapeProcessorRef Reporting::m_singleton; @@ -174,6 +175,15 @@ void Reporting::ThreadHandler(void *args) } } + else + { + // Tape is wanted + if(CONFIG.m_lookBackRecording == false && ptapeMsg->m_stage.Equals("start")) + { + CapturePluginProxy::Singleton()->StartCapture(ptapeMsg->m_localParty); + CapturePluginProxy::Singleton()->StartCapture(ptapeMsg->m_remoteParty); + } + } //else //{ // if(!startMsg) |