| /third_party/lwip/src/include/lwip/apps/ |
| H A D | mqtt.h | 189 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub);
193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1)
198 err_t mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
|
| /third_party/libwebsockets/include/libwebsockets/ |
| H A D | lws-mqtt.h | 79 uint8_t qos:2; member
107 lws_mqtt_qos_levels_t qos; member
114 lws_mqtt_qos_levels_t qos; member
133 lws_mqtt_qos_levels_t qos; member
145 lws_mqtt_qos_levels_t qos; /* Requested QoS */ member
326 * frame contains the header, and uses the .qos and .payload_len parts of \p pub
|
| H A D | lws-secure-streams-policy.h | 319 uint8_t qos; member
|
| /third_party/libwebsockets/lib/secure-streams/protocols/ |
| H A D | ss-mqtt.c | 118 h->u.mqtt.sub_top.qos = h->policy->u.mqtt.qos; in secstream_mqtt_subscribe()
125 h->u.mqtt.sub_info.topic[0].qos = h->policy->u.mqtt.qos; in secstream_mqtt_subscribe()
147 lws_mqtt_qos_levels_t qos, uint8_t retain, uint8_t dup, in secstream_mqtt_publish()
192 mqpp.qos = qos; in secstream_mqtt_publish()
214 if ((mqpp.qos == QOS1 || mqpp.qos == QOS2) && buf_len > 0) { in secstream_mqtt_publish()
278 h->policy->u.mqtt.qos, in secstream_mqtt_resend()
145 secstream_mqtt_publish(struct lws *wsi, uint8_t *buf, size_t buf_len, uint32_t payload_len, const char* topic, lws_mqtt_qos_levels_t qos, uint8_t retain, uint8_t dup, int f) secstream_mqtt_publish() argument
[all...] |
| /third_party/libuv/src/ |
| H A D | threadpool.c | 634 int qos = (ffrt_qos_t)(intptr_t)req->reserved[0]; in uv__work_cancel() local
640 addr->post_task_func(addr->event_handler, uv__task_done_wrapper, (void*)w, status, qos); in uv__work_cancel()
642 uv__queue_insert_tail(&(lfields->wq_sub[qos]), &w->wq); in uv__work_cancel()
758 void uv__ffrt_work(ffrt_executor_task_t* data, ffrt_qos_t qos) in uv__ffrt_work() argument
788 addr->post_task_func(addr->event_handler, uv__task_done_wrapper, (void*)w, status, qos); in uv__ffrt_work()
791 uv__queue_insert_tail(&(lfields->wq_sub[qos]), &w->wq); in uv__ffrt_work()
851 ffrt_qos_t qos, in uv__work_submit_with_qos()
857 ffrt_task_attr_set_qos(&attr, qos); in uv__work_submit_with_qos()
916 uv_qos_t qos) { in uv_queue_work_with_qos()
925 if (qos < ffrt_qos_backgroun in uv_queue_work_with_qos()
848 uv__work_submit_with_qos(uv_loop_t* loop, uv_req_t* req, struct uv__work* w, ffrt_qos_t qos, void (*work)(struct uv__work *w), void (*done)(struct uv__work *w, int status)) uv__work_submit_with_qos() argument
912 uv_queue_work_with_qos(uv_loop_t* loop, uv_work_t* req, uv_work_cb work_cb, uv_after_work_cb after_work_cb, uv_qos_t qos) uv_queue_work_with_qos() argument
[all...] |
| /third_party/lwip/src/apps/mqtt/ |
| H A D | mqtt.c | 109 /** Helpers to extract control packet type and qos from first byte in fixed header */
631 * @param qos QoS value
635 pub_ack_rec_rel_response(mqtt_client_t *client, u8_t msg, u16_t pkt_id, u8_t qos) in pub_ack_rec_rel_response() argument
639 mqtt_output_append_fixed_header(&client->output, msg, 0, qos, 0, 2); in pub_ack_rec_rel_response()
714 u8_t qos = MQTT_CTL_PACKET_QOS(client->rx_buffer[0]); in mqtt_message_received() local
722 u16_t qos_len = (qos ? 2U : 0U); in mqtt_message_received()
738 if ((after_topic + (qos ? 2U : 1U)) > var_hdr_payload_bufsize) { in mqtt_message_received()
744 if (qos > 0) { in mqtt_message_received()
763 qos, topic, remaining_length + payload_length)); in mqtt_message_received()
779 if (remaining_length == 0 && qos > in mqtt_message_received()
1096 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain, mqtt_request_cb_t cb, void *arg) mqtt_publish() argument
1172 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub) mqtt_sub_unsub() argument
[all...] |
| /third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client/ |
| H A D | minimal-mqtt-client.c | 50 .qos = 0,
60 [0] = { .name = "test/topic0", .qos = QOS0 },
61 [1] = { .name = "test/topic1", .qos = QOS1 },
218 pub_param.qos = pss->state == STATE_PUBLISH_QOS0 ? QOS0 : QOS1; in callback_mqtt()
|
| /third_party/libwebsockets/lib/roles/mqtt/ |
| H A D | mqtt.c | 175 * For each command index, maps flags, id, qos and payload legality
883 pub->qos = (lws_mqtt_qos_levels_t) in _lws_mqtt_rx_parser()
889 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser()
891 switch (pub->qos) { in _lws_mqtt_rx_parser()
929 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser()
1092 lws_mqtt_qos_levels_t qos = (lws_mqtt_qos_levels_t)*buf++; in _lws_mqtt_rx_parser() local
1095 switch (qos) { in _lws_mqtt_rx_parser()
1682 if (pub->qos == 1) { in _lws_mqtt_rx_parser()
1686 } else if (pub->qos == 2) { in _lws_mqtt_rx_parser()
1894 uint8_t dup, lws_mqtt_qos_levels_t qos, in lws_mqtt_fill_fixed_header()
1893 lws_mqtt_fill_fixed_header(uint8_t *p, lws_mqtt_control_packet_t ctrl_pkt_type, uint8_t dup, lws_mqtt_qos_levels_t qos, uint8_t retain) lws_mqtt_fill_fixed_header() argument
[all...] |
| H A D | private-lib-roles-mqtt.h | 346 lws_mqtt_qos_levels_t qos; member
436 uint8_t dup, lws_mqtt_qos_levels_t qos,
|
| /third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client-multi/ |
| H A D | minimal-mqtt-client-multi.c | 62 .qos = 0,
70 [0] = { .name = "test/topic0", .qos = QOS0 },
71 [1] = { .name = "test/topic1", .qos = QOS1 },
276 pss->pub_param.qos = in callback_mqtt()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/ap/ |
| H A D | ap_drv_ops.h | 257 int qos) in hostapd_drv_poll_client()
261 hapd->driver->poll_client(hapd->drv_priv, own_addr, addr, qos); in hostapd_drv_poll_client()
255 hostapd_drv_poll_client(struct hostapd_data *hapd, const u8 *own_addr, const u8 *addr, int qos) hostapd_drv_poll_client() argument
|
| /third_party/libbpf/include/uapi/linux/ |
| H A D | if_link.h | 1054 __u32 qos; member
1069 __u32 qos; member
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-policy2c/ |
| H A D | minimal-secure-streams.c | 597 if (pol->u.mqtt.qos) in main()
598 printf("\t\t\t.qos = %u,\n", in main()
599 pol->u.mqtt.qos); in main()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/ap/ |
| H A D | ap_drv_ops.h | 262 int qos) in hostapd_drv_poll_client()
266 hapd->driver->poll_client(hapd->drv_priv, own_addr, addr, qos); in hostapd_drv_poll_client()
260 hostapd_drv_poll_client(struct hostapd_data *hapd, const u8 *own_addr, const u8 *addr, int qos) hostapd_drv_poll_client() argument
|
| /third_party/libwebsockets/lib/roles/mqtt/client/ |
| H A D | client-mqtt.c | 149 c->conn_flags = (uint16_t)(unsigned int)(c->conn_flags | ((cp->will_param.qos << 3) & LMQCFT_WILL_QOS_MASK)); in lws_create_client_mqtt_object()
|
| /third_party/libuv/src/unix/ |
| H A D | linux.c | 66 ffrt_qos_t qos = ffrt_this_task_get_qos(); in uv__epoll_wait() local
67 nfds = ffrt_epoll_wait(qos, events, eventsize, timeout); in uv__epoll_wait()
76 ffrt_qos_t qos = ffrt_this_task_get_qos(); in uv__epoll_ctl() local
77 return ffrt_epoll_ctl(qos, op, fd, event == NULL ? 0 : event->events, NULL, NULL); in uv__epoll_ctl()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/drivers/ |
| H A D | driver_nl80211.c | 5089 int qos = flags & WPA_STA_WMM; in wpa_driver_nl80211_hapd_send_eapol() local
5094 len = sizeof(*hdr) + (qos ? 2 : 0) + sizeof(rfc1042_header) + 2 + in wpa_driver_nl80211_hapd_send_eapol()
5108 if (qos) { in wpa_driver_nl80211_hapd_send_eapol()
5118 if (qos) { in wpa_driver_nl80211_hapd_send_eapol()
8299 const u8 *addr, int qos) in nl80211_send_null_frame()
8313 if (qos) { in nl80211_send_null_frame()
8337 int qos) in nl80211_poll_client()
8346 nl80211_send_null_frame(bss, own_addr, addr, qos); in nl80211_poll_client()
8298 nl80211_send_null_frame(struct i802_bss *bss, const u8 *own_addr, const u8 *addr, int qos) nl80211_send_null_frame() argument
8336 nl80211_poll_client(void *priv, const u8 *own_addr, const u8 *addr, int qos) nl80211_poll_client() argument
|
| H A D | driver_hostap.c | 1150 const u8 *addr, int qos) in wpa_driver_hostap_poll_client()
1149 wpa_driver_hostap_poll_client(void *priv, const u8 *own_addr, const u8 *addr, int qos) wpa_driver_hostap_poll_client() argument
|
| H A D | driver.h | 3669 * @qos: Indicates whether station is QoS station
3676 const u8 *addr, int qos);
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/drivers/ |
| H A D | driver_nl80211.c | 5958 int qos = flags & WPA_STA_WMM; in wpa_driver_nl80211_hapd_send_eapol() local
5970 len = sizeof(*hdr) + (qos ? 2 : 0) + sizeof(rfc1042_header) + 2 + in wpa_driver_nl80211_hapd_send_eapol()
5984 if (qos) { in wpa_driver_nl80211_hapd_send_eapol()
5994 if (qos) { in wpa_driver_nl80211_hapd_send_eapol()
9602 const u8 *addr, int qos)
9616 if (qos) {
9640 int qos)
9649 nl80211_send_null_frame(bss, own_addr, addr, qos);
9601 nl80211_send_null_frame(struct i802_bss *bss, const u8 *own_addr, const u8 *addr, int qos) global() argument
9639 nl80211_poll_client(void *priv, const u8 *own_addr, const u8 *addr, int qos) global() argument
|
| H A D | driver_hostap.c | 1154 const u8 *addr, int qos) in wpa_driver_hostap_poll_client()
1153 wpa_driver_hostap_poll_client(void *priv, const u8 *own_addr, const u8 *addr, int qos) wpa_driver_hostap_poll_client() argument
|
| H A D | driver.h | 4092 * @qos: Indicates whether station is QoS station
4099 const u8 *addr, int qos);
|
| /third_party/libwebsockets/lib/secure-streams/ |
| H A D | policy-json.c | 1022 a->curr[LTY_POLICY].p->u.mqtt.qos = (uint8_t)atoi(ctx->buf); in lws_ss_policy_parser_cb()
|
| /third_party/libuv/include/ |
| H A D | uv.h | 1196 uv_qos_t qos);
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-staticpolicy/ |
| H A D | static-policy.h | 1338 .qos = 1,
|