src/reader.cc


1
2
3
4
5
6

#include "reader.hh"
#include "threads.hh"

static Semaphore OrderBufferEmpty(200);
static Semaphore OrderBufferFull(0);
static TDynamicWriteBuffer HelpBuffer(KB(64));