Home
last modified time | relevance | path

Searched refs:topic_len (Results 1 – 25 of 42) sorted by relevance

12

/AliOS-Things-master/components/linkkit/wifi_provision/dev_bind/awss_reset/
A Dawss_dev_reset.c77 int topic_len = AWSS_RESET_TOPIC_LEN; in awss_report_reset_to_cloud() local
96 topic = (char *)devrst_malloc(topic_len + 1); in awss_report_reset_to_cloud()
100 memset(topic, 0, topic_len + 1); in awss_report_reset_to_cloud()
102 HAL_Snprintf(topic, topic_len, TOPIC_RESET_REPORT_REPLY, pk, dn); in awss_report_reset_to_cloud()
117 memset(topic, 0, topic_len + 1); in awss_report_reset_to_cloud()
118 HAL_Snprintf(topic, topic_len, TOPIC_RESET_REPORT, pk, dn); in awss_report_reset_to_cloud()
/AliOS-Things-master/components/linkkit/dev_model/deprecated/
A Dimpl_ntp.c137 int topic_len = 128; in linkkit_ntp_time_request() local
148 topic = (char *)IMPL_NTP_MALLOC(topic_len + 1); in linkkit_ntp_time_request()
152 memset(topic, 0, topic_len + 1); in linkkit_ntp_time_request()
154 HAL_Snprintf(topic, topic_len, TOPIC_NTP_REPLY, pk, dn); in linkkit_ntp_time_request()
170 memset(topic, 0, topic_len + 1); in linkkit_ntp_time_request()
171 HAL_Snprintf(topic, topic_len, TOPIC_NTP, pk, dn); in linkkit_ntp_time_request()
/AliOS-Things-master/components/py_engine/external/app_mgr/
A Dapp_message.c128 …ug(MOD_STR, "pub, qos: %d, len: %d, topic: %.*s", packet->data.pub.qos, packet->data.pub.topic_len, in pyamp_verify_message_handler()
141 int topic_len = 0; in topic_subscribe() local
151 topic_len = strlen(fmt) + strlen(amp_internal_productkey) + strlen(amp_internal_devicename) + 1; in topic_subscribe()
152 topic = aos_malloc(topic_len); in topic_subscribe()
157 memset(topic, 0, topic_len); in topic_subscribe()
158 aos_snprintf(topic, topic_len, fmt, amp_internal_productkey, amp_internal_devicename); in topic_subscribe()
175 int topic_len = 0; in topic_publish() local
184 topic_len = strlen(fmt) + strlen(amp_internal_productkey) + strlen(amp_internal_devicename) + 1; in topic_publish()
185 topic = aos_malloc(topic_len); in topic_publish()
190 memset(topic, 0, topic_len); in topic_publish()
[all …]
/AliOS-Things-master/components/linkkit/dev_model/
A Diotx_cm_coap.c265 unsigned int topic_len = strlen(node->topic) + 1; in _coap_response_default() local
266 char *topic = cm_malloc(topic_len); in _coap_response_default()
271 memset(topic, 0, topic_len); in _coap_response_default()
272 strncpy(topic, node->topic, topic_len); in _coap_response_default()
295 int topic_len; in _coap_publish() local
330 topic_len = strlen(topic) + 1; in _coap_publish()
331 node->topic = (char *)cm_malloc(topic_len); in _coap_publish()
337 memset(node->topic, 0, topic_len); in _coap_publish()
338 strncpy(node->topic, topic, topic_len); in _coap_publish()
A Diotx_cm_mqtt.c200 topic_info->topic_len, topic_info->ptopic); in iotx_cloud_conn_mqtt_event_handle()
205 topic_info->topic_len, topic_info->payload, in iotx_cloud_conn_mqtt_event_handle()
208 topic = cm_malloc(topic_info->topic_len + 1); in iotx_cloud_conn_mqtt_event_handle()
213 memset(topic, 0, topic_info->topic_len + 1); in iotx_cloud_conn_mqtt_event_handle()
214 memcpy(topic, topic_info->ptopic, topic_info->topic_len); in iotx_cloud_conn_mqtt_event_handle()
A Diotx_cm.h95 uint32_t topic_len, const char *payload,
/AliOS-Things-master/components/linksdk/components/data-model/
A Daiot_dm_api.c359 static int32_t _dm_get_topic_level(aiot_sysdep_portfile_t *sysdep, char *topic, uint32_t topic_len,… in _dm_get_topic_level() argument
369 for (i = 0; i < (topic_len - 1); i++) { in _dm_get_topic_level()
386 p_close = topic + topic_len; in _dm_get_topic_level()
443 …if (_dm_get_topic_level(dm_handle->sysdep, msg->data.pub.topic, msg->data.pub.topic_len, 2, &recv.… in _dm_recv_generic_reply_handler()
444 …_dm_get_topic_level(dm_handle->sysdep, msg->data.pub.topic, msg->data.pub.topic_len, 3, &recv.devi… in _dm_recv_generic_reply_handler()
497 …if (_dm_get_topic_level(dm_handle->sysdep, msg->data.pub.topic, msg->data.pub.topic_len, 2, &recv.… in _dm_recv_property_set_handler()
498 …_dm_get_topic_level(dm_handle->sysdep, msg->data.pub.topic, msg->data.pub.topic_len, 3, &recv.devi… in _dm_recv_property_set_handler()
535 _dm_get_topic_level(dm_handle->sysdep, msg->data.pub.topic, msg->data.pub.topic_len, 6, in _dm_recv_async_service_invoke_handler()
574 _dm_get_topic_level(dm_handle->sysdep, msg->data.pub.topic, msg->data.pub.topic_len, 3, in _dm_recv_sync_service_invoke_handler()
576 _dm_get_topic_level(dm_handle->sysdep, msg->data.pub.topic, msg->data.pub.topic_len, 9, in _dm_recv_sync_service_invoke_handler()
[all …]
/AliOS-Things-master/components/linksdk/components/ota/
A Daiot_ota_api.c355 uint8_t topic_len = sizeof(src) / sizeof(char *); in aiot_ota_report_version() local
359 uint8_t topic_len = sizeof(src) / sizeof(char *); in aiot_ota_report_version() local
398 uint8_t topic_len = sizeof(src) / sizeof(char *); in aiot_ota_report_version_ext() local
422 uint8_t topic_len = sizeof(src) / sizeof(char *); in aiot_ota_query_firmware() local
426 uint8_t topic_len = sizeof(src) / sizeof(char *); in aiot_ota_query_firmware() local
460 uint8_t topic_len = sizeof(src) / sizeof(char *); in aiot_download_report_progress() local
464 uint8_t topic_len = sizeof(src) / sizeof(char *); in aiot_download_report_progress() local
602 _device_name_len = topic_len - (_device_name - topic); in _ota_prase_topic()
1094 uint8_t topic_len = sizeof(src) / sizeof(char *); in _ota_publish_base() local
1101 uint8_t topic_len = sizeof(src) / sizeof(char *); in _ota_publish_base() local
[all …]
/AliOS-Things-master/components/linkkit/dev_model/alcs/
A Dalcs_mqtt.c244 int topic_len; in __alcs_mqtt_subscribe_callback() local
265 topic_len = ptopic_info->topic_len; in __alcs_mqtt_subscribe_callback()
273 if (topic == NULL || payload == NULL || topic_len == 0 || in __alcs_mqtt_subscribe_callback()
283 COAP_INFO("Receivce Message, Topic: %.*s\n", topic_len, topic); in __alcs_mqtt_subscribe_callback()
285 if ((strlen(topic_compare) == topic_len) && in __alcs_mqtt_subscribe_callback()
286 (strncmp(topic_compare, topic, topic_len) == 0)) { in __alcs_mqtt_subscribe_callback()
374 if ((strlen(topic_compare) == topic_len) && in __alcs_mqtt_subscribe_callback()
375 (strncmp(topic_compare, topic, topic_len) == 0)) { in __alcs_mqtt_subscribe_callback()
439 if ((strlen(topic_compare) == topic_len) && in __alcs_mqtt_subscribe_callback()
440 (strncmp(topic_compare, topic, topic_len) == 0)) { in __alcs_mqtt_subscribe_callback()
A Dalcs_adapter.c34 uint16_t topic_len = 0; in iotx_alcs_topic_parse_pk() local
41 topic_len = strlen(topic); in iotx_alcs_topic_parse_pk()
43 while (idx < topic_len) { in iotx_alcs_topic_parse_pk()
64 uint16_t topic_len = 0; in iotx_alcs_topic_parse_dn() local
71 topic_len = strlen(topic); in iotx_alcs_topic_parse_dn()
73 while (idx < topic_len) { in iotx_alcs_topic_parse_dn()
/AliOS-Things-master/components/py_engine/modules/aliyunIoT/
A Dmodule_aiot_mqtt.c112 packet->data.pub.qos, packet->data.pub.topic_len, in pyamp_aiot_app_mqtt_recv_handler()
125 packet->data.pub.topic_len); in pyamp_aiot_app_mqtt_recv_handler()
128 message.recv.topic_len = packet->data.pub.topic_len; in pyamp_aiot_app_mqtt_recv_handler()
A Dmodule_aiot.h181 int topic_len; member
/AliOS-Things-master/components/linksdk/components/dynreg-mqtt/
A Daiot_dynregmq_api.c40 uint32_t topic_len = packet->data.pub.topic_len; in _dynregmq_recv_handler() local
46 if (strlen(topic_register) == topic_len && !memcmp(topic_register, topic, topic_len)) { in _dynregmq_recv_handler()
69 … } else if (strlen(topic_regnwl) == topic_len && !memcmp(topic_regnwl, topic, topic_len)) { in _dynregmq_recv_handler()
/AliOS-Things-master/components/amp/engine/quickjs_engine/addons/advanced/aiot/
A Dmodule_aiot_mqtt.c131 …TR, "pub, qos: %d, topic: %.*s", packet->data.pub.qos, packet->data.pub.topic_len, packet->data.pu… in aiot_app_mqtt_recv_handler()
135 message.recv.topic = __amp_strdup(packet->data.pub.topic, packet->data.pub.topic_len); in aiot_app_mqtt_recv_handler()
137 message.recv.topic_len = packet->data.pub.topic_len; in aiot_app_mqtt_recv_handler()
/AliOS-Things-master/components/uagent/src/
A Duagent_comm_mqtt.c34 packet->data.pub.topic_len, in uagent_handler()
36 packet->data.pub.topic_len); in uagent_handler()
/AliOS-Things-master/components/amp/engine/quickjs_engine/addons/network/mqtt/
A Dmodule_mqtt_client.c108 … message.recv.topic = __amp_strdup(packet->data.pub.topic, packet->data.pub.topic_len); in mqtt_recv_handler()
110 message.recv.topic_len = packet->data.pub.topic_len; in mqtt_recv_handler()
A Dmodule_mqtt.h57 int topic_len; member
/AliOS-Things-master/components/ota/hal/
A Dota_hal_trans.h21 unsigned short topic_len; member
/AliOS-Things-master/components/amp/engine/duktape_engine/addons/advanced/aiot/
A Dmodule_aiot_mqtt.c113 … message.recv.topic = __amp_strdup(packet->data.pub.topic, packet->data.pub.topic_len); in aiot_app_mqtt_recv_handler()
115 message.recv.topic_len = packet->data.pub.topic_len; in aiot_app_mqtt_recv_handler()
A Dmodule_aiot.h172 int topic_len; member
/AliOS-Things-master/components/linksdk/components/shadow/
A Daiot_shadow_api.c17 static int32_t _shadow_get_pk_dn(aiot_sysdep_portfile_t *sysdep, char *topic, uint16_t topic_len, in _shadow_get_pk_dn() argument
27 for (idx = pk_offset; idx < topic_len - 1; idx++) { in _shadow_get_pk_dn()
31 dn_len = topic_len - idx - 1; in _shadow_get_pk_dn()
107 …dow_get_pk_dn(shadow_handle->sysdep, msg->data.pub.topic, msg->data.pub.topic_len, &pk, &dn)) < 0)… in _shadow_recv_message_handler()
/AliOS-Things-master/components/linkkit/include/linkkit/wrappers/
A Dwrappers_atm.h149 uint32_t topic_len; member
/AliOS-Things-master/components/linksdk/core/
A Daiot_mqtt_api.c511 pos[idx++] = topic_len >> 8; in _core_write_general_prop()
512 pos[idx++] = topic_len & 0xFF; in _core_write_general_prop()
514 idx += topic_len; in _core_write_general_prop()
1517 memcpy(&pkt[idx], topic, topic_len); in _core_mqtt_subunsub()
1518 idx += topic_len; in _core_mqtt_subunsub()
1883 if (idx + 1 == topic_len) { in _core_mqtt_topic_compare()
1964 if (topic_len > 0) { in _core_mqtt_process_topic_alias()
1968 .len = topic_len, in _core_mqtt_process_topic_alias()
1999 uint32_t topic_len = 0; in _core_mqtt_pub_handler() local
2028 packet.data.pub.topic_len = utf8_strlen; in _core_mqtt_pub_handler()
[all …]
/AliOS-Things-master/components/linkkit/include/linkkit/
A Dmqtt_api.h83 uint16_t topic_len; member
/AliOS-Things-master/components/linksdk/components/devinfo/
A Daiot_devinfo_api.c30 static void _devinfo_find_pk_dn(devinfo_handle_t *devinfo_handle, char *topic, uint16_t topic_len, … in _devinfo_find_pk_dn() argument
35 for (idx = 0;idx < topic_len;idx++) { in _devinfo_find_pk_dn()
88 …_devinfo_find_pk_dn(devinfo_handle, packet->data.pub.topic, packet->data.pub.topic_len, &product_k… in _devinfo_mqtt_recv_handler()

Completed in 34 milliseconds

12