Default immediate processing queue size is now 10000. Default batch processing queue size is now 20000. Both values are now configurable.

git-svn-id: https://oreka.svn.sourceforge.net/svnroot/oreka/trunk@198 09dcff7a-b715-0410-9601-b79a96267cd0

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;)