| /AliOS-Things-master/components/linkkit/dev_model/client/ |
| A D | dm_client.c | 221 void dm_client_thing_event_notify(int fd, const char *topic, in dm_client_thing_event_notify()
266 void dm_client_thing_model_down_raw(int fd, const char *topic, in dm_client_thing_model_down_raw()
379 void dm_client_thing_service_request(int fd, const char *topic, in dm_client_thing_service_request()
395 void dm_client_thing_event_post_reply(int fd, const char *topic, in dm_client_thing_event_post_reply()
497 void dm_client_rrpc_request_wildcard(int fd, const char *topic, in dm_client_rrpc_request_wildcard()
574 void dm_client_thing_topo_add_notify(int fd, const char *topic, in dm_client_thing_topo_add_notify()
696 void dm_client_thing_gateway_permit(int fd, const char *topic, in dm_client_thing_gateway_permit()
777 void dm_client_thing_topo_add_reply(int fd, const char *topic, in dm_client_thing_topo_add_reply()
809 void dm_client_thing_topo_get_reply(int fd, const char *topic, in dm_client_thing_topo_get_reply()
841 void dm_client_combine_login_reply(int fd, const char *topic, in dm_client_combine_login_reply()
[all …]
|
| /AliOS-Things-master/components/linkkit/wifi_provision/dev_bind/ |
| A D | awss_cmp_mqtt.c | 12 int awss_cmp_mqtt_register_cb(char *topic, void *cb) in awss_cmp_mqtt_register_cb()
26 int awss_cmp_mqtt_unregister_cb(char *topic) in awss_cmp_mqtt_unregister_cb()
31 int awss_cmp_mqtt_send(char *topic, void *data, int len, int qos) in awss_cmp_mqtt_send()
52 char topic[TOPIC_LEN_MAX] = { 0 }; in awss_cmp_online_init() local
74 char topic[TOPIC_LEN_MAX] = { 0 }; in awss_cmp_online_deinit() local
|
| A D | awss_cmp_coap.c | 110 int awss_cmp_coap_register_cb(char *topic, void *cb) in awss_cmp_coap_register_cb()
215 char topic[TOPIC_LEN_MAX] = { 0 }; in awss_cmp_local_init() local
|
| A D | awss_cmp.h | 32 char *topic; member
|
| /AliOS-Things-master/components/linksdk/components/data-model/ |
| A D | aiot_dm_api.c | 149 …atic int32_t _dm_prepare_send_topic(dm_handle_t *dm_handle, const aiot_dm_msg_t *msg, char **topic) in _dm_prepare_send_topic()
231 static int32_t _dm_send_alink_req(dm_handle_t *handle, const char *topic, char *params) in _dm_send_alink_req()
267 static int32_t _dm_send_alink_rsp(dm_handle_t *handle, const char *topic, uint64_t msg_id, uint32_t… in _dm_send_alink_rsp()
300 static int32_t _dm_send_property_post(dm_handle_t *handle, const char *topic, const aiot_dm_msg_t *… in _dm_send_property_post()
305 static int32_t _dm_send_event_post(dm_handle_t *handle, const char *topic, const aiot_dm_msg_t *msg) in _dm_send_event_post()
310 static int32_t _dm_send_property_set_reply(dm_handle_t *handle, const char *topic, const aiot_dm_ms… in _dm_send_property_set_reply()
331 static int32_t _dm_send_raw_data(dm_handle_t *handle, const char *topic, const aiot_dm_msg_t *msg) in _dm_send_raw_data()
336 static int32_t _dm_send_raw_service_reply(dm_handle_t *handle, const char *topic, const aiot_dm_msg… in _dm_send_raw_service_reply()
342 static int32_t _dm_send_desired_get(dm_handle_t *handle, const char *topic, const aiot_dm_msg_t *ms… in _dm_send_desired_get()
347 static int32_t _dm_send_desired_delete(dm_handle_t *handle, const char *topic, const aiot_dm_msg_t … in _dm_send_desired_delete()
[all …]
|
| A D | dm_private.h | 63 char *topic; member
69 char *topic; member
|
| /AliOS-Things-master/components/ota/hal/ |
| A D | ota_hal_trans.c | 10 int ota_hal_mqtt_publish(void *mqtt_client, char *topic, int qos, void *data, int len) in ota_hal_mqtt_publish()
15 int ota_hal_mqtt_subscribe(void *mqtt_client, char *topic, void* cb, void *ctx) in ota_hal_mqtt_subscribe()
|
| /AliOS-Things-master/components/linkkit/dev_model/ |
| A D | iotx_cm_mqtt.c | 196 char *topic = NULL; in iotx_cloud_conn_mqtt_event_handle() local
298 static int _mqtt_publish(iotx_cm_ext_params_t *ext, const char *topic, in _mqtt_publish()
323 static int _mqtt_sub(iotx_cm_ext_params_t *ext, const char *topic, in _mqtt_sub()
359 static int _mqtt_unsub(const char *topic) in _mqtt_unsub()
|
| A D | iotx_cm_coap.c | 266 char *topic = cm_malloc(topic_len); in _coap_response_default() local
289 static int _coap_publish(iotx_cm_ext_params_t *ext, const char *topic, in _coap_publish()
360 static int _coap_sub(iotx_cm_ext_params_t *ext, const char *topic, in _coap_sub()
366 static int _coap_unsub(const char *topic) in _coap_unsub()
|
| A D | iotx_cm.c | 154 int iotx_cm_sub(int fd, iotx_cm_ext_params_t *ext, const char *topic, in iotx_cm_sub()
170 int iotx_cm_unsub(int fd, const char *topic) in iotx_cm_unsub()
185 int iotx_cm_pub(int fd, iotx_cm_ext_params_t *ext, const char *topic, in iotx_cm_pub()
|
| A D | iotx_cm_coap.h | 14 char *topic; member
|
| A D | iotx_cm_mqtt.h | 13 char *topic; member
|
| /AliOS-Things-master/components/linkkit/dev_model/alcs/ |
| A D | alcs_mqtt.c | 25 static alcs_mqtt_status_e __alcs_mqtt_publish(char *topic, int qos, void *data, in __alcs_mqtt_publish()
33 static alcs_mqtt_status_e __alcs_mqtt_send_response(char *topic, int id, in __alcs_mqtt_send_response()
243 char *topic; in __alcs_mqtt_subscribe_callback() local
485 static alcs_mqtt_status_e __alcs_mqtt_subscribe(void *ctx, char *topic) in __alcs_mqtt_subscribe()
496 char topic[ALCS_MQTT_TOPIC_MAX_LEN] = { 0 }; in alcs_mqtt_init() local
619 char topic[ALCS_MQTT_TOPIC_MAX_LEN] = { 0 }; in alcs_prefixkey_get() local
654 char topic[ALCS_MQTT_TOPIC_MAX_LEN] = { 0 }; in alcs_mqtt_subdev_prefix_get() local
|
| /AliOS-Things-master/components/py_engine/modules/mqtt/ |
| A D | module_mqtt.c | 159 const char *topic = NULL; in native_mqtt_subscribe() local
207 const char *topic; in native_mqtt_unsubscribe() local
247 const char *topic; in native_mqtt_publish() local
|
| /AliOS-Things-master/components/amp/engine/duktape_engine/addons/network/mqtt/ |
| A D | module_mqtt.c | 154 const char *topic = NULL; in native_mqtt_subscribe() local
202 const char *topic; in native_mqtt_unsubscribe() local
241 const char *topic; in native_mqtt_publish() local
|
| /AliOS-Things-master/components/ota/ota_agent/transport/ |
| A D | ota_transport_mqtt.c | 198 char topic[OTA_MSG_LEN] = {0}; in ota_mqtt_publish() local
290 char topic[OTA_MSG_LEN] = {0}; in ota_transport_inform_otaver() local
331 char topic[OTA_MSG_LEN] = {0}; in ota_transport_upgrade() local
|
| /AliOS-Things-master/components/linksdk/core/ |
| A D | aiot_mqtt_api.c | 145 static int32_t _core_mqtt_sublist_insert(core_mqtt_handle_t *mqtt_handle, core_mqtt_buff_t *topic, in _core_mqtt_sublist_insert()
194 …nt32_t _core_mqtt_topic_alias_list_insert(core_mqtt_handle_t *mqtt_handle, core_mqtt_buff_t *topic, in _core_mqtt_topic_alias_list_insert()
258 static void _core_mqtt_sublist_remove(core_mqtt_handle_t *mqtt_handle, core_mqtt_buff_t *topic) in _core_mqtt_sublist_remove()
272 …ic void _core_mqtt_sublist_remove_handler(core_mqtt_handle_t *mqtt_handle, core_mqtt_buff_t *topic, in _core_mqtt_sublist_remove_handler()
303 static int32_t _core_mqtt_topic_is_valid(char *topic, uint32_t len) in _core_mqtt_topic_is_valid()
1957 char *topic, in _core_mqtt_process_topic_alias()
3307 int32_t aiot_mqtt_pub(void *handle, char *topic, uint8_t *payload, uint32_t payload_len, uint8_t qo… in aiot_mqtt_pub()
3400 static int32_t _core_mqtt_unsub(void *handle, core_mqtt_buff_t *topic, unsub_property_t *unsub_prop) in _core_mqtt_unsub()
3440 static int32_t _mqtt_unsub(void *handle, char *topic, unsub_property_t *unsub_prop) in _mqtt_unsub()
3461 int32_t aiot_mqtt_unsub(void *handle, char *topic) in aiot_mqtt_unsub()
[all …]
|
| /AliOS-Things-master/components/linkkit/include/linkkit/wrappers/ |
| A D | wrappers_atm.h | 148 char *topic; member
|
| /AliOS-Things-master/components/amp/example-js/ |
| A D | iot.js | 8 var topic = '/sys/' + productKey + '/' + deviceName + '/user/haas/info'; variable
|
| A D | mqtt.js | 52 mqttClient.on('message', function(topic, payload) { argument
|
| /AliOS-Things-master/components/amp/engine/quickjs_engine/addons/network/mqtt/ |
| A D | module_mqtt.c | 39 char *topic; member
303 const char *topic = NULL; in native_mqtt_subscribe() local
332 const char *topic; in native_mqtt_unsubscribe() local
361 const char *topic; in native_mqtt_publish() local
|
| /AliOS-Things-master/components/amp/engine/duktape_engine/addons/advanced/aiot/ |
| A D | module_aiot_device.c | 34 char *topic; member
732 char *topic; in native_aiot_publish() local
782 char *topic; in native_aiot_unsubscribe() local
816 char *topic = NULL; in native_aiot_subscribe() local
|
| A D | module_aiot_gateway.c | 26 char *topic; member
957 char *topic; in native_aiot_publish() local
1010 char *topic; in native_aiot_unsubscribe() local
1047 char *topic = NULL; in native_aiot_subscribe() local
|
| /AliOS-Things-master/components/linkkit/dev_reset/ |
| A D | dev_reset.c | 49 char topic[IOTX_PRODUCT_KEY_LEN + IOTX_DEVICE_NAME_LEN + 30] = { 0 }; in IOT_DevReset_Report() local
|
| /AliOS-Things-master/components/linksdk/components/ntp/ |
| A D | aiot_ntp_api.c | 105 char *topic = NULL; in _ntp_operate_topic_map() local
290 char *topic = NULL, *payload = NULL; in aiot_ntp_send_request() local
|