1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22

__code initDataGears(struct LoopCounter* loopCounter, struct TaskManager* taskManager) {
    // loopCounter->tree = createRedBlackTree(context);
    loopCounter->i = 0;
    taskManager->taskManager = (union Data*)createTaskManagerImpl(context, cpu_num, gpu_num, 0);
    struct Timer* timer = Gearef(context, Timer);
    goto code1();
}

__code code1(struct Timer* timer) {
    printf("cpus:\t\t%d\n", cpu_num);
    printf("gpus:\t\t%d\n", gpu_num);
    printf("length:\t\t%d\n", length);
    goto createTask1();
}

__code code2(struct TaskManager* taskManager) {
    goto taskManager->shutdown(exit_code);
}

__code code2_stub(struct Context* context) {
    goto code2(context, &Gearef(context, TaskManager)->taskManager->TaskManager);
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

__code putSynchronizedQueue(struct SynchronizedQueue* queue, union Data* data, __code next(...)) {
    Element* element = new Element();
    element->data = data;
    element->next = NULL;
    Element* last = queue->last;
    Element* nextElement = last->next;
    if (last != queue->last) {
        goto putSynchronizedQueue();
    }
    if (nextElement == NULL) {
        struct Atomic* atomic = queue->atomic;
        goto atomic->checkAndSet(&last->next, nextElement, element, next(...), putSynchronizedQueue);
    } else {
        struct Atomic* atomic = queue->atomic;
        goto atomic->checkAndSet(&queue->last, last, nextElement, putSynchronizedQueue, putSynchronizedQueue);
    }
}

__code takeSynchronizedQueue(struct SynchronizedQueue* queue, __code next(union Data* data, ...)) {
    struct Element* top = queue->top;
    struct Element* last = queue->last;
    struct Element* nextElement = top->next;
    if (top != queue->top) {
        goto takeSynchronizedQueue();
    }
    if (top == last) {
        if (nextElement != NULL) {
            struct Atomic* atomic = queue->atomic;
            goto atomic->checkAndSet(&queue->last, last, nextElement, takeSynchronizedQueue, takeSynchronizedQueue);
        }
    } else {
        struct Atomic* atomic = queue->atomic;
        goto atomic->checkAndSet(&queue->top, top, nextElement, takeSynchronizedQueue1, takeSynchronizedQueue);
    }
    goto takeSynchronizedQueue();
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c: In function 'initDataGears':
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c:21:10: warning: implicit declaration of function 'code1' [-Wimplicit-function-declaration]
   21 |     goto code1(context, timer);
      |          ^~~~~
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c: At top level:
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c:30:8: warning: conflicting types for 'code1'
   30 | __code code1(struct Context *context,struct Timer* timer) {
      |        ^~~~~
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c:21:10: note: previous implicit declaration of 'code1' was here
   21 |     goto code1(context, timer);
      |          ^~~~~
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c: In function 'code1':
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c:34:10: warning: implicit declaration of function 'createTask1'; did you mean 'createTask1_stub'? [-Wimplicit-function-declaration]
   34 |     goto createTask1(context, &GearImpl(context, TaskManager, taskManager));
      |          ^~~~~~~~~~~
      |          createTask1_stub
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c: At top level:
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c:53:8: warning: conflicting types for 'createTask1'
   53 | __code createTask1(struct Context *context,struct TaskManager* taskManager) {
      |        ^~~~~~~~~~~
/Users/anatofuz/src/firefly/hg/Gears/Gears/src/parallel_execution/c/examples/boundedBuffer/main.c:34:10: note: previous implicit declaration of 'createTask1' was here
   34 |     goto createTask1(context, &GearImpl(context, TaskManager, taskManager));
      |          ^~~~~~~~~~~

1
2
3

goto meta(context, arg[type => C_exampleXtake2_single_linked_stack, 
                       InputData => struct exampleXtak2_sinle_linked_stack { },
                       ]);