| |
104 |
104 |
{ |
| |
105 |
105 |
bStopProcessing = true; |
| |
106 |
106 |
break; |
| |
107 |
107 |
} |
| |
108 |
108 |
|
| |
109 |
109 |
std::vector<TLogFileDataPtr> vLogs; |
| |
110 |
110 |
{ |
| |
111 |
111 |
boost::shared_lock<boost::shared_mutex> lock(m_mutex); |
| |
112 |
112 |
vLogs.insert(vLogs.begin(), m_setLoggerData.begin(), m_setLoggerData.end()); |
| |
113 |
113 |
} |
| |
114 |
114 |
|
| |
115 |
115 |
for (const TLogFileDataPtr& spLogData : vLogs) |
| |
116 |
116 |
{ |
| |
117 |
117 |
try |
| |
118 |
118 |
{ |
| |
119 |
119 |
spLogData->StoreLogEntries(); |
| |
120 |
120 |
spLogData->CloseUnusedFile(); |
| |
121 |
121 |
} |
| |
122 |
122 |
catch (const std::exception& e) |
| |
123 |
123 |
{ |
| |
|
124 |
e; |
| |
124 |
125 |
ATLTRACE(e.what()); |
| |
125 |
126 |
} |
| |
126 |
127 |
} |
| |
127 |
128 |
} |
| |
128 |
129 |
while(!bStopProcessing); |
| |
129 |
130 |
} |
| |
130 |
131 |
|
| |
131 |
132 |
} |