diff options
Diffstat (limited to 'orkaudio/ImmediateProcessing.cpp')
-rw-r--r-- | orkaudio/ImmediateProcessing.cpp | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/orkaudio/ImmediateProcessing.cpp b/orkaudio/ImmediateProcessing.cpp index 1298117..5aeb1dc 100644 --- a/orkaudio/ImmediateProcessing.cpp +++ b/orkaudio/ImmediateProcessing.cpp @@ -17,6 +17,7 @@ #include "ace/OS_NS_unistd.h" #include "BatchProcessing.h" #include "Daemon.h" +#include "ConfigManager.h" ImmediateProcessing ImmediateProcessing::m_immediateProcessingSingleton; @@ -34,10 +35,23 @@ void ImmediateProcessing::AddAudioTape(AudioTapeRef audioTapeRef) } } +void ImmediateProcessing::SetQueueSize(int size) +{ + m_audioTapeQueue.setSize(size); +} + + void ImmediateProcessing::ThreadHandler(void *args) { + CStdString logMsg; + ImmediateProcessing* pImmediateProcessing = ImmediateProcessing::GetInstance(); + pImmediateProcessing->SetQueueSize(CONFIG.m_immediateProcessingQueueSize); + + logMsg.Format("thread starting - queue size:%d", CONFIG.m_immediateProcessingQueueSize); + LOG4CXX_INFO(LOG.immediateProcessingLog, logMsg); + bool stop = false; for(;stop == false;) |