|
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
|
#include "FWCore/Concurrency/interface/ThreadSafeOutputFileStream.h"
#include <sstream>
namespace edm {
ThreadSafeOutputFileStream::ThreadSafeOutputFileStream(std::string const& name) : file_{name} {}
ThreadSafeOutputFileStream::~ThreadSafeOutputFileStream() {
std::string tmp;
while (waitingMessages_.try_pop(tmp)) {
file_ << tmp;
}
file_.close();
}
void ThreadSafeOutputFileStream::write(std::string&& msg) {
waitingMessages_.push(std::move(msg));
bool expected{false};
if (msgBeingLogged_.compare_exchange_strong(expected, true)) {
std::string tmp;
while (waitingMessages_.try_pop(tmp)) {
file_ << tmp;
}
msgBeingLogged_.store(false);
}
}
} // namespace edm
|