l4/pkg/libevent/lib/src/event.cc

   1 /**
   2  * \file
   3  * \brief Event handling routines.
   4  */
   5 /*
   6  * (c) 2008-2010 Adam Lackorzynski <adam@os.inf.tu-dresden.de>,
   7  *               Alexander Warg <warg@os.inf.tu-dresden.de>
   8  *     economic rights: Technische Universität Dresden (Germany)
   9  *
  10  * This file is part of TUD:OS and distributed under the terms of the
  11  * GNU General Public License 2.
  12  * Please see the COPYING-GPL-2 file for details.
  13  *
  14  * As a special exception, you may use this file as part of a free software
  15  * library without restriction.  Specifically, if other files instantiate
  16  * templates or use macros or inline functions from this file, or you compile
  17  * this file and link it with other files to produce an executable, this
  18  * file does not by itself cause the resulting executable to be covered by
  19  * the GNU General Public License.  This exception does not however
  20  * invalidate any other reasons why the executable file might be covered by
  21  * the GNU General Public License.
  22  */
  23
  24 #include <l4/event/event>
  25
  26
  27 namespace Event {
  28
  29
  30 int
  31 Event::wait()
  32 {
  33   return l4_error(_irq->down());
  34 }
  35
  36 Event_loop::Event_loop(L4::Cap<L4::Semaphore> irq, int prio)
  37   : Event_base(irq), _pthread(0)
  38 {
  39   pthread_attr_t a;
  40   pthread_attr_init(&a);
  41   if (prio != -1)
  42     {
  43       sched_param sp;
  44       sp.sched_priority = prio;
  45       pthread_attr_setschedpolicy(&a, SCHED_L4);
  46       pthread_attr_setschedparam(&a, &sp);
  47       pthread_attr_setinheritsched(&a, PTHREAD_EXPLICIT_SCHED);
  48     }
  49   else
  50     pthread_attr_setinheritsched(&a, PTHREAD_INHERIT_SCHED);
  51
  52   if (pthread_create(&_pthread, &a, event_loop, this))
  53     {
  54       _irq = L4::Cap<void>::Invalid;
  55       return;
  56     }
  57 }
  58
  59 void
  60 Event_loop::start()
  61 {
  62 }
  63
  64 Event_loop::~Event_loop()
  65 {
  66   if (_pthread)
  67     pthread_cancel(_pthread);
  68 }
  69
  70 void *
  71 Event_loop::event_loop(void *data)
  72 {
  73   Event_loop *e = reinterpret_cast<Event_loop *>(data);
  74   while (1)
  75     {
  76       l4_msgtag_t res = e->_irq->down();
  77       if (l4_ipc_error(res, l4_utcb()))
  78         continue;
  79
  80       e->handle();
  81     }
  82   return 0;
  83 }
  84
  85 }