Src/DasherCore/SocketInput.h

   1 // SocketInput.h
   2 //
   3 // (C) Copyright Seb Wills 2005
   4 //
   5 // Linux-specific subclass of SocketInputBase: provides network socket control of Dasher cursor
   6
   7 #ifndef __SocketInput_h__
   8 #define __SocketInput_h__
   9
  10 #include "./SocketInputBase.h"
  11 #include "./DasherComponent.h"
  12 #include "./EventHandler.h"
  13
  14 #include <iostream>
  15 #include <pthread.h>
  16
  17 #define GCC_VERSION (__GNUC__ * 10000 \
  18                      + __GNUC_MINOR__ * 100 \
  19                      + __GNUC_PATCHLEVEL__)
  20
  21
  22
  23 namespace Dasher {
  24   class CSocketInput;
  25 #if GCC_VERSION >= 40100
  26   void *ThreadLauncherStub(void *_myClass);
  27 #endif
  28 }
  29
  30 using namespace Dasher;
  31 using namespace std;
  32
  33 class Dasher::CSocketInput:public CSocketInputBase {
  34
  35   // This non-member launcher stub function is required because pthreads can't launch a non-static member method.
  36   friend void *ThreadLauncherStub(void *_myClass) {
  37     CSocketInput *myClass = (CSocketInput *) _myClass;
  38
  39     pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);     // kill this thread immediately if another thread cancels it
  40     // don't know how this interacts with recv blocking
  41
  42     myClass->ReadForever();
  43
  44     return NULL;
  45   }
  46
  47 public:
  48
  49   CSocketInput(CEventHandler * pEventHandler, CSettingsStore * pSettingsStore);
  50   ~CSocketInput();
  51
  52 private:
  53
  54   pthread_t readerThread;
  55
  56   bool LaunchReaderThread();
  57
  58   void CancelReaderThread();
  59
  60   // TODO: should probably override ReportErrnoError() to popup a Gtk error message
  61
  62 };
  63
  64 #endif