10_drain.c File Reference

#include <stdint.h>
#include <stdio.h>
#include <serene/rt/fiber/io.h>
#include <serene/runtime.h>

Include dependency graph for 10_drain.c:

Go to the source code of this file.

Functions
static srn_fiber_result_t	worker_loop (srn_context_t *ctx, void *arg)
static srn_fiber_result_t	controller (srn_context_t *ctx, void *arg)
int	main (void)

Function Documentation

controller()

srn_fiber_result_t controller ( srn_context_t * ctx, void * arg )

static

Definition at line 53 of file 10_drain.c.

                                                                    {
  (void)ctx;
  srn_scheduler_t *sched = arg;
  // Let the worker fiber run a few rounds before winding the pool down. This
  // sleep is submitted before the drain, so it completes normally.
  (void)srn_fiber_sleep_ms(70);
  printf("controller: draining\n");
  srn_sched_drain(sched);
  return nullptr;
}

Here is the call graph for this function:

main()

int main

(

void

)

Definition at line 64 of file 10_drain.c.

               {
  SERENE_RUNTIME_INIT_WITH_SCHED(engine, sched, nullptr);
  srn_context_t *ctx = srn_context_make(engine);
 
  (void)srn_fiber_spawn(ctx, worker_loop, nullptr);
  (void)srn_fiber_spawn(ctx, controller, sched);
 
  srn_sched_run(sched, 1);
  printf("run returned; drain converged\n");
 
  srn_context_release(ctx);
  SERENE_RUNTIME_SHUTDOWN(engine);
  return 0;
}

Here is the call graph for this function:

worker_loop()

srn_fiber_result_t worker_loop ( srn_context_t * ctx, void * arg )

static

Definition at line 39 of file 10_drain.c.

                                                                     {
  (void)ctx;
  (void)arg;
  for (int i = 0;; i++) {
    srn_error_t *err = srn_fiber_sleep_ms(20);
    if (err != nullptr && err->tag == CANCELED) {
      printf("worker: sleep cancelled after %d rounds, winding down\n", i);
      break;
    }
    printf("worker: round %d\n", i);
  }
  return nullptr;
}

Here is the call graph for this function:

Here is the caller graph for this function: