1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
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"));
}
|
