X-Git-Url: https://git.ucc.asn.au/?p=progcomp2012.git;a=blobdiff_plain;f=manager%2Fthread_util.cpp;fp=manager%2Fthread_util.cpp;h=0000000000000000000000000000000000000000;hp=2d12438f1857107da5ccc6e23b435d118deafa19;hb=e3b15cd5dea739f7523920d83bda592db95a7b93;hpb=7f7bc05439b70b3139086086608996de3c9ae2ed;ds=sidebyside diff --git a/manager/thread_util.cpp b/manager/thread_util.cpp deleted file mode 100644 index 2d12438..0000000 --- a/manager/thread_util.cpp +++ /dev/null @@ -1,47 +0,0 @@ -#include "thread_util.h" - -#include -#include - -using namespace std; - -pthread_mutex_t GetterThread::mutex = PTHREAD_MUTEX_INITIALIZER; - -void * GetterThread::GetMessage(void * p) -{ - - GetterThread * getter = (GetterThread*)(p); - - stringstream inputStream; - - char s = fgetc(getter->stream); - while (s != '\n' && s != EOF) - { - - inputStream << s; - s = fgetc(getter->stream); - } - if (s == EOF) - { - getter->buffer = ""; - getter->buffer += s; - return NULL; - } - - pthread_mutex_lock(&mutex); - getter->buffer = inputStream.str(); - pthread_mutex_unlock(&mutex); - - getter->finished = true; - - return NULL; -} - -void * TimerThread::Timeout(void * p) -{ - TimerThread * timer = (TimerThread*)(p); - usleep(timer->count); - timer->finished = true; - return NULL; -} -