13_map_reduce.c File Reference

#include <stdint.h>
#include <stdio.h>
#include <serene/rt/trace.h>
#include <serene/runtime.h>
#include "serene/utils.h"

Include dependency graph for 13_map_reduce.c:

Go to the source code of this file.

Data Structures
struct	mapper_args_t

Macros
#define	NUMBER_OF_ELEMENTS   1000

Typedefs
typedef uint64_t(*	mapper_f) (uint64_t v)
typedef struct mapper_args_t	mapper_args_t

Functions
static uint64_t	add_1 (uint64_t v)
static srn_fiber_result_t	mapper_fiber (srn_context_t *ctx, void *arg)
static int	main_13 (srn_context_t *ctx, int argc, char **argv)

Macro Definition Documentation

NUMBER_OF_ELEMENTS

#define NUMBER_OF_ELEMENTS   1000

Definition at line 29 of file 13_map_reduce.c.

Typedef Documentation

mapper_args_t

typedef struct mapper_args_t mapper_args_t

mapper_f

typedef uint64_t(* mapper_f) (uint64_t v)

Definition at line 31 of file 13_map_reduce.c.

Function Documentation

add_1()

uint64_t add_1 ( uint64_t v )

static

Definition at line 38 of file 13_map_reduce.c.

{ return v + 10; }

Here is the caller graph for this function:

main_13()

int main_13 ( srn_context_t * ctx, int argc, char ** argv )

static

Definition at line 48 of file 13_map_reduce.c.

                                                              {
  UNUSED(argc);
  UNUSED(argv);
 
  srn_fiber_t *fibers[NUMBER_OF_ELEMENTS];
 
  uint64_t xs[NUMBER_OF_ELEMENTS] = {0};
 
  for (int i = 0; i < NUMBER_OF_ELEMENTS; i++) {
    // Fan out, one mapper per element. SRN_FIBER_SPAWN_COPY copies the argument
    // into the context, so each fiber owns its own copy and the loop-local
    // `args` can die at the end of the iteration.
    mapper_args_t args = {
      .val = i,
      .f   = &add_1,
    };
    fibers[i] = SRN_FIBER_SPAWN_COPY(ctx, mapper_fiber, args);
  }
 
  // Fan in, join each mapper and read the value it returned.
  for (int i = 0; i < NUMBER_OF_ELEMENTS; i++) {
    xs[i] = (uint64_t)(uintptr_t)srn_fiber_wait_for(fibers[i]);
  }
 
  for (int i = 0; i < NUMBER_OF_ELEMENTS; i++) {
    printf(">> %lu\n", xs[i]);
  };
 
  return 0;
}

Here is the call graph for this function:

mapper_fiber()

srn_fiber_result_t mapper_fiber ( srn_context_t * ctx, void * arg )

static

Definition at line 40 of file 13_map_reduce.c.

                                                                      {
  (void)ctx;
  auto mapper_args = (mapper_args_t *)arg;
 
  uint64_t val = mapper_args->f(mapper_args->val);
  return (void *)(uintptr_t)val;
}

Here is the caller graph for this function: