hvirtual/guicast/thread.C

   1 #include "bcsignals.h"
   2 #include <sys/wait.h>
   3 #include <signal.h>
   4 #include <stdio.h>
   5 #include <unistd.h>
   6 #include "thread.h"
   7
   8
   9 Thread::Thread(int synchronous, int realtime, int autodelete)
  10 {
  11         this->synchronous = synchronous;
  12         this->realtime = realtime;
  13         this->autodelete = autodelete;
  14         tid = (pthread_t)-1;
  15         thread_running = 0;
  16 }
  17
  18 Thread::~Thread()
  19 {
  20 }
  21
  22 void* Thread::entrypoint(void *parameters)
  23 {
  24         Thread *thread = (Thread*)parameters;
  25
  26 // allow thread to be cancelled at any point during a region where it is enabled.
  27         pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, 0);
  28 // Disable cancellation by default.
  29         pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, 0);
  30 //printf("Thread::entrypoint 1 %d\n", getpid());
  31
  32         thread->run();
  33
  34         thread->thread_running = 0;
  35
  36         if(thread->autodelete && !thread->synchronous) delete thread;
  37         return NULL;
  38 }
  39
  40 void Thread::start()
  41 {
  42         pthread_attr_t  attr;
  43         struct sched_param param;
  44
  45         pthread_attr_init(&attr);
  46
  47         thread_running = 1;
  48         if(!synchronous) pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
  49
  50         if(realtime && getuid() == 0)
  51         {
  52                 if(pthread_attr_setschedpolicy(&attr, SCHED_FIFO) < 0)
  53                         perror("PFCThread::start pthread_attr_setschedpolicy");
  54                 param.sched_priority = 50;
  55                 if(pthread_attr_setschedparam(&attr, &param) < 0)
  56                         perror("PFCThread::start pthread_attr_setschedparam");
  57         }
  58         else
  59         {
  60                 if(pthread_attr_setinheritsched(&attr, PTHREAD_INHERIT_SCHED) < 0)
  61                         perror("Thread::start pthread_attr_setinheritsched");
  62         }
  63
  64         pthread_create(&tid, &attr, Thread::entrypoint, this);
  65 }
  66
  67 int Thread::end(pthread_t tid)           // need to join after this if synchronous
  68 {
  69         if((int)tid > 0) pthread_cancel(tid);
  70         return 0;
  71 }
  72
  73 int Thread::end()           // need to join after this if synchronous
  74 {
  75         cancel();
  76         return 0;
  77 }
  78
  79 int Thread::cancel()
  80 {
  81         if((int)tid > 0) pthread_cancel(tid);
  82         if(!synchronous) tid = (pthread_t)-1;
  83         return 0;
  84 }
  85
  86 int Thread::join()   // join this thread
  87 {
  88         int result = 0;
  89         if((int)tid > 0)
  90         {
  91                 result = pthread_join(tid, 0);
  92         }
  93
  94         tid = (pthread_t)-1;
  95
  96 // Don't execute anything after this.
  97         if(autodelete && synchronous) delete this;
  98         return 0;
  99 }
 100
 101 int Thread::enable_cancel()
 102 {
 103         pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
 104         return 0;
 105 }
 106
 107 int Thread::disable_cancel()
 108 {
 109         pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
 110         return 0;
 111 }
 112
 113 int Thread::exit_thread()
 114 {
 115         pthread_exit(0);
 116         if(!synchronous) tid = (pthread_t)-1;
 117         return 0;
 118 }
 119
 120
 121 int Thread::suspend_thread()
 122 {
 123         if((int)tid > 0) pthread_kill(tid, SIGSTOP);
 124         return 0;
 125 }
 126
 127 int Thread::continue_thread()
 128 {
 129         if((int)tid > 0) pthread_kill(tid, SIGCONT);
 130         return 0;
 131 }
 132
 133 int Thread::running()
 134 {
 135         return thread_running;
 136 }
 137
 138 int Thread::set_synchronous(int value)
 139 {
 140         this->synchronous = value;
 141         return 0;
 142 }
 143
 144 int Thread::set_realtime(int value)
 145 {
 146         this->realtime = value;
 147         return 0;
 148 }
 149
 150 int Thread::set_autodelete(int value)
 151 {
 152         this->autodelete = value;
 153         return 0;
 154 }
 155
 156 int Thread::get_autodelete()
 157 {
 158         return autodelete;
 159 }
 160
 161 int Thread::get_synchronous()
 162 {
 163         return synchronous;
 164 }
 165
 166 int Thread::calculate_realtime()
 167 {
 168 //printf("Thread::calculate_realtime %d %d\n", getpid(), sched_getscheduler(0));
 169         return (sched_getscheduler(0) == SCHED_RR ||
 170                 sched_getscheduler(0) == SCHED_FIFO);
 171 }
 172
 173 int Thread::get_realtime()
 174 {
 175         return realtime;
 176 }
 177
 178 int Thread::get_tid()
 179 {
 180         return tid;
 181 }
 182