04_suspend_resume.c File Reference

#include <stdio.h>
#include "serene/rt/context.h"
#include "serene/rt/engine.h"
#include "serene/rt/fiber.h"
#include "serene/rt/mm/interface.h"

Include dependency graph for 04_suspend_resume.c:

Go to the source code of this file.

Data Structures
struct	mailbox_t

Functions
static bool	park_on_empty (srn_fiber_t *self, void *arg)
static srn_fiber_result_t	consumer (srn_context_t *ctx, void *arg)
static srn_fiber_result_t	producer (srn_context_t *ctx, void *arg)
int	main (void)

Variables
static int	ok
static mailbox_t	mailbox

Function Documentation

consumer()

static srn_fiber_result_t consumer ( srn_context_t * ctx, void * arg )

static

Definition at line 67 of file 04_suspend_resume.c.

                                                                  {
  (void)ctx;
  (void)arg;
  printf("consumer: waiting for a value\n");
  srn_fiber_suspend(park_on_empty, &mailbox);
  printf("consumer: received %d\n", mailbox.value);
  return &ok;
}

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main

(

void

)

Definition at line 91 of file 04_suspend_resume.c.

               {
  srn_mm_t *mm = srn_mm_init();
  srn_engine_t *engine = srn_engine_make(mm);
  srn_context_t *ctx = srn_context_make(engine);
  srn_scheduler_t *sched = engine->scheduler;
 
  // The consumer is created first so it runs and parks before the producer
  // fills the slot.
  (void)srn_fiber_make(ctx, sched, consumer, nullptr, 0);
  (void)srn_fiber_make(ctx, sched, producer, nullptr, 0);
 
  srn_sched_run(sched, 1);
 
  srn_context_release(ctx);
  srn_engine_shutdown(engine);
  srn_mm_shutdown(mm);
  return 0;
}

Here is the call graph for this function:

park_on_empty()

static bool park_on_empty ( srn_fiber_t * self, void * arg )

static

Definition at line 58 of file 04_suspend_resume.c.

                                                        {
  mailbox_t *mb = arg;
  if (mb->has_value) {
    return false;
  }
  mb->waiter = self;
  return true;
}

Here is the caller graph for this function:

producer()

static srn_fiber_result_t producer ( srn_context_t * ctx, void * arg )

static

Definition at line 76 of file 04_suspend_resume.c.

                                                                  {
  (void)ctx;
  (void)arg;
  mailbox.value = 42;
  mailbox.has_value = true;
  printf("producer: put %d in the mailbox\n", mailbox.value);
  // Wake the consumer if one is parked on the mailbox.
  if (mailbox.waiter != nullptr) {
    srn_fiber_t *w = mailbox.waiter;
    mailbox.waiter = nullptr;
    srn_fiber_ready(w);
  }
  return &ok;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

mailbox

mailbox_t mailbox

static

Definition at line 53 of file 04_suspend_resume.c.

ok

int ok

static

Definition at line 44 of file 04_suspend_resume.c.