Serene Runtime 1.0.0-dev
C runtime for the Serene programming language
Loading...
Searching...
No Matches
12_http_server.c File Reference
#include <arpa/inet.h>
#include <fcntl.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <unistd.h>
#include <serene/rt/fiber/io.h>
#include <serene/rt/trace.h>
#include <serene/runtime.h>
#include "serene/utils.h"
Include dependency graph for 12_http_server.c:

Go to the source code of this file.

Data Structures

struct  server_args_t
struct  worker_args_t

Typedefs

typedef struct server_args_t server_args_t
typedef struct worker_args_t worker_args_t

Functions

static srn_fiber_result_t srn_fiber_web_worker (srn_context_t *ctx, void *arg)
static srn_fiber_result_t server (srn_context_t *ctx, void *arg)
static void set_nonblock (int fd)
int main (void)

Variables

static atomic_uint counter

Typedef Documentation

◆ server_args_t

typedef struct server_args_t server_args_t

◆ worker_args_t

typedef struct worker_args_t worker_args_t

Function Documentation

◆ main()

int main ( void )

Definition at line 140 of file 12_http_server.c.

140 {
141 SERENE_RUNTIME_INIT_WITH_SCHED(engine, sched, nullptr);
142 srn_context_t *ctx = srn_context_make(engine);
143
144 atomic_init(&counter, 0);
145
146 int one = 1;
147 int sock = socket(AF_INET, SOCK_STREAM, 0);
148 setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(int));
149
150 int port = 8080;
151 struct sockaddr_in a = {
152 .sin_family = AF_INET,
153 .sin_addr = {INADDR_ANY},
154 .sin_port = htons(port),
155 };
156
157 if (sock < 0 || bind(sock, (struct sockaddr *)&a, sizeof(a)) != 0 || listen(sock, 128) != 0) {
158 perror("listener setup");
159 return 1;
160 }
161
162 set_nonblock(sock);
163 socklen_t al = sizeof(a);
164 if (getsockname(sock, (struct sockaddr *)&a, &al) != 0) {
165 perror("getsockname");
166 return 1;
167 }
168
169 printf("Running the webserver on 0.0.0.0:%d\n", port);
170 server_args_t s = {sock};
171 SRN_TRACEPOINT(http_main_start);
172 (void)srn_fiber_spawn(ctx, server, &s);
173
174 srn_sched_run(sched, 0);
175 close(sock);
176
177 srn_context_release(ctx);
178 SERENE_RUNTIME_SHUTDOWN(engine);
179 return 0;
180}
server
static srn_fiber_result_t server(srn_context_t *ctx, void *arg)
Definition 09_tcp_echo.c:56
set_nonblock
static void set_nonblock(int fd)
Definition 12_http_server.c:135
counter
static atomic_uint counter
Definition 12_http_server.c:41
srn_context_make
srn_context_t * srn_context_make(srn_engine_t *engine)
Make an empty context, by allocating a new memory block.
Definition context.c:39
srn_context_release
int srn_context_release(srn_context_t *ctx)
Definition context.c:64
srn_fiber_spawn
srn_fiber_t * srn_fiber_spawn(srn_context_t *ctx, srn_fiber_entry_t entry, void *arg)
Make and schedule a fiber with every default, the engine's scheduler, the configured stack size,...
Definition fiber.c:245
SERENE_RUNTIME_SHUTDOWN
#define SERENE_RUNTIME_SHUTDOWN(engine)
Tear down what SERENE_RUNTIME_INIT brought up, in reverse order, the engine (reactor,...
Definition runtime.h:58
SERENE_RUNTIME_INIT_WITH_SCHED
#define SERENE_RUNTIME_INIT_WITH_SCHED(engine, sched, config)
SERENE_RUNTIME_INIT plus a sched variable bound to the engine's scheduler, which every run and fiber ...
Definition runtime.h:46
srn_sched_run
void srn_sched_run(srn_scheduler_t *sched, size_t nworkers)
Run the scheduler with nworkers os threads draining it, returning once the pool goes quiescent (every...
Definition scheduler.c:875
server_args_t
Definition 09_tcp_echo.c:43
srn_context_t
Definition context.h:47
SRN_TRACEPOINT
#define SRN_TRACEPOINT(name,...)
Placement matters.
Definition trace.h:79
Here is the call graph for this function:

◆ server()

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

Definition at line 113 of file 12_http_server.c.

113 {
114 (void)ctx;
115 server_args_t *s = arg;
116
117 for (;;) {
118 srn_io_accept_result_t conn = srn_fiber_accept(s->listener, nullptr, 0);
119
120 if (HAS_ERROR(conn)) {
121 printf("server: accept failed: %s\n", conn.maybe_error->msg);
122 return nullptr;
123 }
124
125 worker_args_t *wargs = ALLOC(ctx, worker_args_t);
126 PANIC_IF_NULL(wargs);
127 wargs->fd = conn.fd;
128 wargs->id = atomic_fetch_add(&counter, 1);
129 (void)srn_fiber_spawn(ctx, srn_fiber_web_worker, (void *)wargs);
130 }
131
132 return nullptr;
133}
srn_fiber_web_worker
static srn_fiber_result_t srn_fiber_web_worker(srn_context_t *ctx, void *arg)
Definition 12_http_server.c:52
ALLOC
#define ALLOC(ctx, T)
Definition context.h:84
HAS_ERROR
#define HAS_ERROR(x)
True when x – a value carrying an ERROR_HEADER – has an error attached.
Definition errors.h:63
srn_fiber_accept
srn_io_accept_result_t srn_fiber_accept(int fd, struct sockaddr *addr, socklen_t addr_cap)
Accept a pending connection on the listening socket fd, suspending the calling fiber until one arrive...
Definition io.c:327
server_args_t::listener
int listener
Definition 09_tcp_echo.c:44
srn_io_accept_result_t
The result of srn_fiber_accept.
Definition io.h:86
srn_io_accept_result_t::fd
int fd
Definition io.h:88
worker_args_t
Definition 12_http_server.c:47
worker_args_t::id
uint64_t id
Definition 12_http_server.c:49
worker_args_t::fd
int fd
Definition 12_http_server.c:48
PANIC_IF_NULL
#define PANIC_IF_NULL(ptr)
Definition utils.h:66
Here is the call graph for this function:

◆ set_nonblock()

void set_nonblock ( int fd)
static

Definition at line 135 of file 12_http_server.c.

135 {
136 int fl = fcntl(fd, F_GETFL, 0);
137 (void)fcntl(fd, F_SETFL, fl | O_NONBLOCK);
138}
Here is the caller graph for this function:

◆ srn_fiber_web_worker()

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

Definition at line 52 of file 12_http_server.c.

52 {
53
54 worker_args_t *wargs = arg;
55 int client_fd = wargs->fd;
56
57 int rd_num = (rand() % (5 - 1 + 1)) + 1;
58 srn_fiber_t *self = srn_fiber_current();
59 auto worker_id = srn_sched_current_worker_id();
60
61 SRN_TRACEPOINT(http_worker_start, worker_id, wargs->id, self->name, rd_num);
62
63 // Drain the request first. Closing a socket with unread bytes makes the
64 // kernel answer with RST instead of FIN and the client reports a reset.
65 char req[1024];
66
67 (void)srn_fiber_read(client_fd, req, sizeof(req), -1);
68
69 worker_id = srn_sched_current_worker_id();
70 SRN_TRACEPOINT(http_worker_switch, worker_id, wargs->id, self->name, rd_num);
71
72 char body[256];
73 int body_len = snprintf(
74 body, sizeof(body),
75 "<!DOCTYPE html><html><head><title>12-http-server-example</title>"
76 "<body><h1>%d</h1></body></html>",
77 rd_num
78 );
79
80 // Content-Length tells the client where the body ends, so it does not
81 // depend on how the connection is torn down to finish the read.
82 char response[1024];
83 int len = snprintf(
84 response, sizeof(response),
85 "HTTP/1.1 200 OK\r\n"
86 "Content-Type: text/html; charset=UTF-8\r\n"
87 "Content-Length: %d\r\n"
88 "Connection: close\r\n\r\n"
89 "%s",
90 body_len, body
91 );
92
93 printf("[%s] sleeping\n", self->name);
94 srn_fiber_sleep(rd_num);
95
96 worker_id = srn_sched_current_worker_id();
97 SRN_TRACEPOINT(http_worker_switch, worker_id, wargs->id, self->name, rd_num);
98
99 auto result = srn_fiber_write(client_fd, response, (size_t)len, -1);
100 if (HAS_ERROR(result)) {
101 printf("Failed to write: %s\n", result.maybe_error->msg);
102 }
103
104 worker_id = srn_sched_current_worker_id();
105 SRN_TRACEPOINT(http_worker_end, worker_id, wargs->id, self->name, rd_num);
106
107 printf("[%s] Replied back to the client\n", self->name);
108 close(client_fd);
109
110 return nullptr;
111}
srn_fiber_write
srn_io_size_result_t srn_fiber_write(int fd, const void *buf, size_t len, int64_t offset)
Write len bytes from buf to fd, suspending the calling fiber until the operation completes rather tha...
Definition io.c:315
srn_fiber_sleep
srn_error_t * srn_fiber_sleep(uint64_t duration)
Suspend the calling fiber for at least duration seconds, letting its worker run other fibers meanwhil...
Definition io.c:301
srn_fiber_read
srn_io_size_result_t srn_fiber_read(int fd, void *buf, size_t len, int64_t offset)
Read up to len bytes from fd into buf, suspending the calling fiber until the operation completes rat...
Definition io.c:303
srn_sched_current_worker_id
srn_worker_id_t srn_sched_current_worker_id()
Return the id of the worker that the calling os thread is running, or SIZE_MAX when the calling threa...
Definition scheduler.c:1157
srn_fiber_current
srn_fiber_t * srn_fiber_current(void)
The fiber currently running on this os thread, or null when the calling thread is not a worker or the...
Definition scheduler.c:1097
srn_fiber_t
Definition fiber.h:268
srn_fiber_t::name
char name[SRN_FIBER_NAME_MAX]
Debug name, the caller's choice copied at creation, or autogenerated when the caller passed none (see...
Definition fiber.h:333
Here is the call graph for this function:
Here is the caller graph for this function:

Variable Documentation

◆ counter

atomic_uint counter
static

Definition at line 41 of file 12_http_server.c.