Lines Matching refs:source
226 dm_msg_source_t source; in dm_client_thing_event_notify() local
231 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_event_notify()
236 source.uri = topic; in dm_client_thing_event_notify()
237 source.payload = (unsigned char *)payload; in dm_client_thing_event_notify()
238 source.payload_len = payload_len; in dm_client_thing_event_notify()
239 source.context = NULL; in dm_client_thing_event_notify()
243 res = dm_msg_proc_thing_event_notify(&source, &dest, &request, &response); in dm_client_thing_event_notify()
270 dm_msg_source_t source; in dm_client_thing_model_down_raw() local
272 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_model_down_raw()
274 source.uri = topic; in dm_client_thing_model_down_raw()
275 source.payload = (unsigned char *)payload; in dm_client_thing_model_down_raw()
276 source.payload_len = payload_len; in dm_client_thing_model_down_raw()
277 source.context = NULL; in dm_client_thing_model_down_raw()
279 dm_msg_proc_thing_model_down_raw(&source); in dm_client_thing_model_down_raw()
286 dm_msg_source_t source; in dm_client_thing_model_up_raw_reply() local
288 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_model_up_raw_reply()
290 source.uri = topic; in dm_client_thing_model_up_raw_reply()
291 source.payload = (unsigned char *)payload; in dm_client_thing_model_up_raw_reply()
292 source.payload_len = payload_len; in dm_client_thing_model_up_raw_reply()
293 source.context = NULL; in dm_client_thing_model_up_raw_reply()
295 dm_msg_proc_thing_model_up_raw_reply(&source); in dm_client_thing_model_up_raw_reply()
304 dm_msg_source_t source; in dm_client_thing_service_property_set() local
310 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_service_property_set()
315 source.uri = topic; in dm_client_thing_service_property_set()
316 source.payload = (unsigned char *)payload; in dm_client_thing_service_property_set()
317 source.payload_len = payload_len; in dm_client_thing_service_property_set()
318 source.context = NULL; in dm_client_thing_service_property_set()
322 res = dm_msg_proc_thing_service_property_set(&source, &dest, &request, in dm_client_thing_service_property_set()
352 dm_msg_source_t source; in dm_client_thing_service_property_get() local
359 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_service_property_get()
364 source.uri = topic; in dm_client_thing_service_property_get()
365 source.payload = (unsigned char *)payload; in dm_client_thing_service_property_get()
366 source.payload_len = payload_len; in dm_client_thing_service_property_get()
367 source.context = NULL; in dm_client_thing_service_property_get()
371 res = dm_msg_proc_thing_service_property_get(&source, &dest, &request, in dm_client_thing_service_property_get()
383 dm_msg_source_t source; in dm_client_thing_service_request() local
385 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_service_request()
387 source.uri = topic; in dm_client_thing_service_request()
388 source.payload = (unsigned char *)payload; in dm_client_thing_service_request()
389 source.payload_len = payload_len; in dm_client_thing_service_request()
390 source.context = NULL; in dm_client_thing_service_request()
392 dm_msg_proc_thing_service_request(&source); in dm_client_thing_service_request()
399 dm_msg_source_t source; in dm_client_thing_event_post_reply() local
401 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_event_post_reply()
403 source.uri = topic; in dm_client_thing_event_post_reply()
404 source.payload = (unsigned char *)payload; in dm_client_thing_event_post_reply()
405 source.payload_len = payload_len; in dm_client_thing_event_post_reply()
406 source.context = NULL; in dm_client_thing_event_post_reply()
408 dm_msg_proc_thing_event_post_reply(&source); in dm_client_thing_event_post_reply()
416 dm_msg_source_t source; in dm_client_thing_property_desired_get_reply() local
418 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_property_desired_get_reply()
420 source.uri = topic; in dm_client_thing_property_desired_get_reply()
421 source.payload = (unsigned char *)payload; in dm_client_thing_property_desired_get_reply()
422 source.payload_len = payload_len; in dm_client_thing_property_desired_get_reply()
423 source.context = NULL; in dm_client_thing_property_desired_get_reply()
425 dm_msg_proc_thing_property_desired_get_reply(&source); in dm_client_thing_property_desired_get_reply()
433 dm_msg_source_t source; in dm_client_thing_property_desired_delete_reply() local
435 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_property_desired_delete_reply()
437 source.uri = topic; in dm_client_thing_property_desired_delete_reply()
438 source.payload = (unsigned char *)payload; in dm_client_thing_property_desired_delete_reply()
439 source.payload_len = payload_len; in dm_client_thing_property_desired_delete_reply()
440 source.context = NULL; in dm_client_thing_property_desired_delete_reply()
442 dm_msg_proc_thing_property_desired_delete_reply(&source); in dm_client_thing_property_desired_delete_reply()
451 dm_msg_source_t source; in dm_client_thing_deviceinfo_update_reply() local
453 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_deviceinfo_update_reply()
455 source.uri = topic; in dm_client_thing_deviceinfo_update_reply()
456 source.payload = (unsigned char *)payload; in dm_client_thing_deviceinfo_update_reply()
457 source.payload_len = payload_len; in dm_client_thing_deviceinfo_update_reply()
458 source.context = NULL; in dm_client_thing_deviceinfo_update_reply()
460 dm_msg_proc_thing_deviceinfo_update_reply(&source); in dm_client_thing_deviceinfo_update_reply()
468 dm_msg_source_t source; in dm_client_thing_deviceinfo_delete_reply() local
470 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_deviceinfo_delete_reply()
472 source.uri = topic; in dm_client_thing_deviceinfo_delete_reply()
473 source.payload = (unsigned char *)payload; in dm_client_thing_deviceinfo_delete_reply()
474 source.payload_len = payload_len; in dm_client_thing_deviceinfo_delete_reply()
475 source.context = NULL; in dm_client_thing_deviceinfo_delete_reply()
477 dm_msg_proc_thing_deviceinfo_delete_reply(&source); in dm_client_thing_deviceinfo_delete_reply()
485 dm_msg_source_t source; in dm_client_thing_dynamictsl_get_reply() local
487 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_dynamictsl_get_reply()
489 source.uri = topic; in dm_client_thing_dynamictsl_get_reply()
490 source.payload = (unsigned char *)payload; in dm_client_thing_dynamictsl_get_reply()
491 source.payload_len = payload_len; in dm_client_thing_dynamictsl_get_reply()
492 source.context = NULL; in dm_client_thing_dynamictsl_get_reply()
494 dm_msg_proc_thing_dynamictsl_get_reply(&source); in dm_client_thing_dynamictsl_get_reply()
501 dm_msg_source_t source; in dm_client_rrpc_request_wildcard() local
503 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_rrpc_request_wildcard()
505 source.uri = topic; in dm_client_rrpc_request_wildcard()
506 source.payload = (unsigned char *)payload; in dm_client_rrpc_request_wildcard()
507 source.payload_len = payload_len; in dm_client_rrpc_request_wildcard()
508 source.context = NULL; in dm_client_rrpc_request_wildcard()
510 dm_msg_proc_rrpc_request(&source); in dm_client_rrpc_request_wildcard()
516 dm_msg_source_t source; in dm_client_ntp_response() local
518 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_ntp_response()
520 source.uri = topic; in dm_client_ntp_response()
521 source.payload = (unsigned char *)payload; in dm_client_ntp_response()
522 source.payload_len = payload_len; in dm_client_ntp_response()
523 source.context = NULL; in dm_client_ntp_response()
525 dm_disp_ntp_response(&source); in dm_client_ntp_response()
531 dm_msg_source_t source; in dm_client_ext_error() local
533 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_ext_error()
535 source.uri = topic; in dm_client_ext_error()
536 source.payload = (unsigned char *)payload; in dm_client_ext_error()
537 source.payload_len = payload_len; in dm_client_ext_error()
538 source.context = NULL; in dm_client_ext_error()
540 dm_disp_ext_error_response(&source); in dm_client_ext_error()
579 dm_msg_source_t source; in dm_client_thing_topo_add_notify() local
584 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_topo_add_notify()
589 source.uri = topic; in dm_client_thing_topo_add_notify()
590 source.payload = (unsigned char *)payload; in dm_client_thing_topo_add_notify()
591 source.payload_len = payload_len; in dm_client_thing_topo_add_notify()
592 source.context = NULL; in dm_client_thing_topo_add_notify()
597 dm_msg_proc_thing_topo_add_notify(&source, &dest, &request, &response); in dm_client_thing_topo_add_notify()
610 dm_msg_source_t source; in dm_client_thing_disable() local
615 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_disable()
620 source.uri = topic; in dm_client_thing_disable()
621 source.payload = (unsigned char *)payload; in dm_client_thing_disable()
622 source.payload_len = payload_len; in dm_client_thing_disable()
623 source.context = NULL; in dm_client_thing_disable()
627 res = dm_msg_proc_thing_disable(&source, &dest, &request, &response); in dm_client_thing_disable()
640 dm_msg_source_t source; in dm_client_thing_enable() local
645 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_enable()
650 source.uri = topic; in dm_client_thing_enable()
651 source.payload = (unsigned char *)payload; in dm_client_thing_enable()
652 source.payload_len = payload_len; in dm_client_thing_enable()
653 source.context = NULL; in dm_client_thing_enable()
657 res = dm_msg_proc_thing_enable(&source, &dest, &request, &response); in dm_client_thing_enable()
670 dm_msg_source_t source; in dm_client_thing_delete() local
675 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_delete()
680 source.uri = topic; in dm_client_thing_delete()
681 source.payload = (unsigned char *)payload; in dm_client_thing_delete()
682 source.payload_len = payload_len; in dm_client_thing_delete()
683 source.context = NULL; in dm_client_thing_delete()
687 res = dm_msg_proc_thing_delete(&source, &dest, &request, &response); in dm_client_thing_delete()
701 dm_msg_source_t source; in dm_client_thing_gateway_permit() local
706 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_gateway_permit()
711 source.uri = topic; in dm_client_thing_gateway_permit()
712 source.payload = (unsigned char *)payload; in dm_client_thing_gateway_permit()
713 source.payload_len = payload_len; in dm_client_thing_gateway_permit()
714 source.context = NULL; in dm_client_thing_gateway_permit()
718 res = dm_msg_proc_thing_gateway_permit(&source, &dest, &request, &response); in dm_client_thing_gateway_permit()
731 dm_msg_source_t source; in dm_client_thing_sub_register_reply() local
733 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_sub_register_reply()
735 source.uri = topic; in dm_client_thing_sub_register_reply()
736 source.payload = (unsigned char *)payload; in dm_client_thing_sub_register_reply()
737 source.payload_len = payload_len; in dm_client_thing_sub_register_reply()
738 source.context = NULL; in dm_client_thing_sub_register_reply()
740 dm_msg_proc_thing_sub_register_reply(&source); in dm_client_thing_sub_register_reply()
748 dm_msg_source_t source; in dm_client_thing_proxy_product_register_reply() local
750 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_proxy_product_register_reply()
752 source.uri = topic; in dm_client_thing_proxy_product_register_reply()
753 source.payload = (unsigned char *)payload; in dm_client_thing_proxy_product_register_reply()
754 source.payload_len = payload_len; in dm_client_thing_proxy_product_register_reply()
755 source.context = NULL; in dm_client_thing_proxy_product_register_reply()
757 dm_msg_proc_thing_proxy_product_register_reply(&source); in dm_client_thing_proxy_product_register_reply()
765 dm_msg_source_t source; in dm_client_thing_sub_unregister_reply() local
767 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_sub_unregister_reply()
769 source.uri = topic; in dm_client_thing_sub_unregister_reply()
770 source.payload = (unsigned char *)payload; in dm_client_thing_sub_unregister_reply()
771 source.payload_len = payload_len; in dm_client_thing_sub_unregister_reply()
772 source.context = NULL; in dm_client_thing_sub_unregister_reply()
774 dm_msg_proc_thing_sub_unregister_reply(&source); in dm_client_thing_sub_unregister_reply()
781 dm_msg_source_t source; in dm_client_thing_topo_add_reply() local
783 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_topo_add_reply()
785 source.uri = topic; in dm_client_thing_topo_add_reply()
786 source.payload = (unsigned char *)payload; in dm_client_thing_topo_add_reply()
787 source.payload_len = payload_len; in dm_client_thing_topo_add_reply()
788 source.context = NULL; in dm_client_thing_topo_add_reply()
790 dm_msg_proc_thing_topo_add_reply(&source); in dm_client_thing_topo_add_reply()
797 dm_msg_source_t source; in dm_client_thing_topo_delete_reply() local
799 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_topo_delete_reply()
801 source.uri = topic; in dm_client_thing_topo_delete_reply()
802 source.payload = (unsigned char *)payload; in dm_client_thing_topo_delete_reply()
803 source.payload_len = payload_len; in dm_client_thing_topo_delete_reply()
804 source.context = NULL; in dm_client_thing_topo_delete_reply()
806 dm_msg_proc_thing_topo_delete_reply(&source); in dm_client_thing_topo_delete_reply()
813 dm_msg_source_t source; in dm_client_thing_topo_get_reply() local
815 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_topo_get_reply()
817 source.uri = topic; in dm_client_thing_topo_get_reply()
818 source.payload = (unsigned char *)payload; in dm_client_thing_topo_get_reply()
819 source.payload_len = payload_len; in dm_client_thing_topo_get_reply()
820 source.context = NULL; in dm_client_thing_topo_get_reply()
822 dm_msg_proc_thing_topo_get_reply(&source); in dm_client_thing_topo_get_reply()
829 dm_msg_source_t source; in dm_client_thing_list_found_reply() local
831 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_thing_list_found_reply()
833 source.uri = topic; in dm_client_thing_list_found_reply()
834 source.payload = (unsigned char *)payload; in dm_client_thing_list_found_reply()
835 source.payload_len = payload_len; in dm_client_thing_list_found_reply()
836 source.context = NULL; in dm_client_thing_list_found_reply()
838 dm_msg_proc_thing_list_found_reply(&source); in dm_client_thing_list_found_reply()
845 dm_msg_source_t source; in dm_client_combine_login_reply() local
847 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_combine_login_reply()
849 source.uri = topic; in dm_client_combine_login_reply()
850 source.payload = (unsigned char *)payload; in dm_client_combine_login_reply()
851 source.payload_len = payload_len; in dm_client_combine_login_reply()
852 source.context = NULL; in dm_client_combine_login_reply()
854 dm_msg_proc_combine_login_reply(&source); in dm_client_combine_login_reply()
861 dm_msg_source_t source; in dm_client_combine_logout_reply() local
863 memset(&source, 0, sizeof(dm_msg_source_t)); in dm_client_combine_logout_reply()
865 source.uri = topic; in dm_client_combine_logout_reply()
866 source.payload = (unsigned char *)payload; in dm_client_combine_logout_reply()
867 source.payload_len = payload_len; in dm_client_combine_logout_reply()
868 source.context = NULL; in dm_client_combine_logout_reply()
870 dm_msg_proc_combine_logout_reply(&source); in dm_client_combine_logout_reply()