|
| #define | CS_MONGOOSE_SRC_COMMON_H_ |
| |
| #define | MG_VERSION "6.16" |
| |
| #define | CS_COMMON_PLATFORM_H_ |
| |
| #define | CS_P_CUSTOM 0 |
| |
| #define | CS_P_UNIX 1 |
| |
| #define | CS_P_WINDOWS 2 |
| |
| #define | CS_P_ESP32 15 |
| |
| #define | CS_P_ESP8266 3 |
| |
| #define | CS_P_CC3100 6 |
| |
| #define | CS_P_CC3200 4 |
| |
| #define | CS_P_CC3220 17 |
| |
| #define | CS_P_MSP432 5 |
| |
| #define | CS_P_TM4C129 14 |
| |
| #define | CS_P_MBED 7 |
| |
| #define | CS_P_WINCE 8 |
| |
| #define | CS_P_NXP_LPC 13 |
| |
| #define | CS_P_NXP_KINETIS 9 |
| |
| #define | CS_P_NRF51 12 |
| |
| #define | CS_P_NRF52 10 |
| |
| #define | CS_P_PIC32 11 |
| |
| #define | CS_P_RS14100 18 |
| |
| #define | CS_P_STM32 16 |
| |
| #define | MG_NET_IF_SOCKET 1 |
| |
| #define | MG_NET_IF_SIMPLELINK 2 |
| |
| #define | MG_NET_IF_LWIP_LOW_LEVEL 3 |
| |
| #define | MG_NET_IF_PIC32 4 |
| |
| #define | MG_NET_IF_NULL 5 |
| |
| #define | MG_SSL_IF_OPENSSL 1 |
| |
| #define | MG_SSL_IF_MBEDTLS 2 |
| |
| #define | MG_SSL_IF_SIMPLELINK 3 |
| |
| #define | PRINTF_LIKE(f, a) |
| |
| #define | WEAK |
| |
| #define | NORETURN |
| |
| #define | NOINLINE |
| |
| #define | WARN_UNUSED_RESULT |
| |
| #define | NOINSTR |
| |
| #define | DO_NOT_WARN_UNUSED |
| |
| #define | ARRAY_SIZE(array) (sizeof(array) / sizeof(array[0])) |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_WINDOWS_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_UNIX_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_ESP32_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_ESP8266_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_CC3100_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_CC3200_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_CC3220_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_MSP432_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_TM4C129_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_MBED_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_NRF51_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_NRF52_H_ |
| |
| #define | CS_COMMON_PLATFORMS_SIMPLELINK_CS_SIMPLELINK_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_WINCE_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_NXP_LPC_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_NXP_KINETIS_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_PIC32_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_RS14100_H_ |
| |
| #define | CS_COMMON_PLATFORMS_PLATFORM_STM32_H_ |
| |
| #define | CS_COMMON_PLATFORMS_LWIP_MG_LWIP_H_ |
| |
| #define | MG_LWIP 0 |
| |
| #define | CS_COMMON_MD5_H_ |
| |
| #define | CS_DISABLE_MD5 0 |
| |
| #define | CS_COMMON_SHA1_H_ |
| |
| #define | CS_DISABLE_SHA1 0 |
| |
| #define | CS_COMMON_CS_TIME_H_ |
| |
| #define | CS_COMMON_MG_STR_H_ |
| |
| #define | MG_MK_STR(str_literal) { str_literal, sizeof(str_literal) - 1 } |
| |
| #define | MG_MK_STR_N(str_literal, len) { str_literal, len } |
| |
| #define | MG_NULL_STR { NULL, 0 } |
| |
| #define | CS_COMMON_MBUF_H_ |
| |
| #define | MBUF_SIZE_MULTIPLIER 1.5 |
| |
| #define | MBUF_SIZE_MAX_HEADROOM 1024 |
| |
| #define | CS_COMMON_CS_BASE64_H_ |
| |
| #define | DISABLE_BASE64 0 |
| |
| #define | CS_COMMON_STR_UTIL_H_ |
| |
| #define | CS_ENABLE_STRDUP 0 |
| |
| #define | CS_ENABLE_TO64 0 |
| |
| #define | CS_STRINGIFY_LIT(...) #__VA_ARGS__ |
| |
| #define | CS_STRINGIFY_MACRO(x) CS_STRINGIFY_LIT(x) |
| |
| #define | _SYS_QUEUE_H_ |
| |
| #define | QMD_TRACE_ELEM(elem) |
| |
| #define | QMD_TRACE_HEAD(head) |
| |
| #define | QMD_SAVELINK(name, link) |
| |
| #define | TRACEBUF |
| |
| #define | TRACEBUF_INITIALIZER |
| |
| #define | TRASHIT(x) |
| |
| #define | QUEUE_TYPEOF(type) struct type |
| |
| #define | SLIST_HEAD(name, type) |
| |
| #define | SLIST_CLASS_HEAD(name, type) |
| |
| #define | SLIST_HEAD_INITIALIZER(head) { NULL } |
| |
| #define | SLIST_ENTRY(type) |
| |
| #define | SLIST_CLASS_ENTRY(type) |
| |
| #define | SLIST_EMPTY(head) ((head)->slh_first == NULL) |
| |
| #define | SLIST_FIRST(head) ((head)->slh_first) |
| |
| #define | SLIST_FOREACH(var, head, field) |
| |
| #define | SLIST_FOREACH_FROM(var, head, field) |
| |
| #define | SLIST_FOREACH_SAFE(var, head, field, tvar) |
| |
| #define | SLIST_FOREACH_FROM_SAFE(var, head, field, tvar) |
| |
| #define | SLIST_FOREACH_PREVPTR(var, varp, head, field) |
| |
| #define | SLIST_INIT(head) |
| |
| #define | SLIST_INSERT_AFTER(slistelm, elm, field) |
| |
| #define | SLIST_INSERT_HEAD(head, elm, field) |
| |
| #define | SLIST_NEXT(elm, field) ((elm)->field.sle_next) |
| |
| #define | SLIST_REMOVE(head, elm, type, field) |
| |
| #define | SLIST_REMOVE_AFTER(elm, field) |
| |
| #define | SLIST_REMOVE_HEAD(head, field) |
| |
| #define | SLIST_SWAP(head1, head2, type) |
| |
| #define | STAILQ_HEAD(name, type) |
| |
| #define | STAILQ_CLASS_HEAD(name, type) |
| |
| #define | STAILQ_HEAD_INITIALIZER(head) { NULL, &(head).stqh_first } |
| |
| #define | STAILQ_ENTRY(type) |
| |
| #define | STAILQ_CLASS_ENTRY(type) |
| |
| #define | STAILQ_CONCAT(head1, head2) |
| |
| #define | STAILQ_EMPTY(head) ((head)->stqh_first == NULL) |
| |
| #define | STAILQ_FIRST(head) ((head)->stqh_first) |
| |
| #define | STAILQ_FOREACH(var, head, field) |
| |
| #define | STAILQ_FOREACH_FROM(var, head, field) |
| |
| #define | STAILQ_FOREACH_SAFE(var, head, field, tvar) |
| |
| #define | STAILQ_FOREACH_FROM_SAFE(var, head, field, tvar) |
| |
| #define | STAILQ_INIT(head) |
| |
| #define | STAILQ_INSERT_AFTER(head, tqelm, elm, field) |
| |
| #define | STAILQ_INSERT_HEAD(head, elm, field) |
| |
| #define | STAILQ_INSERT_TAIL(head, elm, field) |
| |
| #define | STAILQ_LAST(head, type, field) |
| |
| #define | STAILQ_NEXT(elm, field) ((elm)->field.stqe_next) |
| |
| #define | STAILQ_REMOVE(head, elm, type, field) |
| |
| #define | STAILQ_REMOVE_AFTER(head, elm, field) |
| |
| #define | STAILQ_REMOVE_HEAD(head, field) |
| |
| #define | STAILQ_SWAP(head1, head2, type) |
| |
| #define | LIST_HEAD(name, type) |
| |
| #define | LIST_CLASS_HEAD(name, type) |
| |
| #define | LIST_HEAD_INITIALIZER(head) { NULL } |
| |
| #define | LIST_ENTRY(type) |
| |
| #define | LIST_CLASS_ENTRY(type) |
| |
| #define | QMD_LIST_CHECK_HEAD(head, field) |
| |
| #define | QMD_LIST_CHECK_NEXT(elm, field) |
| |
| #define | QMD_LIST_CHECK_PREV(elm, field) |
| |
| #define | LIST_EMPTY(head) ((head)->lh_first == NULL) |
| |
| #define | LIST_FIRST(head) ((head)->lh_first) |
| |
| #define | LIST_FOREACH(var, head, field) |
| |
| #define | LIST_FOREACH_FROM(var, head, field) |
| |
| #define | LIST_FOREACH_SAFE(var, head, field, tvar) |
| |
| #define | LIST_FOREACH_FROM_SAFE(var, head, field, tvar) |
| |
| #define | LIST_INIT(head) |
| |
| #define | LIST_INSERT_AFTER(listelm, elm, field) |
| |
| #define | LIST_INSERT_BEFORE(listelm, elm, field) |
| |
| #define | LIST_INSERT_HEAD(head, elm, field) |
| |
| #define | LIST_NEXT(elm, field) ((elm)->field.le_next) |
| |
| #define | LIST_PREV(elm, head, type, field) |
| |
| #define | LIST_REMOVE(elm, field) |
| |
| #define | LIST_SWAP(head1, head2, type, field) |
| |
| #define | TAILQ_HEAD(name, type) |
| |
| #define | TAILQ_CLASS_HEAD(name, type) |
| |
| #define | TAILQ_HEAD_INITIALIZER(head) { NULL, &(head).tqh_first, TRACEBUF_INITIALIZER } |
| |
| #define | TAILQ_ENTRY(type) |
| |
| #define | TAILQ_CLASS_ENTRY(type) |
| |
| #define | QMD_TAILQ_CHECK_HEAD(head, field) |
| |
| #define | QMD_TAILQ_CHECK_TAIL(head, headname) |
| |
| #define | QMD_TAILQ_CHECK_NEXT(elm, field) |
| |
| #define | QMD_TAILQ_CHECK_PREV(elm, field) |
| |
| #define | TAILQ_CONCAT(head1, head2, field) |
| |
| #define | TAILQ_EMPTY(head) ((head)->tqh_first == NULL) |
| |
| #define | TAILQ_FIRST(head) ((head)->tqh_first) |
| |
| #define | TAILQ_FOREACH(var, head, field) |
| |
| #define | TAILQ_FOREACH_FROM(var, head, field) |
| |
| #define | TAILQ_FOREACH_SAFE(var, head, field, tvar) |
| |
| #define | TAILQ_FOREACH_FROM_SAFE(var, head, field, tvar) |
| |
| #define | TAILQ_FOREACH_REVERSE(var, head, headname, field) |
| |
| #define | TAILQ_FOREACH_REVERSE_FROM(var, head, headname, field) |
| |
| #define | TAILQ_FOREACH_REVERSE_SAFE(var, head, headname, field, tvar) |
| |
| #define | TAILQ_FOREACH_REVERSE_FROM_SAFE(var, head, headname, field, tvar) |
| |
| #define | TAILQ_INIT(head) |
| |
| #define | TAILQ_INSERT_AFTER(head, listelm, elm, field) |
| |
| #define | TAILQ_INSERT_BEFORE(listelm, elm, field) |
| |
| #define | TAILQ_INSERT_HEAD(head, elm, field) |
| |
| #define | TAILQ_INSERT_TAIL(head, elm, field) |
| |
| #define | TAILQ_LAST(head, headname) (*(((struct headname *)((head)->tqh_last))->tqh_last)) |
| |
| #define | TAILQ_NEXT(elm, field) ((elm)->field.tqe_next) |
| |
| #define | TAILQ_PREV(elm, headname, field) (*(((struct headname *)((elm)->field.tqe_prev))->tqh_last)) |
| |
| #define | TAILQ_REMOVE(head, elm, field) |
| |
| #define | TAILQ_SWAP(head1, head2, type, field) |
| |
| #define | CS_MONGOOSE_SRC_FEATURES_H_ |
| |
| #define | MG_DISABLE_HTTP_DIGEST_AUTH 0 |
| |
| #define | MG_DISABLE_HTTP_KEEP_ALIVE 0 |
| |
| #define | MG_DISABLE_PFS 0 |
| |
| #define | MG_DISABLE_WS_RANDOM_MASK 0 |
| |
| #define | MG_ENABLE_ASYNC_RESOLVER 1 |
| |
| #define | MG_ENABLE_BROADCAST 0 |
| |
| #define | MG_ENABLE_COAP 0 |
| |
| #define | MG_ENABLE_DEBUG 0 |
| |
| #define | MG_ENABLE_DIRECTORY_LISTING 0 |
| |
| #define | MG_ENABLE_DNS 1 |
| |
| #define | MG_ENABLE_DNS_SERVER 0 |
| |
| #define | MG_ENABLE_FAKE_DAVLOCK 0 |
| |
| #define | MG_ENABLE_FILESYSTEM 0 |
| |
| #define | MG_ENABLE_GETADDRINFO 0 |
| |
| #define | MG_ENABLE_HEXDUMP CS_ENABLE_STDIO |
| |
| #define | MG_ENABLE_HTTP 1 |
| |
| #define | MG_ENABLE_HTTP_CGI 0 |
| |
| #define | MG_ENABLE_HTTP_SSI MG_ENABLE_FILESYSTEM |
| |
| #define | MG_ENABLE_HTTP_SSI_EXEC 0 |
| |
| #define | MG_ENABLE_HTTP_STREAMING_MULTIPART 0 |
| |
| #define | MG_ENABLE_HTTP_WEBDAV 0 |
| |
| #define | MG_ENABLE_HTTP_WEBSOCKET MG_ENABLE_HTTP |
| |
| #define | MG_ENABLE_IPV6 0 |
| |
| #define | MG_ENABLE_MQTT 1 |
| |
| #define | MG_ENABLE_SOCKS 0 |
| |
| #define | MG_ENABLE_MQTT_BROKER 0 |
| |
| #define | MG_ENABLE_SSL 0 |
| |
| #define | MG_ENABLE_SYNC_RESOLVER 0 |
| |
| #define | MG_ENABLE_STDIO CS_ENABLE_STDIO |
| |
| #define | MG_NET_IF MG_NET_IF_SOCKET |
| |
| #define | MG_SSL_IF MG_SSL_IF_OPENSSL |
| |
| #define | MG_ENABLE_THREADS 0 |
| |
| #define | MG_ENABLE_HTTP_URL_REWRITES (CS_PLATFORM == CS_P_WINDOWS || CS_PLATFORM == CS_P_UNIX) |
| |
| #define | MG_ENABLE_SNTP 0 |
| |
| #define | MG_ENABLE_EXTRA_ERRORS_DESC 0 |
| |
| #define | MG_ENABLE_CALLBACK_USERDATA 0 |
| |
| #define | MG_UD_ARG(ud) |
| |
| #define | MG_CB(cb, ud) cb |
| |
| #define | CS_MONGOOSE_SRC_NET_IF_H_ |
| |
| #define | MG_MAIN_IFACE 0 |
| |
| #define | CS_MONGOOSE_SRC_SSL_IF_H_ |
| |
| #define | CS_MONGOOSE_SRC_NET_H_ |
| |
| #define | MG_VPRINTF_BUFFER_SIZE 100 |
| |
| #define | MG_RECV_FUNC(s, b, l, f) recv(s, b, l, f) |
| |
| #define | MG_SEND_FUNC(s, b, l, f) send(s, b, l, f) |
| |
| #define | MG_EV_POLL 0 /* Sent to each connection on each mg_mgr_poll() call */ |
| |
| #define | MG_EV_ACCEPT 1 /* New connection accepted. union socket_address * */ |
| |
| #define | MG_EV_CONNECT 2 /* connect() succeeded or failed. int * */ |
| |
| #define | MG_EV_RECV 3 /* Data has been received. int *num_bytes */ |
| |
| #define | MG_EV_SEND 4 /* Data has been written to a socket. int *num_bytes */ |
| |
| #define | MG_EV_CLOSE 5 /* Connection is closed. NULL */ |
| |
| #define | MG_EV_TIMER 6 /* now >= conn->ev_timer_time. double * */ |
| |
| #define | MG_F_LISTENING (1 << 0) /* This connection is listening */ |
| |
| #define | MG_F_UDP (1 << 1) /* This connection is UDP */ |
| |
| #define | MG_F_RESOLVING (1 << 2) /* Waiting for async resolver */ |
| |
| #define | MG_F_CONNECTING (1 << 3) /* connect() call in progress */ |
| |
| #define | MG_F_SSL (1 << 4) /* SSL is enabled on the connection */ |
| |
| #define | MG_F_SSL_HANDSHAKE_DONE (1 << 5) /* SSL hanshake has completed */ |
| |
| #define | MG_F_WANT_READ (1 << 6) /* SSL specific */ |
| |
| #define | MG_F_WANT_WRITE (1 << 7) /* SSL specific */ |
| |
| #define | MG_F_IS_WEBSOCKET (1 << 8) /* Websocket specific */ |
| |
| #define | MG_F_RECV_AND_CLOSE (1 << 9) /* Drain rx and close the connection. */ |
| |
| #define | MG_F_SEND_AND_CLOSE (1 << 10) /* Push remaining data and close */ |
| |
| #define | MG_F_CLOSE_IMMEDIATELY (1 << 11) /* Disconnect */ |
| |
| #define | MG_F_WEBSOCKET_NO_DEFRAG (1 << 12) /* Websocket specific */ |
| |
| #define | MG_F_DELETE_CHUNK (1 << 13) /* HTTP specific */ |
| |
| #define | MG_F_ENABLE_BROADCAST (1 << 14) /* Allow broadcast address usage */ |
| |
| #define | MG_F_USER_1 (1 << 20) /* Flags left for application */ |
| |
| #define | MG_F_USER_2 (1 << 21) |
| |
| #define | MG_F_USER_3 (1 << 22) |
| |
| #define | MG_F_USER_4 (1 << 23) |
| |
| #define | MG_F_USER_5 (1 << 24) |
| |
| #define | MG_F_USER_6 (1 << 25) |
| |
| #define | CS_MONGOOSE_SRC_URI_H_ |
| |
| #define | CS_MONGOOSE_SRC_UTIL_H_ |
| |
| #define | MG_MAX_PATH 256 |
| |
| #define | MG_SOCK_STRINGIFY_IP 1 |
| |
| #define | MG_SOCK_STRINGIFY_PORT 2 |
| |
| #define | MG_SOCK_STRINGIFY_REMOTE 4 |
| |
| #define | MG_URL_ENCODE_F_SPACE_AS_PLUS (1 << 0) |
| |
| #define | MG_URL_ENCODE_F_UPPERCASE_HEX (1 << 1) |
| |
| #define | CS_MONGOOSE_SRC_HTTP_H_ |
| |
| #define | MG_MAX_HTTP_HEADERS 20 |
| |
| #define | MG_MAX_HTTP_REQUEST_SIZE 1024 |
| |
| #define | MG_MAX_HTTP_SEND_MBUF 1024 |
| |
| #define | MG_CGI_ENVIRONMENT_SIZE 8192 |
| |
| #define | MG_EV_HTTP_REQUEST 100 /* struct http_message * */ |
| |
| #define | MG_EV_HTTP_REPLY 101 /* struct http_message * */ |
| |
| #define | MG_EV_HTTP_CHUNK 102 /* struct http_message * */ |
| |
| #define | MG_EV_SSI_CALL 105 /* char * */ |
| |
| #define | MG_EV_SSI_CALL_CTX 106 /* struct mg_ssi_call_ctx * */ |
| |
| #define | MG_EV_WEBSOCKET_HANDSHAKE_REQUEST 111 /* struct http_message * */ |
| |
| #define | MG_EV_WEBSOCKET_HANDSHAKE_DONE 112 /* struct http_message * */ |
| |
| #define | MG_EV_WEBSOCKET_FRAME 113 /* struct websocket_message * */ |
| |
| #define | MG_EV_WEBSOCKET_CONTROL_FRAME 114 /* struct websocket_message * */ |
| |
| #define | WEBSOCKET_OP_CONTINUE 0 |
| |
| #define | WEBSOCKET_OP_TEXT 1 |
| |
| #define | WEBSOCKET_OP_BINARY 2 |
| |
| #define | WEBSOCKET_OP_CLOSE 8 |
| |
| #define | WEBSOCKET_OP_PING 9 |
| |
| #define | WEBSOCKET_OP_PONG 10 |
| |
| #define | WEBSOCKET_DONT_FIN 0x100 |
| |
| #define | MG_AUTH_FLAG_IS_DIRECTORY (1 << 0) |
| |
| #define | MG_AUTH_FLAG_IS_GLOBAL_PASS_FILE (1 << 1) |
| |
| #define | MG_AUTH_FLAG_ALLOW_MISSING_FILE (1 << 2) |
| |
| #define | CS_MONGOOSE_SRC_HTTP_SERVER_H_ |
| |
| #define | CS_MONGOOSE_SRC_HTTP_CLIENT_H_ |
| |
| #define | CS_MONGOOSE_SRC_MQTT_H_ |
| |
| #define | MG_MQTT_CMD_CONNECT 1 |
| |
| #define | MG_MQTT_CMD_CONNACK 2 |
| |
| #define | MG_MQTT_CMD_PUBLISH 3 |
| |
| #define | MG_MQTT_CMD_PUBACK 4 |
| |
| #define | MG_MQTT_CMD_PUBREC 5 |
| |
| #define | MG_MQTT_CMD_PUBREL 6 |
| |
| #define | MG_MQTT_CMD_PUBCOMP 7 |
| |
| #define | MG_MQTT_CMD_SUBSCRIBE 8 |
| |
| #define | MG_MQTT_CMD_SUBACK 9 |
| |
| #define | MG_MQTT_CMD_UNSUBSCRIBE 10 |
| |
| #define | MG_MQTT_CMD_UNSUBACK 11 |
| |
| #define | MG_MQTT_CMD_PINGREQ 12 |
| |
| #define | MG_MQTT_CMD_PINGRESP 13 |
| |
| #define | MG_MQTT_CMD_DISCONNECT 14 |
| |
| #define | MG_MQTT_EVENT_BASE 200 |
| |
| #define | MG_EV_MQTT_CONNECT (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_CONNECT) |
| |
| #define | MG_EV_MQTT_CONNACK (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_CONNACK) |
| |
| #define | MG_EV_MQTT_PUBLISH (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_PUBLISH) |
| |
| #define | MG_EV_MQTT_PUBACK (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_PUBACK) |
| |
| #define | MG_EV_MQTT_PUBREC (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_PUBREC) |
| |
| #define | MG_EV_MQTT_PUBREL (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_PUBREL) |
| |
| #define | MG_EV_MQTT_PUBCOMP (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_PUBCOMP) |
| |
| #define | MG_EV_MQTT_SUBSCRIBE (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_SUBSCRIBE) |
| |
| #define | MG_EV_MQTT_SUBACK (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_SUBACK) |
| |
| #define | MG_EV_MQTT_UNSUBSCRIBE (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_UNSUBSCRIBE) |
| |
| #define | MG_EV_MQTT_UNSUBACK (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_UNSUBACK) |
| |
| #define | MG_EV_MQTT_PINGREQ (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_PINGREQ) |
| |
| #define | MG_EV_MQTT_PINGRESP (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_PINGRESP) |
| |
| #define | MG_EV_MQTT_DISCONNECT (MG_MQTT_EVENT_BASE + MG_MQTT_CMD_DISCONNECT) |
| |
| #define | MG_MQTT_RETAIN 0x1 |
| |
| #define | MG_MQTT_DUP 0x4 |
| |
| #define | MG_MQTT_QOS(qos) ((qos) << 1) |
| |
| #define | MG_MQTT_GET_QOS(flags) (((flags) &0x6) >> 1) |
| |
| #define | MG_MQTT_SET_QOS(flags, qos) (flags) = ((flags) & ~0x6) | ((qos) << 1) |
| |
| #define | MG_MQTT_CLEAN_SESSION 0x02 |
| |
| #define | MG_MQTT_HAS_WILL 0x04 |
| |
| #define | MG_MQTT_WILL_RETAIN 0x20 |
| |
| #define | MG_MQTT_HAS_PASSWORD 0x40 |
| |
| #define | MG_MQTT_HAS_USER_NAME 0x80 |
| |
| #define | MG_MQTT_GET_WILL_QOS(flags) (((flags) &0x18) >> 3) |
| |
| #define | MG_MQTT_SET_WILL_QOS(flags, qos) (flags) = ((flags) & ~0x18) | ((qos) << 3) |
| |
| #define | MG_EV_MQTT_CONNACK_ACCEPTED 0 |
| |
| #define | MG_EV_MQTT_CONNACK_UNACCEPTABLE_VERSION 1 |
| |
| #define | MG_EV_MQTT_CONNACK_IDENTIFIER_REJECTED 2 |
| |
| #define | MG_EV_MQTT_CONNACK_SERVER_UNAVAILABLE 3 |
| |
| #define | MG_EV_MQTT_CONNACK_BAD_AUTH 4 |
| |
| #define | MG_EV_MQTT_CONNACK_NOT_AUTHORIZED 5 |
| |
| #define | CS_MONGOOSE_SRC_MQTT_BROKER_H_ |
| |
| #define | CS_MONGOOSE_SRC_DNS_H_ |
| |
| #define | MG_DNS_A_RECORD 0x01 /* Lookup IP address */ |
| |
| #define | MG_DNS_CNAME_RECORD 0x05 /* Lookup CNAME */ |
| |
| #define | MG_DNS_PTR_RECORD 0x0c /* Lookup PTR */ |
| |
| #define | MG_DNS_TXT_RECORD 0x10 /* Lookup TXT */ |
| |
| #define | MG_DNS_AAAA_RECORD 0x1c /* Lookup IPv6 address */ |
| |
| #define | MG_DNS_SRV_RECORD 0x21 /* Lookup SRV */ |
| |
| #define | MG_DNS_MX_RECORD 0x0f /* Lookup mail server for domain */ |
| |
| #define | MG_DNS_ANY_RECORD 0xff |
| |
| #define | MG_DNS_NSEC_RECORD 0x2f |
| |
| #define | MG_MAX_DNS_QUESTIONS 32 |
| |
| #define | MG_MAX_DNS_ANSWERS 32 |
| |
| #define | MG_DNS_MESSAGE 100 /* High-level DNS message event */ |
| |
| #define | CS_MONGOOSE_SRC_DNS_SERVER_H_ |
| |
| #define | CS_MONGOOSE_SRC_RESOLV_H_ |
| |
| #define | CS_MONGOOSE_SRC_COAP_H_ |
| |
| #define | CS_MONGOOSE_SRC_SNTP_H_ |
| |
| #define | CS_MONGOOSE_SRC_SOCKS_H_ |
| |
|
| void | cs_md5_init (cs_md5_ctx *c) |
| |
| void | cs_md5_update (cs_md5_ctx *c, const unsigned char *data, size_t len) |
| |
| void | cs_md5_final (unsigned char *md, cs_md5_ctx *c) |
| |
| void | cs_sha1_init (cs_sha1_ctx *) |
| |
| void | cs_sha1_update (cs_sha1_ctx *, const unsigned char *data, uint32_t len) |
| |
| void | cs_sha1_final (unsigned char digest[20], cs_sha1_ctx *) |
| |
| void | cs_hmac_sha1 (const unsigned char *key, size_t key_len, const unsigned char *text, size_t text_len, unsigned char out[20]) |
| |
| double | cs_time (void) |
| |
| double | cs_timegm (const struct tm *tm) |
| |
| struct mg_str | mg_mk_str (const char *s) |
| |
| struct mg_str | mg_mk_str_n (const char *s, size_t len) |
| |
| int | mg_vcmp (const struct mg_str *str2, const char *str1) |
| |
| int | mg_vcasecmp (const struct mg_str *str2, const char *str1) |
| |
| struct mg_str | mg_strdup (const struct mg_str s) |
| |
| struct mg_str | mg_strdup_nul (const struct mg_str s) |
| |
| const char * | mg_strchr (const struct mg_str s, int c) |
| |
| int | mg_strcmp (const struct mg_str str1, const struct mg_str str2) |
| |
| int | mg_strncmp (const struct mg_str str1, const struct mg_str str2, size_t n) |
| |
| void | mg_strfree (struct mg_str *s) |
| |
| const char * | mg_strstr (const struct mg_str haystack, const struct mg_str needle) |
| |
| struct mg_str | mg_strstrip (struct mg_str s) |
| |
| int | mg_str_starts_with (struct mg_str s, struct mg_str prefix) |
| |
| void | mbuf_init (struct mbuf *, size_t initial_capacity) |
| |
| void | mbuf_free (struct mbuf *) |
| |
| size_t | mbuf_append (struct mbuf *, const void *data, size_t data_size) |
| |
| size_t | mbuf_append_and_free (struct mbuf *, void *data, size_t data_size) |
| |
| size_t | mbuf_insert (struct mbuf *, size_t, const void *, size_t) |
| |
| void | mbuf_remove (struct mbuf *, size_t data_size) |
| |
| void | mbuf_resize (struct mbuf *, size_t new_size) |
| |
| void | mbuf_move (struct mbuf *from, struct mbuf *to) |
| |
| void | mbuf_clear (struct mbuf *) |
| |
| void | mbuf_trim (struct mbuf *) |
| |
| void | cs_base64_init (struct cs_base64_ctx *ctx, cs_base64_putc_t putc, void *user_data) |
| |
| void | cs_base64_update (struct cs_base64_ctx *ctx, const char *str, size_t len) |
| |
| void | cs_base64_finish (struct cs_base64_ctx *ctx) |
| |
| void | cs_base64_encode (const unsigned char *src, int src_len, char *dst) |
| |
| void | cs_fprint_base64 (FILE *f, const unsigned char *src, int src_len) |
| |
| int | cs_base64_decode (const unsigned char *s, int len, char *dst, int *dec_len) |
| |
| size_t | c_strnlen (const char *s, size_t maxlen) |
| |
| int | c_snprintf (char *buf, size_t buf_size, const char *format,...) PRINTF_LIKE(3 |
| |
| int int | c_vsnprintf (char *buf, size_t buf_size, const char *format, va_list ap) |
| |
| const char * | c_strnstr (const char *s, const char *find, size_t slen) |
| |
| void | cs_to_hex (char *to, const unsigned char *p, size_t len) |
| |
| void | cs_from_hex (char *to, const char *p, size_t len) |
| |
| int | mg_ncasecmp (const char *s1, const char *s2, size_t len) |
| |
| int | mg_casecmp (const char *s1, const char *s2) |
| |
| int | mg_asprintf (char **buf, size_t size, const char *fmt,...) PRINTF_LIKE(3 |
| |
| int int | mg_avprintf (char **buf, size_t size, const char *fmt, va_list ap) |
| |
| const char * | mg_next_comma_list_entry (const char *list, struct mg_str *val, struct mg_str *eq_val) |
| |
| struct mg_str | mg_next_comma_list_entry_n (struct mg_str list, struct mg_str *val, struct mg_str *eq_val) |
| |
| size_t | mg_match_prefix (const char *pattern, int pattern_len, const char *str) |
| |
| size_t | mg_match_prefix_n (const struct mg_str pattern, const struct mg_str str) |
| |
| struct mg_iface * | mg_if_create_iface (const struct mg_iface_vtable *vtable, struct mg_mgr *mgr) |
| |
| struct mg_iface * | mg_find_iface (struct mg_mgr *mgr, const struct mg_iface_vtable *vtable, struct mg_iface *from) |
| |
| struct mg_connection * | mg_if_accept_new_conn (struct mg_connection *lc) |
| |
| void | mg_if_accept_tcp_cb (struct mg_connection *nc, union socket_address *sa, size_t sa_len) |
| |
| void | mg_if_connect_cb (struct mg_connection *nc, int err) |
| |
| void | mg_if_can_recv_cb (struct mg_connection *nc) |
| |
| void | mg_if_can_send_cb (struct mg_connection *nc) |
| |
| void | mg_if_recv_udp_cb (struct mg_connection *nc, void *buf, int len, union socket_address *sa, size_t sa_len) |
| |
| int | mg_if_poll (struct mg_connection *nc, double now) |
| |
| double | mg_mgr_min_timer (const struct mg_mgr *mgr) |
| |
| void | mg_mgr_init (struct mg_mgr *mgr, void *user_data) |
| |
| void | mg_mgr_init_opt (struct mg_mgr *mgr, void *user_data, struct mg_mgr_init_opts opts) |
| |
| void | mg_mgr_free (struct mg_mgr *mgr) |
| |
| int | mg_mgr_poll (struct mg_mgr *mgr, int milli) |
| |
| struct mg_connection * | mg_next (struct mg_mgr *mgr, struct mg_connection *c) |
| |
| struct mg_connection * | mg_add_sock (struct mg_mgr *mgr, sock_t sock, MG_CB(mg_event_handler_t handler, void *user_data)) |
| |
| struct mg_connection * | mg_add_sock_opt (struct mg_mgr *mgr, sock_t sock, MG_CB(mg_event_handler_t handler, void *user_data), struct mg_add_sock_opts opts) |
| |
| struct mg_connection * | mg_bind (struct mg_mgr *mgr, const char *address, MG_CB(mg_event_handler_t handler, void *user_data)) |
| |
| struct mg_connection * | mg_bind_opt (struct mg_mgr *mgr, const char *address, MG_CB(mg_event_handler_t handler, void *user_data), struct mg_bind_opts opts) |
| |
| struct mg_connection * | mg_connect (struct mg_mgr *mgr, const char *address, MG_CB(mg_event_handler_t handler, void *user_data)) |
| |
| struct mg_connection * | mg_connect_opt (struct mg_mgr *mgr, const char *address, MG_CB(mg_event_handler_t handler, void *user_data), struct mg_connect_opts opts) |
| |
| void | mg_send (struct mg_connection *, const void *buf, int len) |
| |
| int | mg_printf (struct mg_connection *, const char *fmt,...) |
| |
| int | mg_vprintf (struct mg_connection *, const char *fmt, va_list ap) |
| |
| int | mg_socketpair (sock_t[2], int sock_type) |
| |
| int | mg_check_ip_acl (const char *acl, uint32_t remote_ip) |
| |
| double | mg_set_timer (struct mg_connection *c, double timestamp) |
| |
| double | mg_time (void) |
| |
| int | mg_parse_uri (const struct mg_str uri, struct mg_str *scheme, struct mg_str *user_info, struct mg_str *host, unsigned int *port, struct mg_str *path, struct mg_str *query, struct mg_str *fragment) |
| |
| int | mg_assemble_uri (const struct mg_str *scheme, const struct mg_str *user_info, const struct mg_str *host, unsigned int port, const struct mg_str *path, const struct mg_str *query, const struct mg_str *fragment, int normalize_path, struct mg_str *uri) |
| |
| int | mg_normalize_uri_path (const struct mg_str *in, struct mg_str *out) |
| |
| const char * | mg_skip (const char *s, const char *end_string, const char *delimiters, struct mg_str *v) |
| |
| int | mg_base64_decode (const unsigned char *s, int len, char *dst) |
| |
| void | mg_base64_encode (const unsigned char *src, int src_len, char *dst) |
| |
| void | mg_set_close_on_exec (sock_t) |
| |
| int | mg_conn_addr_to_str (struct mg_connection *c, char *buf, size_t len, int flags) |
| |
| void | mg_sock_to_str (sock_t sock, char *buf, size_t len, int flags) |
| |
| int | mg_sock_addr_to_str (const union socket_address *sa, char *buf, size_t len, int flags) |
| |
| int | mg_is_big_endian (void) |
| |
| void | mg_mbuf_append_base64_putc (char ch, void *user_data) |
| |
| void | mg_mbuf_append_base64 (struct mbuf *mbuf, const void *data, size_t len) |
| |
| void | mg_basic_auth_header (const struct mg_str user, const struct mg_str pass, struct mbuf *buf) |
| |
| struct mg_str | mg_url_encode_opt (const struct mg_str src, const struct mg_str safe, unsigned int flags) |
| |
| struct mg_str | mg_url_encode (const struct mg_str src) |
| |
| void | mg_set_protocol_http_websocket (struct mg_connection *nc) |
| |
| void | mg_send_websocket_handshake (struct mg_connection *nc, const char *uri, const char *extra_headers) |
| |
| void | mg_send_websocket_handshake2 (struct mg_connection *nc, const char *path, const char *host, const char *protocol, const char *extra_headers) |
| |
| void | mg_send_websocket_handshake3 (struct mg_connection *nc, const char *path, const char *host, const char *protocol, const char *extra_headers, const char *user, const char *pass) |
| |
| void | mg_send_websocket_handshake3v (struct mg_connection *nc, const struct mg_str path, const struct mg_str host, const struct mg_str protocol, const struct mg_str extra_headers, const struct mg_str user, const struct mg_str pass) |
| |
| struct mg_connection * | mg_connect_ws (struct mg_mgr *mgr, MG_CB(mg_event_handler_t event_handler, void *user_data), const char *url, const char *protocol, const char *extra_headers) |
| |
| struct mg_connection * | mg_connect_ws_opt (struct mg_mgr *mgr, MG_CB(mg_event_handler_t ev_handler, void *user_data), struct mg_connect_opts opts, const char *url, const char *protocol, const char *extra_headers) |
| |
| void | mg_send_websocket_frame (struct mg_connection *nc, int op_and_flags, const void *data, size_t data_len) |
| |
| void | mg_send_websocket_framev (struct mg_connection *nc, int op_and_flags, const struct mg_str *strings, int num_strings) |
| |
| void | mg_printf_websocket_frame (struct mg_connection *nc, int op_and_flags, const char *fmt,...) |
| |
| int | mg_url_decode (const char *src, int src_len, char *dst, int dst_len, int is_form_url_encoded) |
| |
| void | mg_hash_md5_v (size_t num_msgs, const uint8_t *msgs[], const size_t *msg_lens, uint8_t *digest) |
| |
| void | mg_hash_sha1_v (size_t num_msgs, const uint8_t *msgs[], const size_t *msg_lens, uint8_t *digest) |
| |
| int | mg_http_is_authorized (struct http_message *hm, struct mg_str path, const char *domain, const char *passwords_file, int flags) |
| |
| void | mg_http_send_digest_auth_request (struct mg_connection *c, const char *domain) |
| |
| int | mg_parse_http (const char *s, int n, struct http_message *hm, int is_req) |
| |
| struct mg_str * | mg_get_http_header (struct http_message *hm, const char *name) |
| |
| int | mg_http_parse_header2 (struct mg_str *hdr, const char *var_name, char **buf, size_t buf_size) |
| |
| int | mg_http_parse_header (struct mg_str *hdr, const char *var_name, char *buf, size_t buf_size) |
| |
| int | mg_get_http_basic_auth (struct http_message *hm, char *user, size_t user_len, char *pass, size_t pass_len) |
| |
| int | mg_parse_http_basic_auth (struct mg_str *hdr, char *user, size_t user_len, char *pass, size_t pass_len) |
| |
| size_t | mg_parse_multipart (const char *buf, size_t buf_len, char *var_name, size_t var_name_len, char *file_name, size_t file_name_len, const char **chunk, size_t *chunk_len) |
| |
| int | mg_get_http_var (const struct mg_str *buf, const char *name, char *dst, size_t dst_len) |
| |
| void | mg_register_http_endpoint (struct mg_connection *nc, const char *uri_path, MG_CB(mg_event_handler_t handler, void *user_data)) |
| |
| void | mg_register_http_endpoint_opt (struct mg_connection *nc, const char *uri_path, mg_event_handler_t handler, struct mg_http_endpoint_opts opts) |
| |
| int | mg_http_check_digest_auth (struct http_message *hm, const char *auth_domain, FILE *fp) |
| |
| int | mg_check_digest_auth (struct mg_str method, struct mg_str uri, struct mg_str username, struct mg_str cnonce, struct mg_str response, struct mg_str qop, struct mg_str nc, struct mg_str nonce, struct mg_str auth_domain, FILE *fp) |
| |
| void | mg_send_http_chunk (struct mg_connection *nc, const char *buf, size_t len) |
| |
| void | mg_printf_http_chunk (struct mg_connection *nc, const char *fmt,...) |
| |
| void | mg_send_response_line (struct mg_connection *nc, int status_code, const char *extra_headers) |
| |
| void | mg_http_send_error (struct mg_connection *nc, int code, const char *reason) |
| |
| void | mg_http_send_redirect (struct mg_connection *nc, int status_code, const struct mg_str location, const struct mg_str extra_headers) |
| |
| void | mg_send_head (struct mg_connection *n, int status_code, int64_t content_length, const char *extra_headers) |
| |
| void | mg_printf_html_escape (struct mg_connection *nc, const char *fmt,...) |
| |
| struct mg_connection * | mg_connect_http (struct mg_mgr *mgr, MG_CB(mg_event_handler_t event_handler, void *user_data), const char *url, const char *extra_headers, const char *post_data) |
| |
| struct mg_connection * | mg_connect_http_opt (struct mg_mgr *mgr, MG_CB(mg_event_handler_t ev_handler, void *user_data), struct mg_connect_opts opts, const char *url, const char *extra_headers, const char *post_data) |
| |
| int | mg_http_create_digest_auth_header (char *buf, size_t buf_len, const char *method, const char *uri, const char *auth_domain, const char *user, const char *passwd, const char *nonce) |
| |
| void | mg_set_protocol_mqtt (struct mg_connection *nc) |
| |
| void | mg_send_mqtt_handshake (struct mg_connection *nc, const char *client_id) |
| |
| void | mg_send_mqtt_handshake_opt (struct mg_connection *nc, const char *client_id, struct mg_send_mqtt_handshake_opts) |
| |
| void | mg_mqtt_publish (struct mg_connection *nc, const char *topic, uint16_t message_id, int flags, const void *data, size_t len) |
| |
| void | mg_mqtt_subscribe (struct mg_connection *nc, const struct mg_mqtt_topic_expression *topics, size_t topics_len, uint16_t message_id) |
| |
| void | mg_mqtt_unsubscribe (struct mg_connection *nc, char **topics, size_t topics_len, uint16_t message_id) |
| |
| void | mg_mqtt_disconnect (struct mg_connection *nc) |
| |
| void | mg_mqtt_connack (struct mg_connection *nc, uint8_t return_code) |
| |
| void | mg_mqtt_puback (struct mg_connection *nc, uint16_t message_id) |
| |
| void | mg_mqtt_pubrec (struct mg_connection *nc, uint16_t message_id) |
| |
| void | mg_mqtt_pubrel (struct mg_connection *nc, uint16_t message_id) |
| |
| void | mg_mqtt_pubcomp (struct mg_connection *nc, uint16_t message_id) |
| |
| void | mg_mqtt_suback (struct mg_connection *nc, uint8_t *qoss, size_t qoss_len, uint16_t message_id) |
| |
| void | mg_mqtt_unsuback (struct mg_connection *nc, uint16_t message_id) |
| |
| void | mg_mqtt_ping (struct mg_connection *nc) |
| |
| void | mg_mqtt_pong (struct mg_connection *nc) |
| |
| int | mg_mqtt_next_subscribe_topic (struct mg_mqtt_message *msg, struct mg_str *topic, uint8_t *qos, int pos) |
| |
| int | mg_mqtt_match_topic_expression (struct mg_str exp, struct mg_str topic) |
| |
| int | mg_mqtt_vmatch_topic_expression (const char *exp, struct mg_str topic) |
| |
| struct mg_dns_resource_record * | mg_dns_next_record (struct mg_dns_message *msg, int query, struct mg_dns_resource_record *prev) |
| |
| int | mg_dns_parse_record_data (struct mg_dns_message *msg, struct mg_dns_resource_record *rr, void *data, size_t data_len) |
| |
| void | mg_send_dns_query (struct mg_connection *nc, const char *name, int query_type) |
| |
| int | mg_dns_insert_header (struct mbuf *io, size_t pos, struct mg_dns_message *msg) |
| |
| int | mg_dns_copy_questions (struct mbuf *io, struct mg_dns_message *msg) |
| |
| int | mg_dns_encode_record (struct mbuf *io, struct mg_dns_resource_record *rr, const char *name, size_t nlen, const void *rdata, size_t rlen) |
| |
| int | mg_dns_encode_name (struct mbuf *io, const char *name, size_t len) |
| |
| int | mg_parse_dns (const char *buf, int len, struct mg_dns_message *msg) |
| |
| size_t | mg_dns_uncompress_name (struct mg_dns_message *msg, struct mg_str *name, char *dst, int dst_len) |
| |
| void | mg_set_protocol_dns (struct mg_connection *nc) |
| |
| int | mg_resolve_async (struct mg_mgr *mgr, const char *name, int query, mg_resolve_callback_t cb, void *data) |
| |
| void | mg_set_nameserver (struct mg_mgr *mgr, const char *nameserver) |
| |
| int | mg_resolve_async_opt (struct mg_mgr *mgr, const char *name, int query, mg_resolve_callback_t cb, void *data, struct mg_resolve_async_opts opts) |
| |
| int | mg_resolve_from_hosts_file (const char *host, union socket_address *usa) |
| |