| /third_party/lwip/src/include/lwip/apps/ |
| 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…
193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) argument
198 …ent_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain,
|
| /third_party/libwebsockets/include/libwebsockets/ |
| 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
|
| D | lws-secure-streams-policy.h | 319 uint8_t qos; member
|
| /third_party/libwebsockets/lib/secure-streams/protocols/ |
| 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() argument
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()
459 h->u.mqtt.shadow_sub.topic[i].qos = h->policy->u.mqtt.qos; in secstream_mqtt_shadow_subscribe()
857 h->policy->u.mqtt.qos, in secstream_mqtt()
1032 ct->ccp.will_param.qos = h->policy->u.mqtt.will_qos; in secstream_connect_munge_mqtt()
1034 ct->ccp.birth_param.qos = h->policy->u.mqtt.birth_qos; in secstream_connect_munge_mqtt()
[all …]
|
| /third_party/lwip/src/apps/mqtt/ |
| D | mqtt.c | 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 > 0) { in mqtt_message_received()
781 u8_t resp_msg = (qos == 1) ? MQTT_MSG_TYPE_PUBACK : MQTT_MSG_TYPE_PUBREC; in mqtt_message_received()
1096 …ent_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain, in mqtt_publish() argument
[all …]
|
| /third_party/libuv/src/ |
| D | threadpool.c | 643 int qos = (ffrt_qos_t)(intptr_t)req->reserved[0]; in uv__work_cancel() local
649 addr->post_task_func(addr->event_handler, uv__task_done_wrapper, (void*)w, status, qos); in uv__work_cancel()
651 QUEUE_INSERT_TAIL(&(lfields->wq_sub[qos]), &w->wq); in uv__work_cancel()
750 void uv__ffrt_work(ffrt_executor_task_t* data, ffrt_qos_t qos) in uv__ffrt_work() argument
774 addr->post_task_func(addr->event_handler, uv__task_done_wrapper, (void*)w, status, qos); in uv__ffrt_work()
776 QUEUE_INSERT_TAIL(&(lfields->wq_sub[qos]), &w->wq); in uv__ffrt_work()
832 ffrt_qos_t qos, in uv__work_submit_with_qos() argument
838 ffrt_task_attr_set_qos(&attr, qos); in uv__work_submit_with_qos()
897 uv_qos_t qos) { in uv_queue_work_with_qos() argument
906 if (qos < ffrt_qos_background || qos > ffrt_qos_user_initiated) { in uv_queue_work_with_qos()
[all …]
|
| /third_party/libwebsockets/lib/roles/mqtt/ |
| D | mqtt.c | 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() argument
1911 if (qos >= RESERVED_QOS_LEVEL) { in lws_mqtt_fill_fixed_header()
[all …]
|
| 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/ |
| 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/minimal-examples/mqtt-client/minimal-mqtt-client-multi/ |
| 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/libuv/src/unix/ |
| D | epoll.c | 35 ffrt_qos_t qos = ffrt_this_task_get_qos(); in uv__epoll_wait() local
36 nfds = ffrt_epoll_wait(qos, events, eventsize, timeout); in uv__epoll_wait()
45 ffrt_qos_t qos = ffrt_this_task_get_qos(); in uv__epoll_ctl() local
46 return ffrt_epoll_ctl(qos, op, fd, event->events, NULL, NULL); in uv__epoll_ctl()
|
| /third_party/lwip/doc/ |
| D | mqtt_client.txt | 143 u8_t qos = 2; /* 0 1 or 2, see MQTT specification */
145 …err = mqtt_publish(client, "pub_topic", pub_payload, strlen(pub_payload), qos, retain, mqtt_pub_re…
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/ap/ |
| D | ap_drv_ops.h | 257 int qos) in hostapd_drv_poll_client() argument
261 hapd->driver->poll_client(hapd->drv_priv, own_addr, addr, qos); in hostapd_drv_poll_client()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-staticpolicy/ |
| D | static-policy.h | 1338 .qos = 1,
|
| /third_party/libbpf/include/uapi/linux/ |
| D | if_link.h | 1054 __u32 qos; member
1069 __u32 qos; member
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/ap/ |
| D | ap_drv_ops.h | 262 int qos) in hostapd_drv_poll_client() argument
266 hapd->driver->poll_client(hapd->drv_priv, own_addr, addr, qos); in hostapd_drv_poll_client()
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-policy2c/ |
| D | minimal-secure-streams.c | 597 if (pol->u.mqtt.qos) in main()
599 pol->u.mqtt.qos); in main()
|
| /third_party/libwebsockets/lib/roles/mqtt/client/ |
| D | client-mqtt.c | 149 …c->conn_flags = (uint16_t)(unsigned int)(c->conn_flags | ((cp->will_param.qos << 3) & LMQCFT_WILL_… in lws_create_client_mqtt_object()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/drivers/ |
| 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() argument
8313 if (qos) { in nl80211_send_null_frame()
8337 int qos) in nl80211_poll_client() argument
8346 nl80211_send_null_frame(bss, own_addr, addr, qos); in nl80211_poll_client()
|
| D | driver_hostap.c | 1150 const u8 *addr, int qos) in wpa_driver_hostap_poll_client() argument
|
| D | driver.h | 3676 const u8 *addr, int qos);
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/drivers/ |
| D | driver_hostap.c | 1154 const u8 *addr, int qos) in wpa_driver_hostap_poll_client() argument
|
| D | driver_nl80211.c | 5766 int qos = flags & WPA_STA_WMM; in wpa_driver_nl80211_hapd_send_eapol() local
5778 len = sizeof(*hdr) + (qos ? 2 : 0) + sizeof(rfc1042_header) + 2 + in wpa_driver_nl80211_hapd_send_eapol()
5792 if (qos) { in wpa_driver_nl80211_hapd_send_eapol()
5802 if (qos) { in wpa_driver_nl80211_hapd_send_eapol()
9151 const u8 *addr, int qos) in nl80211_send_null_frame() argument
9165 if (qos) { in nl80211_send_null_frame()
9189 int qos) in nl80211_poll_client() argument
9198 nl80211_send_null_frame(bss, own_addr, addr, qos); in nl80211_poll_client()
|
| D | driver.h | 3993 const u8 *addr, int qos);
|
| /third_party/libwebsockets/lib/secure-streams/ |
| D | policy-json.c | 1022 a->curr[LTY_POLICY].p->u.mqtt.qos = (uint8_t)atoi(ctx->buf); in lws_ss_policy_parser_cb()
|