2 * libwebsockets - small server side websockets and web server implementation
4 * Copyright (C) 2010 - 2013 Andy Green <andy@warmcat.com>
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation:
9 * version 2.1 of the License.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
22 /* System introspection configs */
24 #include "lws_config.h"
26 #if defined(WIN32) || defined(_WIN32)
27 #define inline __inline
31 #endif /* not WIN32 */
32 #endif /* not CMAKE */
34 #ifdef HAVE_SYS_TYPES_H
35 #include <sys/types.h>
46 #ifdef HAVE_SYS_STAT_H
50 #if defined(WIN32) || defined(_WIN32)
51 #define LWS_NO_DAEMONIZE
52 #define LWS_ERRNO WSAGetLastError()
53 #define LWS_EAGAIN WSAEWOULDBLOCK
54 #define LWS_EALREADY WSAEALREADY
55 #define LWS_EINPROGRESS WSAEINPROGRESS
56 #define LWS_EINTR WSAEINTR
57 #define LWS_EISCONN WSAEISCONN
58 #define LWS_EWOULDBLOCK WSAEWOULDBLOCK
59 #define LWS_POLLHUP (FD_CLOSE)
60 #define LWS_POLLIN (FD_READ | FD_ACCEPT)
61 #define LWS_POLLOUT (FD_WRITE)
62 #define MSG_NOSIGNAL 0
63 #define SHUT_RDWR SD_BOTH
64 #define SOL_TCP IPPROTO_TCP
66 #define compatible_close(fd) closesocket(fd)
67 #define compatible_file_close(fd) CloseHandle(fd)
68 #define compatible_file_seek_cur(fd, offset) SetFilePointer(fd, offset, NULL, FILE_CURRENT)
69 #define compatible_file_read(amount, fd, buf, len) {\
71 if (!ReadFile(fd, buf, len, &_amount, NULL)) \
76 #define lws_set_blocking_send(wsi) wsi->sock_send_blocking = TRUE
86 #define __func__ __FUNCTION__
90 #define vsnprintf _vsnprintf
93 #define LWS_INVALID_FILE INVALID_HANDLE_VALUE
94 #else /* not windows --> */
101 #include <sys/types.h>
102 #include <sys/socket.h>
103 #ifdef LWS_BUILTIN_GETIFADDRS
104 #include <getifaddrs.h>
108 #if defined (__ANDROID__)
111 #include <sys/syslog.h>
114 #include <sys/socket.h>
117 #ifdef HAVE_SYS_PRCTL_H
118 #include <sys/prctl.h>
121 #include <netinet/in.h>
122 #include <netinet/tcp.h>
123 #include <arpa/inet.h>
127 #endif /* LWS_USE_LIBEV */
129 #include <sys/mman.h>
130 #include <sys/time.h>
132 #define LWS_ERRNO errno
133 #define LWS_EAGAIN EAGAIN
134 #define LWS_EALREADY EALREADY
135 #define LWS_EINPROGRESS EINPROGRESS
136 #define LWS_EINTR EINTR
137 #define LWS_EISCONN EISCONN
138 #define LWS_EWOULDBLOCK EWOULDBLOCK
139 #define LWS_INVALID_FILE -1
140 #define LWS_POLLHUP (POLLHUP|POLLERR)
141 #define LWS_POLLIN (POLLIN)
142 #define LWS_POLLOUT (POLLOUT)
143 #define compatible_close(fd) close(fd)
144 #define compatible_file_close(fd) close(fd)
145 #define compatible_file_seek_cur(fd, offset) lseek(fd, offset, SEEK_CUR)
146 #define compatible_file_read(amount, fd, buf, len) \
147 amount = read(fd, buf, len);
148 #define lws_set_blocking_send(wsi)
152 #define bzero(b, len) (memset((b), '\0', (len)), (void) 0)
155 #ifndef HAVE_STRERROR
156 #define strerror(x) ""
159 #ifdef LWS_OPENSSL_SUPPORT
161 #include <cyassl/openssl/ssl.h>
162 #include <cyassl/error-ssl.h>
164 #include <openssl/ssl.h>
165 #include <openssl/evp.h>
166 #include <openssl/err.h>
167 #include <openssl/md5.h>
168 #include <openssl/sha.h>
169 #endif /* not USE_CYASSL */
172 #include "libwebsockets.h"
174 #if defined(WIN32) || defined(_WIN32)
177 #define BIG_ENDIAN 4321 /* to show byte order (taken from gcc) */
179 #ifndef LITTLE_ENDIAN
180 #define LITTLE_ENDIAN 1234
183 #define BYTE_ORDER LITTLE_ENDIAN
185 typedef unsigned __int64 u_int64_t;
190 #define __P(protos) protos
192 #define __P(protos) ()
198 #include <sys/stat.h>
199 #include <sys/cdefs.h>
200 #include <sys/time.h>
202 #if defined(__APPLE__)
203 #include <machine/endian.h>
204 #elif defined(__FreeBSD__)
205 #include <sys/endian.h>
206 #elif defined(__linux__)
211 #include <gulliver.h>
212 #if defined(__LITTLEENDIAN__)
213 #define BYTE_ORDER __LITTLEENDIAN__
214 #define LITTLE_ENDIAN __LITTLEENDIAN__
215 #define BIG_ENDIAN 4321 /* to show byte order (taken from gcc); for suppres warning that BIG_ENDIAN is not defined. */
217 #if defined(__BIGENDIAN__)
218 #define BYTE_ORDER __BIGENDIAN__
219 #define LITTLE_ENDIAN 1234 /* to show byte order (taken from gcc); for suppres warning that LITTLE_ENDIAN is not defined. */
220 #define BIG_ENDIAN __BIGENDIAN__
224 #if !defined(BYTE_ORDER)
225 # define BYTE_ORDER __BYTE_ORDER
227 #if !defined(LITTLE_ENDIAN)
228 # define LITTLE_ENDIAN __LITTLE_ENDIAN
230 #if !defined(BIG_ENDIAN)
231 # define BIG_ENDIAN __BIG_ENDIAN
237 * Mac OSX as well as iOS do not define the MSG_NOSIGNAL flag,
238 * but happily have something equivalent in the SO_NOSIGPIPE flag.
241 #define MSG_NOSIGNAL SO_NOSIGPIPE
244 #ifndef LWS_MAX_HEADER_LEN
245 #define LWS_MAX_HEADER_LEN 1024
247 #ifndef LWS_MAX_PROTOCOLS
248 #define LWS_MAX_PROTOCOLS 5
250 #ifndef LWS_MAX_EXTENSIONS_ACTIVE
251 #define LWS_MAX_EXTENSIONS_ACTIVE 3
253 #ifndef SPEC_LATEST_SUPPORTED
254 #define SPEC_LATEST_SUPPORTED 13
256 #ifndef AWAITING_TIMEOUT
257 #define AWAITING_TIMEOUT 5
259 #ifndef CIPHERS_LIST_STRING
260 #define CIPHERS_LIST_STRING "DEFAULT"
262 #ifndef LWS_SOMAXCONN
263 #define LWS_SOMAXCONN SOMAXCONN
266 #define MAX_WEBSOCKET_04_KEY_LEN 128
267 #define LWS_MAX_SOCKET_IO_BUF 4096
269 #ifndef SYSTEM_RANDOM_FILEPATH
270 #define SYSTEM_RANDOM_FILEPATH "/dev/urandom"
272 #ifndef LWS_MAX_ZLIB_CONN_BUFFER
273 #define LWS_MAX_ZLIB_CONN_BUFFER (64 * 1024)
277 * if not in a connection storm, check for incoming
278 * connections this many normal connection services
280 #define LWS_LISTEN_SERVICE_MODULO 10
282 enum lws_websocket_opcodes_07 {
283 LWS_WS_OPCODE_07__CONTINUATION = 0,
284 LWS_WS_OPCODE_07__TEXT_FRAME = 1,
285 LWS_WS_OPCODE_07__BINARY_FRAME = 2,
287 LWS_WS_OPCODE_07__NOSPEC__MUX = 7,
289 /* control extensions 8+ */
291 LWS_WS_OPCODE_07__CLOSE = 8,
292 LWS_WS_OPCODE_07__PING = 9,
293 LWS_WS_OPCODE_07__PONG = 0xa,
297 enum lws_connection_states {
299 WSI_STATE_HTTP_ISSUING_FILE,
300 WSI_STATE_HTTP_HEADERS,
302 WSI_STATE_DEAD_SOCKET,
303 WSI_STATE_ESTABLISHED,
304 WSI_STATE_CLIENT_UNCONNECTED,
305 WSI_STATE_RETURNED_CLOSE_ALREADY,
306 WSI_STATE_AWAITING_CLOSE_ACK,
307 WSI_STATE_FLUSHING_STORED_SEND_BEFORE_CLOSE,
309 WSI_STATE_HTTP2_AWAIT_CLIENT_PREFACE,
310 WSI_STATE_HTTP2_ESTABLISHED_PRE_SETTINGS,
311 WSI_STATE_HTTP2_ESTABLISHED,
319 enum http_connection_type {
320 HTTP_CONNECTION_CLOSE,
321 HTTP_CONNECTION_KEEP_ALIVE
324 enum lws_pending_protocol_send {
326 LWS_PPS_HTTP2_MY_SETTINGS,
327 LWS_PPS_HTTP2_ACK_SETTINGS,
330 enum lws_rx_parse_state {
333 LWS_RXPS_04_MASK_NONCE_1,
334 LWS_RXPS_04_MASK_NONCE_2,
335 LWS_RXPS_04_MASK_NONCE_3,
337 LWS_RXPS_04_FRAME_HDR_1,
338 LWS_RXPS_04_FRAME_HDR_LEN,
339 LWS_RXPS_04_FRAME_HDR_LEN16_2,
340 LWS_RXPS_04_FRAME_HDR_LEN16_1,
341 LWS_RXPS_04_FRAME_HDR_LEN64_8,
342 LWS_RXPS_04_FRAME_HDR_LEN64_7,
343 LWS_RXPS_04_FRAME_HDR_LEN64_6,
344 LWS_RXPS_04_FRAME_HDR_LEN64_5,
345 LWS_RXPS_04_FRAME_HDR_LEN64_4,
346 LWS_RXPS_04_FRAME_HDR_LEN64_3,
347 LWS_RXPS_04_FRAME_HDR_LEN64_2,
348 LWS_RXPS_04_FRAME_HDR_LEN64_1,
350 LWS_RXPS_07_COLLECT_FRAME_KEY_1,
351 LWS_RXPS_07_COLLECT_FRAME_KEY_2,
352 LWS_RXPS_07_COLLECT_FRAME_KEY_3,
353 LWS_RXPS_07_COLLECT_FRAME_KEY_4,
355 LWS_RXPS_PAYLOAD_UNTIL_LENGTH_EXHAUSTED
359 enum connection_mode {
360 LWS_CONNMODE_HTTP_SERVING,
361 LWS_CONNMODE_HTTP_SERVING_ACCEPTED, /* actual HTTP service going on */
362 LWS_CONNMODE_PRE_WS_SERVING_ACCEPT,
364 LWS_CONNMODE_WS_SERVING,
365 LWS_CONNMODE_WS_CLIENT,
367 LWS_CONNMODE_HTTP2_SERVING,
369 /* transient, ssl delay hiding */
370 LWS_CONNMODE_SSL_ACK_PENDING,
372 /* transient modes */
373 LWS_CONNMODE_WS_CLIENT_WAITING_CONNECT,
374 LWS_CONNMODE_WS_CLIENT_WAITING_PROXY_REPLY,
375 LWS_CONNMODE_WS_CLIENT_ISSUE_HANDSHAKE,
376 LWS_CONNMODE_WS_CLIENT_ISSUE_HANDSHAKE2,
377 LWS_CONNMODE_WS_CLIENT_WAITING_SSL,
378 LWS_CONNMODE_WS_CLIENT_WAITING_SERVER_REPLY,
379 LWS_CONNMODE_WS_CLIENT_WAITING_EXTENSION_CONNECT,
380 LWS_CONNMODE_WS_CLIENT_PENDING_CANDIDATE_CHILD,
382 /* special internal types */
383 LWS_CONNMODE_SERVER_LISTENER,
387 LWS_RXFLOW_ALLOW = (1 << 0),
388 LWS_RXFLOW_PENDING_CHANGE = (1 << 1),
391 struct libwebsocket_protocols;
395 struct lws_io_watcher {
396 struct ev_io watcher;
397 struct libwebsocket_context* context;
400 struct lws_signal_watcher {
401 struct ev_signal watcher;
402 struct libwebsocket_context* context;
404 #endif /* LWS_USE_LIBEV */
406 struct libwebsocket_context {
410 struct libwebsocket_pollfd *fds;
411 struct libwebsocket **lws_lookup; /* fd to wsi */
414 struct ev_loop* io_loop;
415 struct lws_io_watcher w_accept;
416 struct lws_signal_watcher w_sigint;
417 #endif /* LWS_USE_LIBEV */
421 char http_proxy_address[128];
422 char canonical_hostname[128];
423 unsigned int http_proxy_port;
424 unsigned int options;
425 time_t last_timeout_check_s;
428 * usable by anything in the service code, but only if the scope
429 * does not last longer than the service action (since next service
430 * of any socket can likewise use it and overwrite)
432 unsigned char service_buffer[LWS_MAX_SOCKET_IO_BUF];
434 int started_with_parent;
437 int listen_service_modulo;
438 int listen_service_count;
439 int listen_service_fd;
440 int listen_service_extraseen;
443 * set to the Thread ID that's doing the service loop just before entry
444 * to poll indicates service thread likely idling in poll()
445 * volatile because other threads may check it as part of processing
446 * for pollfd event change.
448 volatile int service_tid;
450 int dummy_pipe_fds[2];
458 unsigned long worst_latency;
459 char worst_latency_info[256];
462 #ifdef LWS_OPENSSL_SUPPORT
464 int allow_non_ssl_on_ssl_port;
465 unsigned int user_supplied_ssl_ctx:1;
467 SSL_CTX *ssl_client_ctx;
468 unsigned int ssl_flag_buffered_reads:1;
470 struct libwebsocket_protocols *protocols;
472 #ifndef LWS_NO_EXTENSIONS
473 struct libwebsocket_extension *extensions;
475 struct lws_token_limits *token_limits;
480 LWS_EV_READ = (1 << 0),
481 LWS_EV_WRITE = (1 << 1),
482 LWS_EV_START = (1 << 2),
483 LWS_EV_STOP = (1 << 3),
487 #define LWS_LIBEV_ENABLED(context) (context->options & LWS_SERVER_OPTION_LIBEV)
488 LWS_EXTERN void lws_feature_status_libev(struct lws_context_creation_info *info);
490 lws_libev_accept(struct libwebsocket_context *context,
491 struct libwebsocket *new_wsi, int accept_fd);
493 lws_libev_io(struct libwebsocket_context *context,
494 struct libwebsocket *wsi, int flags);
496 lws_libev_init_fd_table(struct libwebsocket_context *context);
498 lws_libev_run(struct libwebsocket_context *context);
500 #define LWS_LIBEV_ENABLED(context) (0)
501 #define lws_feature_status_libev(_a) \
502 lwsl_notice("libev support not compiled in\n")
503 #define lws_libev_accept(_a, _b, _c) ((void) 0)
504 #define lws_libev_io(_a, _b, _c) ((void) 0)
505 #define lws_libev_init_fd_table(_a) (0)
506 #define lws_libev_run(_a) ((void) 0)
510 #define LWS_IPV6_ENABLED(context) (!(context->options & LWS_SERVER_OPTION_DISABLE_IPV6))
512 #define LWS_IPV6_ENABLED(context) (0)
515 enum uri_path_states {
518 URIPS_SEEN_SLASH_DOT,
519 URIPS_SEEN_SLASH_DOT_DOT,
523 enum uri_esc_states {
526 URIES_SEEN_PERCENT_H1,
530 * This is totally opaque to code using the library. It's exported as a
531 * forward-reference pointer-only declaration; the user can use the pointer with
532 * other APIs to get information out of it.
535 struct lws_fragments {
536 unsigned short offset;
538 unsigned char next_frag_index;
541 /* notice that these union members:
547 * all have a pointer to allocated_headers struct as their first member.
549 * It means for allocated_headers access, the three union paths can all be
550 * used interchangably to access the same data
553 struct allocated_headers {
554 unsigned short next_frag_index;
556 unsigned char frag_index[WSI_TOKEN_COUNT];
557 struct lws_fragments frags[WSI_TOKEN_COUNT * 2];
558 char data[LWS_MAX_HEADER_LEN];
559 #ifndef LWS_NO_CLIENT
560 char initial_handshake_hash_base64[30];
561 unsigned short c_port;
565 struct _lws_http_mode_related {
566 /* MUST be first in struct */
567 struct allocated_headers *ah; /* mirroring _lws_header_related */
568 #if defined(WIN32) || defined(_WIN32)
573 unsigned long filepos;
574 unsigned long filelen;
576 enum http_version request_version;
577 enum http_connection_type connection_type;
585 enum lws_http2_settings {
586 LWS_HTTP2_SETTINGS__HEADER_TABLE_SIZE = 1,
587 LWS_HTTP2_SETTINGS__ENABLE_PUSH,
588 LWS_HTTP2_SETTINGS__MAX_CONCURRENT_STREAMS,
589 LWS_HTTP2_SETTINGS__INITIAL_WINDOW_SIZE,
590 LWS_HTTP2_SETTINGS__MAX_FRAME_SIZE,
591 LWS_HTTP2_SETTINGS__MAX_HEADER_LIST_SIZE,
593 LWS_HTTP2_SETTINGS__COUNT /* always last */
596 enum lws_http2_wellknown_frame_types {
597 LWS_HTTP2_FRAME_TYPE_DATA,
598 LWS_HTTP2_FRAME_TYPE_HEADERS,
599 LWS_HTTP2_FRAME_TYPE_PRIORITY,
600 LWS_HTTP2_FRAME_TYPE_RST_STREAM,
601 LWS_HTTP2_FRAME_TYPE_SETTINGS,
602 LWS_HTTP2_FRAME_TYPE_PUSH_PROMISE,
603 LWS_HTTP2_FRAME_TYPE_PING,
604 LWS_HTTP2_FRAME_TYPE_GOAWAY,
605 LWS_HTTP2_FRAME_TYPE_WINDOW_UPDATE,
606 LWS_HTTP2_FRAME_TYPE_CONTINUATION,
608 LWS_HTTP2_FRAME_TYPE_COUNT /* always last */
611 #define LWS_HTTP2_STREAM_ID_MASTER 0
612 #define LWS_HTTP2_FRAME_HEADER_LENGTH 9
613 #define LWS_HTTP2_SETTINGS_LENGTH 6
615 #define LWS_HTTP2_FLAGS__HEADER__END_HEADER 4
617 struct http2_settings {
618 unsigned int setting[LWS_HTTP2_SETTINGS__COUNT];
621 enum http2_hpack_state {
632 enum http2_hpack_type {
634 HPKT_INDEXED_HDR_6_VALUE_INCR,
635 HPKT_LITERAL_HDR_VALUE_INCR,
636 HPKT_INDEXED_HDR_4_VALUE,
637 HPKT_LITERAL_HDR_VALUE,
641 struct _lws_http2_related {
643 * having this first lets us also re-use all HTTP union code
644 * and in turn, http_mode_related has allocated headers in right
645 * place so we can use the header apis on the wsi directly still
647 struct _lws_http_mode_related http; /* MUST BE FIRST IN STRUCT */
649 struct http2_settings my_settings;
650 struct http2_settings peer_settings;
652 struct libwebsocket *parent_wsi;
653 struct libwebsocket *next_child_wsi;
659 unsigned int stream_id;
660 struct libwebsocket *stream_wsi;
663 unsigned char frame_state;
666 enum http2_hpack_state hpack;
667 enum http2_hpack_type hpack_type;
668 unsigned int header_index;
669 unsigned int hpack_len;
670 unsigned short hpack_pos;
671 unsigned char hpack_m;
673 unsigned int value:1;
675 unsigned int tx_credit;
676 unsigned int my_stream_id;
677 unsigned int child_count;
679 unsigned char initialized;
680 unsigned char one_setting[LWS_HTTP2_SETTINGS_LENGTH];
683 #define HTTP2_IS_TOPLEVEL_WSI(wsi) (!wsi->parent_wsi)
687 struct _lws_header_related {
688 /* MUST be first in struct */
689 struct allocated_headers *ah;
691 unsigned short current_token_limit;
692 unsigned char parser_state; /* enum lws_token_indexes */
693 enum uri_path_states ups;
694 enum uri_esc_states ues;
698 struct _lws_websocket_related {
699 char *rx_user_buffer;
700 int rx_user_buffer_head;
701 unsigned char frame_masking_nonce_04[4];
702 unsigned char frame_mask_index;
703 size_t rx_packet_length;
704 unsigned char opcode;
705 unsigned int final:1;
707 unsigned int frame_is_binary:1;
708 unsigned int all_zero_nonce:1;
709 short close_reason; /* enum lws_close_status */
711 unsigned int this_frame_masked:1;
712 unsigned int inside_frame:1; /* next write will be more of frame */
713 unsigned int clean_buffer:1; /* buffer not rewritten by extension */
715 unsigned char *ping_payload_buf; /* non-NULL if malloc'd */
716 unsigned int ping_payload_alloc; /* length malloc'd */
717 unsigned int ping_payload_len; /* nonzero if PONG pending */
720 struct libwebsocket {
722 /* lifetime members */
725 struct lws_io_watcher w_read;
726 struct lws_io_watcher w_write;
727 #endif /* LWS_USE_LIBEV */
728 const struct libwebsocket_protocols *protocol;
729 #ifndef LWS_NO_EXTENSIONS
730 struct libwebsocket_extension *
731 active_extensions[LWS_MAX_EXTENSIONS_ACTIVE];
732 void *active_extensions_user[LWS_MAX_EXTENSIONS_ACTIVE];
733 unsigned char count_active_extensions;
734 unsigned int extension_data_pending:1;
736 unsigned char ietf_spec_revision;
737 enum lws_pending_protocol_send pps;
739 char mode; /* enum connection_mode */
740 char state; /* enum lws_connection_states */
741 char lws_rx_parse_state; /* enum lws_rx_parse_state */
742 char rx_frame_type; /* enum libwebsocket_write_protocol */
744 unsigned int hdr_parsing_completed:1;
745 unsigned int user_space_externally_allocated:1;
746 unsigned int socket_is_permanently_unusable:1;
748 char pending_timeout; /* enum pending_timeout */
749 time_t pending_timeout_limit;
752 int position_in_fds_table;
754 unsigned long action_start;
755 unsigned long latency_start;
757 /* rxflow handling */
758 unsigned char *rxflow_buffer;
761 unsigned int rxflow_change_to:2;
763 /* truncated send handling */
764 unsigned char *truncated_send_malloc; /* non-NULL means buffering in progress */
765 unsigned int truncated_send_allocation; /* size of malloc */
766 unsigned int truncated_send_offset; /* where we are in terms of spilling */
767 unsigned int truncated_send_len; /* how much is buffered */
771 /* members with mutually exclusive lifetimes are unionized */
774 struct _lws_http_mode_related http;
776 struct _lws_http2_related http2;
778 struct _lws_header_related hdr;
779 struct _lws_websocket_related ws;
782 #ifdef LWS_OPENSSL_SUPPORT
785 unsigned int use_ssl:2;
786 unsigned int buffered_reads_pending:1;
790 BOOL sock_send_blocking;
794 LWS_EXTERN int log_level;
797 libwebsocket_close_and_free_session(struct libwebsocket_context *context,
798 struct libwebsocket *wsi, enum lws_close_status);
801 remove_wsi_socket_from_fds(struct libwebsocket_context *context,
802 struct libwebsocket *wsi);
804 lws_rxflow_cache(struct libwebsocket *wsi, unsigned char *buf, int n, int len);
807 static inline void lws_latency(struct libwebsocket_context *context,
808 struct libwebsocket *wsi, const char *action,
809 int ret, int completion) { while (0); }
810 static inline void lws_latency_pre(struct libwebsocket_context *context,
811 struct libwebsocket *wsi) { while (0); }
813 #define lws_latency_pre(_context, _wsi) lws_latency(_context, _wsi, NULL, 0, 0)
815 lws_latency(struct libwebsocket_context *context,
816 struct libwebsocket *wsi, const char *action,
817 int ret, int completion);
820 LWS_EXTERN void lws_set_protocol_write_pending(struct libwebsocket_context *context,
821 struct libwebsocket *wsi,
822 enum lws_pending_protocol_send pend);
824 libwebsocket_client_rx_sm(struct libwebsocket *wsi, unsigned char c);
827 libwebsocket_parse(struct libwebsocket_context *context,
828 struct libwebsocket *wsi, unsigned char c);
831 lws_http_action(struct libwebsocket_context *context, struct libwebsocket *wsi);
834 lws_b64_selftest(void);
836 LWS_EXTERN struct libwebsocket *
837 wsi_from_fd(struct libwebsocket_context *context, int fd);
840 insert_wsi_socket_into_fds(struct libwebsocket_context *context,
841 struct libwebsocket *wsi);
844 lws_issue_raw(struct libwebsocket *wsi, unsigned char *buf, size_t len);
848 libwebsocket_service_timeout_check(struct libwebsocket_context *context,
849 struct libwebsocket *wsi, unsigned int sec);
851 LWS_EXTERN struct libwebsocket *
852 libwebsocket_client_connect_2(struct libwebsocket_context *context,
853 struct libwebsocket *wsi);
855 LWS_EXTERN struct libwebsocket *
856 libwebsocket_create_new_server_wsi(struct libwebsocket_context *context);
859 libwebsockets_generate_client_handshake(struct libwebsocket_context *context,
860 struct libwebsocket *wsi, char *pkt);
863 lws_handle_POLLOUT_event(struct libwebsocket_context *context,
864 struct libwebsocket *wsi, struct libwebsocket_pollfd *pollfd);
869 #ifndef LWS_NO_EXTENSIONS
871 lws_context_init_extensions(struct lws_context_creation_info *info,
872 struct libwebsocket_context *context);
874 lws_any_extension_handled(struct libwebsocket_context *context,
875 struct libwebsocket *wsi,
876 enum libwebsocket_extension_callback_reasons r,
877 void *v, size_t len);
880 lws_ext_callback_for_each_active(struct libwebsocket *wsi, int reason,
883 lws_ext_callback_for_each_extension_type(
884 struct libwebsocket_context *context, struct libwebsocket *wsi,
885 int reason, void *arg, int len);
887 #define lws_any_extension_handled(_a, _b, _c, _d, _e) (0)
888 #define lws_ext_callback_for_each_active(_a, _b, _c, _d) (0)
889 #define lws_ext_callback_for_each_extension_type(_a, _b, _c, _d, _e) (0)
890 #define lws_issue_raw_ext_access lws_issue_raw
891 #define lws_context_init_extensions(_a, _b)
895 lws_client_interpret_server_handshake(struct libwebsocket_context *context,
896 struct libwebsocket *wsi);
899 libwebsocket_rx_sm(struct libwebsocket *wsi, unsigned char c);
902 lws_issue_raw_ext_access(struct libwebsocket *wsi,
903 unsigned char *buf, size_t len);
906 _libwebsocket_rx_flow_control(struct libwebsocket *wsi);
909 user_callback_handle_rxflow(callback_function,
910 struct libwebsocket_context *context,
911 struct libwebsocket *wsi,
912 enum libwebsocket_callback_reasons reason, void *user,
913 void *in, size_t len);
916 lws_http2_interpret_settings_payload(struct http2_settings *settings, unsigned char *buf, int len);
917 LWS_EXTERN void lws_http2_init(struct http2_settings *settings);
919 lws_http2_parser(struct libwebsocket_context *context,
920 struct libwebsocket *wsi, unsigned char c);
921 LWS_EXTERN int lws_http2_do_pps_send(struct libwebsocket_context *context, struct libwebsocket *wsi);
922 LWS_EXTERN int lws_http2_frame_write(struct libwebsocket *wsi, int type, int flags, unsigned int sid, unsigned int len, unsigned char *buf);
923 LWS_EXTERN struct libwebsocket *
924 lws_http2_wsi_from_id(struct libwebsocket *wsi, unsigned int sid);
925 LWS_EXTERN int lws_hpack_interpret(struct libwebsocket_context *context,
926 struct libwebsocket *wsi,
929 lws_add_http2_header_by_name(struct libwebsocket_context *context,
930 struct libwebsocket *wsi,
931 const unsigned char *name,
932 const unsigned char *value,
937 lws_add_http2_header_by_token(struct libwebsocket_context *context,
938 struct libwebsocket *wsi,
939 enum lws_token_indexes token,
940 const unsigned char *value,
945 lws_add_http2_header_status(struct libwebsocket_context *context,
946 struct libwebsocket *wsi,
953 lws_plat_set_socket_options(struct libwebsocket_context *context, int fd);
956 lws_allocate_header_table(struct libwebsocket *wsi);
959 lws_hdr_simple_ptr(struct libwebsocket *wsi, enum lws_token_indexes h);
962 lws_hdr_simple_create(struct libwebsocket *wsi,
963 enum lws_token_indexes h, const char *s);
966 libwebsocket_ensure_user_space(struct libwebsocket *wsi);
969 lws_change_pollfd(struct libwebsocket *wsi, int _and, int _or);
971 #ifndef LWS_NO_SERVER
972 int lws_context_init_server(struct lws_context_creation_info *info,
973 struct libwebsocket_context *context);
974 LWS_EXTERN int handshake_0405(struct libwebsocket_context *context,
975 struct libwebsocket *wsi);
977 libwebsocket_interpret_incoming_packet(struct libwebsocket *wsi,
978 unsigned char *buf, size_t len);
980 lws_server_get_canonical_hostname(struct libwebsocket_context *context,
981 struct lws_context_creation_info *info);
983 #define lws_context_init_server(_a, _b) (0)
984 #define libwebsocket_interpret_incoming_packet(_a, _b, _c) (0)
985 #define lws_server_get_canonical_hostname(_a, _b)
988 #ifndef LWS_NO_DAEMONIZE
989 LWS_EXTERN int get_daemonize_pid();
991 #define get_daemonize_pid() (0)
994 LWS_EXTERN int interface_to_sa(struct libwebsocket_context *context,
995 const char *ifname, struct sockaddr_in *addr, size_t addrlen);
997 LWS_EXTERN void lwsl_emit_stderr(int level, const char *line);
1000 LWS_EXTERN HANDLE lws_plat_open_file(const char* filename, unsigned long* filelen);
1002 LWS_EXTERN int lws_plat_open_file(const char* filename, unsigned long* filelen);
1005 enum lws_ssl_capable_status {
1006 LWS_SSL_CAPABLE_ERROR = -1,
1007 LWS_SSL_CAPABLE_MORE_SERVICE = -2,
1010 #ifndef LWS_OPENSSL_SUPPORT
1011 #define LWS_SSL_ENABLED(context) (0)
1012 #define lws_context_init_server_ssl(_a, _b) (0)
1013 #define lws_ssl_destroy(_a)
1014 #define lws_context_init_http2_ssl(_a)
1015 #define lws_ssl_capable_read lws_ssl_capable_read_no_ssl
1016 #define lws_ssl_capable_write lws_ssl_capable_write_no_ssl
1017 #define lws_server_socket_service_ssl(_a, _b, _c, _d, _e) (0)
1018 #define lws_ssl_close(_a) (0)
1019 #define lws_ssl_context_destroy(_a)
1021 #define LWS_SSL_ENABLED(context) (context->use_ssl)
1022 LWS_EXTERN int openssl_websocket_private_data_index;
1024 lws_ssl_capable_read(struct libwebsocket_context *context,
1025 struct libwebsocket *wsi, unsigned char *buf, int len);
1028 lws_ssl_capable_write(struct libwebsocket *wsi, unsigned char *buf, int len);
1030 lws_server_socket_service_ssl(struct libwebsocket_context *context,
1031 struct libwebsocket **wsi, struct libwebsocket *new_wsi,
1032 int accept_fd, struct libwebsocket_pollfd *pollfd);
1034 lws_ssl_close(struct libwebsocket *wsi);
1036 lws_ssl_context_destroy(struct libwebsocket_context *context);
1037 #ifndef LWS_NO_SERVER
1039 lws_context_init_server_ssl(struct lws_context_creation_info *info,
1040 struct libwebsocket_context *context);
1042 #define lws_context_init_server_ssl(_a, _b) (0)
1045 lws_ssl_destroy(struct libwebsocket_context *context);
1049 #ifdef LWS_USE_HTTP2
1051 lws_context_init_http2_ssl(struct libwebsocket_context *context);
1053 #define lws_context_init_http2_ssl(_a)
1058 lws_ssl_capable_read_no_ssl(struct libwebsocket_context *context,
1059 struct libwebsocket *wsi, unsigned char *buf, int len);
1062 lws_ssl_capable_write_no_ssl(struct libwebsocket *wsi, unsigned char *buf, int len);
1064 #ifndef LWS_NO_CLIENT
1065 LWS_EXTERN int lws_client_socket_service(
1066 struct libwebsocket_context *context,
1067 struct libwebsocket *wsi, struct libwebsocket_pollfd *pollfd);
1068 #ifdef LWS_OPENSSL_SUPPORT
1069 LWS_EXTERN int lws_context_init_client_ssl(struct lws_context_creation_info *info,
1070 struct libwebsocket_context *context);
1072 #define lws_context_init_client_ssl(_a, _b) (0)
1074 LWS_EXTERN int lws_handshake_client(struct libwebsocket *wsi, unsigned char **buf, size_t len);
1076 libwebsockets_decode_ssl_error(void);
1078 #define lws_context_init_client_ssl(_a, _b) (0)
1079 #define lws_handshake_client(_a, _b, _c) (0)
1081 #ifndef LWS_NO_SERVER
1082 LWS_EXTERN int lws_server_socket_service(
1083 struct libwebsocket_context *context,
1084 struct libwebsocket *wsi, struct libwebsocket_pollfd *pollfd);
1085 LWS_EXTERN int _libwebsocket_rx_flow_control(struct libwebsocket *wsi);
1086 LWS_EXTERN int lws_handshake_server(struct libwebsocket_context *context,
1087 struct libwebsocket *wsi, unsigned char **buf, size_t len);
1089 #define lws_server_socket_service(_a, _b, _c) (0)
1090 #define _libwebsocket_rx_flow_control(_a) (0)
1091 #define lws_handshake_server(_a, _b, _c, _d) (0)
1098 lws_plat_delete_socket_from_fds(struct libwebsocket_context *context,
1099 struct libwebsocket *wsi, int m);
1101 lws_plat_insert_socket_into_fds(struct libwebsocket_context *context,
1102 struct libwebsocket *wsi);
1104 lws_plat_service_periodic(struct libwebsocket_context *context);
1107 lws_plat_change_pollfd(struct libwebsocket_context *context,
1108 struct libwebsocket *wsi, struct libwebsocket_pollfd *pfd);
1110 lws_plat_context_early_init(void);
1112 lws_plat_context_early_destroy(struct libwebsocket_context *context);
1114 lws_plat_context_late_destroy(struct libwebsocket_context *context);
1116 lws_poll_listen_fd(struct libwebsocket_pollfd *fd);
1118 lws_plat_service(struct libwebsocket_context *context, int timeout_ms);
1120 lws_plat_init_fd_tables(struct libwebsocket_context *context);
1122 lws_plat_drop_app_privileges(struct lws_context_creation_info *info);
1123 LWS_EXTERN unsigned long long
1124 time_in_microseconds(void);
1125 LWS_EXTERN const char *
1126 lws_plat_inet_ntop(int af, const void *src, char *dst, int cnt);