works/life/computer-network-experiment/Output.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

#include "Output.h"

folly::MPMCQueue<Output> output_queue(100);

void OutputThread() {
  while (true) {
    Output output;
    output_queue.blockingRead(output);
    switch (output.type) {
    case OutputType::Error:
      error_stream << output.message;
      break;
    default:
      output_stream << output.message;
      break;
    }
  }
}