04_suspend_resume.c File Reference

#include <stdio.h>
#include <serene/runtime.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 mailbox_t	mailbox

Function Documentation

consumer()

srn_fiber_result_t consumer ( srn_context_t * ctx, void * arg )

static

Definition at line 62 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 nullptr;
}

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main

(

void

)

Definition at line 86 of file 04_suspend_resume.c.

               {
  SERENE_RUNTIME_INIT_WITH_SCHED(engine, sched, nullptr);
  srn_context_t *ctx = srn_context_make(engine);
 
  // The consumer is created first so it runs and parks before the producer
  // fills the slot.
  (void)srn_fiber_spawn(ctx, consumer, nullptr);
  (void)srn_fiber_spawn(ctx, producer, nullptr);
 
  srn_sched_run(sched, 1);
 
  srn_context_release(ctx);
  SERENE_RUNTIME_SHUTDOWN(engine);
  return 0;
}

Here is the call graph for this function:

park_on_empty()

bool park_on_empty ( srn_fiber_t * self, void * arg )

static

Definition at line 53 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()

srn_fiber_result_t producer ( srn_context_t * ctx, void * arg )

static

Definition at line 71 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 nullptr;
}

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 48 of file 04_suspend_resume.c.