Added new TapeFileNaming tape processor, corrected it not to modify the MCF file

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

1 files changed, 139 insertions, 0 deletions

diff --git a/orkbasecxx/TapeFileNaming.cpp b/orkbasecxx/TapeFileNaming.cpp
new file mode 100644
index 0000000..cb9e296
--- /dev/null
+++ b/orkbasecxx/TapeFileNaming.cpp
@@ -0,0 +1,139 @@
+/*
+ * Oreka -- A media capture and retrieval platform
+ *
+ * Copyright (C) 2005, orecx LLC
+ *
+ * http://www.orecx.com
+ *
+ * This program is free software, distributed under the terms of
+ * the GNU General Public License.
+ * Please refer to http://www.gnu.org/copyleft/gpl.html
+ *
+ */
+#pragma warning( disable: 4786 )
+
+#define _WINSOCKAPI_		// prevents the inclusion of winsock.h
+
+#include <vector>
+#include <bitset>
+
+#include "ConfigManager.h"
+#include "ace/OS_NS_unistd.h"
+#include "Daemon.h"
+#include "Filter.h"
+#include "Reporting.h"
+#include "TapeFileNaming.h"
+
+TapeProcessorRef TapeFileNaming::m_singleton;
+
+void TapeFileNaming::Initialize()
+{
+	if(m_singleton.get() == NULL)
+	{
+		m_singleton.reset(new TapeFileNaming());
+		TapeProcessorRegistry::instance()->RegisterTapeProcessor(m_singleton);
+	}
+}
+
+TapeFileNaming::TapeFileNaming()
+{
+	m_threadCount = 0;
+
+	struct tm date = {0};
+	time_t now = time(NULL);
+	ACE_OS::localtime_r(&now, &date);
+	m_currentDay = date.tm_mday;
+}
+
+CStdString __CDECL__ TapeFileNaming::GetName()
+{
+	return "TapeFileNaming";
+}
+
+TapeProcessorRef TapeFileNaming::Instanciate()
+{
+	return m_singleton;
+}
+
+void TapeFileNaming::AddAudioTape(AudioTapeRef& audioTapeRef)
+{
+	if (!m_audioTapeQueue.push(audioTapeRef))
+	{
+		LOG4CXX_ERROR(LOG.tapeFileNamingLog, CStdString("queue full"));
+	}
+}
+
+void TapeFileNaming::SetQueueSize(int size)
+{
+	m_audioTapeQueue.setSize(size);
+}
+
+void TapeFileNaming::ThreadHandler(void *args)
+{
+	CStdString logMsg;
+
+	CStdString processorName("TapeFileNaming");
+	TapeProcessorRef tapeFileNaming = TapeProcessorRegistry::instance()->GetNewTapeProcessor(processorName);
+	if(tapeFileNaming.get() == NULL)
+	{
+		LOG4CXX_ERROR(LOG.tapeFileNamingLog, "Could not instanciate TapeFileNaming");
+		return;
+	}
+
+	TapeFileNaming *pTapeFileNaming = (TapeFileNaming*)(tapeFileNaming->Instanciate().get());
+
+	pTapeFileNaming->SetQueueSize(20000);
+	LOG4CXX_INFO(LOG.tapeFileNamingLog, "Started");
+
+	bool stop = false;
+
+	for(;stop == false;)
+	{
+		AudioTapeRef audioTapeRef;
+		CStdString trackingId = "[no-trk]";
+
+		try
+		{
+			audioTapeRef = pTapeFileNaming->m_audioTapeQueue.pop();
+			if(audioTapeRef.get() == NULL)
+			{
+				if(Daemon::Singleton()->IsStopping())
+				{
+					stop = true;
+				}
+				if(Daemon::Singleton()->GetShortLived())
+				{
+					Daemon::Singleton()->Stop();
+				}
+			}
+			else
+			{
+				CStdString originalFilename, newFilename;
+
+				trackingId = audioTapeRef->m_trackingId;
+	
+				originalFilename = CONFIG.m_audioOutputPath + "/" + audioTapeRef->GetFilename();
+				audioTapeRef->GenerateFinalFilePathAndIdentifier();
+				newFilename = CONFIG.m_audioOutputPath + "/" + audioTapeRef->GetFilename();
+
+				if(originalFilename.Compare(newFilename) != 0)
+				{
+					if(ACE_OS::rename((PCSTR)originalFilename, (PCSTR)newFilename) != 0)
+					{
+						logMsg.Format("[%s] error renaming file from %s to %s.", trackingId, originalFilename, newFilename);
+						LOG4CXX_ERROR(LOG.tapeFileNamingLog, logMsg);
+					}
+				}
+
+				pTapeFileNaming->RunNextProcessor(audioTapeRef);
+			}
+		}
+		catch (CStdString& e)
+		{
+			LOG4CXX_ERROR(LOG.tapeFileNamingLog, e);
+		}
+	}
+
+	LOG4CXX_INFO(LOG.tapeFileNamingLog, CStdString("Exited"));
+}
+