Home
last modified time | relevance | path

Searched refs:qos (Results 1 – 25 of 70) sorted by relevance

123

/AliOS-Things-master/components/mqtt/MQTTPacket/
A DMQTTSerializePublish.c31 int MQTTSerialize_publishLength(int qos, MQTTString topicName, int payloadlen) in MQTTSerialize_publishLength() argument
36 if (qos > 0) in MQTTSerialize_publishLength()
55 int MQTTSerialize_publish(unsigned char* buf, int buflen, unsigned char dup, int qos, unsigned char… in MQTTSerialize_publish() argument
64 if (MQTTPacket_len(rem_len = MQTTSerialize_publishLength(qos, topicName, payloadlen)) > buflen) in MQTTSerialize_publish()
72 header.bits.qos = qos; in MQTTSerialize_publish()
80 if (qos > 0) in MQTTSerialize_publish()
118 header.bits.qos = (packettype == PUBREL) ? 1 : 0; in MQTTSerialize_ack()
A DMQTTDeserializePublish.c36 int MQTTDeserialize_publish(unsigned char* dup, int* qos, unsigned char* retained, unsigned short* … in MQTTDeserialize_publish() argument
50 *qos = header.bits.qos; in MQTTDeserialize_publish()
60 if (*qos > 0) in MQTTDeserialize_publish()
A DMQTTFormat.c48 data->will.qos, data->will.retained, in MQTTStringFormat_connect()
68 int MQTTStringFormat_publish(char* strbuf, int strbuflen, unsigned char dup, int qos, unsigned char… in MQTTStringFormat_publish() argument
73 dup, qos, retained, packetid, in MQTTStringFormat_publish()
142 int qos, payloadlen; in MQTTFormat_toClientString() local
144 if (MQTTDeserialize_publish(&dup, &qos, &retained, &packetid, &topicName, in MQTTFormat_toClientString()
146 strindex = MQTTStringFormat_publish(strbuf, strbuflen, dup, qos, retained, packetid, in MQTTFormat_toClientString()
212 int qos, payloadlen; in MQTTFormat_toServerString() local
214 if (MQTTDeserialize_publish(&dup, &qos, &retained, &packetid, &topicName, in MQTTFormat_toServerString()
216 strindex = MQTTStringFormat_publish(strbuf, strbuflen, dup, qos, retained, packetid, in MQTTFormat_toServerString()
A DMQTTPublish.h28 DLLExport int MQTTSerialize_publish(unsigned char* buf, int buflen, unsigned char dup, int qos, uns…
31 DLLExport int MQTTDeserialize_publish(unsigned char* dup, int* qos, unsigned char* retained, unsign…
/AliOS-Things-master/components/linkkit/mqtt/impl/
A DMQTTSerializePublish.c32 int MQTTSerialize_publishLength(int qos, MQTTString topicName, int payloadlen) in MQTTSerialize_publishLength() argument
37 if (qos > 0) { in MQTTSerialize_publishLength()
58 int qos, unsigned char retained, in MQTTSerialize_publish() argument
67 rem_len = MQTTSerialize_publishLength(qos, topicName, payloadlen); in MQTTSerialize_publish()
75 MQTT_HEADER_SET_QOS(header.byte, qos); in MQTTSerialize_publish()
84 if (qos > 0) { in MQTTSerialize_publish()
A DMQTTDeserializePublish.c37 int MQTTDeserialize_publish(unsigned char *dup, int *qos, in MQTTDeserialize_publish() argument
53 *qos = MQTT_HEADER_GET_QOS(header.byte); in MQTTDeserialize_publish()
66 if (*qos > 0) { in MQTTDeserialize_publish()
A DMQTTPublish.h29 unsigned char dup, int qos,
35 DLLExport int MQTTDeserialize_publish(unsigned char *dup, int *qos,
/AliOS-Things-master/components/linkkit/include/linkkit/
A Dmqtt_api.h80 uint8_t qos; member
255 iotx_mqtt_qos_t qos,
278 iotx_mqtt_qos_t qos,
331 int IOT_MQTT_Publish_Simple(void *handle, const char *topic_name, int qos,
/AliOS-Things-master/components/linkkit/mqtt/
A Dmqtt_api.c493 iotx_mqtt_qos_t qos, in IOT_MQTT_Subscribe() argument
505 if (qos > IOTX_MQTT_QOS3_SUB_LOCAL) { in IOT_MQTT_Subscribe()
506 mqtt_warning("Invalid qos(%d) out of [%d, %d], using %d", qos, in IOT_MQTT_Subscribe()
508 qos = IOTX_MQTT_QOS0; in IOT_MQTT_Subscribe()
517 iotx_mqtt_qos_t qos, in IOT_MQTT_Subscribe_Sync() argument
533 if (qos > IOTX_MQTT_QOS3_SUB_LOCAL) { in IOT_MQTT_Subscribe_Sync()
534 mqtt_warning("Invalid qos(%d) out of [%d, %d], using %d", qos, in IOT_MQTT_Subscribe_Sync()
536 qos = IOTX_MQTT_QOS0; in IOT_MQTT_Subscribe_Sync()
539 return wrapper_mqtt_subscribe_sync(client, topic_filter, qos, in IOT_MQTT_Subscribe_Sync()
570 int IOT_MQTT_Publish_Simple(void *handle, const char *topic_name, int qos, in IOT_MQTT_Publish_Simple() argument
[all …]
A Dmqtt_wrapper.h13 iotx_mqtt_qos_t qos,
17 void *client, const char *topic_filter, iotx_mqtt_qos_t qos,
/AliOS-Things-master/components/py_engine/modules/mqtt/
A Dmodule_mqtt.c160 uint8_t qos = 0; in native_mqtt_subscribe() local
184 qos = duk_get_number(ctx, -1); in native_mqtt_subscribe()
192 res = aiot_mqtt_sub(amp_mqtt_handle->mqtt_handle, topic, NULL, qos, NULL); in native_mqtt_subscribe()
208 uint8_t qos = 0; in native_mqtt_unsubscribe() local
250 uint8_t qos = 0; in native_mqtt_publish() local
276 qos = duk_get_number(ctx, -1); in native_mqtt_publish()
287 payload, qos); in native_mqtt_publish()
290 payload_len, qos); in native_mqtt_publish()
A Dmqttclient.c181 int qos = mp_obj_get_int(args[2]); in mqtt_subscribe() local
182 rc = MQTTSubscribe(&mqtt_client_obj->c, subtopic, qos, messageArrived); in mqtt_subscribe()
232 int qos = mp_obj_get_int(args[3]); in mqtt_publish() local
235 msg.qos = qos; in mqtt_publish()
/AliOS-Things-master/components/amp/engine/duktape_engine/addons/network/mqtt/
A Dmodule_mqtt.c155 uint8_t qos = 0; in native_mqtt_subscribe() local
179 qos = duk_get_number(ctx, -1); in native_mqtt_subscribe()
187 res = aiot_mqtt_sub(amp_mqtt_handle->mqtt_handle, topic, NULL, qos, NULL); in native_mqtt_subscribe()
203 uint8_t qos = 0; in native_mqtt_unsubscribe() local
244 uint8_t qos = 0; in native_mqtt_publish() local
269 qos = duk_get_number(ctx, -1); in native_mqtt_publish()
279 amp_debug(MOD_STR, "publish topic: %s, payload: %s, qos is: %d", topic, payload, qos); in native_mqtt_publish()
281 res = aiot_mqtt_pub(amp_mqtt_handle->mqtt_handle, topic, payload, payload_len, qos); in native_mqtt_publish()
/AliOS-Things-master/components/linksdk/core/
A Daiot_mqtt_api.h220 uint8_t qos; member
897 …32_t aiot_mqtt_pub(void *handle, char *topic, uint8_t *payload, uint32_t payload_len, uint8_t qos);
915 int32_t aiot_mqtt_sub(void *handle, char *topic, aiot_mqtt_recv_handler_t handler, uint8_t qos, voi…
1014 …_mqtt_pub_with_prop(void *handle, char *topic, uint8_t *payload, uint32_t payload_len, uint8_t qos,
1060 …t aiot_mqtt_sub_with_prop(void *handle, char *topic, aiot_mqtt_recv_handler_t handler, uint8_t qos,
/AliOS-Things-master/components/mqtt/MQTTClient-C/
A DMQTTClient.c286 msg.qos = (enum QoS)intQoS; in cycle()
288 if (msg.qos != QOS0) in cycle()
290 if (msg.qos == QOS1) in cycle()
292 else if (msg.qos == QOS2) in cycle()
517 int MQTTSubscribeWithResults(MQTTClient* c, const char* topicFilter, enum QoS qos, in MQTTSubscribeWithResults() argument
535 … len = MQTTSerialize_subscribe(c->buf, c->buf_size, 0, getNextPacketId(c), 1, &topic, (int*)&qos); in MQTTSubscribeWithResults()
565 int MQTTSubscribe(MQTTClient* c, const char* topicFilter, enum QoS qos, in MQTTSubscribe() argument
569 return MQTTSubscribeWithResults(c, topicFilter, qos, messageHandler, &data); in MQTTSubscribe()
634 if (message->qos == QOS1 || message->qos == QOS2) in MQTTPublish()
644 if (message->qos == QOS1) in MQTTPublish()
[all …]
/AliOS-Things-master/components/ota/hal/
A Dota_hal_trans.c10 int ota_hal_mqtt_publish(void *mqtt_client, char *topic, int qos, void *data, int len) in ota_hal_mqtt_publish() argument
12 return aiot_mqtt_pub(mqtt_client, topic, data, len, qos); in ota_hal_mqtt_publish()
A Dota_hal_trans.h18 unsigned char qos; member
39 int ota_hal_mqtt_publish(void *mqtt_client, char *topic, int qos, void *data, int len);
/AliOS-Things-master/components/linkkit/dev_model/
A Diotx_cm_mqtt.c301 int qos = 0; in _mqtt_publish() local
308 qos = (int)_get_mqtt_qos(ext->ack_type); in _mqtt_publish()
310 return IOT_MQTT_Publish_Simple(_mqtt_conncection->context, topic, qos, in _mqtt_publish()
327 iotx_mqtt_qos_t qos = IOTX_MQTT_QOS0; in _mqtt_sub() local
343 qos = (int)_get_mqtt_qos(ext->ack_type); in _mqtt_sub()
347 ret = IOT_MQTT_Subscribe_Sync(_mqtt_conncection->context, topic, qos, in _mqtt_sub()
351 ret = IOT_MQTT_Subscribe(_mqtt_conncection->context, topic, qos, in _mqtt_sub()
/AliOS-Things-master/components/linksdk/components/diag/
A Ddiag_private.h39 uint8_t qos; member
60 uint8_t qos; /* 使用MQTT发送告警报文至云端时，使用的QoS值 */ member
125 uint8_t qos; member
/AliOS-Things-master/components/amp/engine/quickjs_engine/addons/network/mqtt/
A Dmodule_mqtt.c304 uint8_t qos = 0; in native_mqtt_subscribe() local
314 JS_ToInt32(ctx, &qos, argv[2]); in native_mqtt_subscribe()
316 res = aiot_mqtt_sub(amp_mqtt_handle->mqtt_handle, topic, NULL, qos, NULL); in native_mqtt_subscribe()
333 uint8_t qos = 0; in native_mqtt_unsubscribe() local
364 uint8_t qos = 0; in native_mqtt_publish() local
375 JS_ToInt32(ctx, &qos, argv[1]); in native_mqtt_publish()
378 amp_debug(MOD_STR, "publish topic: %s, payload: %s, qos is: %d", topic, payload, qos); in native_mqtt_publish()
380 res = aiot_mqtt_pub(amp_mqtt_handle->mqtt_handle, topic, payload, payload_len, qos); in native_mqtt_publish()
/AliOS-Things-master/components/linkkit/ota/
A Dota_mqtt.c59 int qos, const char *msg) in otamqtt_Publish() argument
67 if (0 == qos) { in otamqtt_Publish()
68 topic_info.qos = IOTX_MQTT_QOS0; in otamqtt_Publish()
70 topic_info.qos = IOTX_MQTT_QOS1; in otamqtt_Publish()
172 message_info.qos = IOTX_MQTT_QOS0; in otamqtt_UpgrageCb()
/AliOS-Things-master/components/linkkit/include/linkkit/wrappers/
A Dwrappers_atm.h158 int HAL_AT_MQTT_Subscribe(const char *topic, int qos,
163 int HAL_AT_MQTT_Publish(const char *topic, int qos, const char *message,
/AliOS-Things-master/components/amp/example-js/
A Diot.js23 qos: 0
33 qos: 1
/AliOS-Things-master/components/linkkit/wifi_provision/dev_bind/
A Dawss_cmp.h57 void *req, void *cb, uint16_t *msgid, char qos);
64 int awss_cmp_mqtt_send(char *topic, void *pkt, int pkt_len, int qos);
/AliOS-Things-master/components/oss/src/model/
A DSetBucketQosInfoRequest.cc25 …etQosInfoRequest::SetBucketQosInfoRequest(const std::string& bucket, const QosConfiguration& qos) : in SetBucketQosInfoRequest() argument
27 qosInfo_(qos) in SetBucketQosInfoRequest()

Completed in 29 milliseconds

123