lib/base/thread.cpp

   1 #include <lib/base/thread.h>
   2
   3 #include <stdio.h>
   4 #include <unistd.h>
   5 #include <lib/base/eerror.h>
   6
   7 void eThread::thread_completed(void *ptr)
   8 {
   9         eThread *p = (eThread*) ptr;
  10         eDebug("thread has completed..");
  11         p->alive=0;
  12         p->thread_finished();
  13 }
  14
  15 void *eThread::wrapper(void *ptr)
  16 {
  17         eThread *p = (eThread*)ptr;
  18         pthread_cleanup_push( thread_completed, (void*)p );
  19         p->thread();
  20         pthread_exit(0);
  21         pthread_cleanup_pop(1);
  22         return 0;
  23 }
  24
  25 eThread::eThread()
  26         :the_thread(0), alive(0)
  27 {
  28 }
  29
  30 void eThread::run( int prio, int policy )
  31 {
  32         if (alive)
  33         {
  34                 eDebug("thread already running !!");
  35                 return;
  36         }
  37         pthread_attr_t attr;
  38         pthread_attr_init(&attr);
  39         if (prio||policy)
  40         {
  41                 struct sched_param p;
  42                 p.__sched_priority=prio;
  43                 pthread_attr_setschedpolicy(&attr, policy );
  44                 pthread_attr_setschedparam(&attr, &p);
  45         }
  46         if ( pthread_create(&the_thread, &attr, wrapper, this) )
  47         {
  48                 eDebug("couldn't create new thread");
  49                 return;
  50         }
  51         alive = 1;
  52 }
  53
  54 eThread::~eThread()
  55 {
  56         kill();
  57 }
  58
  59 void eThread::kill(bool sendcancel)
  60 {
  61         if (!the_thread)
  62                 return;
  63         if ( alive && sendcancel )
  64         {
  65                 eDebug("send cancel to thread");
  66                 pthread_cancel(the_thread);
  67         }
  68         eDebug("thread joined %d", pthread_join(the_thread, 0));
  69         the_thread=0;
  70 }