// 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() {

const char* log_level_lookup_table[] = {

"ERROR", "WARN", "INFO", "DEBUG", "TRACE"

};

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

std::string msg = "ENTRY log level = ";

msg += log_level_lookup_table[CPPA_LOG_LEVEL];

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

}

void destroy() {

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

// an empty string means: shut down

m_queue.synchronized_enqueue(m_queue_mtx, m_queue_cv,

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::out | ios::app);

unique_ptr<log_event> event;

for (;;) {

event.reset(m_queue.synchronized_pop(m_queue_mtx, m_queue_cv));

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) override {

string class_name = c_class_name;

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

replace_all(class_name, "(anonymous namespace)", "$anon$");

string file_name;

string full_file_name = c_full_file_name;

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

if (ri != full_file_name.rend()) {

auto i = ri.base();

if (i == full_file_name.end()) file_name = move(full_file_name);

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

}

else file_name = move(full_file_name);

ostringstream line;

line << time(0) << " "

<< level << " "

<< "actor" << t_self_id << " "

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

<< class_name << " "

<< function_name << " "

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

<< msg

<< endl;

m_queue.synchronized_enqueue(m_queue_mtx, m_queue_cv,

new log_event{nullptr, line.str()});

}

private:

thread m_thread;

mutex m_queue_mtx;

condition_variable m_queue_cv;

intrusive::single_reader_queue<log_event> m_queue;

actor_id prev = t_self_id;

t_self_id = aid;

return prev;