Mirrors/libwebsockets
1
0
Fork 0
mirror of https://github.com/warmcat/libwebsockets.git synced 2025-03-09 00:00:04 +01:00
Code Issues Releases Wiki Activity

attempt to restore tabs

Browse source
This commit is contained in:
rwachtfogel 2023-06-01 12:15:08 +03:00
parent 0d04284b1a
commit 949adfc5cf
3 changed files with 325 additions and 325 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

122
include/libwebsockets.h
View file

@ -369,7 +369,7 @@ lws_pthread_mutex_unlock(pthread_mutex_t *lock)
#include <stddef.h>
#ifndef lws_container_of
#define lws_container_of(P,T,M) ((T *)((char *)(P) - offsetof(T, M)))
#define lws_container_of(P,T,M) ((T *)((char *)(P) - offsetof(T, M)))
#endif
#define LWS_ALIGN_TO(x, bou) x += ((bou) - ((x) % (bou))) % (bou)
@ -407,9 +407,9 @@ typedef HANDLE lws_filefd_type;
#define lws_pollfd pollfd
#define LWS_POLLHUP (POLLHUP)
#define LWS_POLLIN (POLLRDNORM | POLLRDBAND)
#define LWS_POLLOUT (POLLWRNORM)
#define LWS_POLLHUP (POLLHUP)
#define LWS_POLLIN (POLLRDNORM | POLLRDBAND)
#define LWS_POLLOUT (POLLWRNORM)
#else
@ -424,8 +424,8 @@ typedef int lws_filefd_type;
#if defined(LWS_PLAT_OPTEE)
#include <time.h>
struct timeval {
time_t tv_sec;
unsigned int tv_usec;
time_t tv_sec;
unsigned int tv_usec;
};
#if defined(LWS_WITH_NETWORK)
// #include <poll.h>
@ -435,10 +435,10 @@ struct timezone;
int gettimeofday(struct timeval *tv, struct timezone *tz);
/* Internet address. */
struct in_addr {
uint32_t s_addr; /* address in network byte order */
};
/* Internet address. */
struct in_addr {
uint32_t s_addr; /* address in network byte order */
};
typedef unsigned short sa_family_t;
typedef unsigned short in_port_t;
@ -447,27 +447,27 @@ typedef uint32_t socklen_t;
#include <libwebsockets/lws-optee.h>
#if !defined(TEE_SE_READER_NAME_MAX)
struct addrinfo {
int ai_flags;
int ai_family;
int ai_socktype;
int ai_protocol;
socklen_t ai_addrlen;
struct sockaddr *ai_addr;
char *ai_canonname;
struct addrinfo *ai_next;
};
struct addrinfo {
int ai_flags;
int ai_family;
int ai_socktype;
int ai_protocol;
socklen_t ai_addrlen;
struct sockaddr *ai_addr;
char *ai_canonname;
struct addrinfo *ai_next;
};
#endif
ssize_t recv(int sockfd, void *buf, size_t len, int flags);
ssize_t send(int sockfd, const void *buf, size_t len, int flags);
ssize_t read(int fd, void *buf, size_t count);
int getsockopt(int sockfd, int level, int optname,
void *optval, socklen_t *optlen);
int setsockopt(int sockfd, int level, int optname,
const void *optval, socklen_t optlen);
void *optval, socklen_t *optlen);
int setsockopt(int sockfd, int level, int optname,
const void *optval, socklen_t optlen);
int connect(int sockfd, const struct sockaddr *addr,
socklen_t addrlen);
socklen_t addrlen);
extern int errno;
@ -475,46 +475,46 @@ uint16_t ntohs(uint16_t netshort);
uint16_t htons(uint16_t hostshort);
int bind(int sockfd, const struct sockaddr *addr,
socklen_t addrlen);
socklen_t addrlen);
#define MSG_NOSIGNAL 0x4000
#define EAGAIN 11
#define EINTR 4
#define EWOULDBLOCK EAGAIN
#define EADDRINUSE 98
#define INADDR_ANY 0
#define AF_INET 2
#define EAGAIN 11
#define EINTR 4
#define EWOULDBLOCK EAGAIN
#define EADDRINUSE 98
#define INADDR_ANY 0
#define AF_INET 2
#define SHUT_WR 1
#define AF_UNSPEC 0
#define PF_UNSPEC 0
#define SOCK_STREAM 1
#define SOCK_DGRAM 2
# define AI_PASSIVE 0x0001
#define IPPROTO_UDP 17
#define SOL_SOCKET 1
#define SOCK_STREAM 1
#define SOCK_DGRAM 2
# define AI_PASSIVE 0x0001
#define IPPROTO_UDP 17
#define SOL_SOCKET 1
#define SO_SNDBUF 7
#define EISCONN 106
#define EALREADY 114
#define EINPROGRESS 115
#define EISCONN 106
#define EALREADY 114
#define EINPROGRESS 115
int shutdown(int sockfd, int how);
int close(int fd);
int atoi(const char *nptr);
long long atoll(const char *nptr);
int socket(int domain, int type, int protocol);
int getaddrinfo(const char *node, const char *service,
const struct addrinfo *hints,
struct addrinfo **res);
int getaddrinfo(const char *node, const char *service,
const struct addrinfo *hints,
struct addrinfo **res);
void freeaddrinfo(struct addrinfo *res);
void freeaddrinfo(struct addrinfo *res);
#if !defined(TEE_SE_READER_NAME_MAX)
struct lws_pollfd
{
int fd; /* File descriptor to poll. */
short int events; /* Types of events poller cares about. */
short int revents; /* Types of events that actually occurred. */
int fd; /* File descriptor to poll. */
short int events; /* Types of events poller cares about. */
short int revents; /* Types of events that actually occurred. */
};
#endif
@ -576,8 +576,8 @@ typedef uint32_t lws_fop_flags_t;
/** struct lws_pollargs - argument structure for all external poll related calls
* passed in via 'in' */
struct lws_pollargs {
lws_sockfd_type fd; /**< applicable socket descriptor */
int events; /**< the new event mask */
lws_sockfd_type fd; /**< applicable socket descriptor */
int events; /**< the new event mask */
int prev_events; /**< the previous event mask */
};
@ -588,10 +588,10 @@ struct lws_pollargs {
#if defined(__x86_64__)
#define _LWS_PAD_SIZE 16 /* Intel recommended for best performance */
#else
#define _LWS_PAD_SIZE LWS_SIZEOFPTR /* Size of a pointer on the target arch */
#define _LWS_PAD_SIZE LWS_SIZEOFPTR /* Size of a pointer on the target arch */
#endif
#define _LWS_PAD(n) (((n) % _LWS_PAD_SIZE) ? \
((n) + (_LWS_PAD_SIZE - ((n) % _LWS_PAD_SIZE))) : (n))
((n) + (_LWS_PAD_SIZE - ((n) % _LWS_PAD_SIZE))) : (n))
/* last 2 is for lws-meta */
#define LWS_PRE _LWS_PAD(4 + 10 + 2)
/* used prior to 1.7 and retained for backward compatibility */
@ -611,32 +611,32 @@ struct lws;
/* Generic stateful operation return codes */
typedef enum {
LWS_SRET_OK = 0,
LWS_SRET_WANT_INPUT = (1 << 16),
LWS_SRET_WANT_OUTPUT = (1 << 17),
LWS_SRET_FATAL = (1 << 18),
LWS_SRET_OK = 0,
LWS_SRET_WANT_INPUT = (1 << 16),
LWS_SRET_WANT_OUTPUT = (1 << 17),
LWS_SRET_FATAL = (1 << 18),
LWS_SRET_NO_FURTHER_IN = (1 << 19),
LWS_SRET_NO_FURTHER_OUT = (1 << 20),
LWS_SRET_AWAIT_RETRY = (1 << 21),
LWS_SRET_YIELD = (1 << 22), /* return to the event loop and continue */
LWS_SRET_AWAIT_RETRY = (1 << 21),
LWS_SRET_YIELD = (1 << 22), /* return to the event loop and continue */
} lws_stateful_ret_t;
typedef struct lws_fixed3232 {
int32_t whole; /* signed 32-bit int */
int32_t frac; /* signed frac proportion from 0 to (100M - 1) */
int32_t whole; /* signed 32-bit int */
int32_t frac; /* signed frac proportion from 0 to (100M - 1) */
} lws_fx_t;
#define LWS_FX_FRACTION_MSD 100000000
#define lws_neg(a) (a->whole < 0 || a->frac < 0)
#define lws_fx_set(a, x, y) { a.whole = x; a.frac = x < 0 ? -y : y; }
#define lws_fix64(a) (((int64_t)a->whole << 32) + \
(((1ll << 32) * (a->frac < 0 ? -a->frac : a->frac)) / LWS_FX_FRACTION_MSD))
(((1ll << 32) * (a->frac < 0 ? -a->frac : a->frac)) / LWS_FX_FRACTION_MSD))
#define lws_fix64_abs(a) \
((((int64_t)(a->whole < 0 ? (-a->whole) : a->whole) << 32) + \
(((1ll << 32) * (a->frac < 0 ? -a->frac : a->frac)) / LWS_FX_FRACTION_MSD)))
(((1ll << 32) * (a->frac < 0 ? -a->frac : a->frac)) / LWS_FX_FRACTION_MSD)))
#define lws_fix3232(a, a64) { a->whole = (int32_t)(a64 >> 32); \
a->frac = (int32_t)((100000000 * (a64 & 0xffffffff)) >> 32); }
a->frac = (int32_t)((100000000 * (a64 & 0xffffffff)) >> 32); }
LWS_VISIBLE LWS_EXTERN const lws_fx_t *
lws_fx_add(lws_fx_t *r, const lws_fx_t *a, const lws_fx_t *b);

54
lib/core/CMakeLists.txt
View file

@ -25,40 +25,40 @@
include_directories(.)
list(APPEND SOURCES
core/lws_dll2.c
core/lws_dll2.c
)
if (NOT LWS_ONLY_SSPC)
list(APPEND SOURCES
core/alloc.c
core/assert.c
core/buflist.c
core/context.c
core/lws_map.c
core/libwebsockets.c
core/logs.c
)
if (LWS_WITH_FILE_OPS)
list(APPEND SOURCES core/vfs.c)
endif()
list(APPEND SOURCES
core/alloc.c
core/assert.c
core/buflist.c
core/context.c
core/lws_map.c
core/libwebsockets.c
core/logs.c
)
if (LWS_WITH_FILE_OPS)
list(APPEND SOURCES core/vfs.c)
endif()
else()
#
# libwebsockets.a with only SSPC pieces in
#
list(APPEND SOURCES
secure-streams/serialized/client/sspc.c
secure-streams/serialized/client/sspc-transport.c
secure-streams/serialized/client/sspc-deserialize.c
core-net/lws-dsh.c
core-net/transport-mux-client.c
core-net/transport-mux-common.c
)
#
# libwebsockets.a with only SSPC pieces in
#
list(APPEND SOURCES
secure-streams/serialized/client/sspc.c
secure-streams/serialized/client/sspc-transport.c
secure-streams/serialized/client/sspc-deserialize.c
core-net/lws-dsh.c
core-net/transport-mux-client.c
core-net/transport-mux-common.c
)
endif()
exports_to_parent_scope()

474
lib/core/private-lib-core.h
View file

@ -30,7 +30,7 @@
#if defined(LWS_WITH_CGI) && defined(LWS_HAVE_VFORK) && \
!defined(NO_GNU_SOURCE_THIS_TIME) && !defined(_GNU_SOURCE)
!defined(NO_GNU_SOURCE_THIS_TIME) && !defined(_GNU_SOURCE)
#define _GNU_SOURCE
#endif
@ -128,16 +128,16 @@
#include "private-lib-plat-freertos.h"
#else
#if defined(WIN32) || defined(_WIN32)
#include "private-lib-plat-windows.h"
#include "private-lib-plat-windows.h"
#else
#if defined(LWS_PLAT_BAREMETAL)
#else
#if defined(LWS_PLAT_OPTEE)
#include "private-lib-plat.h"
#else
#include "private-lib-plat-unix.h"
#endif
#endif
#if defined(LWS_PLAT_BAREMETAL)
#else
#if defined(LWS_PLAT_OPTEE)
#include "private-lib-plat.h"
#else
#include "private-lib-plat-unix.h"
#endif
#endif
#endif
#endif
@ -155,37 +155,37 @@
*/
typedef struct lws_dsh_obj_head {
lws_dll2_owner_t owner;
size_t total_size; /* for this kind in dsh */
int kind;
lws_dll2_owner_t owner;
size_t total_size; /* for this kind in dsh */
int kind;
} lws_dsh_obj_head_t;
typedef struct lws_dsh_obj {
lws_dll2_t list; /* must be first */
struct lws_dsh *dsh; /* invalid when on free list */
size_t size; /* invalid when on free list */
size_t pos; /* invalid when on free list */
size_t asize;
int kind; /* so we can account at free */
lws_dll2_t list; /* must be first */
struct lws_dsh *dsh; /* invalid when on free list */
size_t size; /* invalid when on free list */
size_t pos; /* invalid when on free list */
size_t asize;
int kind; /* so we can account at free */
} lws_dsh_obj_t;
typedef struct lws_dsh {
lws_dll2_t list;
uint8_t *buf;
lws_dsh_obj_head_t *oha; /* array of object heads/kind */
size_t splitat;
size_t buffer_size;
size_t locally_in_use;
size_t locally_free;
int count_kinds;
uint32_t flags;
uint8_t being_destroyed;
lws_dll2_t list;
uint8_t *buf;
lws_dsh_obj_head_t *oha; /* array of object heads/kind */
size_t splitat;
size_t buffer_size;
size_t locally_in_use;
size_t locally_free;
int count_kinds;
uint32_t flags;
uint8_t being_destroyed;
/*
* Overallocations at create:
*
* - the buffer itself
* - the object heads array
*/
* Overallocations at create:
*
* - the buffer itself
* - the object heads array
*/
} lws_dsh_t;
/*
@ -195,26 +195,26 @@ typedef struct lws_dsh {
*/
typedef struct lws_lifecycle_group {
lws_dll2_owner_t owner; /* active count / list */
uint64_t ordinal; /* monotonic uid count */
const char *tag_prefix; /* eg, "wsi" */
lws_dll2_owner_t owner; /* active count / list */
uint64_t ordinal; /* monotonic uid count */
const char *tag_prefix; /* eg, "wsi" */
} lws_lifecycle_group_t;
typedef struct lws_lifecycle {
#if defined(LWS_WITH_SECURE_STREAMS_PROXY_API)
/* we append parent streams on the tag */
char gutag[96]; /* object unique tag + relationship info */
char gutag[96]; /* object unique tag + relationship info */
#else
char gutag[64];
char gutag[64];
#endif
lws_dll2_t list; /* group list membership */
uint64_t us_creation; /* creation timestamp */
lws_log_cx_t *log_cx;
lws_dll2_t list; /* group list membership */
uint64_t us_creation; /* creation timestamp */
lws_log_cx_t *log_cx;
} lws_lifecycle_t;
void
__lws_lc_tag(struct lws_context *cx, lws_lifecycle_group_t *grp,
lws_lifecycle_t *lc, const char *format, ...);
lws_lifecycle_t *lc, const char *format, ...);
void
__lws_lc_tag_append(lws_lifecycle_t *lc, const char *app);
@ -232,13 +232,13 @@ extern lws_log_cx_t log_cx;
*/
struct lws_tx_credit {
int32_t tx_cr; /* our credit to write peer */
int32_t peer_tx_cr_est; /* peer's credit to write us */
int32_t tx_cr; /* our credit to write peer */
int32_t peer_tx_cr_est; /* peer's credit to write us */
int32_t manual_initial_tx_credit;
int32_t manual_initial_tx_credit;
uint8_t skint; /* unable to write anything */
uint8_t manual;
uint8_t skint; /* unable to write anything */
uint8_t manual;
};
#ifdef LWS_WITH_IPV6
@ -261,18 +261,18 @@ struct lws_tx_credit {
* Non-SSL mode also uses these types.
*/
enum lws_ssl_capable_status {
LWS_SSL_CAPABLE_ERROR = -1, /* it failed */
LWS_SSL_CAPABLE_DONE = 0, /* it succeeded */
LWS_SSL_CAPABLE_ERROR = -1, /* it failed */
LWS_SSL_CAPABLE_DONE = 0, /* it succeeded */
LWS_SSL_CAPABLE_MORE_SERVICE_READ = -2, /* retry WANT_READ */
LWS_SSL_CAPABLE_MORE_SERVICE_WRITE = -3, /* retry WANT_WRITE */
LWS_SSL_CAPABLE_MORE_SERVICE = -4, /* general retry */
LWS_SSL_CAPABLE_MORE_SERVICE_WRITE = -3, /* retry WANT_WRITE */
LWS_SSL_CAPABLE_MORE_SERVICE = -4, /* general retry */
};
enum lws_context_destroy {
LWSCD_NO_DESTROY, /* running */
LWSCD_PT_WAS_DEFERRED, /* destroy from inside service */
LWSCD_NO_DESTROY, /* running */
LWSCD_PT_WAS_DEFERRED, /* destroy from inside service */
LWSCD_PT_WAIT_ALL_DESTROYED, /* libuv ends up here later */
LWSCD_FINALIZATION /* the final destruction of context */
LWSCD_FINALIZATION /* the final destruction of context */
};
#if defined(LWS_WITH_TLS)
@ -280,7 +280,7 @@ enum lws_context_destroy {
#endif
#if defined(WIN32) || defined(_WIN32)
// Visual studio older than 2015 and WIN_CE has only _stricmp
// Visual studio older than 2015 and WIN_CE has only _stricmp
#if (defined(_MSC_VER) && _MSC_VER < 1900) || defined(_WIN32_WCE)
#define strcasecmp _stricmp
#define strncasecmp _strnicmp
@ -349,21 +349,21 @@ struct lws_foreign_thread_pollfd {
struct lws_system_blob {
union {
struct lws_buflist *bl;
struct {
const uint8_t *ptr;
size_t len;
} direct;
struct lws_buflist *bl;
struct {
const uint8_t *ptr;
size_t len;
} direct;
} u;
char is_direct;
};
typedef struct lws_attach_item {
lws_dll2_t list;
lws_attach_cb_t cb;
void *opaque;
lws_system_states_t state;
lws_dll2_t list;
lws_attach_cb_t cb;
void *opaque;
lws_system_states_t state;
} lws_attach_item_t;
/*
@ -373,52 +373,52 @@ typedef struct lws_attach_item {
*/
enum {
LWSLCG_WSI, /* generic wsi, eg, pipe, listen */
LWSLCG_WSI, /* generic wsi, eg, pipe, listen */
LWSLCG_VHOST,
LWSLCG_WSI_SERVER, /* server wsi */
LWSLCG_WSI_SERVER, /* server wsi */
#if defined(LWS_ROLE_H2) || defined(LWS_ROLE_MQTT)
LWSLCG_WSI_MUX, /* a mux child wsi */
LWSLCG_WSI_MUX, /* a mux child wsi */
#endif
#if defined(LWS_WITH_CLIENT)
LWSLCG_WSI_CLIENT, /* client wsi */
LWSLCG_WSI_CLIENT, /* client wsi */
#endif
#if defined(LWS_WITH_SECURE_STREAMS)
#if defined(LWS_WITH_CLIENT)
LWSLCG_SS_CLIENT, /* secstream client handle */
LWSLCG_SS_CLIENT, /* secstream client handle */
#endif
#if defined(LWS_WITH_SERVER)
LWSLCG_SS_SERVER, /* secstream server handle */
LWSLCG_SS_SERVER, /* secstream server handle */
#endif
#if defined(LWS_WITH_CLIENT)
LWSLCG_WSI_SS_CLIENT, /* wsi bound to ss client handle */
LWSLCG_WSI_SS_CLIENT, /* wsi bound to ss client handle */
#endif
#if defined(LWS_WITH_SERVER)
LWSLCG_WSI_SS_SERVER, /* wsi bound to ss server handle */
LWSLCG_WSI_SS_SERVER, /* wsi bound to ss server handle */
#endif
#endif
#if defined(LWS_WITH_SECURE_STREAMS_PROXY_API)
#if defined(LWS_WITH_CLIENT)
LWSLCG_SSP_CLIENT, /* SSPC handle client connection to proxy */
LWSLCG_SSP_CLIENT, /* SSPC handle client connection to proxy */
#endif
#if defined(LWS_WITH_SERVER)
LWSLCG_SSP_ONWARD, /* SS handle at proxy for onward conn */
LWSLCG_SSP_ONWARD, /* SS handle at proxy for onward conn */
#endif
#if defined(LWS_WITH_CLIENT)
LWSLCG_WSI_SSP_CLIENT, /* wsi bound to SSPC cli conn to proxy */
LWSLCG_WSI_SSP_CLIENT, /* wsi bound to SSPC cli conn to proxy */
#endif
#if defined(LWS_WITH_SERVER)
LWSLCG_WSI_SSP_ONWARD, /* wsi bound to Proxy onward connection */
LWSLCG_WSI_SSP_ONWARD, /* wsi bound to Proxy onward connection */
#endif
#endif
#if defined(LWS_WITH_SERVER)
LWSLCG_WSI_SSP_SINK, /* accepted sink conn */
LWSLCG_WSI_SSP_SOURCE, /* accepted source conn */
LWSLCG_WSI_SSP_SINK, /* accepted sink conn */
LWSLCG_WSI_SSP_SOURCE, /* accepted source conn */
#endif
/* always last */
@ -427,9 +427,9 @@ enum {
#if defined(LWS_WITH_SECURE_STREAMS) && defined(LWS_WITH_SERVER)
typedef struct lws_ss_sinks {
lws_dll2_t list;
lws_ss_info_t info;
lws_dll2_owner_t accepts;
lws_dll2_t list;
lws_ss_info_t info;
lws_dll2_owner_t accepts;
} lws_ss_sinks_t;
#endif
@ -446,7 +446,7 @@ struct lws_context {
#endif
#if defined(LWS_HAVE_SSL_CTX_set_keylog_callback) && \
defined(LWS_WITH_TLS) && defined(LWS_WITH_CLIENT)
char keylog_file[96];
char keylog_file[96];
#endif
#if defined(LWS_WITH_FILE_OPS)
@ -460,53 +460,53 @@ struct lws_context {
lws_system_blob_t system_blobs[LWS_SYSBLOB_TYPE_COUNT];
#if defined(LWS_WITH_SYS_SMD)
lws_smd_t smd;
lws_smd_t smd;
#endif
#if defined(LWS_WITH_SECURE_STREAMS)
struct lws_ss_handle *ss_cpd;
struct lws_ss_handle *ss_cpd;
#endif
lws_sorted_usec_list_t sul_cpd_defer;
lws_sorted_usec_list_t sul_cpd_defer;
#if defined(LWS_WITH_DLO)
lws_dll2_owner_t fonts;
lws_dll2_owner_t dlo_file;
lws_dll2_owner_t fonts;
lws_dll2_owner_t dlo_file;
#if defined(LWS_WITH_SECURE_STREAMS)
lws_dll2_owner_t active_assets; /* dloss_t */
lws_dll2_owner_t active_assets; /* dloss_t */
#endif
#endif
#if defined(LWS_WITH_NETWORK)
struct lws_context_per_thread pt[LWS_MAX_SMP];
lws_retry_bo_t default_retry;
lws_sorted_usec_list_t sul_system_state;
struct lws_context_per_thread pt[LWS_MAX_SMP];
lws_retry_bo_t default_retry;
lws_sorted_usec_list_t sul_system_state;
lws_lifecycle_group_t lcg[LWSLCG_COUNT];
lws_lifecycle_group_t lcg[LWSLCG_COUNT];
const struct lws_protocols *protocols_copy;
const struct lws_protocols *protocols_copy;
#if defined(LWS_WITH_NETLINK)
lws_sorted_usec_list_t sul_nl_coldplug;
lws_sorted_usec_list_t sul_nl_coldplug;
/* process can only have one netlink socket, have to do it in ctx */
lws_dll2_owner_t routing_table;
struct lws *netlink;
lws_dll2_owner_t routing_table;
struct lws *netlink;
#endif
#if defined(LWS_PLAT_FREERTOS)
struct sockaddr_in frt_pipe_si;
struct sockaddr_in frt_pipe_si;
#endif
#if defined(LWS_WITH_HTTP2)
struct http2_settings set;
struct http2_settings set;
#endif
#if LWS_MAX_SMP > 1
struct lws_mutex_refcount mr;
struct lws_mutex_refcount mr;
#endif
#if defined(LWS_WITH_SYS_METRICS)
lws_dll2_owner_t owner_mtr_dynpol;
lws_dll2_owner_t owner_mtr_dynpol;
/**< owner for lws_metric_policy_dyn_t (dynamic part of metric pols) */
lws_dll2_owner_t owner_mtr_no_pol;
lws_dll2_owner_t owner_mtr_no_pol;
/**< owner for lws_metric_pub_t with no policy to bind to */
#endif
@ -515,61 +515,61 @@ struct lws_context {
* LWS_WITH_NETWORK =====>
*/
lws_dll2_owner_t owner_vh_being_destroyed;
lws_dll2_owner_t owner_vh_being_destroyed;
lws_metric_t *mt_service; /* doing service */
lws_metric_t *mt_service; /* doing service */
const lws_metric_policy_t *metrics_policies;
const char *metrics_prefix;
const char *metrics_prefix;
#if defined(LWS_WITH_SYS_METRICS) && defined(LWS_WITH_CLIENT)
lws_metric_t *mt_conn_tcp; /* client tcp conns */
lws_metric_t *mt_conn_tls; /* client tcp conns */
lws_metric_t *mt_conn_dns; /* client dns external lookups */
lws_metric_t *mth_conn_failures; /* histogram of conn failure reasons */
lws_metric_t *mt_conn_tcp; /* client tcp conns */
lws_metric_t *mt_conn_tls; /* client tcp conns */
lws_metric_t *mt_conn_dns; /* client dns external lookups */
lws_metric_t *mth_conn_failures; /* histogram of conn failure reasons */
#if defined(LWS_ROLE_H1) || defined(LWS_ROLE_H2)
lws_metric_t *mt_http_txn; /* client http transaction */
lws_metric_t *mt_http_txn; /* client http transaction */
#endif
#if defined(LWS_WITH_SYS_ASYNC_DNS)
lws_metric_t *mt_adns_cache; /* async dns lookup lat */
lws_metric_t *mt_adns_cache; /* async dns lookup lat */
#endif
#if defined(LWS_WITH_SECURE_STREAMS)
lws_metric_t *mth_ss_conn; /* SS connection outcomes */
lws_metric_t *mth_ss_conn; /* SS connection outcomes */
#endif
#if defined(LWS_WITH_SECURE_STREAMS_PROXY_API)
lws_metric_t *mt_ss_cliprox_conn; /* SS cli->prox conn */
lws_metric_t *mt_ss_cliprox_paylat; /* cli->prox payload latency */
lws_metric_t *mt_ss_proxcli_paylat; /* prox->cli payload latency */
lws_metric_t *mt_ss_cliprox_conn; /* SS cli->prox conn */
lws_metric_t *mt_ss_cliprox_paylat; /* cli->prox payload latency */
lws_metric_t *mt_ss_proxcli_paylat; /* prox->cli payload latency */
#endif
#endif /* client */
#if defined(LWS_WITH_SERVER)
lws_metric_t *mth_srv;
lws_metric_t *mth_srv;
#endif
#if defined(LWS_WITH_EVENT_LIBS)
struct lws_plugin *evlib_plugin_list;
void *evlib_ctx; /* overallocated */
struct lws_plugin *evlib_plugin_list;
void *evlib_ctx; /* overallocated */
#endif
#if defined(LWS_WITH_TLS)
struct lws_context_tls tls;
struct lws_context_tls tls;
#if defined (LWS_WITH_TLS_JIT_TRUST)
lws_dll2_owner_t jit_inflight;
lws_dll2_owner_t jit_inflight;
/* ongoing sync or async jit trust lookups */
struct lws_cache_ttl_lru *trust_cache;
/* caches host -> truncated trust SKID mappings */
#endif
#endif
#if defined(LWS_WITH_DRIVERS)
lws_netdevs_t netdevs;
lws_netdevs_t netdevs;
#endif
#if defined(LWS_WITH_SYS_ASYNC_DNS)
lws_async_dns_t async_dns;
lws_async_dns_t async_dns;
#endif
#if defined(LWS_WITH_SYS_FAULT_INJECTION)
lws_fi_ctx_t fic;
lws_fi_ctx_t fic;
/**< Toplevel Fault Injection ctx */
#endif
@ -578,42 +578,42 @@ struct lws_context {
#endif
#if defined(LWS_WITH_SYS_NTPCLIENT)
void *ntpclient_priv;
void *ntpclient_priv;
#endif
#if defined(LWS_WITH_SECURE_STREAMS)
struct lws_ss_handle *hss_fetch_policy;
struct lws_ss_handle *hss_fetch_policy;
#if defined(LWS_WITH_SECURE_STREAMS_SYS_AUTH_API_AMAZON_COM)
struct lws_ss_handle *hss_auth;
lws_sorted_usec_list_t sul_api_amazon_com;
lws_sorted_usec_list_t sul_api_amazon_com_kick;
struct lws_ss_handle *hss_auth;
lws_sorted_usec_list_t sul_api_amazon_com;
lws_sorted_usec_list_t sul_api_amazon_com_kick;
#endif
#if !defined(LWS_WITH_SECURE_STREAMS_STATIC_POLICY_ONLY)
struct lws_ss_x509 *server_der_list;
struct lws_ss_x509 *server_der_list;
#endif
#endif
#if defined(LWS_WITH_SYS_STATE)
lws_state_manager_t mgr_system;
lws_state_notify_link_t protocols_notify;
lws_state_manager_t mgr_system;
lws_state_notify_link_t protocols_notify;
#endif
#if defined (LWS_WITH_SYS_DHCP_CLIENT)
lws_dll2_owner_t dhcpc_owner;
/**< list of ifaces with dhcpc */
lws_dll2_owner_t dhcpc_owner;
/**< list of ifaces with dhcpc */
#endif
/* pointers */
struct lws_vhost *vhost_list;
struct lws_vhost *no_listener_vhost_list;
struct lws_vhost *vhost_pending_destruction_list;
struct lws_vhost *vhost_system;
struct lws_vhost *vhost_list;
struct lws_vhost *no_listener_vhost_list;
struct lws_vhost *vhost_pending_destruction_list;
struct lws_vhost *vhost_system;
#if defined(LWS_WITH_SERVER)
const char *server_string;
const char *server_string;
#endif
const struct lws_event_loop_ops *event_loop_ops;
const struct lws_event_loop_ops *event_loop_ops;
#endif
#if defined(LWS_WITH_TLS)
@ -621,7 +621,7 @@ struct lws_context {
#endif
#if defined(LWS_WITH_PLUGINS)
struct lws_plugin *plugin_list;
struct lws_plugin *plugin_list;
#endif
#ifdef _WIN32
/* different implementation between unix and windows */
@ -632,8 +632,8 @@ struct lws_context {
#endif
#if defined(LWS_WITH_OTA)
lws_sorted_usec_list_t sul_ota_periodic;
lws_ss_handle_t * ota_ss; /* opaque to platform */
lws_sorted_usec_list_t sul_ota_periodic;
lws_ss_handle_t * ota_ss; /* opaque to platform */
#endif
/*
@ -642,17 +642,17 @@ struct lws_context {
#endif /* NETWORK */
lws_log_cx_t *log_cx;
const char *name;
lws_log_cx_t *log_cx;
const char *name;
#if defined(LWS_WITH_SECURE_STREAMS_PROXY_API)
const char *ss_proxy_bind;
const char *ss_proxy_address;
const char *ss_proxy_bind;
const char *ss_proxy_address;
lws_txp_path_proxy_t txp_ppath;
lws_txp_path_client_t txp_cpath;
lws_txp_path_proxy_t txp_ppath;
lws_txp_path_client_t txp_cpath;
const void *txp_ssproxy_info;
const void *txp_ssproxy_info;
#endif
@ -675,27 +675,27 @@ struct lws_context {
#endif
#if defined(LWS_WITH_PEER_LIMITS)
struct lws_peer **pl_hash_table;
struct lws_peer *peer_wait_list;
struct lws_peer **pl_hash_table;
struct lws_peer *peer_wait_list;
lws_peer_limits_notify_t pl_notify_cb;
time_t next_cull;
time_t next_cull;
#endif
const lws_system_ops_t *system_ops;
const lws_system_ops_t *system_ops;
#if defined(LWS_WITH_SECURE_STREAMS)
#if !defined(LWS_WITH_SECURE_STREAMS_STATIC_POLICY_ONLY)
const char *pss_policies_json;
struct lwsac *ac_policy;
void *pol_args;
const char *pss_policies_json;
struct lwsac *ac_policy;
void *pol_args;
#endif
const lws_ss_policy_t *pss_policies;
const lws_ss_auth_t *pss_auths;
const lws_ss_policy_t *pss_policies;
const lws_ss_auth_t *pss_auths;
#if defined(LWS_WITH_SERVER)
lws_dll2_owner_t sinks;
lws_dll2_owner_t sinks;
#endif
#if defined(LWS_WITH_SSPLUGINS)
const lws_ss_plugin_t **pss_plugins;
const lws_ss_plugin_t **pss_plugins;
#endif
#endif
@ -723,7 +723,7 @@ struct lws_context {
time_t last_ws_ping_pong_check_s;
#if defined(LWS_WITH_SECURE_STREAMS)
time_t last_policy;
time_t last_policy;
#endif
#if defined(LWS_PLAT_FREERTOS)
@ -756,11 +756,11 @@ struct lws_context {
int simultaneous_ssl_handshake_restriction;
int simultaneous_ssl_handshake;
#if defined(LWS_WITH_TLS_JIT_TRUST)
int vh_idle_grace_ms;
int vh_idle_grace_ms;
#endif
#if defined(LWS_WITH_PEER_LIMITS)
uint32_t pl_hash_elements; /* protected by context->lock */
uint32_t count_peers; /* protected by context->lock */
uint32_t pl_hash_elements; /* protected by context->lock */
uint32_t count_peers; /* protected by context->lock */
unsigned short ip_limit_ah;
unsigned short ip_limit_wsi;
#endif
@ -770,10 +770,10 @@ struct lws_context {
#endif
#if defined(LWS_WITH_NETLINK) && defined(LWS_WITH_NETWORK)
lws_route_uidx_t route_uidx;
lws_route_uidx_t route_uidx;
#endif
char tls_gate_accepts;
char tls_gate_accepts;
unsigned int deprecated:1;
unsigned int interrupted:1;
@ -808,7 +808,7 @@ struct lws_context {
uint8_t captive_portal_detect;
uint8_t captive_portal_detect_type;
uint8_t destroy_state; /* enum lws_context_destroy */
uint8_t destroy_state; /* enum lws_context_destroy */
};
#define lws_get_context_protocol(ctx, x) ctx->vhost_list->protocols[x]
@ -852,28 +852,28 @@ lws_strdup(const char *s);
int
lws_b64_selftest(void);
#define FIRST_LENGTH_CODE_INDEX 257
#define LAST_LENGTH_CODE_INDEX 285
#define FIRST_LENGTH_CODE_INDEX 257
#define LAST_LENGTH_CODE_INDEX 285
/*256 literals, the end code, some length codes, and 2 unused codes */
#define NUM_DEFLATE_CODE_SYMBOLS 288
/*the distance codes have their own symbols, 30 used, 2 unused */
#define NUM_DISTANCE_SYMBOLS 32
#define NUM_DISTANCE_SYMBOLS 32
/* The code length codes. 0-15: code lengths, 16: copy previous 3-6 times,
* 17: 3-10 zeros, 18: 11-138 zeros */
#define NUM_CODE_LENGTH_CODES 19
#define NUM_CODE_LENGTH_CODES 19
/* largest number of symbols used by any tree type */
#define MAX_SYMBOLS 288
#define MAX_SYMBOLS 288
#define DEFLATE_CODE_BITLEN 15
#define DISTANCE_BITLEN 15
#define CODE_LENGTH_BITLEN 7
#define DEFLATE_CODE_BITLEN 15
#define DISTANCE_BITLEN 15
#define CODE_LENGTH_BITLEN 7
/* largest bitlen used by any tree type */
#define MAX_BIT_LENGTH 15
#define MAX_BIT_LENGTH 15
#define DEFLATE_CODE_BUFFER_SIZE (NUM_DEFLATE_CODE_SYMBOLS * 2)
#define DISTANCE_BUFFER_SIZE (NUM_DISTANCE_SYMBOLS * 2)
#define CODE_LENGTH_BUFFER_SIZE (NUM_DISTANCE_SYMBOLS * 2)
#define DISTANCE_BUFFER_SIZE (NUM_DISTANCE_SYMBOLS * 2)
#define CODE_LENGTH_BUFFER_SIZE (NUM_DISTANCE_SYMBOLS * 2)
typedef uint16_t huff_t;
@ -924,74 +924,74 @@ typedef enum {
} upng_inflate_states_t;
typedef struct htree {
huff_t *tree2d;
huff_t *tree2d;
/*maximum number of bits a single code can get */
uint16_t maxbitlen;
uint16_t maxbitlen;
/*number of symbols in the alphabet = number of codes */
uint16_t numcodes;
uint16_t numcodes;
} htree_t;
typedef struct inflator_ctx {
unsigned int clenc[NUM_CODE_LENGTH_CODES];
unsigned int bitlen[NUM_DEFLATE_CODE_SYMBOLS];
unsigned int bitlenD[NUM_DISTANCE_SYMBOLS];
huff_t clct_buffer[CODE_LENGTH_BUFFER_SIZE];
huff_t ct_buffer[DEFLATE_CODE_BUFFER_SIZE];
huff_t ctD_buffer[DISTANCE_BUFFER_SIZE];
unsigned int clenc[NUM_CODE_LENGTH_CODES];
unsigned int bitlen[NUM_DEFLATE_CODE_SYMBOLS];
unsigned int bitlenD[NUM_DISTANCE_SYMBOLS];
huff_t clct_buffer[CODE_LENGTH_BUFFER_SIZE];
huff_t ct_buffer[DEFLATE_CODE_BUFFER_SIZE];
huff_t ctD_buffer[DISTANCE_BUFFER_SIZE];
lws_upng_t *upng;
lws_upng_t *upng;
const uint8_t *in;
uint8_t *out;
const uint8_t *in;
uint8_t *out;
htree_t clct;
htree_t ct;
htree_t ctD;
htree_t clct;
htree_t ct;
htree_t ctD;
size_t bp;
size_t inpos;
size_t inlen;
size_t archive_pos;
size_t outpos;
size_t outpos_linear;
size_t consumed_linear;
size_t outlen;
size_t length;
size_t start;
size_t forward;
size_t backward;
size_t exbits;
size_t bypl;
size_t bp;
size_t inpos;
size_t inlen;
size_t archive_pos;
size_t outpos;
size_t outpos_linear;
size_t consumed_linear;
size_t outlen;
size_t length;
size_t start;
size_t forward;
size_t backward;
size_t exbits;
size_t bypl;
upng_inflate_states_t state;
unsigned int len;
unsigned int nlen;
unsigned int n;
unsigned int hlit;
unsigned int hdist;
unsigned int hclen;
unsigned int i;
unsigned int t;
unsigned int codeD;
unsigned int distance;
unsigned int exbitsD;
unsigned int code;
unsigned int treepos;
unsigned int len;
unsigned int nlen;
unsigned int n;
unsigned int hlit;
unsigned int hdist;
unsigned int hclen;
unsigned int i;
unsigned int t;
unsigned int codeD;
unsigned int distance;
unsigned int exbitsD;
unsigned int code;
unsigned int treepos;
unsigned int read_bits_shifter;
unsigned int read_bits_limit;
unsigned int read_bits_i;
unsigned int read_bits_shifter;
unsigned int read_bits_limit;
unsigned int read_bits_i;
unsigned int info_size;
unsigned int info_size;
uint16_t ctr;
uint8_t subsequent;
uint8_t btype;
uint8_t done;
uint8_t gz_flags;
uint16_t ctr;
uint8_t subsequent;
uint8_t btype;
uint8_t done;
uint8_t gz_flags;
char read_bits_ongoing;
char read_bits_ongoing;
} inflator_ctx_t;
lws_stateful_ret_t
@ -1076,7 +1076,7 @@ lws_protocol_init(struct lws_context *context);
int
lws_bind_protocol(struct lws *wsi, const struct lws_protocols *p,
const char *reason);
const char *reason);
const struct lws_protocol_vhost_options *
lws_vhost_protocol_options(struct lws_vhost *vh, const char *name);
@ -1099,10 +1099,10 @@ lws_zalloc(size_t size, const char *reason);
#ifdef LWS_PLAT_OPTEE
void *lws_malloc(size_t size, const char *reason);
void lws_free(void *p);
#define lws_free_set_NULL(P) do { lws_free(P); (P) = NULL; } while(0)
#define lws_free_set_NULL(P) do { lws_free(P); (P) = NULL; } while(0)
#else
#define lws_malloc(S, R) lws_realloc(NULL, S, R)
#define lws_free(P) lws_realloc(P, 0, "lws_free")
#define lws_free(P) lws_realloc(P, 0, "lws_free")
#define lws_free_set_NULL(P) do { lws_realloc(P, 0, "free"); (P) = NULL; } while(0)
#endif
@ -1114,7 +1114,7 @@ lws_plat_apply_FD_CLOEXEC(int n);
const struct lws_plat_file_ops *
lws_vfs_select_fops(const struct lws_plat_file_ops *fops, const char *vfs_path,
const char **vpath);
const char **vpath);
/* lws_plat_ */
@ -1127,7 +1127,7 @@ lws_plat_context_late_destroy(struct lws_context *context);
int
lws_plat_init(struct lws_context *context,
const struct lws_context_creation_info *info);
const struct lws_context_creation_info *info);
int
lws_plat_drop_app_privileges(struct lws_context *context, int actually_drop);
@ -1150,7 +1150,7 @@ lws_check_byte_utf8(unsigned char state, unsigned char c);
int LWS_WARN_UNUSED_RESULT
lws_check_utf8(unsigned char *state, unsigned char *buf, size_t len);
int alloc_file(struct lws_context *context, const char *filename,
uint8_t **buf, lws_filepos_t *amount);
uint8_t **buf, lws_filepos_t *amount);
int
lws_lec_scratch(lws_lec_pctx_t *ctx);
@ -1159,7 +1159,7 @@ lws_lec_signed(lws_lec_pctx_t *ctx, int64_t num);
int
lws_cose_key_checks(const lws_cose_key_t *key, int64_t kty, int64_t alg,
int key_op, const char *crv);
int key_op, const char *crv);
void lws_msleep(unsigned int);