ThreadSafeOutputFileStream.cc

Go to the documentation of this file.

#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