1*1c60b9acSAndroid Build Coastguard Worker /*
2*1c60b9acSAndroid Build Coastguard Worker  * lws-minimal-http-server-eventlib-custom
3*1c60b9acSAndroid Build Coastguard Worker  *
4*1c60b9acSAndroid Build Coastguard Worker  * Written in 2010-2021 by Andy Green <[email protected]>
5*1c60b9acSAndroid Build Coastguard Worker  *
6*1c60b9acSAndroid Build Coastguard Worker  * This file is made available under the Creative Commons CC0 1.0
7*1c60b9acSAndroid Build Coastguard Worker  * Universal Public Domain Dedication.
8*1c60b9acSAndroid Build Coastguard Worker  *
9*1c60b9acSAndroid Build Coastguard Worker  * This demonstrates a minimal http server using lws, on top of a custom "event
10*1c60b9acSAndroid Build Coastguard Worker  * library" that uses an existing application POLL loop.
11*1c60b9acSAndroid Build Coastguard Worker  *
12*1c60b9acSAndroid Build Coastguard Worker  * To keep it simple, it serves stuff from the subdirectory  "./mount-origin" of
13*1c60b9acSAndroid Build Coastguard Worker  * the dir it was started in.  Change mount.origin to serve from elsewhere.
14*1c60b9acSAndroid Build Coastguard Worker  */
15*1c60b9acSAndroid Build Coastguard Worker 
16*1c60b9acSAndroid Build Coastguard Worker #include <libwebsockets.h>
17*1c60b9acSAndroid Build Coastguard Worker #include <string.h>
18*1c60b9acSAndroid Build Coastguard Worker #include <signal.h>
19*1c60b9acSAndroid Build Coastguard Worker 
20*1c60b9acSAndroid Build Coastguard Worker static int interrupted;
21*1c60b9acSAndroid Build Coastguard Worker static struct lws_context *context;
22*1c60b9acSAndroid Build Coastguard Worker 
23*1c60b9acSAndroid Build Coastguard Worker #define MAX_CUSTOM_POLLFDS	64
24*1c60b9acSAndroid Build Coastguard Worker 
25*1c60b9acSAndroid Build Coastguard Worker /* this represents the existing application poll loop context we want lws
26*1c60b9acSAndroid Build Coastguard Worker  * to cooperate with */
27*1c60b9acSAndroid Build Coastguard Worker 
28*1c60b9acSAndroid Build Coastguard Worker typedef struct custom_poll_ctx {
29*1c60b9acSAndroid Build Coastguard Worker 	struct lws_pollfd	pollfds[MAX_CUSTOM_POLLFDS];
30*1c60b9acSAndroid Build Coastguard Worker 	int			count_pollfds;
31*1c60b9acSAndroid Build Coastguard Worker } custom_poll_ctx_t;
32*1c60b9acSAndroid Build Coastguard Worker 
33*1c60b9acSAndroid Build Coastguard Worker /* for this example we just have the one, but it is passed into lws as a
34*1c60b9acSAndroid Build Coastguard Worker  * foreign loop pointer, and all callbacks have access to it via that, so it
35*1c60b9acSAndroid Build Coastguard Worker  * is not needed to be defined at file scope. */
36*1c60b9acSAndroid Build Coastguard Worker static custom_poll_ctx_t a_cpcx;
37*1c60b9acSAndroid Build Coastguard Worker 
38*1c60b9acSAndroid Build Coastguard Worker /*
39*1c60b9acSAndroid Build Coastguard Worker  * These are the custom event loop operators that just make the custom event
40*1c60b9acSAndroid Build Coastguard Worker  * loop able to work by itself.  These would already exist in some form in an
41*1c60b9acSAndroid Build Coastguard Worker  * existing application.
42*1c60b9acSAndroid Build Coastguard Worker  */
43*1c60b9acSAndroid Build Coastguard Worker 
44*1c60b9acSAndroid Build Coastguard Worker static struct lws_pollfd *
custom_poll_find_fd(custom_poll_ctx_t * cpcx,lws_sockfd_type fd)45*1c60b9acSAndroid Build Coastguard Worker custom_poll_find_fd(custom_poll_ctx_t *cpcx, lws_sockfd_type fd)
46*1c60b9acSAndroid Build Coastguard Worker {
47*1c60b9acSAndroid Build Coastguard Worker 	int n;
48*1c60b9acSAndroid Build Coastguard Worker 
49*1c60b9acSAndroid Build Coastguard Worker 	for (n = 0; n < cpcx->count_pollfds; n++)
50*1c60b9acSAndroid Build Coastguard Worker 		if (cpcx->pollfds[n].fd == fd)
51*1c60b9acSAndroid Build Coastguard Worker 			return &cpcx->pollfds[n];
52*1c60b9acSAndroid Build Coastguard Worker 
53*1c60b9acSAndroid Build Coastguard Worker 	return NULL;
54*1c60b9acSAndroid Build Coastguard Worker }
55*1c60b9acSAndroid Build Coastguard Worker 
56*1c60b9acSAndroid Build Coastguard Worker static int
custom_poll_add_fd(custom_poll_ctx_t * cpcx,lws_sockfd_type fd,int events)57*1c60b9acSAndroid Build Coastguard Worker custom_poll_add_fd(custom_poll_ctx_t *cpcx, lws_sockfd_type fd, int events)
58*1c60b9acSAndroid Build Coastguard Worker {
59*1c60b9acSAndroid Build Coastguard Worker 	struct lws_pollfd *pfd;
60*1c60b9acSAndroid Build Coastguard Worker 
61*1c60b9acSAndroid Build Coastguard Worker 	lwsl_info("%s: ADD fd %d, ev %d\n", __func__, fd, events);
62*1c60b9acSAndroid Build Coastguard Worker 
63*1c60b9acSAndroid Build Coastguard Worker 	pfd = custom_poll_find_fd(cpcx, fd);
64*1c60b9acSAndroid Build Coastguard Worker 	if (pfd) {
65*1c60b9acSAndroid Build Coastguard Worker 		lwsl_err("%s: ADD fd %d already in ext table\n", __func__, fd);
66*1c60b9acSAndroid Build Coastguard Worker 		return 1;
67*1c60b9acSAndroid Build Coastguard Worker 	}
68*1c60b9acSAndroid Build Coastguard Worker 
69*1c60b9acSAndroid Build Coastguard Worker 	if (cpcx->count_pollfds == LWS_ARRAY_SIZE(cpcx->pollfds)) {
70*1c60b9acSAndroid Build Coastguard Worker 		lwsl_err("%s: no room left\n", __func__);
71*1c60b9acSAndroid Build Coastguard Worker 		return 1;
72*1c60b9acSAndroid Build Coastguard Worker 	}
73*1c60b9acSAndroid Build Coastguard Worker 
74*1c60b9acSAndroid Build Coastguard Worker 	pfd = &cpcx->pollfds[cpcx->count_pollfds++];
75*1c60b9acSAndroid Build Coastguard Worker 	pfd->fd = fd;
76*1c60b9acSAndroid Build Coastguard Worker 	pfd->events = (short)events;
77*1c60b9acSAndroid Build Coastguard Worker 	pfd->revents = 0;
78*1c60b9acSAndroid Build Coastguard Worker 
79*1c60b9acSAndroid Build Coastguard Worker 	return 0;
80*1c60b9acSAndroid Build Coastguard Worker }
81*1c60b9acSAndroid Build Coastguard Worker 
82*1c60b9acSAndroid Build Coastguard Worker static int
custom_poll_del_fd(custom_poll_ctx_t * cpcx,lws_sockfd_type fd)83*1c60b9acSAndroid Build Coastguard Worker custom_poll_del_fd(custom_poll_ctx_t *cpcx, lws_sockfd_type fd)
84*1c60b9acSAndroid Build Coastguard Worker {
85*1c60b9acSAndroid Build Coastguard Worker 	struct lws_pollfd *pfd;
86*1c60b9acSAndroid Build Coastguard Worker 
87*1c60b9acSAndroid Build Coastguard Worker 	lwsl_info("%s: DEL fd %d\n", __func__, fd);
88*1c60b9acSAndroid Build Coastguard Worker 
89*1c60b9acSAndroid Build Coastguard Worker 	pfd = custom_poll_find_fd(cpcx, fd);
90*1c60b9acSAndroid Build Coastguard Worker 	if (!pfd) {
91*1c60b9acSAndroid Build Coastguard Worker 		lwsl_err("%s: DEL fd %d missing in ext table\n", __func__, fd);
92*1c60b9acSAndroid Build Coastguard Worker 		return 1;
93*1c60b9acSAndroid Build Coastguard Worker 	}
94*1c60b9acSAndroid Build Coastguard Worker 
95*1c60b9acSAndroid Build Coastguard Worker 	if (cpcx->count_pollfds > 1)
96*1c60b9acSAndroid Build Coastguard Worker 		*pfd = cpcx->pollfds[cpcx->count_pollfds - 1];
97*1c60b9acSAndroid Build Coastguard Worker 
98*1c60b9acSAndroid Build Coastguard Worker 	cpcx->count_pollfds--;
99*1c60b9acSAndroid Build Coastguard Worker 
100*1c60b9acSAndroid Build Coastguard Worker 	return 0;
101*1c60b9acSAndroid Build Coastguard Worker }
102*1c60b9acSAndroid Build Coastguard Worker 
103*1c60b9acSAndroid Build Coastguard Worker static int
custom_poll_change_fd(custom_poll_ctx_t * cpcx,lws_sockfd_type fd,int events_add,int events_remove)104*1c60b9acSAndroid Build Coastguard Worker custom_poll_change_fd(custom_poll_ctx_t *cpcx, lws_sockfd_type fd,
105*1c60b9acSAndroid Build Coastguard Worker 		     int events_add, int events_remove)
106*1c60b9acSAndroid Build Coastguard Worker {
107*1c60b9acSAndroid Build Coastguard Worker 	struct lws_pollfd *pfd;
108*1c60b9acSAndroid Build Coastguard Worker 
109*1c60b9acSAndroid Build Coastguard Worker 	lwsl_info("%s: CHG fd %d, ev_add %d, ev_rem %d\n", __func__, fd,
110*1c60b9acSAndroid Build Coastguard Worker 			events_add, events_remove);
111*1c60b9acSAndroid Build Coastguard Worker 
112*1c60b9acSAndroid Build Coastguard Worker 	pfd = custom_poll_find_fd(cpcx, fd);
113*1c60b9acSAndroid Build Coastguard Worker 	if (!pfd)
114*1c60b9acSAndroid Build Coastguard Worker 		return 1;
115*1c60b9acSAndroid Build Coastguard Worker 
116*1c60b9acSAndroid Build Coastguard Worker 	pfd->events = (short)((pfd->events & (~events_remove)) | events_add);
117*1c60b9acSAndroid Build Coastguard Worker 
118*1c60b9acSAndroid Build Coastguard Worker 	return 0;
119*1c60b9acSAndroid Build Coastguard Worker }
120*1c60b9acSAndroid Build Coastguard Worker 
121*1c60b9acSAndroid Build Coastguard Worker int
custom_poll_run(custom_poll_ctx_t * cpcx)122*1c60b9acSAndroid Build Coastguard Worker custom_poll_run(custom_poll_ctx_t *cpcx)
123*1c60b9acSAndroid Build Coastguard Worker {
124*1c60b9acSAndroid Build Coastguard Worker 	int n;
125*1c60b9acSAndroid Build Coastguard Worker 
126*1c60b9acSAndroid Build Coastguard Worker 	while (!interrupted) {
127*1c60b9acSAndroid Build Coastguard Worker 
128*1c60b9acSAndroid Build Coastguard Worker 		/*
129*1c60b9acSAndroid Build Coastguard Worker 		 * Notice that the existing loop must consult with lws about
130*1c60b9acSAndroid Build Coastguard Worker 		 * the maximum wait timeout to use.  Lws will reduce the
131*1c60b9acSAndroid Build Coastguard Worker 		 * timeout to the earliest scheduled event time if any earlier
132*1c60b9acSAndroid Build Coastguard Worker 		 * than the provided timeout.
133*1c60b9acSAndroid Build Coastguard Worker 		 */
134*1c60b9acSAndroid Build Coastguard Worker 
135*1c60b9acSAndroid Build Coastguard Worker 		n = lws_service_adjust_timeout(context, 5000, 0);
136*1c60b9acSAndroid Build Coastguard Worker 
137*1c60b9acSAndroid Build Coastguard Worker 		lwsl_debug("%s: entering poll wait %dms\n", __func__, n);
138*1c60b9acSAndroid Build Coastguard Worker 
139*1c60b9acSAndroid Build Coastguard Worker 		n = poll(cpcx->pollfds, (nfds_t)cpcx->count_pollfds, n);
140*1c60b9acSAndroid Build Coastguard Worker 
141*1c60b9acSAndroid Build Coastguard Worker 		lwsl_debug("%s: exiting poll ret %d\n", __func__, n);
142*1c60b9acSAndroid Build Coastguard Worker 
143*1c60b9acSAndroid Build Coastguard Worker 		if (n <= 0)
144*1c60b9acSAndroid Build Coastguard Worker 			continue;
145*1c60b9acSAndroid Build Coastguard Worker 
146*1c60b9acSAndroid Build Coastguard Worker 		for (n = 0; n < cpcx->count_pollfds; n++) {
147*1c60b9acSAndroid Build Coastguard Worker 			lws_sockfd_type fd = cpcx->pollfds[n].fd;
148*1c60b9acSAndroid Build Coastguard Worker 			int m;
149*1c60b9acSAndroid Build Coastguard Worker 
150*1c60b9acSAndroid Build Coastguard Worker 			if (!cpcx->pollfds[n].revents)
151*1c60b9acSAndroid Build Coastguard Worker 				continue;
152*1c60b9acSAndroid Build Coastguard Worker 
153*1c60b9acSAndroid Build Coastguard Worker 			m = lws_service_fd(context, &cpcx->pollfds[n]);
154*1c60b9acSAndroid Build Coastguard Worker 
155*1c60b9acSAndroid Build Coastguard Worker 			/* if something closed, retry this slot since may have been
156*1c60b9acSAndroid Build Coastguard Worker 			 * swapped with end fd */
157*1c60b9acSAndroid Build Coastguard Worker 			if (m && cpcx->pollfds[n].fd != fd)
158*1c60b9acSAndroid Build Coastguard Worker 				n--;
159*1c60b9acSAndroid Build Coastguard Worker 
160*1c60b9acSAndroid Build Coastguard Worker 			if (m < 0)
161*1c60b9acSAndroid Build Coastguard Worker 				/* lws feels something bad happened, but
162*1c60b9acSAndroid Build Coastguard Worker 				 * the outer application may not care */
163*1c60b9acSAndroid Build Coastguard Worker 				continue;
164*1c60b9acSAndroid Build Coastguard Worker 			if (!m) {
165*1c60b9acSAndroid Build Coastguard Worker 				/* check if it is an fd owned by the
166*1c60b9acSAndroid Build Coastguard Worker 				 * application */
167*1c60b9acSAndroid Build Coastguard Worker 			}
168*1c60b9acSAndroid Build Coastguard Worker 		}
169*1c60b9acSAndroid Build Coastguard Worker 	}
170*1c60b9acSAndroid Build Coastguard Worker 
171*1c60b9acSAndroid Build Coastguard Worker 	return 0;
172*1c60b9acSAndroid Build Coastguard Worker }
173*1c60b9acSAndroid Build Coastguard Worker 
174*1c60b9acSAndroid Build Coastguard Worker 
175*1c60b9acSAndroid Build Coastguard Worker /*
176*1c60b9acSAndroid Build Coastguard Worker  * These is the custom "event library" interface layer between lws event lib
177*1c60b9acSAndroid Build Coastguard Worker  * support and the custom loop implementation above.  We only need to support
178*1c60b9acSAndroid Build Coastguard Worker  * a few key apis.
179*1c60b9acSAndroid Build Coastguard Worker  *
180*1c60b9acSAndroid Build Coastguard Worker  * We are user code, so all the internal lws objects are opaque.  But there are
181*1c60b9acSAndroid Build Coastguard Worker  * enough public helpers to get everything done.
182*1c60b9acSAndroid Build Coastguard Worker  */
183*1c60b9acSAndroid Build Coastguard Worker 
184*1c60b9acSAndroid Build Coastguard Worker /* one of these is appended to each pt for our use */
185*1c60b9acSAndroid Build Coastguard Worker struct pt_eventlibs_custom {
186*1c60b9acSAndroid Build Coastguard Worker 	custom_poll_ctx_t		*io_loop;
187*1c60b9acSAndroid Build Coastguard Worker };
188*1c60b9acSAndroid Build Coastguard Worker 
189*1c60b9acSAndroid Build Coastguard Worker /*
190*1c60b9acSAndroid Build Coastguard Worker  * During lws context creation, we get called with the foreign loop pointer
191*1c60b9acSAndroid Build Coastguard Worker  * that was passed in the creation info struct.  Stash it in our private part
192*1c60b9acSAndroid Build Coastguard Worker  * of the pt, so we can reference it in the other callbacks subsequently.
193*1c60b9acSAndroid Build Coastguard Worker  */
194*1c60b9acSAndroid Build Coastguard Worker 
195*1c60b9acSAndroid Build Coastguard Worker static int
init_pt_custom(struct lws_context * cx,void * _loop,int tsi)196*1c60b9acSAndroid Build Coastguard Worker init_pt_custom(struct lws_context *cx, void *_loop, int tsi)
197*1c60b9acSAndroid Build Coastguard Worker {
198*1c60b9acSAndroid Build Coastguard Worker 	struct pt_eventlibs_custom *priv = (struct pt_eventlibs_custom *)
199*1c60b9acSAndroid Build Coastguard Worker 					     lws_evlib_tsi_to_evlib_pt(cx, tsi);
200*1c60b9acSAndroid Build Coastguard Worker 
201*1c60b9acSAndroid Build Coastguard Worker 	/* store the loop we are bound to in our private part of the pt */
202*1c60b9acSAndroid Build Coastguard Worker 
203*1c60b9acSAndroid Build Coastguard Worker 	priv->io_loop = (custom_poll_ctx_t *)_loop;
204*1c60b9acSAndroid Build Coastguard Worker 
205*1c60b9acSAndroid Build Coastguard Worker 	return 0;
206*1c60b9acSAndroid Build Coastguard Worker }
207*1c60b9acSAndroid Build Coastguard Worker 
208*1c60b9acSAndroid Build Coastguard Worker static int
sock_accept_custom(struct lws * wsi)209*1c60b9acSAndroid Build Coastguard Worker sock_accept_custom(struct lws *wsi)
210*1c60b9acSAndroid Build Coastguard Worker {
211*1c60b9acSAndroid Build Coastguard Worker 	struct pt_eventlibs_custom *priv = (struct pt_eventlibs_custom *)
212*1c60b9acSAndroid Build Coastguard Worker 						lws_evlib_wsi_to_evlib_pt(wsi);
213*1c60b9acSAndroid Build Coastguard Worker 
214*1c60b9acSAndroid Build Coastguard Worker 	return custom_poll_add_fd(priv->io_loop, lws_get_socket_fd(wsi), POLLIN);
215*1c60b9acSAndroid Build Coastguard Worker }
216*1c60b9acSAndroid Build Coastguard Worker 
217*1c60b9acSAndroid Build Coastguard Worker static void
io_custom(struct lws * wsi,unsigned int flags)218*1c60b9acSAndroid Build Coastguard Worker io_custom(struct lws *wsi, unsigned int flags)
219*1c60b9acSAndroid Build Coastguard Worker {
220*1c60b9acSAndroid Build Coastguard Worker 	struct pt_eventlibs_custom *priv = (struct pt_eventlibs_custom *)
221*1c60b9acSAndroid Build Coastguard Worker 						lws_evlib_wsi_to_evlib_pt(wsi);
222*1c60b9acSAndroid Build Coastguard Worker 	int e_add = 0, e_remove = 0;
223*1c60b9acSAndroid Build Coastguard Worker 
224*1c60b9acSAndroid Build Coastguard Worker 	if (flags & LWS_EV_START) {
225*1c60b9acSAndroid Build Coastguard Worker 		if (flags & LWS_EV_WRITE)
226*1c60b9acSAndroid Build Coastguard Worker 			e_add |= POLLOUT;
227*1c60b9acSAndroid Build Coastguard Worker 
228*1c60b9acSAndroid Build Coastguard Worker 		if (flags & LWS_EV_READ)
229*1c60b9acSAndroid Build Coastguard Worker 			e_add |= POLLIN;
230*1c60b9acSAndroid Build Coastguard Worker 	} else {
231*1c60b9acSAndroid Build Coastguard Worker 		if (flags & LWS_EV_WRITE)
232*1c60b9acSAndroid Build Coastguard Worker 			e_remove |= POLLOUT;
233*1c60b9acSAndroid Build Coastguard Worker 
234*1c60b9acSAndroid Build Coastguard Worker 		if (flags & LWS_EV_READ)
235*1c60b9acSAndroid Build Coastguard Worker 			e_remove |= POLLIN;
236*1c60b9acSAndroid Build Coastguard Worker 	}
237*1c60b9acSAndroid Build Coastguard Worker 
238*1c60b9acSAndroid Build Coastguard Worker 	custom_poll_change_fd(priv->io_loop, lws_get_socket_fd(wsi),
239*1c60b9acSAndroid Build Coastguard Worker 			      e_add, e_remove);
240*1c60b9acSAndroid Build Coastguard Worker }
241*1c60b9acSAndroid Build Coastguard Worker 
242*1c60b9acSAndroid Build Coastguard Worker static int
wsi_logical_close_custom(struct lws * wsi)243*1c60b9acSAndroid Build Coastguard Worker wsi_logical_close_custom(struct lws *wsi)
244*1c60b9acSAndroid Build Coastguard Worker {
245*1c60b9acSAndroid Build Coastguard Worker 	struct pt_eventlibs_custom *priv = (struct pt_eventlibs_custom *)
246*1c60b9acSAndroid Build Coastguard Worker 						lws_evlib_wsi_to_evlib_pt(wsi);
247*1c60b9acSAndroid Build Coastguard Worker 	return custom_poll_del_fd(priv->io_loop, lws_get_socket_fd(wsi));
248*1c60b9acSAndroid Build Coastguard Worker }
249*1c60b9acSAndroid Build Coastguard Worker 
250*1c60b9acSAndroid Build Coastguard Worker static const struct lws_event_loop_ops event_loop_ops_custom = {
251*1c60b9acSAndroid Build Coastguard Worker 	.name				= "custom",
252*1c60b9acSAndroid Build Coastguard Worker 
253*1c60b9acSAndroid Build Coastguard Worker 	.init_pt			= init_pt_custom,
254*1c60b9acSAndroid Build Coastguard Worker 	.init_vhost_listen_wsi		= sock_accept_custom,
255*1c60b9acSAndroid Build Coastguard Worker 	.sock_accept			= sock_accept_custom,
256*1c60b9acSAndroid Build Coastguard Worker 	.io				= io_custom,
257*1c60b9acSAndroid Build Coastguard Worker 	.wsi_logical_close		= wsi_logical_close_custom,
258*1c60b9acSAndroid Build Coastguard Worker 
259*1c60b9acSAndroid Build Coastguard Worker 	.evlib_size_pt			= sizeof(struct pt_eventlibs_custom)
260*1c60b9acSAndroid Build Coastguard Worker };
261*1c60b9acSAndroid Build Coastguard Worker 
262*1c60b9acSAndroid Build Coastguard Worker static const lws_plugin_evlib_t evlib_custom = {
263*1c60b9acSAndroid Build Coastguard Worker 	.hdr = {
264*1c60b9acSAndroid Build Coastguard Worker 		"custom event loop",
265*1c60b9acSAndroid Build Coastguard Worker 		"lws_evlib_plugin",
266*1c60b9acSAndroid Build Coastguard Worker 		LWS_BUILD_HASH,
267*1c60b9acSAndroid Build Coastguard Worker 		LWS_PLUGIN_API_MAGIC
268*1c60b9acSAndroid Build Coastguard Worker 	},
269*1c60b9acSAndroid Build Coastguard Worker 
270*1c60b9acSAndroid Build Coastguard Worker 	.ops	= &event_loop_ops_custom
271*1c60b9acSAndroid Build Coastguard Worker };
272*1c60b9acSAndroid Build Coastguard Worker 
273*1c60b9acSAndroid Build Coastguard Worker /*
274*1c60b9acSAndroid Build Coastguard Worker  * The rest is just the normal minimal example for lws, with a couple of extra
275*1c60b9acSAndroid Build Coastguard Worker  * lines wiring up the custom event library handlers above.
276*1c60b9acSAndroid Build Coastguard Worker  */
277*1c60b9acSAndroid Build Coastguard Worker 
278*1c60b9acSAndroid Build Coastguard Worker static const struct lws_http_mount mount = {
279*1c60b9acSAndroid Build Coastguard Worker 	/* .mount_next */		NULL,		/* linked-list "next" */
280*1c60b9acSAndroid Build Coastguard Worker 	/* .mountpoint */		"/",		/* mountpoint URL */
281*1c60b9acSAndroid Build Coastguard Worker 	/* .origin */			"./mount-origin", /* serve from dir */
282*1c60b9acSAndroid Build Coastguard Worker 	/* .def */			"index.html",	/* default filename */
283*1c60b9acSAndroid Build Coastguard Worker 	/* .protocol */			NULL,
284*1c60b9acSAndroid Build Coastguard Worker 	/* .cgienv */			NULL,
285*1c60b9acSAndroid Build Coastguard Worker 	/* .extra_mimetypes */		NULL,
286*1c60b9acSAndroid Build Coastguard Worker 	/* .interpret */		NULL,
287*1c60b9acSAndroid Build Coastguard Worker 	/* .cgi_timeout */		0,
288*1c60b9acSAndroid Build Coastguard Worker 	/* .cache_max_age */		0,
289*1c60b9acSAndroid Build Coastguard Worker 	/* .auth_mask */		0,
290*1c60b9acSAndroid Build Coastguard Worker 	/* .cache_reusable */		0,
291*1c60b9acSAndroid Build Coastguard Worker 	/* .cache_revalidate */		0,
292*1c60b9acSAndroid Build Coastguard Worker 	/* .cache_intermediaries */	0,
293*1c60b9acSAndroid Build Coastguard Worker 	/* .origin_protocol */		LWSMPRO_FILE,	/* files in a dir */
294*1c60b9acSAndroid Build Coastguard Worker 	/* .mountpoint_len */		1,		/* char count */
295*1c60b9acSAndroid Build Coastguard Worker 	/* .basic_auth_login_file */	NULL,
296*1c60b9acSAndroid Build Coastguard Worker };
297*1c60b9acSAndroid Build Coastguard Worker 
298*1c60b9acSAndroid Build Coastguard Worker /*
299*1c60b9acSAndroid Build Coastguard Worker  * This demonstrates a client connection operating on the same loop
300*1c60b9acSAndroid Build Coastguard Worker  * It's optional...
301*1c60b9acSAndroid Build Coastguard Worker  */
302*1c60b9acSAndroid Build Coastguard Worker 
303*1c60b9acSAndroid Build Coastguard Worker static int
callback_http(struct lws * wsi,enum lws_callback_reasons reason,void * user,void * in,size_t len)304*1c60b9acSAndroid Build Coastguard Worker callback_http(struct lws *wsi, enum lws_callback_reasons reason,
305*1c60b9acSAndroid Build Coastguard Worker 	      void *user, void *in, size_t len)
306*1c60b9acSAndroid Build Coastguard Worker {
307*1c60b9acSAndroid Build Coastguard Worker 	switch (reason) {
308*1c60b9acSAndroid Build Coastguard Worker 
309*1c60b9acSAndroid Build Coastguard Worker 	case LWS_CALLBACK_ESTABLISHED_CLIENT_HTTP:
310*1c60b9acSAndroid Build Coastguard Worker 		lwsl_user("LWS_CALLBACK_ESTABLISHED_CLIENT_HTTP: resp %u\n",
311*1c60b9acSAndroid Build Coastguard Worker 				lws_http_client_http_response(wsi));
312*1c60b9acSAndroid Build Coastguard Worker 		break;
313*1c60b9acSAndroid Build Coastguard Worker 
314*1c60b9acSAndroid Build Coastguard Worker 	/* because we are protocols[0] ... */
315*1c60b9acSAndroid Build Coastguard Worker 	case LWS_CALLBACK_CLIENT_CONNECTION_ERROR:
316*1c60b9acSAndroid Build Coastguard Worker 		lwsl_err("CLIENT_CONNECTION_ERROR: %s\n",
317*1c60b9acSAndroid Build Coastguard Worker 			 in ? (char *)in : "(null)");
318*1c60b9acSAndroid Build Coastguard Worker 		break;
319*1c60b9acSAndroid Build Coastguard Worker 
320*1c60b9acSAndroid Build Coastguard Worker 	/* chunks of chunked content, with header removed */
321*1c60b9acSAndroid Build Coastguard Worker 	case LWS_CALLBACK_RECEIVE_CLIENT_HTTP_READ:
322*1c60b9acSAndroid Build Coastguard Worker 		lwsl_user("RECEIVE_CLIENT_HTTP_READ: read %d\n", (int)len);
323*1c60b9acSAndroid Build Coastguard Worker 		lwsl_hexdump_info(in, len);
324*1c60b9acSAndroid Build Coastguard Worker 		return 0; /* don't passthru */
325*1c60b9acSAndroid Build Coastguard Worker 
326*1c60b9acSAndroid Build Coastguard Worker 	/* uninterpreted http content */
327*1c60b9acSAndroid Build Coastguard Worker 	case LWS_CALLBACK_RECEIVE_CLIENT_HTTP:
328*1c60b9acSAndroid Build Coastguard Worker 		{
329*1c60b9acSAndroid Build Coastguard Worker 			char buffer[1024 + LWS_PRE];
330*1c60b9acSAndroid Build Coastguard Worker 			char *px = buffer + LWS_PRE;
331*1c60b9acSAndroid Build Coastguard Worker 			int lenx = sizeof(buffer) - LWS_PRE;
332*1c60b9acSAndroid Build Coastguard Worker 
333*1c60b9acSAndroid Build Coastguard Worker 			if (lws_http_client_read(wsi, &px, &lenx) < 0)
334*1c60b9acSAndroid Build Coastguard Worker 				return -1;
335*1c60b9acSAndroid Build Coastguard Worker 		}
336*1c60b9acSAndroid Build Coastguard Worker 		return 0; /* don't passthru */
337*1c60b9acSAndroid Build Coastguard Worker 
338*1c60b9acSAndroid Build Coastguard Worker 	case LWS_CALLBACK_COMPLETED_CLIENT_HTTP:
339*1c60b9acSAndroid Build Coastguard Worker 		lwsl_user("LWS_CALLBACK_COMPLETED_CLIENT_HTTP %s\n",
340*1c60b9acSAndroid Build Coastguard Worker 			  lws_wsi_tag(wsi));
341*1c60b9acSAndroid Build Coastguard Worker 		break;
342*1c60b9acSAndroid Build Coastguard Worker 
343*1c60b9acSAndroid Build Coastguard Worker 	case LWS_CALLBACK_CLOSED_CLIENT_HTTP:
344*1c60b9acSAndroid Build Coastguard Worker 		lwsl_info("%s: closed: %s\n", __func__, lws_wsi_tag(wsi));
345*1c60b9acSAndroid Build Coastguard Worker 		break;
346*1c60b9acSAndroid Build Coastguard Worker 
347*1c60b9acSAndroid Build Coastguard Worker 	default:
348*1c60b9acSAndroid Build Coastguard Worker 		break;
349*1c60b9acSAndroid Build Coastguard Worker 	}
350*1c60b9acSAndroid Build Coastguard Worker 
351*1c60b9acSAndroid Build Coastguard Worker 	return lws_callback_http_dummy(wsi, reason, user, in, len);
352*1c60b9acSAndroid Build Coastguard Worker }
353*1c60b9acSAndroid Build Coastguard Worker 
354*1c60b9acSAndroid Build Coastguard Worker static const struct lws_protocols protocols[] = {
355*1c60b9acSAndroid Build Coastguard Worker 	{ "httptest", callback_http, 0, 0, 0, NULL, 0},
356*1c60b9acSAndroid Build Coastguard Worker 	LWS_PROTOCOL_LIST_TERM
357*1c60b9acSAndroid Build Coastguard Worker };
358*1c60b9acSAndroid Build Coastguard Worker 
359*1c60b9acSAndroid Build Coastguard Worker static int
do_client_conn(void)360*1c60b9acSAndroid Build Coastguard Worker do_client_conn(void)
361*1c60b9acSAndroid Build Coastguard Worker {
362*1c60b9acSAndroid Build Coastguard Worker 	struct lws_client_connect_info i;
363*1c60b9acSAndroid Build Coastguard Worker 
364*1c60b9acSAndroid Build Coastguard Worker 	memset(&i, 0, sizeof i); /* otherwise uninitialized garbage */
365*1c60b9acSAndroid Build Coastguard Worker 
366*1c60b9acSAndroid Build Coastguard Worker 	i.context		= context;
367*1c60b9acSAndroid Build Coastguard Worker 
368*1c60b9acSAndroid Build Coastguard Worker 	i.ssl_connection	= LCCSCF_USE_SSL;
369*1c60b9acSAndroid Build Coastguard Worker 	i.port			= 443;
370*1c60b9acSAndroid Build Coastguard Worker 	i.address		= "warmcat.com";
371*1c60b9acSAndroid Build Coastguard Worker 
372*1c60b9acSAndroid Build Coastguard Worker 	i.ssl_connection	|= LCCSCF_H2_QUIRK_OVERFLOWS_TXCR |
373*1c60b9acSAndroid Build Coastguard Worker 				   LCCSCF_H2_QUIRK_NGHTTP2_END_STREAM;
374*1c60b9acSAndroid Build Coastguard Worker 	i.path			= "/";
375*1c60b9acSAndroid Build Coastguard Worker 	i.host			= i.address;
376*1c60b9acSAndroid Build Coastguard Worker 	i.origin		= i.address;
377*1c60b9acSAndroid Build Coastguard Worker 	i.method		= "GET";
378*1c60b9acSAndroid Build Coastguard Worker 	i.protocol	= protocols[0].name;
379*1c60b9acSAndroid Build Coastguard Worker #if defined(LWS_WITH_SYS_FAULT_INJECTION)
380*1c60b9acSAndroid Build Coastguard Worker 	i.fi_wsi_name		= "user";
381*1c60b9acSAndroid Build Coastguard Worker #endif
382*1c60b9acSAndroid Build Coastguard Worker 
383*1c60b9acSAndroid Build Coastguard Worker 	if (!lws_client_connect_via_info(&i)) {
384*1c60b9acSAndroid Build Coastguard Worker 		lwsl_err("Client creation failed\n");
385*1c60b9acSAndroid Build Coastguard Worker 
386*1c60b9acSAndroid Build Coastguard Worker 		return 1;
387*1c60b9acSAndroid Build Coastguard Worker 	}
388*1c60b9acSAndroid Build Coastguard Worker 
389*1c60b9acSAndroid Build Coastguard Worker 	lwsl_notice("Client creation OK\n");
390*1c60b9acSAndroid Build Coastguard Worker 
391*1c60b9acSAndroid Build Coastguard Worker 	return 0;
392*1c60b9acSAndroid Build Coastguard Worker }
393*1c60b9acSAndroid Build Coastguard Worker 
394*1c60b9acSAndroid Build Coastguard Worker /*
395*1c60b9acSAndroid Build Coastguard Worker  * End of client part
396*1c60b9acSAndroid Build Coastguard Worker  *
397*1c60b9acSAndroid Build Coastguard Worker  * Initialization part -->
398*1c60b9acSAndroid Build Coastguard Worker  */
399*1c60b9acSAndroid Build Coastguard Worker 
sigint_handler(int sig)400*1c60b9acSAndroid Build Coastguard Worker void sigint_handler(int sig)
401*1c60b9acSAndroid Build Coastguard Worker {
402*1c60b9acSAndroid Build Coastguard Worker 	interrupted = 1;
403*1c60b9acSAndroid Build Coastguard Worker }
404*1c60b9acSAndroid Build Coastguard Worker 
main(int argc,const char ** argv)405*1c60b9acSAndroid Build Coastguard Worker int main(int argc, const char **argv)
406*1c60b9acSAndroid Build Coastguard Worker {
407*1c60b9acSAndroid Build Coastguard Worker 	struct lws_context_creation_info info;
408*1c60b9acSAndroid Build Coastguard Worker 	const char *p;
409*1c60b9acSAndroid Build Coastguard Worker 	int logs = LLL_USER | LLL_ERR | LLL_WARN | LLL_NOTICE;
410*1c60b9acSAndroid Build Coastguard Worker 	void *foreign_loops[1];
411*1c60b9acSAndroid Build Coastguard Worker 
412*1c60b9acSAndroid Build Coastguard Worker 	signal(SIGINT, sigint_handler);
413*1c60b9acSAndroid Build Coastguard Worker 
414*1c60b9acSAndroid Build Coastguard Worker 	if ((p = lws_cmdline_option(argc, argv, "-d")))
415*1c60b9acSAndroid Build Coastguard Worker 		logs = atoi(p);
416*1c60b9acSAndroid Build Coastguard Worker 
417*1c60b9acSAndroid Build Coastguard Worker 	/*
418*1c60b9acSAndroid Build Coastguard Worker 	 * init the existing custom event loop here if anything to do, don't
419*1c60b9acSAndroid Build Coastguard Worker 	 * run it yet. In our example, no init required.
420*1c60b9acSAndroid Build Coastguard Worker 	 */
421*1c60b9acSAndroid Build Coastguard Worker 
422*1c60b9acSAndroid Build Coastguard Worker 	lws_set_log_level(logs, NULL);
423*1c60b9acSAndroid Build Coastguard Worker 	lwsl_user("LWS minimal http server | visit http://localhost:7681\n");
424*1c60b9acSAndroid Build Coastguard Worker 
425*1c60b9acSAndroid Build Coastguard Worker 	memset(&info, 0, sizeof info); /* otherwise uninitialized garbage */
426*1c60b9acSAndroid Build Coastguard Worker 	info.port = 7681;
427*1c60b9acSAndroid Build Coastguard Worker 	info.mounts = &mount;
428*1c60b9acSAndroid Build Coastguard Worker 	info.error_document_404 = "/404.html";
429*1c60b9acSAndroid Build Coastguard Worker 	info.options = LWS_SERVER_OPTION_DO_SSL_GLOBAL_INIT |
430*1c60b9acSAndroid Build Coastguard Worker 		LWS_SERVER_OPTION_HTTP_HEADERS_SECURITY_BEST_PRACTICES_ENFORCE;
431*1c60b9acSAndroid Build Coastguard Worker 
432*1c60b9acSAndroid Build Coastguard Worker 	info.event_lib_custom = &evlib_custom; /* bind lws to our custom event
433*1c60b9acSAndroid Build Coastguard Worker 						* lib implementation above */
434*1c60b9acSAndroid Build Coastguard Worker 	foreign_loops[0] = &a_cpcx; /* pass in the custom poll object as the
435*1c60b9acSAndroid Build Coastguard Worker 				     * foreign loop object we will bind to */
436*1c60b9acSAndroid Build Coastguard Worker 	info.foreign_loops = foreign_loops;
437*1c60b9acSAndroid Build Coastguard Worker 
438*1c60b9acSAndroid Build Coastguard Worker 	/* optional to demonstrate client connection */
439*1c60b9acSAndroid Build Coastguard Worker 	info.protocols = protocols;
440*1c60b9acSAndroid Build Coastguard Worker 
441*1c60b9acSAndroid Build Coastguard Worker 	context = lws_create_context(&info);
442*1c60b9acSAndroid Build Coastguard Worker 	if (!context) {
443*1c60b9acSAndroid Build Coastguard Worker 		lwsl_err("lws init failed\n");
444*1c60b9acSAndroid Build Coastguard Worker 		return 1;
445*1c60b9acSAndroid Build Coastguard Worker 	}
446*1c60b9acSAndroid Build Coastguard Worker 
447*1c60b9acSAndroid Build Coastguard Worker 	/* optional to demonstrate client connection */
448*1c60b9acSAndroid Build Coastguard Worker 	do_client_conn();
449*1c60b9acSAndroid Build Coastguard Worker 
450*1c60b9acSAndroid Build Coastguard Worker 	/*
451*1c60b9acSAndroid Build Coastguard Worker 	 * We're going to run the custom loop now, instead of the lws loop.
452*1c60b9acSAndroid Build Coastguard Worker 	 * We have told lws to cooperate with this loop to get stuff done.
453*1c60b9acSAndroid Build Coastguard Worker 	 *
454*1c60b9acSAndroid Build Coastguard Worker 	 * We only come back from this when interrupted gets set by SIGINT
455*1c60b9acSAndroid Build Coastguard Worker 	 */
456*1c60b9acSAndroid Build Coastguard Worker 
457*1c60b9acSAndroid Build Coastguard Worker 	custom_poll_run(&a_cpcx);
458*1c60b9acSAndroid Build Coastguard Worker 
459*1c60b9acSAndroid Build Coastguard Worker 	/* clean up lws part */
460*1c60b9acSAndroid Build Coastguard Worker 
461*1c60b9acSAndroid Build Coastguard Worker 	lws_context_destroy(context);
462*1c60b9acSAndroid Build Coastguard Worker 
463*1c60b9acSAndroid Build Coastguard Worker 	return 0;
464*1c60b9acSAndroid Build Coastguard Worker }
465