Robust/src/Runtime/oooJava/rcr_runtime.c

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