Lines Matching refs:source
133 int dm_msg_proc_thing_model_down_raw(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_model_down_raw() argument
140 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_model_down_raw()
148 product_key, device_name, (char *)source->payload, source->payload_len); in dm_msg_proc_thing_model_down_raw()
151 int dm_msg_proc_thing_model_up_raw_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_model_up_raw_reply() argument
159 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_model_up_raw_reply()
168 product_key, device_name, (char *)source->payload, source->payload_len); in dm_msg_proc_thing_model_up_raw_reply()
178 _IN_ dm_msg_source_t *source, _IN_ dm_msg_dest_t *dest, in dm_msg_proc_thing_service_property_set() argument
188 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_service_property_set()
200 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_service_property_set()
220 int dm_msg_proc_thing_event_notify(_IN_ dm_msg_source_t *source, in dm_msg_proc_thing_event_notify() argument
232 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_event_notify()
244 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_event_notify()
265 _IN_ dm_msg_source_t *source, _IN_ dm_msg_dest_t *dest, in dm_msg_proc_thing_service_property_get() argument
276 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_service_property_get()
288 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_service_property_get()
296 res = dm_msg_property_get(devid, request, source->context); in dm_msg_proc_thing_service_property_get()
330 _IN_ dm_msg_source_t *source, _IN_ dm_msg_dest_t *dest, in dm_msg_proc_thing_service_property_post() argument
340 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_service_property_post()
347 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_service_property_post()
361 int dm_msg_proc_thing_service_request(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_service_request() argument
370 res = dm_utils_memtok((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_service_request()
376 (int)(strlen(source->uri) - serviceid_pos - 1), in dm_msg_proc_thing_service_request()
377 source->uri + serviceid_pos + 1); in dm_msg_proc_thing_service_request()
380 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_service_request()
388 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_service_request()
396 product_key, device_name, (char *)source->uri + serviceid_pos + 1, in dm_msg_proc_thing_service_request()
397 strlen(source->uri) - serviceid_pos - 1, &request, source->context); in dm_msg_proc_thing_service_request()
400 int dm_msg_proc_thing_event_post_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_event_post_reply() argument
408 res = dm_utils_memtok((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_event_post_reply()
415 res = dm_utils_memtok((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_event_post_reply()
422 source->uri + eventid_start_pos + 1); in dm_msg_proc_thing_event_post_reply()
425 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_event_post_reply()
433 (memcmp("property", source->uri + eventid_start_pos + 1, in dm_msg_proc_thing_event_post_reply()
438 (char *)source->uri + eventid_start_pos + 1, in dm_msg_proc_thing_event_post_reply()
454 int dm_msg_proc_thing_property_desired_get_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_property_desired_get_reply() argument
465 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_property_desired_get_reply()
486 _IN_ dm_msg_source_t *source) in dm_msg_proc_thing_property_desired_delete_reply() argument
497 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_property_desired_delete_reply()
518 int dm_msg_proc_thing_deviceinfo_update_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_deviceinfo_update_reply() argument
529 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_deviceinfo_update_reply()
549 int dm_msg_proc_thing_deviceinfo_delete_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_deviceinfo_delete_reply() argument
560 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_deviceinfo_delete_reply()
580 int dm_msg_proc_thing_dynamictsl_get_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_dynamictsl_get_reply() argument
591 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_dynamictsl_get_reply()
611 int dm_msg_proc_rrpc_request(_IN_ dm_msg_source_t *source) in dm_msg_proc_rrpc_request() argument
620 res = dm_utils_memtok((char *)source->uri, strlen(source->uri), in dm_msg_proc_rrpc_request()
625 dm_log_info("Rrpc Id: %.*s", (int)(strlen(source->uri) - rrpcid_pos - 1), in dm_msg_proc_rrpc_request()
626 source->uri + rrpcid_pos + 1); in dm_msg_proc_rrpc_request()
629 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_rrpc_request()
637 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_rrpc_request()
645 (char *)source->uri + rrpcid_pos + 1, in dm_msg_proc_rrpc_request()
646 strlen(source->uri) - rrpcid_pos - 1, &request); in dm_msg_proc_rrpc_request()
649 int dm_disp_ntp_response(_IN_ dm_msg_source_t *source) in dm_disp_ntp_response() argument
654 return dm_msg_ntp_response((char *)source->payload, source->payload_len); in dm_disp_ntp_response()
657 int dm_disp_ext_error_response(_IN_ dm_msg_source_t *source) in dm_disp_ext_error_response() argument
659 return dm_msg_ext_error_response((char *)source->payload, in dm_disp_ext_error_response()
660 source->payload_len); in dm_disp_ext_error_response()
665 int dm_msg_proc_thing_topo_add_notify(_IN_ dm_msg_source_t *source, in dm_msg_proc_thing_topo_add_notify() argument
677 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_topo_add_notify()
684 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_topo_add_notify()
708 int dm_msg_proc_thing_disable(_IN_ dm_msg_source_t *source, in dm_msg_proc_thing_disable() argument
720 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_disable()
727 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_disable()
747 int dm_msg_proc_thing_enable(_IN_ dm_msg_source_t *source, in dm_msg_proc_thing_enable() argument
759 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_enable()
766 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_enable()
786 int dm_msg_proc_thing_delete(_IN_ dm_msg_source_t *source, in dm_msg_proc_thing_delete() argument
798 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_delete()
805 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_delete()
825 int dm_msg_proc_thing_gateway_permit(_IN_ dm_msg_source_t *source, in dm_msg_proc_thing_gateway_permit() argument
837 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_gateway_permit()
844 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_gateway_permit()
865 int dm_msg_proc_thing_sub_register_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_sub_register_reply() argument
878 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_sub_register_reply()
899 int dm_msg_proc_thing_proxy_product_register_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_proxy_product_register_reply() argument
912 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_proxy_product_register_reply()
934 int dm_msg_proc_thing_sub_unregister_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_sub_unregister_reply() argument
947 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_sub_unregister_reply()
967 int dm_msg_proc_thing_topo_add_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_topo_add_reply() argument
980 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_topo_add_reply()
1000 int dm_msg_proc_thing_topo_delete_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_topo_delete_reply() argument
1013 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_topo_delete_reply()
1033 int dm_msg_proc_thing_topo_get_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_topo_get_reply() argument
1046 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_topo_get_reply()
1066 int dm_msg_proc_thing_list_found_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_list_found_reply() argument
1079 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_list_found_reply()
1099 int dm_msg_proc_combine_login_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_combine_login_reply() argument
1112 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_combine_login_reply()
1132 int dm_msg_proc_combine_logout_reply(_IN_ dm_msg_source_t *source) in dm_msg_proc_combine_logout_reply() argument
1145 res = dm_msg_response_parse((char *)source->payload, source->payload_len, in dm_msg_proc_combine_logout_reply()
1168 _IN_ dm_msg_source_t *source, _IN_ dm_msg_dest_t *dest, in dm_msg_proc_thing_dev_core_service_dev() argument
1177 res = dm_msg_request_parse((char *)source->payload, source->payload_len, in dm_msg_proc_thing_dev_core_service_dev()
1199 int dm_msg_proc_thing_model_user_sub(_IN_ dm_msg_source_t *source) in dm_msg_proc_thing_model_user_sub() argument
1206 res = dm_msg_uri_parse_pkdn((char *)source->uri, strlen(source->uri), in dm_msg_proc_thing_model_user_sub()
1213 product_key, device_name, (char *)source->payload, source->payload_len); in dm_msg_proc_thing_model_user_sub()