| /* |
| * lws-minimal-ws-server=threadpool |
| * |
| * Written in 2010-2019 by Andy Green <andy@warmcat.com> |
| * |
| * This file is made available under the Creative Commons CC0 1.0 |
| * Universal Public Domain Dedication. |
| * |
| * This demonstrates a minimal ws server that can cooperate with |
| * other threads cleanly. Two other threads are started, which fill |
| * a ringbuffer with strings at 10Hz. |
| * |
| * The actual work and thread spawning etc are done in the protocol |
| * implementation in protocol_lws_minimal.c. |
| * |
| * To keep it simple, it serves stuff in the subdirectory "./mount-origin" of |
| * the directory it was started in. |
| * You can change that by changing mount.origin. |
| */ |
| |
| #include <libwebsockets.h> |
| #include <string.h> |
| #include <signal.h> |
| #if defined(WIN32) |
| #define HAVE_STRUCT_TIMESPEC |
| #if defined(pid_t) |
| #undef pid_t |
| #endif |
| #endif |
| #include <pthread.h> |
| |
| #define LWS_PLUGIN_STATIC |
| #include "protocol_lws_minimal_threadpool.c" |
| |
| static struct lws_protocols protocols[] = { |
| { "http", lws_callback_http_dummy, 0, 0, 0, NULL, 0 }, |
| LWS_PLUGIN_PROTOCOL_MINIMAL, |
| LWS_PROTOCOL_LIST_TERM |
| }; |
| |
| static int interrupted; |
| |
| static const struct lws_http_mount mount = { |
| /* .mount_next */ NULL, /* linked-list "next" */ |
| /* .mountpoint */ "/", /* mountpoint URL */ |
| /* .origin */ "./mount-origin", /* serve from dir */ |
| /* .def */ "index.html", /* default filename */ |
| /* .protocol */ NULL, |
| /* .cgienv */ NULL, |
| /* .extra_mimetypes */ NULL, |
| /* .interpret */ NULL, |
| /* .cgi_timeout */ 0, |
| /* .cache_max_age */ 0, |
| /* .auth_mask */ 0, |
| /* .cache_reusable */ 0, |
| /* .cache_revalidate */ 0, |
| /* .cache_intermediaries */ 0, |
| /* .origin_protocol */ LWSMPRO_FILE, /* files in a dir */ |
| /* .mountpoint_len */ 1, /* char count */ |
| /* .basic_auth_login_file */ NULL, |
| }; |
| |
| /* |
| * This demonstrates how to pass a pointer into a specific protocol handler |
| * running on a specific vhost. In this case, it's our default vhost and |
| * we pass the pvo named "config" with the value a const char * "myconfig". |
| * |
| * This is the preferred way to pass configuration into a specific vhost + |
| * protocol instance. |
| */ |
| |
| static const struct lws_protocol_vhost_options pvo_ops = { |
| NULL, |
| NULL, |
| "config", /* pvo name */ |
| (void *)"myconfig" /* pvo value */ |
| }; |
| |
| static const struct lws_protocol_vhost_options pvo = { |
| NULL, /* "next" pvo linked-list */ |
| &pvo_ops, /* "child" pvo linked-list */ |
| "lws-minimal", /* protocol name we belong to on this vhost */ |
| "" /* ignored */ |
| }; |
| |
| void sigint_handler(int sig) |
| { |
| interrupted = 1; |
| } |
| |
| int main(int argc, const char **argv) |
| { |
| struct lws_context_creation_info info; |
| struct lws_context *context; |
| const char *p; |
| int logs = LLL_USER | LLL_ERR | LLL_WARN | LLL_NOTICE |
| /* for LLL_ verbosity above NOTICE to be built into lws, |
| * lws must have been configured and built with |
| * -DCMAKE_BUILD_TYPE=DEBUG instead of =RELEASE */ |
| /* | LLL_INFO */ /* | LLL_PARSER */ /* | LLL_HEADER */ |
| /* | LLL_EXT */ /* | LLL_CLIENT */ /* | LLL_LATENCY */ |
| /* | LLL_DEBUG */; |
| |
| signal(SIGINT, sigint_handler); |
| |
| if ((p = lws_cmdline_option(argc, argv, "-d"))) |
| logs = atoi(p); |
| |
| lws_set_log_level(logs, NULL); |
| lwsl_user("LWS minimal ws server + threadpool | visit http://localhost:7681\n"); |
| |
| memset(&info, 0, sizeof info); /* otherwise uninitialized garbage */ |
| info.port = 7681; |
| info.mounts = &mount; |
| info.protocols = protocols; |
| info.pvo = &pvo; /* per-vhost options */ |
| info.options = |
| LWS_SERVER_OPTION_HTTP_HEADERS_SECURITY_BEST_PRACTICES_ENFORCE; |
| |
| context = lws_create_context(&info); |
| if (!context) { |
| lwsl_err("lws init failed\n"); |
| return 1; |
| } |
| |
| /* start the threads that create content */ |
| |
| while (!interrupted) |
| if (lws_service(context, 0)) |
| interrupted = 1; |
| |
| lws_context_destroy(context); |
| |
| lwsl_user("%s: exiting cleanly...\n", __func__); |
| |
| return 0; |
| } |