1 #include "thread_util.h"
8 pthread_mutex_t GetterThread::mutex = PTHREAD_MUTEX_INITIALIZER;
10 void * GetterThread::GetMessage(void * p)
13 GetterThread * getter = (GetterThread*)(p);
15 stringstream inputStream;
17 char s = fgetc(getter->stream);
18 while (s != '\n' && s != EOF)
22 s = fgetc(getter->stream);
31 pthread_mutex_lock(&mutex);
32 getter->buffer = inputStream.str();
33 pthread_mutex_unlock(&mutex);
35 getter->finished = true;
40 void * TimerThread::Timeout(void * p)
42 TimerThread * timer = (TimerThread*)(p);
44 timer->finished = true;