#ifdef CMAKE_BUILD
#include "lws_config.h"
#else
-#ifdef WIN32
+#if defined(WIN32) || defined(_WIN32)
#define inline __inline
-#else
+#else /* not WIN32 */
#include "config.h"
-#endif
-#endif
-#if _MSC_VER > 1000 || defined(_WIN32)
-#else
-#include <unistd.h>
-#include <strings.h>
+#endif /* not WIN32 */
+#endif /* not CMAKE */
+
+#ifdef HAVE_SYS_TYPES_H
+#include <sys/types.h>
#endif
+
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
+#include <time.h>
#include <ctype.h>
-#include <errno.h>
-#include <fcntl.h>
-#include <signal.h>
#include <limits.h>
-#ifdef __MINGW64__
-#else
-#ifdef __MINGW32__
-#elif _MSC_VER > 1000 || defined(_WIN32)
-#else
-#include <netdb.h>
-#endif
-#endif
#include <stdarg.h>
+#ifdef HAVE_SYS_STAT_H
#include <sys/stat.h>
+#endif
-#ifdef WIN32
+#if defined(WIN32) || defined(_WIN32)
#define LWS_NO_DAEMONIZE
-#ifndef EWOULDBLOCK
-#define EWOULDBLOCK EAGAIN
+#define LWS_ERRNO WSAGetLastError()
+#define LWS_EAGAIN WSAEWOULDBLOCK
+#define LWS_EALREADY WSAEALREADY
+#define LWS_EINPROGRESS WSAEINPROGRESS
+#define LWS_EINTR WSAEINTR
+#define LWS_EISCONN WSAEISCONN
+#define LWS_EWOULDBLOCK WSAEWOULDBLOCK
+#define LWS_POLLHUP (FD_CLOSE)
+#define LWS_POLLIN (FD_READ | FD_ACCEPT)
+#define LWS_POLLOUT (FD_WRITE)
+#define MSG_NOSIGNAL 0
+#define SHUT_RDWR SD_BOTH
+#define SOL_TCP IPPROTO_TCP
+
+#define compatible_close(fd) closesocket(fd)
+#define compatible_file_close(fd) CloseHandle(fd)
+#define compatible_file_seek_cur(fd, offset) SetFilePointer(fd, offset, NULL, FILE_CURRENT)
+#define compatible_file_read(amount, fd, buf, len) {\
+ DWORD _amount; \
+ if (!ReadFile(fd, buf, len, &_amount, NULL)) \
+ amount = -1; \
+ else \
+ amount = _amount; \
+ }
+#define lws_set_blocking_send(wsi) wsi->sock_send_blocking = TRUE
+#include <winsock2.h>
+#include <windows.h>
+#include <tchar.h>
+#ifdef HAVE_IN6ADDR_H
+#include <in6addr.h>
#endif
+#include <mstcpip.h>
-#define compatible_close(fd) closesocket(fd);
-#ifdef __MINGW64__
-#else
-#ifdef __MINGW32__
-#else
-#include <time.h >
+#ifndef __func__
+#define __func__ __FUNCTION__
#endif
+
+#ifdef _WIN32_WCE
+#define vsnprintf _vsnprintf
#endif
-#include <winsock2.h>
-#include <ws2ipdef.h>
-#include <windows.h>
-#else
+
+#define LWS_INVALID_FILE INVALID_HANDLE_VALUE
+#else /* not windows --> */
+#include <errno.h>
+#include <fcntl.h>
+#include <netdb.h>
+#include <signal.h>
+#include <strings.h>
+#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
+#ifdef LWS_BUILTIN_GETIFADDRS
+ #include <getifaddrs.h>
+#else
+ #include <ifaddrs.h>
+#endif
+#if defined (__ANDROID__)
+#include <syslog.h>
+#else
+#include <sys/syslog.h>
+#endif
+#include <sys/un.h>
+#include <sys/socket.h>
+#include <netdb.h>
#ifndef LWS_NO_FORK
#ifdef HAVE_SYS_PRCTL_H
#include <sys/prctl.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <arpa/inet.h>
-
#include <poll.h>
+#ifdef LWS_USE_LIBEV
+#include <ev.h>
+#endif /* LWS_USE_LIBEV */
+
#include <sys/mman.h>
#include <sys/time.h>
-#define compatible_close(fd) close(fd);
+#define LWS_ERRNO errno
+#define LWS_EAGAIN EAGAIN
+#define LWS_EALREADY EALREADY
+#define LWS_EINPROGRESS EINPROGRESS
+#define LWS_EINTR EINTR
+#define LWS_EISCONN EISCONN
+#define LWS_EWOULDBLOCK EWOULDBLOCK
+#define LWS_INVALID_FILE -1
+#define LWS_POLLHUP (POLLHUP|POLLERR)
+#define LWS_POLLIN (POLLIN)
+#define LWS_POLLOUT (POLLOUT)
+#define compatible_close(fd) close(fd)
+#define compatible_file_close(fd) close(fd)
+#define compatible_file_seek_cur(fd, offset) lseek(fd, offset, SEEK_CUR)
+#define compatible_file_read(amount, fd, buf, len) \
+ amount = read(fd, buf, len);
+#define lws_set_blocking_send(wsi)
+#endif
+
+#ifndef HAVE_BZERO
+#define bzero(b, len) (memset((b), '\0', (len)), (void) 0)
+#endif
+
+#ifndef HAVE_STRERROR
+#define strerror(x) ""
#endif
#ifdef LWS_OPENSSL_SUPPORT
#ifdef USE_CYASSL
#include <cyassl/openssl/ssl.h>
-#include <cyassl/error.h>
-unsigned char *
-SHA1(const unsigned char *d, size_t n, unsigned char *md);
+#include <cyassl/error-ssl.h>
#else
#include <openssl/ssl.h>
#include <openssl/evp.h>
#include "libwebsockets.h"
+#if defined(WIN32) || defined(_WIN32)
+
+#ifndef BIG_ENDIAN
+#define BIG_ENDIAN 4321 /* to show byte order (taken from gcc) */
+#endif
+#ifndef LITTLE_ENDIAN
+#define LITTLE_ENDIAN 1234
+#endif
+#ifndef BYTE_ORDER
+#define BYTE_ORDER LITTLE_ENDIAN
+#endif
+typedef unsigned __int64 u_int64_t;
+
+#undef __P
+#ifndef __P
+#if __STDC__
+#define __P(protos) protos
+#else
+#define __P(protos) ()
+#endif
+#endif
+
+#else
+
+#include <sys/stat.h>
+#include <sys/cdefs.h>
+#include <sys/time.h>
+
+#if defined(__APPLE__)
+#include <machine/endian.h>
+#elif defined(__FreeBSD__)
+#include <sys/endian.h>
+#elif defined(__linux__)
+#include <endian.h>
+#endif
+
+#if defined(__QNX__)
+ #include <gulliver.h>
+ #if defined(__LITTLEENDIAN__)
+ #define BYTE_ORDER __LITTLEENDIAN__
+ #define LITTLE_ENDIAN __LITTLEENDIAN__
+ #define BIG_ENDIAN 4321 /* to show byte order (taken from gcc); for suppres warning that BIG_ENDIAN is not defined. */
+ #endif
+ #if defined(__BIGENDIAN__)
+ #define BYTE_ORDER __BIGENDIAN__
+ #define LITTLE_ENDIAN 1234 /* to show byte order (taken from gcc); for suppres warning that LITTLE_ENDIAN is not defined. */
+ #define BIG_ENDIAN __BIGENDIAN__
+ #endif
+#endif
+
+#if !defined(BYTE_ORDER)
+# define BYTE_ORDER __BYTE_ORDER
+#endif
+#if !defined(LITTLE_ENDIAN)
+# define LITTLE_ENDIAN __LITTLE_ENDIAN
+#endif
+#if !defined(BIG_ENDIAN)
+# define BIG_ENDIAN __BIG_ENDIAN
+#endif
+
+#endif
+
/*
* Mac OSX as well as iOS do not define the MSG_NOSIGNAL flag,
* but happily have something equivalent in the SO_NOSIGPIPE flag.
WSI_STATE_HTTP,
WSI_STATE_HTTP_ISSUING_FILE,
WSI_STATE_HTTP_HEADERS,
+ WSI_STATE_HTTP_BODY,
WSI_STATE_DEAD_SOCKET,
WSI_STATE_ESTABLISHED,
WSI_STATE_CLIENT_UNCONNECTED,
WSI_STATE_RETURNED_CLOSE_ALREADY,
WSI_STATE_AWAITING_CLOSE_ACK,
+ WSI_STATE_FLUSHING_STORED_SEND_BEFORE_CLOSE,
+
+ WSI_STATE_HTTP2_AWAIT_CLIENT_PREFACE,
+ WSI_STATE_HTTP2_ESTABLISHED_PRE_SETTINGS,
+ WSI_STATE_HTTP2_ESTABLISHED,
+};
+
+enum http_version {
+ HTTP_VERSION_1_0,
+ HTTP_VERSION_1_1,
+};
+
+enum http_connection_type {
+ HTTP_CONNECTION_CLOSE,
+ HTTP_CONNECTION_KEEP_ALIVE
+};
+
+enum lws_pending_protocol_send {
+ LWS_PPS_NONE,
+ LWS_PPS_HTTP2_MY_SETTINGS,
+ LWS_PPS_HTTP2_ACK_SETTINGS,
};
enum lws_rx_parse_state {
LWS_CONNMODE_WS_SERVING,
LWS_CONNMODE_WS_CLIENT,
+
+ LWS_CONNMODE_HTTP2_SERVING,
/* transient, ssl delay hiding */
LWS_CONNMODE_SSL_ACK_PENDING,
LWS_CONNMODE_WS_CLIENT_WAITING_CONNECT,
LWS_CONNMODE_WS_CLIENT_WAITING_PROXY_REPLY,
LWS_CONNMODE_WS_CLIENT_ISSUE_HANDSHAKE,
+ LWS_CONNMODE_WS_CLIENT_ISSUE_HANDSHAKE2,
+ LWS_CONNMODE_WS_CLIENT_WAITING_SSL,
LWS_CONNMODE_WS_CLIENT_WAITING_SERVER_REPLY,
LWS_CONNMODE_WS_CLIENT_WAITING_EXTENSION_CONNECT,
LWS_CONNMODE_WS_CLIENT_PENDING_CANDIDATE_CHILD,
struct libwebsocket_protocols;
struct libwebsocket;
+#ifdef LWS_USE_LIBEV
+struct lws_io_watcher {
+ struct ev_io watcher;
+ struct libwebsocket_context* context;
+};
+
+struct lws_signal_watcher {
+ struct ev_signal watcher;
+ struct libwebsocket_context* context;
+};
+#endif /* LWS_USE_LIBEV */
+
struct libwebsocket_context {
- struct pollfd *fds;
+#ifdef _WIN32
+ WSAEVENT *events;
+#endif
+ struct libwebsocket_pollfd *fds;
struct libwebsocket **lws_lookup; /* fd to wsi */
int fds_count;
+#ifdef LWS_USE_LIBEV
+ struct ev_loop* io_loop;
+ struct lws_io_watcher w_accept;
+ struct lws_signal_watcher w_sigint;
+#endif /* LWS_USE_LIBEV */
int max_fds;
int listen_port;
+ const char *iface;
char http_proxy_address[128];
char canonical_hostname[128];
unsigned int http_proxy_port;
unsigned int options;
- unsigned long last_timeout_check_s;
+ time_t last_timeout_check_s;
/*
* usable by anything in the service code, but only if the scope
int listen_service_fd;
int listen_service_extraseen;
+ /*
+ * set to the Thread ID that's doing the service loop just before entry
+ * to poll indicates service thread likely idling in poll()
+ * volatile because other threads may check it as part of processing
+ * for pollfd event change.
+ */
+ volatile int service_tid;
+#ifndef _WIN32
+ int dummy_pipe_fds[2];
+#endif
+
int ka_time;
int ka_probes;
int ka_interval;
#ifdef LWS_OPENSSL_SUPPORT
int use_ssl;
+ int allow_non_ssl_on_ssl_port;
SSL_CTX *ssl_ctx;
SSL_CTX *ssl_client_ctx;
+ unsigned int ssl_flag_buffered_reads:1;
#endif
struct libwebsocket_protocols *protocols;
int count_protocols;
#ifndef LWS_NO_EXTENSIONS
struct libwebsocket_extension *extensions;
#endif
+ struct lws_token_limits *token_limits;
void *user_space;
};
+enum {
+ LWS_EV_READ = (1 << 0),
+ LWS_EV_WRITE = (1 << 1),
+ LWS_EV_START = (1 << 2),
+ LWS_EV_STOP = (1 << 3),
+};
+
+#ifdef LWS_USE_LIBEV
+#define LWS_LIBEV_ENABLED(context) (context->options & LWS_SERVER_OPTION_LIBEV)
+LWS_EXTERN void lws_feature_status_libev(struct lws_context_creation_info *info);
+LWS_EXTERN void
+lws_libev_accept(struct libwebsocket_context *context,
+ struct libwebsocket *new_wsi, int accept_fd);
+LWS_EXTERN void
+lws_libev_io(struct libwebsocket_context *context,
+ struct libwebsocket *wsi, int flags);
+LWS_EXTERN int
+lws_libev_init_fd_table(struct libwebsocket_context *context);
+LWS_EXTERN void
+lws_libev_run(struct libwebsocket_context *context);
+#else
+#define LWS_LIBEV_ENABLED(context) (0)
+#define lws_feature_status_libev(_a) \
+ lwsl_notice("libev support not compiled in\n")
+#define lws_libev_accept(_a, _b, _c) ((void) 0)
+#define lws_libev_io(_a, _b, _c) ((void) 0)
+#define lws_libev_init_fd_table(_a) (0)
+#define lws_libev_run(_a) ((void) 0)
+#endif
+
+#ifdef LWS_USE_IPV6
+#define LWS_IPV6_ENABLED(context) (!(context->options & LWS_SERVER_OPTION_DISABLE_IPV6))
+#else
+#define LWS_IPV6_ENABLED(context) (0)
+#endif
+
+enum uri_path_states {
+ URIPS_IDLE,
+ URIPS_SEEN_SLASH,
+ URIPS_SEEN_SLASH_DOT,
+ URIPS_SEEN_SLASH_DOT_DOT,
+ URIPS_ARGUMENTS,
+};
+
+enum uri_esc_states {
+ URIES_IDLE,
+ URIES_SEEN_PERCENT,
+ URIES_SEEN_PERCENT_H1,
+};
/*
* This is totally opaque to code using the library. It's exported as a
* other APIs to get information out of it.
*/
-struct _lws_http_mode_related {
- int fd;
- unsigned long filepos;
- unsigned long filelen;
-};
-
struct lws_fragments {
unsigned short offset;
unsigned short len;
unsigned char next_frag_index;
};
+/* notice that these union members:
+ *
+ * hdr
+ * http
+ * http2
+ *
+ * all have a pointer to allocated_headers struct as their first member.
+ *
+ * It means for allocated_headers access, the three union paths can all be
+ * used interchangably to access the same data
+ */
+
struct allocated_headers {
unsigned short next_frag_index;
unsigned short pos;
#endif
};
+struct _lws_http_mode_related {
+ /* MUST be first in struct */
+ struct allocated_headers *ah; /* mirroring _lws_header_related */
+#if defined(WIN32) || defined(_WIN32)
+ HANDLE fd;
+#else
+ int fd;
+#endif
+ unsigned long filepos;
+ unsigned long filelen;
+
+ enum http_version request_version;
+ enum http_connection_type connection_type;
+ int content_length;
+ int content_remain;
+};
+
+#ifdef LWS_USE_HTTP2
+
+enum lws_http2_settings {
+ LWS_HTTP2_SETTINGS__HEADER_TABLE_SIZE = 1,
+ LWS_HTTP2_SETTINGS__ENABLE_PUSH,
+ LWS_HTTP2_SETTINGS__MAX_CONCURRENT_STREAMS,
+ LWS_HTTP2_SETTINGS__INITIAL_WINDOW_SIZE,
+ LWS_HTTP2_SETTINGS__MAX_FRAME_SIZE,
+ LWS_HTTP2_SETTINGS__MAX_HEADER_LIST_SIZE,
+
+ LWS_HTTP2_SETTINGS__COUNT /* always last */
+};
+
+enum lws_http2_wellknown_frame_types {
+ LWS_HTTP2_FRAME_TYPE_DATA,
+ LWS_HTTP2_FRAME_TYPE_HEADERS,
+ LWS_HTTP2_FRAME_TYPE_PRIORITY,
+ LWS_HTTP2_FRAME_TYPE_RST_STREAM,
+ LWS_HTTP2_FRAME_TYPE_SETTINGS,
+ LWS_HTTP2_FRAME_TYPE_PUSH_PROMISE,
+ LWS_HTTP2_FRAME_TYPE_PING,
+ LWS_HTTP2_FRAME_TYPE_GOAWAY,
+ LWS_HTTP2_FRAME_TYPE_WINDOW_UPDATE,
+ LWS_HTTP2_FRAME_TYPE_CONTINUATION,
+
+ LWS_HTTP2_FRAME_TYPE_COUNT /* always last */
+};
+
+#define LWS_HTTP2_STREAM_ID_MASTER 0
+#define LWS_HTTP2_FRAME_HEADER_LENGTH 9
+#define LWS_HTTP2_SETTINGS_LENGTH 6
+
+struct http2_settings {
+ unsigned int setting[LWS_HTTP2_SETTINGS__COUNT];
+};
+
+struct _lws_http2_related {
+ /*
+ * having this first lets us also re-use all HTTP union code
+ * and in turn, http_mode_related has allocated headers in right
+ * place so we can use the header apis on the wsi directly still
+ */
+ struct _lws_http_mode_related http; /* MUST BE FIRST IN STRUCT */
+
+ struct http2_settings my_settings;
+ struct http2_settings peer_settings;
+
+ struct libwebsocket *parent_wsi;
+ struct libwebsocket *next_child_wsi;
+
+ unsigned int count;
+
+ /* frame */
+ unsigned int length;
+ unsigned int stream_id;
+ struct libwebsocket *stream_wsi;
+ unsigned char type;
+ unsigned char flags;
+ unsigned char frame_state;
+
+ unsigned int tx_credit;
+ unsigned int my_stream_id;
+ unsigned int child_count;
+ int my_priority;
+ unsigned char initialized;
+ unsigned char one_setting[LWS_HTTP2_SETTINGS_LENGTH];
+};
+
+#define HTTP2_IS_TOPLEVEL_WSI(wsi) (!wsi->parent_wsi)
+
+#endif
+
struct _lws_header_related {
+ /* MUST be first in struct */
struct allocated_headers *ah;
short lextable_pos;
+ unsigned short current_token_limit;
unsigned char parser_state; /* enum lws_token_indexes */
+ enum uri_path_states ups;
+ enum uri_esc_states ues;
+ char esc_stash;
};
struct _lws_websocket_related {
unsigned int frame_is_binary:1;
unsigned int all_zero_nonce:1;
short close_reason; /* enum lws_close_status */
- unsigned char *rxflow_buffer;
- int rxflow_len;
- int rxflow_pos;
- unsigned int rxflow_change_to:2;
+
unsigned int this_frame_masked:1;
+ unsigned int inside_frame:1; /* next write will be more of frame */
+ unsigned int clean_buffer:1; /* buffer not rewritten by extension */
+
+ unsigned char *ping_payload_buf; /* non-NULL if malloc'd */
+ unsigned int ping_payload_alloc; /* length malloc'd */
+ unsigned int ping_payload_len; /* nonzero if PONG pending */
};
struct libwebsocket {
/* lifetime members */
+#ifdef LWS_USE_LIBEV
+ struct lws_io_watcher w_read;
+ struct lws_io_watcher w_write;
+#endif /* LWS_USE_LIBEV */
const struct libwebsocket_protocols *protocol;
#ifndef LWS_NO_EXTENSIONS
struct libwebsocket_extension *
unsigned int extension_data_pending:1;
#endif
unsigned char ietf_spec_revision;
+ enum lws_pending_protocol_send pps;
char mode; /* enum connection_mode */
char state; /* enum lws_connection_states */
char rx_frame_type; /* enum libwebsocket_write_protocol */
unsigned int hdr_parsing_completed:1;
+ unsigned int user_space_externally_allocated:1;
char pending_timeout; /* enum pending_timeout */
- unsigned long pending_timeout_limit;
+ time_t pending_timeout_limit;
int sock;
int position_in_fds_table;
unsigned long action_start;
unsigned long latency_start;
#endif
+ /* rxflow handling */
+ unsigned char *rxflow_buffer;
+ int rxflow_len;
+ int rxflow_pos;
+ unsigned int rxflow_change_to:2;
+
+ /* truncated send handling */
+ unsigned char *truncated_send_malloc; /* non-NULL means buffering in progress */
+ unsigned int truncated_send_allocation; /* size of malloc */
+ unsigned int truncated_send_offset; /* where we are in terms of spilling */
+ unsigned int truncated_send_len; /* how much is buffered */
void *user_space;
union u {
struct _lws_http_mode_related http;
+#ifdef LWS_USE_HTTP2
+ struct _lws_http2_related http2;
+#endif
struct _lws_header_related hdr;
struct _lws_websocket_related ws;
} u;
SSL *ssl;
BIO *client_bio;
unsigned int use_ssl:2;
+ unsigned int buffered_reads_pending:1;
+#endif
+
+#ifdef _WIN32
+ BOOL sock_send_blocking;
#endif
};
+LWS_EXTERN int log_level;
+
LWS_EXTERN void
libwebsocket_close_and_free_session(struct libwebsocket_context *context,
struct libwebsocket *wsi, enum lws_close_status);
+LWS_EXTERN int
+remove_wsi_socket_from_fds(struct libwebsocket_context *context,
+ struct libwebsocket *wsi);
+LWS_EXTERN int
+lws_rxflow_cache(struct libwebsocket *wsi, unsigned char *buf, int n, int len);
+
#ifndef LWS_LATENCY
static inline void lws_latency(struct libwebsocket_context *context,
struct libwebsocket *wsi, const char *action,
int ret, int completion);
#endif
+LWS_EXTERN void lws_set_protocol_write_pending(struct libwebsocket_context *context,
+ struct libwebsocket *wsi,
+ enum lws_pending_protocol_send pend);
LWS_EXTERN int
libwebsocket_client_rx_sm(struct libwebsocket *wsi, unsigned char c);
LWS_EXTERN int
-libwebsocket_parse(struct libwebsocket *wsi, unsigned char c);
+libwebsocket_parse(struct libwebsocket_context *context,
+ struct libwebsocket *wsi, unsigned char c);
LWS_EXTERN int
-libwebsocket_interpret_incoming_packet(struct libwebsocket *wsi,
- unsigned char *buf, size_t len);
+lws_http_action(struct libwebsocket_context *context, struct libwebsocket *wsi);
LWS_EXTERN int
lws_b64_selftest(void);
struct libwebsocket *wsi, unsigned int sec);
LWS_EXTERN struct libwebsocket *
-__libwebsocket_client_connect_2(struct libwebsocket_context *context,
+libwebsocket_client_connect_2(struct libwebsocket_context *context,
struct libwebsocket *wsi);
LWS_EXTERN struct libwebsocket *
LWS_EXTERN int
lws_handle_POLLOUT_event(struct libwebsocket_context *context,
- struct libwebsocket *wsi, struct pollfd *pollfd);
+ struct libwebsocket *wsi, struct libwebsocket_pollfd *pollfd);
+/*
+ * EXTENSIONS
+ */
+
#ifndef LWS_NO_EXTENSIONS
+LWS_VISIBLE void
+lws_context_init_extensions(struct lws_context_creation_info *info,
+ struct libwebsocket_context *context);
LWS_EXTERN int
lws_any_extension_handled(struct libwebsocket_context *context,
struct libwebsocket *wsi,
enum libwebsocket_extension_callback_reasons r,
void *v, size_t len);
-LWS_EXTERN void *
-lws_get_extension_user_matching_ext(struct libwebsocket *wsi,
- struct libwebsocket_extension *ext);
+LWS_EXTERN int
+lws_ext_callback_for_each_active(struct libwebsocket *wsi, int reason,
+ void *buf, int len);
+LWS_EXTERN int
+lws_ext_callback_for_each_extension_type(
+ struct libwebsocket_context *context, struct libwebsocket *wsi,
+ int reason, void *arg, int len);
+#else
+#define lws_any_extension_handled(_a, _b, _c, _d, _e) (0)
+#define lws_ext_callback_for_each_active(_a, _b, _c, _d) (0)
+#define lws_ext_callback_for_each_extension_type(_a, _b, _c, _d, _e) (0)
+#define lws_issue_raw_ext_access lws_issue_raw
+#define lws_context_init_extensions(_a, _b)
#endif
LWS_EXTERN int
struct libwebsocket *wsi,
enum libwebsocket_callback_reasons reason, void *user,
void *in, size_t len);
+#ifdef LWS_USE_HTTP2
+LWS_EXTERN int
+lws_http2_interpret_settings_payload(struct http2_settings *settings, unsigned char *buf, int len);
+LWS_EXTERN void lws_http2_init(struct http2_settings *settings);
+LWS_EXTERN int
+lws_http2_parser(struct libwebsocket_context *context,
+ struct libwebsocket *wsi, unsigned char c);
+LWS_EXTERN int lws_http2_do_pps_send(struct libwebsocket_context *context, struct libwebsocket *wsi);
+LWS_EXTERN int lws_http2_frame_write(struct libwebsocket *wsi, int type, int flags, unsigned int sid, unsigned int len, unsigned char *buf);
+LWS_EXTERN struct libwebsocket *
+lws_http2_wsi_from_id(struct libwebsocket *wsi, unsigned int sid);
+#endif
LWS_EXTERN int
-lws_set_socket_options(struct libwebsocket_context *context, int fd);
+lws_plat_set_socket_options(struct libwebsocket_context *context, int fd);
LWS_EXTERN int
lws_allocate_header_table(struct libwebsocket *wsi);
LWS_EXTERN int
libwebsocket_ensure_user_space(struct libwebsocket *wsi);
+LWS_EXTERN int
+lws_change_pollfd(struct libwebsocket *wsi, int _and, int _or);
+
#ifndef LWS_NO_SERVER
+int lws_context_init_server(struct lws_context_creation_info *info,
+ struct libwebsocket_context *context);
LWS_EXTERN int handshake_0405(struct libwebsocket_context *context,
struct libwebsocket *wsi);
+LWS_EXTERN int
+libwebsocket_interpret_incoming_packet(struct libwebsocket *wsi,
+ unsigned char *buf, size_t len);
+LWS_EXTERN void
+lws_server_get_canonical_hostname(struct libwebsocket_context *context,
+ struct lws_context_creation_info *info);
+#else
+#define lws_context_init_server(_a, _b) (0)
+#define libwebsocket_interpret_incoming_packet(_a, _b, _c) (0)
+#define lws_server_get_canonical_hostname(_a, _b)
#endif
#ifndef LWS_NO_DAEMONIZE
LWS_EXTERN int get_daemonize_pid();
+#else
+#define get_daemonize_pid() (0)
+#endif
+
+LWS_EXTERN int interface_to_sa(struct libwebsocket_context *context,
+ const char *ifname, struct sockaddr_in *addr, size_t addrlen);
+
+LWS_EXTERN void lwsl_emit_stderr(int level, const char *line);
+
+#ifdef _WIN32
+LWS_EXTERN HANDLE lws_plat_open_file(const char* filename, unsigned long* filelen);
+#else
+LWS_EXTERN int lws_plat_open_file(const char* filename, unsigned long* filelen);
#endif
-extern int interface_to_sa(const char *ifname,
- struct sockaddr_in *addr, size_t addrlen);
+enum lws_ssl_capable_status {
+ LWS_SSL_CAPABLE_ERROR = -1,
+ LWS_SSL_CAPABLE_MORE_SERVICE = -2,
+};
#ifndef LWS_OPENSSL_SUPPORT
+#define LWS_SSL_ENABLED(context) (0)
+#define lws_context_init_server_ssl(_a, _b) (0)
+#define lws_ssl_destroy(_a)
+#define lws_context_init_http2_ssl(_a)
+#define lws_ssl_capable_read lws_ssl_capable_read_no_ssl
+#define lws_ssl_capable_write lws_ssl_capable_write_no_ssl
+#define lws_server_socket_service_ssl(_a, _b, _c, _d, _e) (0)
+#define lws_ssl_close(_a) (0)
+#define lws_ssl_context_destroy(_a)
+#else
+#define LWS_SSL_ENABLED(context) (context->use_ssl)
+LWS_EXTERN int openssl_websocket_private_data_index;
+LWS_EXTERN int
+lws_ssl_capable_read(struct libwebsocket_context *context,
+ struct libwebsocket *wsi, unsigned char *buf, int len);
+
+LWS_EXTERN int
+lws_ssl_capable_write(struct libwebsocket *wsi, unsigned char *buf, int len);
+LWS_EXTERN int
+lws_server_socket_service_ssl(struct libwebsocket_context *context,
+ struct libwebsocket **wsi, struct libwebsocket *new_wsi,
+ int accept_fd, struct libwebsocket_pollfd *pollfd);
+LWS_EXTERN int
+lws_ssl_close(struct libwebsocket *wsi);
+LWS_EXTERN void
+lws_ssl_context_destroy(struct libwebsocket_context *context);
+#ifndef LWS_NO_SERVER
+LWS_EXTERN int
+lws_context_init_server_ssl(struct lws_context_creation_info *info,
+ struct libwebsocket_context *context);
+#else
+#define lws_context_init_server_ssl(_a, _b) (0)
+#endif
+LWS_EXTERN void
+lws_ssl_destroy(struct libwebsocket_context *context);
-unsigned char *
-SHA1(const unsigned char *d, size_t n, unsigned char *md);
+/* HTTP2-related */
+#ifdef LWS_USE_HTTP2
+LWS_EXTERN void
+lws_context_init_http2_ssl(struct libwebsocket_context *context);
#else
+#define lws_context_init_http2_ssl(_a)
+#endif
+#endif
-LWS_EXTERN int openssl_websocket_private_data_index;
+LWS_EXTERN int
+lws_ssl_capable_read_no_ssl(struct libwebsocket_context *context,
+ struct libwebsocket *wsi, unsigned char *buf, int len);
+LWS_EXTERN int
+lws_ssl_capable_write_no_ssl(struct libwebsocket *wsi, unsigned char *buf, int len);
+
+#ifndef LWS_NO_CLIENT
+ LWS_EXTERN int lws_client_socket_service(
+ struct libwebsocket_context *context,
+ struct libwebsocket *wsi, struct libwebsocket_pollfd *pollfd);
+#ifdef LWS_OPENSSL_SUPPORT
+ LWS_EXTERN int lws_context_init_client_ssl(struct lws_context_creation_info *info,
+ struct libwebsocket_context *context);
+#else
+ #define lws_context_init_client_ssl(_a, _b) (0)
+#endif
+ LWS_EXTERN int lws_handshake_client(struct libwebsocket *wsi, unsigned char **buf, size_t len);
+ LWS_EXTERN void
+ libwebsockets_decode_ssl_error(void);
+#else
+#define lws_context_init_client_ssl(_a, _b) (0)
+#define lws_handshake_client(_a, _b, _c) (0)
#endif
+#ifndef LWS_NO_SERVER
+ LWS_EXTERN int lws_server_socket_service(
+ struct libwebsocket_context *context,
+ struct libwebsocket *wsi, struct libwebsocket_pollfd *pollfd);
+ LWS_EXTERN int _libwebsocket_rx_flow_control(struct libwebsocket *wsi);
+ LWS_EXTERN int lws_handshake_server(struct libwebsocket_context *context,
+ struct libwebsocket *wsi, unsigned char **buf, size_t len);
+#else
+#define lws_server_socket_service(_a, _b, _c) (0)
+#define _libwebsocket_rx_flow_control(_a) (0)
+#define lws_handshake_server(_a, _b, _c, _d) (0)
+#endif
+
+/*
+ * lws_plat_
+ */
+LWS_EXTERN void
+lws_plat_delete_socket_from_fds(struct libwebsocket_context *context,
+ struct libwebsocket *wsi, int m);
+LWS_EXTERN void
+lws_plat_insert_socket_into_fds(struct libwebsocket_context *context,
+ struct libwebsocket *wsi);
+LWS_EXTERN void
+lws_plat_service_periodic(struct libwebsocket_context *context);
+
+LWS_EXTERN int
+lws_plat_change_pollfd(struct libwebsocket_context *context,
+ struct libwebsocket *wsi, struct libwebsocket_pollfd *pfd);
+LWS_EXTERN int
+lws_plat_context_early_init(void);
+LWS_EXTERN void
+lws_plat_context_early_destroy(struct libwebsocket_context *context);
+LWS_EXTERN void
+lws_plat_context_late_destroy(struct libwebsocket_context *context);
+LWS_EXTERN int
+lws_poll_listen_fd(struct libwebsocket_pollfd *fd);
+LWS_EXTERN int
+lws_plat_service(struct libwebsocket_context *context, int timeout_ms);
+LWS_EXTERN int
+lws_plat_init_fd_tables(struct libwebsocket_context *context);
+LWS_EXTERN void
+lws_plat_drop_app_privileges(struct lws_context_creation_info *info);
+LWS_EXTERN unsigned long long
+time_in_microseconds(void);
+LWS_EXTERN const char *
+lws_plat_inet_ntop(int af, const void *src, char *dst, int cnt);
projects / platform / upstream / libwebsockets.git / blobdiff