Robust/src/Runtime/oooJava/rcr_runtime.c

   1 #include "trqueue.h"
   2 #include "rcr_runtime.h"
   3 #include "mlp_runtime.h"
   4
   5 void * workerTR(void *x) {
   6   struct trQueue * queue=(struct trQueue *)x;
   7   while(1) {
   8     SESEcommon * tmp;
   9     do {
  10       tmp=(SESEcommon *) dequeueTR(queue);
  11       if (tmp!=NULL)
  12         break;
  13       sched_yield();
  14     } while(1);
  15   }
  16   return NULL;
  17 }