// end(before) - 1 points to the null-terminator

auto i = search(begin(str), end(str), begin(before), end(before) - 1);

while (i != end(str)) {

str.replace(i, i + RawSize - 1, after);

i = search(begin(str), end(str), begin(before), end(before) - 1);

}

public:

void initialize() {

m_thread = thread([this] { (*this)(); });

log("TRACE ", "logging", "run", __FILE__, __LINE__, "ENTRY");

}

void destroy() {

log("TRACE ", "logging", "run", __FILE__, __LINE__, "EXIT");

// an empty string means: shut down

m_queue.push_back(new log_event{0, ""});

m_thread.join();

delete this;

}

void operator()() {

ostringstream fname;

fname << "libcppa_" << getpid() << "_" << time(0) << ".log";

fstream out(fname.str().c_str(), ios::app);

unique_ptr<log_event> event;

for (;;) {

event.reset(m_queue.pop());

if (event->msg.empty()) {

out.close();

return;

}

else out << event->msg << flush;

}

}

void log(const char* level,

const char* c_class_name,

const char* function_name,

const char* c_full_file_name,

int line_num,

const std::string &msg) {

string class_name = c_class_name;

replace_all(class_name, "::", ".");

string file_name;

string full_file_name = c_full_file_name;

auto i = find(full_file_name.rbegin(), full_file_name.rend(), '/').base();

if (i == full_file_name.end()) {

file_name = move(full_file_name);

}

else {

file_name = string(i, full_file_name.end());

}

ostringstream line;

line << time(0) << " "

<< level << " "

<< this_thread::get_id() << " "

<< class_name << " "

<< function_name << " "

<< file_name << ":" << line_num << " "

<< msg

<< endl;

m_queue.push_back(new log_event{0, line.str()});

}

private:

thread m_thread;

intrusive::blocking_single_reader_queue<log_event> m_queue;