| /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/gstreamer/gstreamer/docs/random/ensonic/ |
| D | profiling.txt | 9 -> qos profiling
14 = qos profiling =
28 * after EOS, send qos-queries to each element in the pipeline
29 * qos-query will return:
102 * qos ratio via gst_event_new_qos(), gst_pad_send_event()
120 timestamp [qos-ratio] [cpu-load={sum,17284,17285}]
131 LD_PRELOAD=libgstperfmon.so GST_PERFMON_DETAILS="qos-ratio,cpu-load=all" <application>
132 LD_PRELOAD=libgstperfmon.so GST_PERFMON_DETAILS="qos-ratio,cpu-load=sum" <application>
|
| /third_party/libwebsockets/include/libwebsockets/ |
| D | lws-mqtt.h | 56 uint8_t qos:2; member
84 lws_mqtt_qos_levels_t qos; member
91 lws_mqtt_qos_levels_t qos; member
110 lws_mqtt_qos_levels_t qos; member
121 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 | 117 h->u.mqtt.sub_top.qos = h->policy->u.mqtt.qos; in secstream_mqtt_subscribe()
124 h->u.mqtt.sub_info.topic[0].qos = h->policy->u.mqtt.qos; in secstream_mqtt_subscribe()
146 lws_mqtt_qos_levels_t qos, int f) in secstream_mqtt_publish() argument
199 mqpp.qos = h->policy->u.mqtt.qos; in secstream_mqtt_publish()
439 h->policy->u.mqtt.qos, f); in secstream_mqtt()
577 ct->ccp.will_param.qos = h->policy->u.mqtt.will_qos; in secstream_connect_munge_mqtt()
579 ct->ccp.birth_param.qos = h->policy->u.mqtt.birth_qos; in secstream_connect_munge_mqtt()
582 h->u.mqtt.topic_qos.qos = h->policy->u.mqtt.qos; in secstream_connect_munge_mqtt()
|
| /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/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/lib/roles/mqtt/ |
| D | mqtt.c | 838 pub->qos = (lws_mqtt_qos_levels_t) in _lws_mqtt_rx_parser()
844 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser()
846 switch (pub->qos) { in _lws_mqtt_rx_parser()
884 (unsigned int)(2 + pub->topic_len + ((pub->qos) ? 2 : 0)); in _lws_mqtt_rx_parser()
1047 lws_mqtt_qos_levels_t qos = (lws_mqtt_qos_levels_t)*buf++; in _lws_mqtt_rx_parser() local
1050 switch (qos) { in _lws_mqtt_rx_parser()
1637 if (pub->qos == 1) { in _lws_mqtt_rx_parser()
1641 } else if (pub->qos == 2) { in _lws_mqtt_rx_parser()
1849 uint8_t dup, lws_mqtt_qos_levels_t qos, in lws_mqtt_fill_fixed_header() argument
1866 if (qos >= RESERVED_QOS_LEVEL) { in lws_mqtt_fill_fixed_header()
[all …]
|
| D | private-lib-roles-mqtt.h | 345 lws_mqtt_qos_levels_t qos; member
431 uint8_t dup, lws_mqtt_qos_levels_t qos,
|
| /third_party/libnl/lib/route/link/ |
| D | vlan.c | 318 struct nlattr *qos; in vlan_put_attrs() local
321 if (!(qos = nla_nest_start(msg, IFLA_VLAN_INGRESS_QOS))) in vlan_put_attrs()
333 nla_nest_end(msg, qos); in vlan_put_attrs()
338 struct nlattr *qos; in vlan_put_attrs() local
341 if (!(qos = nla_nest_start(msg, IFLA_VLAN_EGRESS_QOS))) in vlan_put_attrs()
351 nla_nest_end(msg, qos); in vlan_put_attrs()
|
| D | sriov.c | 312 vlans->vlans[cur].vf_vlan_qos = vi[cur]->qos ? vi[cur]->qos : 0; in rtnl_link_vf_vlan_info()
332 vlan.qos = vinfo[0].vf_vlan_qos; in sriov_fill_vf_vlan()
353 vlan.qos = vlan_info[cur].vf_vlan_qos; in sriov_fill_vf_vlan_list()
603 vf_vlans->vlans[0].vf_vlan_qos = vf_vlan->qos; in rtnl_link_sriov_parse_vflist()
|
| /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/gstreamer/gstplugins_base/tests/validate/videorate/ |
| D | check-rate-prop.meta | 11 …dth=320,height=240 $(decoder) videorate name=videorate rate=$(rate) ! fakesink sync=true qos=true",
|
| D | change_rate_while_playing.validatetest | 4 …I420,framerate=10/1,width=320,height=240 ! videorate name=videorate ! fakesink sync=true qos=true",
|
| D | change_rate_reverse_playback.validatetest | 6 …I420,framerate=10/1,width=320,height=240 ! videorate name=videorate ! fakesink sync=true qos=true",
|
| /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/libnl/include/linux-private/linux/ |
| D | if_link.h | 686 __u32 qos; member
701 __u32 qos; member
|
| /third_party/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-staticpolicy/ |
| D | static-policy.h | 1338 .qos = 1,
|
| /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-policy2c/ |
| D | minimal-secure-streams.c | 580 if (pol->u.mqtt.qos) in main()
582 pol->u.mqtt.qos); in main()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/ap/ |
| D | ap_drv_ops.h | 260 int qos) in hostapd_drv_poll_client() argument
264 hapd->driver->poll_client(hapd->drv_priv, own_addr, addr, qos); in hostapd_drv_poll_client()
|
| /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/gstreamer/gstplugins_good/gst/shapewipe/ |
| D | gstshapewipe.c | 875 goto qos; in gst_shape_wipe_video_sink_chain()
931 qos: in gst_shape_wipe_video_sink_chain()
|
| /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()
|
| /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
|