Lines Matching refs:message
30 int _dm_msg_send_to_user(iotx_dm_event_types_t type, char *message) in _dm_msg_send_to_user() argument
42 dipc_msg->data = message; in _dm_msg_send_to_user()
59 char *message = NULL; in dm_msg_send_msg_timeout_to_user() local
63 message = DM_malloc(message_len + 1); in dm_msg_send_msg_timeout_to_user()
64 if (message == NULL) { in dm_msg_send_msg_timeout_to_user()
67 memset(message, 0, message_len); in dm_msg_send_msg_timeout_to_user()
68 HAL_Snprintf(message, message_len, DM_MSG_SEND_MSG_TIMEOUT_FMT, msg_id, in dm_msg_send_msg_timeout_to_user()
71 res = _dm_msg_send_to_user(type, message); in dm_msg_send_msg_timeout_to_user()
73 DM_free(message); in dm_msg_send_msg_timeout_to_user()
85 char *hexstr = NULL, *message = NULL; in dm_msg_thing_model_user_sub() local
230 &response->message) == SUCCESS_RETURN) { in dm_msg_response_parse()
232 response->message.value_length, response->message.value); in dm_msg_response_parse()
378 char *hexstr = NULL, *message = NULL; in dm_msg_thing_model_down_raw() local
399 message = DM_malloc(message_len); in dm_msg_thing_model_down_raw()
400 if (message == NULL) { in dm_msg_thing_model_down_raw()
404 memset(message, 0, message_len); in dm_msg_thing_model_down_raw()
405 HAL_Snprintf(message, message_len, DM_MSG_THING_MODEL_DOWN_FMT, devid, in dm_msg_thing_model_down_raw()
409 res = _dm_msg_send_to_user(IOTX_DM_EVENT_MODEL_DOWN_RAW, message); in dm_msg_thing_model_down_raw()
411 DM_free(message); in dm_msg_thing_model_down_raw()
426 char *hexstr = NULL, *message = NULL; in dm_msg_thing_model_up_raw_reply() local
447 message = DM_malloc(message_len); in dm_msg_thing_model_up_raw_reply()
448 if (message == NULL) { in dm_msg_thing_model_up_raw_reply()
452 memset(message, 0, message_len); in dm_msg_thing_model_up_raw_reply()
453 HAL_Snprintf(message, message_len, DM_MSG_THING_MODEL_DOWN_FMT, devid, in dm_msg_thing_model_up_raw_reply()
457 res = _dm_msg_send_to_user(IOTX_DM_EVENT_MODEL_UP_RAW_REPLY, message); in dm_msg_thing_model_up_raw_reply()
459 DM_free(message); in dm_msg_thing_model_up_raw_reply()
478 char *message = NULL; in dm_msg_property_set() local
482 message = DM_malloc(message_len); in dm_msg_property_set()
483 if (message == NULL) { in dm_msg_property_set()
486 memset(message, 0, message_len); in dm_msg_property_set()
488 HAL_Snprintf(message, message_len, DM_MSG_PROPERTY_SET_FMT, devid, in dm_msg_property_set()
492 HAL_Snprintf(message, message_len, DM_MSG_PROPERTY_SET_FMT, devid, in dm_msg_property_set()
495 res = _dm_msg_send_to_user(IOTX_DM_EVENT_PROPERTY_SET, message); in dm_msg_property_set()
497 DM_free(message); in dm_msg_property_set()
506 char *message = NULL; in dm_msg_thing_event_notify() local
510 message = DM_malloc(message_len); in dm_msg_thing_event_notify()
511 if (message == NULL) { in dm_msg_thing_event_notify()
514 memset(message, 0, message_len); in dm_msg_thing_event_notify()
516 HAL_Snprintf(message, message_len, DM_MSG_PROPERTY_SET_FMT, devid, in dm_msg_thing_event_notify()
520 HAL_Snprintf(message, message_len, DM_MSG_PROPERTY_SET_FMT, devid, in dm_msg_thing_event_notify()
523 res = _dm_msg_send_to_user(IOTX_DM_EVENT_THING_EVENT_NOTIFY, message); in dm_msg_thing_event_notify()
525 DM_free(message); in dm_msg_thing_event_notify()
538 char *ctx_addr_str = NULL, *message = NULL; in dm_msg_property_get() local
555 message = DM_malloc(message_len); in dm_msg_property_get()
556 if (message == NULL) { in dm_msg_property_get()
560 memset(message, 0, message_len); in dm_msg_property_get()
561 HAL_Snprintf(message, message_len, DM_MSG_THING_PROPERTY_GET_FMT, in dm_msg_property_get()
568 res = _dm_msg_send_to_user(IOTX_DM_EVENT_PROPERTY_GET, message); in dm_msg_property_get()
570 DM_free(message); in dm_msg_property_get()
586 char *message = NULL; in dm_msg_thing_service_request() local
614 message = DM_malloc(message_len); in dm_msg_thing_service_request()
615 if (message == NULL) { in dm_msg_thing_service_request()
620 memset(message, 0, message_len); in dm_msg_thing_service_request()
621 HAL_Snprintf(message, message_len, DM_MSG_SERVICE_REQUEST_FMT, in dm_msg_thing_service_request()
627 res = _dm_msg_send_to_user(IOTX_DM_EVENT_THING_SERVICE_REQUEST, message); in dm_msg_thing_service_request()
629 DM_free(message); in dm_msg_thing_service_request()
647 char *serviceid = NULL, *message = NULL; in dm_msg_rrpc_request() local
671 message = DM_malloc(message_len); in dm_msg_rrpc_request()
672 if (message == NULL) { in dm_msg_rrpc_request()
675 memset(message, 0, message_len); in dm_msg_rrpc_request()
676 HAL_Snprintf(message, message_len, DM_MSG_EVENT_RRPC_REQUEST_FMT, in dm_msg_rrpc_request()
681 res = _dm_msg_send_to_user(IOTX_DM_EVENT_RRPC_REQUEST, message); in dm_msg_rrpc_request()
683 DM_free(message); in dm_msg_rrpc_request()
695 char *message = NULL, *payload = NULL, *str_payload = NULL; in dm_msg_thing_event_property_post_reply() local
718 if ((strlen("success") == response->message.value_length) && in dm_msg_thing_event_property_post_reply()
719 (memcmp("success", response->message.value, in dm_msg_thing_event_property_post_reply()
720 response->message.value_length) == 0)) { in dm_msg_thing_event_property_post_reply()
724 if (response->message.type == cJSON_String) { in dm_msg_thing_event_property_post_reply()
725 str_payload = DM_malloc(response->message.value_length + 3); in dm_msg_thing_event_property_post_reply()
729 memset(str_payload, 0, response->message.value_length + 3); in dm_msg_thing_event_property_post_reply()
731 memcpy(str_payload + 1, response->message.value, in dm_msg_thing_event_property_post_reply()
732 response->message.value_length); in dm_msg_thing_event_property_post_reply()
733 str_payload[1 + response->message.value_length] = '\"'; in dm_msg_thing_event_property_post_reply()
738 payload = response->message.value; in dm_msg_thing_event_property_post_reply()
739 payload_len = response->message.value_length; in dm_msg_thing_event_property_post_reply()
745 message = DM_malloc(message_len); in dm_msg_thing_event_property_post_reply()
746 if (message == NULL) { in dm_msg_thing_event_property_post_reply()
750 memset(message, 0, message_len); in dm_msg_thing_event_property_post_reply()
751 HAL_Snprintf(message, message_len, DM_MSG_EVENT_PROPERTY_POST_REPLY_FMT, id, in dm_msg_thing_event_property_post_reply()
756 _dm_msg_send_to_user(IOTX_DM_EVENT_EVENT_PROPERTY_POST_REPLY, message); in dm_msg_thing_event_property_post_reply()
758 DM_free(message); in dm_msg_thing_event_property_post_reply()
773 char *message = NULL; in dm_msg_thing_event_post_reply() local
797 response->message.value_length + 1; in dm_msg_thing_event_post_reply()
798 message = DM_malloc(message_len); in dm_msg_thing_event_post_reply()
799 if (message == NULL) { in dm_msg_thing_event_post_reply()
802 memset(message, 0, message_len); in dm_msg_thing_event_post_reply()
803 HAL_Snprintf(message, message_len, DM_MSG_EVENT_SPECIFIC_POST_REPLY_FMT, id, in dm_msg_thing_event_post_reply()
805 response->message.value_length, response->message.value); in dm_msg_thing_event_post_reply()
808 _dm_msg_send_to_user(IOTX_DM_EVENT_EVENT_SPECIFIC_POST_REPLY, message); in dm_msg_thing_event_post_reply()
810 DM_free(message); in dm_msg_thing_event_post_reply()
822 char *message = NULL; in dm_msg_thing_property_desired_get_reply() local
844 message = DM_malloc(message_len); in dm_msg_thing_property_desired_get_reply()
845 if (message == NULL) { in dm_msg_thing_property_desired_get_reply()
848 memset(message, 0, message_len); in dm_msg_thing_property_desired_get_reply()
849 HAL_Snprintf(message, message_len, in dm_msg_thing_property_desired_get_reply()
855 _dm_msg_send_to_user(IOTX_DM_EVENT_PROPERTY_DESIRED_GET_REPLY, message); in dm_msg_thing_property_desired_get_reply()
857 DM_free(message); in dm_msg_thing_property_desired_get_reply()
870 char *message = NULL; in dm_msg_thing_property_desired_delete_reply() local
893 message = DM_malloc(message_len); in dm_msg_thing_property_desired_delete_reply()
894 if (message == NULL) { in dm_msg_thing_property_desired_delete_reply()
897 memset(message, 0, message_len); in dm_msg_thing_property_desired_delete_reply()
898 HAL_Snprintf(message, message_len, in dm_msg_thing_property_desired_delete_reply()
904 message); in dm_msg_thing_property_desired_delete_reply()
906 DM_free(message); in dm_msg_thing_property_desired_delete_reply()
919 char *message = NULL; in dm_msg_thing_deviceinfo_update_reply() local
944 message = DM_malloc(message_len); in dm_msg_thing_deviceinfo_update_reply()
945 if (message == NULL) { in dm_msg_thing_deviceinfo_update_reply()
948 memset(message, 0, message_len); in dm_msg_thing_deviceinfo_update_reply()
949 HAL_Snprintf(message, message_len, DM_MSG_EVENT_DEVICEINFO_UPDATE_REPLY_FMT, in dm_msg_thing_deviceinfo_update_reply()
952 res = _dm_msg_send_to_user(IOTX_DM_EVENT_DEVICEINFO_UPDATE_REPLY, message); in dm_msg_thing_deviceinfo_update_reply()
954 DM_free(message); in dm_msg_thing_deviceinfo_update_reply()
966 char *message = NULL; in dm_msg_thing_deviceinfo_delete_reply() local
991 message = DM_malloc(message_len); in dm_msg_thing_deviceinfo_delete_reply()
992 if (message == NULL) { in dm_msg_thing_deviceinfo_delete_reply()
995 memset(message, 0, message_len); in dm_msg_thing_deviceinfo_delete_reply()
996 HAL_Snprintf(message, message_len, DM_MSG_EVENT_DEVICEINFO_DELETE_REPLY_FMT, in dm_msg_thing_deviceinfo_delete_reply()
999 res = _dm_msg_send_to_user(IOTX_DM_EVENT_DEVICEINFO_DELETE_REPLY, message); in dm_msg_thing_deviceinfo_delete_reply()
1001 DM_free(message); in dm_msg_thing_deviceinfo_delete_reply()
1086 char *message = NULL; in dm_msg_ntp_response() local
1110 message = DM_malloc(message_len); in dm_msg_ntp_response()
1111 if (message == NULL) { in dm_msg_ntp_response()
1114 memset(message, 0, message_len); in dm_msg_ntp_response()
1115 HAL_Snprintf(message, message_len, DM_MSG_THING_NTP_RESPONSE_FMT, in dm_msg_ntp_response()
1119 res = _dm_msg_send_to_user(IOTX_DM_EVENT_NTP_RESPONSE, message); in dm_msg_ntp_response()
1121 DM_free(message); in dm_msg_ntp_response()
1131 char *message = NULL; in dm_msg_ext_error_response() local
1137 message = DM_malloc(message_len); in dm_msg_ext_error_response()
1138 if (message == NULL) { in dm_msg_ext_error_response()
1141 memset(message, 0, message_len); in dm_msg_ext_error_response()
1142 strncpy(message, payload, payload_len); in dm_msg_ext_error_response()
1143 res = _dm_msg_send_to_user(IOTX_DM_EVENT_CLOUD_ERROR, message); in dm_msg_ext_error_response()
1145 DM_free(message); in dm_msg_ext_error_response()
1164 char *message = NULL; in dm_msg_topo_add_notify() local
1175 message = NULL; in dm_msg_topo_add_notify()
1225 message = DM_malloc(message_len); in dm_msg_topo_add_notify()
1226 if (message == NULL) { in dm_msg_topo_add_notify()
1230 memset(message, 0, message_len); in dm_msg_topo_add_notify()
1231 HAL_Snprintf(message, message_len, DM_MSG_TOPO_ADD_NOTIFY_USER_PAYLOAD, in dm_msg_topo_add_notify()
1233 res = _dm_msg_send_to_user(IOTX_DM_EVENT_TOPO_ADD_NOTIFY, message); in dm_msg_topo_add_notify()
1236 DM_free(message); in dm_msg_topo_add_notify()
1248 char *message = NULL; in dm_msg_thing_disable() local
1265 message = DM_malloc(message_len); in dm_msg_thing_disable()
1266 if (message == NULL) { in dm_msg_thing_disable()
1269 memset(message, 0, message_len); in dm_msg_thing_disable()
1270 HAL_Snprintf(message, message_len, DM_MSG_EVENT_THING_DISABLE_FMT, devid); in dm_msg_thing_disable()
1272 res = _dm_msg_send_to_user(IOTX_DM_EVENT_THING_DISABLE, message); in dm_msg_thing_disable()
1274 DM_free(message); in dm_msg_thing_disable()
1286 char *message = NULL; in dm_msg_thing_enable() local
1306 message = DM_malloc(message_len); in dm_msg_thing_enable()
1307 if (message == NULL) { in dm_msg_thing_enable()
1310 memset(message, 0, message_len); in dm_msg_thing_enable()
1311 HAL_Snprintf(message, message_len, DM_MSG_EVENT_THING_ENABLE_FMT, devid); in dm_msg_thing_enable()
1313 res = _dm_msg_send_to_user(IOTX_DM_EVENT_THING_ENABLE, message); in dm_msg_thing_enable()
1315 DM_free(message); in dm_msg_thing_enable()
1328 char *message = NULL; in dm_msg_thing_delete() local
1348 message = DM_malloc(message_len); in dm_msg_thing_delete()
1349 if (message == NULL) { in dm_msg_thing_delete()
1352 memset(message, 0, message_len); in dm_msg_thing_delete()
1353 HAL_Snprintf(message, message_len, DM_MSG_EVENT_THING_DELETE_FMT, res, in dm_msg_thing_delete()
1356 res = _dm_msg_send_to_user(IOTX_DM_EVENT_THING_DELETE, message); in dm_msg_thing_delete()
1358 DM_free(message); in dm_msg_thing_delete()
1368 char *message = NULL; in dm_msg_thing_gateway_permit() local
1381 message = DM_malloc(message_len); in dm_msg_thing_gateway_permit()
1382 if (message == NULL) { in dm_msg_thing_gateway_permit()
1385 memcpy(message, payload, payload_len); in dm_msg_thing_gateway_permit()
1387 res = _dm_msg_send_to_user(IOTX_DM_EVENT_GATEWAY_PERMIT, message); in dm_msg_thing_gateway_permit()
1389 DM_free(message); in dm_msg_thing_gateway_permit()
1402 char *message = NULL; in dm_msg_thing_sub_register_reply() local
1417 message = DM_malloc(message_len); in dm_msg_thing_sub_register_reply()
1418 if (message == NULL) { in dm_msg_thing_sub_register_reply()
1422 memset(message, 0, message_len); in dm_msg_thing_sub_register_reply()
1423 HAL_Snprintf(message, message_len, in dm_msg_thing_sub_register_reply()
1428 _dm_msg_send_to_user(IOTX_DM_EVENT_SUBDEV_REGISTER_REPLY, message); in dm_msg_thing_sub_register_reply()
1430 DM_free(message); in dm_msg_thing_sub_register_reply()
1443 message = NULL; in dm_msg_thing_sub_register_reply()
1523 message = DM_malloc(message_len); in dm_msg_thing_sub_register_reply()
1524 if (message == NULL) { in dm_msg_thing_sub_register_reply()
1528 memset(message, 0, message_len); in dm_msg_thing_sub_register_reply()
1529 HAL_Snprintf(message, message_len, in dm_msg_thing_sub_register_reply()
1534 _dm_msg_send_to_user(IOTX_DM_EVENT_SUBDEV_REGISTER_REPLY, message); in dm_msg_thing_sub_register_reply()
1536 DM_free(message); in dm_msg_thing_sub_register_reply()
1550 char *message = NULL; in dm_msg_thing_proxy_product_register_reply_successes() local
1560 message = NULL; in dm_msg_thing_proxy_product_register_reply_successes()
1630 message = DM_malloc(message_len); in dm_msg_thing_proxy_product_register_reply_successes()
1631 if (message == NULL) { in dm_msg_thing_proxy_product_register_reply_successes()
1635 memset(message, 0, message_len); in dm_msg_thing_proxy_product_register_reply_successes()
1636 HAL_Snprintf(message, message_len, in dm_msg_thing_proxy_product_register_reply_successes()
1641 message); in dm_msg_thing_proxy_product_register_reply_successes()
1643 DM_free(message); in dm_msg_thing_proxy_product_register_reply_successes()
1652 char *message = NULL; in dm_msg_thing_proxy_product_register_reply_failures() local
1662 message = NULL; in dm_msg_thing_proxy_product_register_reply_failures()
1733 message = DM_malloc(message_len); in dm_msg_thing_proxy_product_register_reply_failures()
1734 if (message == NULL) { in dm_msg_thing_proxy_product_register_reply_failures()
1738 memset(message, 0, message_len); in dm_msg_thing_proxy_product_register_reply_failures()
1739 HAL_Snprintf(message, message_len, in dm_msg_thing_proxy_product_register_reply_failures()
1744 message); in dm_msg_thing_proxy_product_register_reply_failures()
1746 DM_free(message); in dm_msg_thing_proxy_product_register_reply_failures()
1757 char *message = NULL; in dm_msg_thing_proxy_product_register_reply() local
1798 char *message = NULL; in dm_msg_thing_sub_unregister_reply() local
1825 message = DM_malloc(message_len); in dm_msg_thing_sub_unregister_reply()
1826 if (message == NULL) { in dm_msg_thing_sub_unregister_reply()
1829 memset(message, 0, message_len); in dm_msg_thing_sub_unregister_reply()
1830 HAL_Snprintf(message, message_len, DM_MSG_EVENT_SUBDEV_UNREGISTER_REPLY_FMT, in dm_msg_thing_sub_unregister_reply()
1833 res = _dm_msg_send_to_user(IOTX_DM_EVENT_SUBDEV_UNREGISTER_REPLY, message); in dm_msg_thing_sub_unregister_reply()
1835 DM_free(message); in dm_msg_thing_sub_unregister_reply()
1847 char *message = NULL; in dm_msg_thing_topo_add_reply() local
1876 message = DM_malloc(message_len); in dm_msg_thing_topo_add_reply()
1877 if (message == NULL) { in dm_msg_thing_topo_add_reply()
1880 memset(message, 0, message_len); in dm_msg_thing_topo_add_reply()
1881 HAL_Snprintf(message, message_len, DM_MSG_EVENT_THING_TOPO_ADD_REPLY_FMT, in dm_msg_thing_topo_add_reply()
1884 res = _dm_msg_send_to_user(IOTX_DM_EVENT_TOPO_ADD_REPLY, message); in dm_msg_thing_topo_add_reply()
1886 DM_free(message); in dm_msg_thing_topo_add_reply()
1899 char *message = NULL; in dm_msg_thing_topo_delete_reply() local
1928 message = DM_malloc(message_len); in dm_msg_thing_topo_delete_reply()
1929 if (message == NULL) { in dm_msg_thing_topo_delete_reply()
1932 memset(message, 0, message_len); in dm_msg_thing_topo_delete_reply()
1933 HAL_Snprintf(message, message_len, DM_MSG_EVENT_THING_TOPO_DELETE_REPLY_FMT, in dm_msg_thing_topo_delete_reply()
1936 res = _dm_msg_send_to_user(IOTX_DM_EVENT_TOPO_DELETE_REPLY, message); in dm_msg_thing_topo_delete_reply()
1938 DM_free(message); in dm_msg_thing_topo_delete_reply()
1950 char *message = NULL; in dm_msg_topo_get_reply() local
1968 message = DM_malloc(message_len); in dm_msg_topo_get_reply()
1969 if (message == NULL) { in dm_msg_topo_get_reply()
1972 memset(message, 0, message_len); in dm_msg_topo_get_reply()
1973 HAL_Snprintf(message, message_len, DM_MSG_TOPO_GET_REPLY_FMT, id, in dm_msg_topo_get_reply()
1977 res = _dm_msg_send_to_user(IOTX_DM_EVENT_TOPO_GET_REPLY, message); in dm_msg_topo_get_reply()
1979 DM_free(message); in dm_msg_topo_get_reply()
1996 char *message = NULL; in dm_msg_combine_login_reply() local
2051 message = DM_malloc(message_len); in dm_msg_combine_login_reply()
2052 if (message == NULL) { in dm_msg_combine_login_reply()
2055 memset(message, 0, message_len); in dm_msg_combine_login_reply()
2056 HAL_Snprintf(message, message_len, DM_MSG_EVENT_COMBINE_LOGIN_REPLY_FMT, in dm_msg_combine_login_reply()
2059 res = _dm_msg_send_to_user(IOTX_DM_EVENT_COMBINE_LOGIN_REPLY, message); in dm_msg_combine_login_reply()
2061 DM_free(message); in dm_msg_combine_login_reply()
2077 char *message = NULL; in dm_msg_combine_logout_reply() local
2132 message = DM_malloc(message_len); in dm_msg_combine_logout_reply()
2133 if (message == NULL) { in dm_msg_combine_logout_reply()
2136 memset(message, 0, message_len); in dm_msg_combine_logout_reply()
2137 HAL_Snprintf(message, message_len, DM_MSG_EVENT_COMBINE_LOGOUT_REPLY_FMT, in dm_msg_combine_logout_reply()
2140 res = _dm_msg_send_to_user(IOTX_DM_EVENT_COMBINE_LOGOUT_REPLY, message); in dm_msg_combine_logout_reply()
2142 DM_free(message); in dm_msg_combine_logout_reply()
2961 char *message = NULL; in dm_msg_property_set() local
2973 message = DM_malloc(message_len); in dm_msg_property_set()
2974 if (message == NULL) { in dm_msg_property_set()
2977 memset(message, 0, message_len); in dm_msg_property_set()
2978 HAL_Snprintf(message, message_len, DM_MSG_PROPERTY_SET_FMT, devid, in dm_msg_property_set()
2981 res = _dm_msg_send_to_user(IOTX_DM_EVENT_PROPERTY_SET, message); in dm_msg_property_set()
2983 DM_free(message); in dm_msg_property_set()
3016 message = DM_malloc(message_len); in dm_msg_property_set()
3017 if (message == NULL) { in dm_msg_property_set()
3020 memset(message, 0, message_len); in dm_msg_property_set()
3021 HAL_Snprintf(message, message_len, DM_MSG_PROPERTY_SET_FMT, devid, in dm_msg_property_set()
3024 res = _dm_msg_send_to_user(IOTX_DM_EVENT_PROPERTY_SET, message); in dm_msg_property_set()
3026 DM_free(message); in dm_msg_property_set()
3110 char *message = NULL; in dm_msg_thing_service_request() local
3138 message = DM_malloc(message_len); in dm_msg_thing_service_request()
3139 if (message == NULL) { in dm_msg_thing_service_request()
3142 memset(message, 0, message_len); in dm_msg_thing_service_request()
3143 HAL_Snprintf(message, message_len, DM_MSG_SERVICE_REQUEST_FMT, id, devid, in dm_msg_thing_service_request()
3176 message = DM_malloc(message_len); in dm_msg_thing_service_request()
3177 if (message == NULL) { in dm_msg_thing_service_request()
3180 memset(message, 0, message_len); in dm_msg_thing_service_request()
3181 HAL_Snprintf(message, message_len, DM_MSG_SERVICE_REQUEST_FMT, id, devid, in dm_msg_thing_service_request()
3184 res = _dm_msg_send_to_user(IOTX_DM_EVENT_THING_SERVICE_REQUEST, message); in dm_msg_thing_service_request()
3186 DM_free(message); in dm_msg_thing_service_request()