08_pipe.c File Reference

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

Include dependency graph for 08_pipe.c:

Go to the source code of this file.

Data Structures
struct	writer_args_t
struct	reader_args_t

Functions
static void	set_nonblock (int fd)
static srn_fiber_result_t	writer (srn_context_t *ctx, void *arg)
static srn_fiber_result_t	reader (srn_context_t *ctx, void *arg)
int	main (void)

Function Documentation

main()

int main

(

void

)

Definition at line 83 of file 08_pipe.c.

               {
  SERENE_RUNTIME_INIT_WITH_SCHED(engine, sched, nullptr);
  srn_context_t *ctx = srn_context_make(engine);
 
  int fds[2];
  if (pipe(fds) != 0) {
    perror("pipe");
    return 1;
  }
  set_nonblock(fds[0]);
  set_nonblock(fds[1]);
 
  char buf[64]    = {0};
  writer_args_t w = {fds[1], "hello over a pipe"};
  reader_args_t r = {fds[0], buf, sizeof(buf)};
  (void)srn_fiber_spawn(ctx, writer, &w);
  (void)srn_fiber_spawn(ctx, reader, &r);
 
  srn_sched_run(sched, 1);
 
  srn_context_release(ctx);
  SERENE_RUNTIME_SHUTDOWN(engine);
  return 0;
}

Here is the call graph for this function:

reader()

srn_fiber_result_t reader ( srn_context_t * ctx, void * arg )

static

Definition at line 69 of file 08_pipe.c.

                                                                {
  (void)ctx;
  reader_args_t *rd      = arg;
  srn_io_size_result_t r = srn_fiber_read(rd->fd, rd->buf, rd->cap - 1, -1);
  if (HAS_ERROR(r)) {
    printf("reader: error: %s\n", r.maybe_error->msg);
  } else {
    rd->buf[r.count] = '\0';
    printf("reader: read %zu bytes: \"%s\"\n", r.count, rd->buf);
  }
  close(rd->fd);
  return nullptr;
}

Here is the call graph for this function:

Here is the caller graph for this function:

set_nonblock()

void set_nonblock ( int fd )

static

Definition at line 51 of file 08_pipe.c.

                                 {
  int fl = fcntl(fd, F_GETFL, 0);
  (void)fcntl(fd, F_SETFL, fl | O_NONBLOCK);
}

Here is the caller graph for this function:

writer()

srn_fiber_result_t writer ( srn_context_t * ctx, void * arg )

static

Definition at line 56 of file 08_pipe.c.

                                                                {
  (void)ctx;
  writer_args_t *w       = arg;
  srn_io_size_result_t r = srn_fiber_write(w->fd, w->msg, strlen(w->msg), -1);
  if (HAS_ERROR(r)) {
    printf("writer: error: %s\n", r.maybe_error->msg);
  } else {
    printf("writer: wrote %zu bytes\n", r.count);
  }
  close(w->fd); // signals EOF to the reader once the bytes are drained
  return nullptr;
}

Here is the call graph for this function:

Here is the caller graph for this function: