Lines Matching refs:recv
281 const aiot_dm_recv_t *recv, void *userdata) in aiot_app_dm_recv_handler() argument
296 param->dm_recv_type = recv->type; in aiot_app_dm_recv_handler()
298 switch (recv->type) { in aiot_app_dm_recv_handler()
303 recv->data.generic_reply.msg_id, in aiot_app_dm_recv_handler()
304 recv->data.generic_reply.code, in aiot_app_dm_recv_handler()
305 recv->data.generic_reply.data_len, in aiot_app_dm_recv_handler()
306 recv->data.generic_reply.data, in aiot_app_dm_recv_handler()
307 recv->data.generic_reply.message_len, in aiot_app_dm_recv_handler()
308 recv->data.generic_reply.message); in aiot_app_dm_recv_handler()
316 (unsigned long)recv->data.property_set.msg_id, in aiot_app_dm_recv_handler()
317 recv->data.property_set.params_len, in aiot_app_dm_recv_handler()
318 recv->data.property_set.params); in aiot_app_dm_recv_handler()
322 param->msg_id = recv->data.property_set.msg_id; in aiot_app_dm_recv_handler()
323 param->params_len = recv->data.property_set.params_len; in aiot_app_dm_recv_handler()
324 param->params = __amp_strdup(recv->data.property_set.params); in aiot_app_dm_recv_handler()
351 (unsigned long)recv->data.async_service_invoke.msg_id, in aiot_app_dm_recv_handler()
352 recv->data.async_service_invoke.service_id, in aiot_app_dm_recv_handler()
353 recv->data.async_service_invoke.params_len, in aiot_app_dm_recv_handler()
354 recv->data.async_service_invoke.params); in aiot_app_dm_recv_handler()
358 param->msg_id = recv->data.async_service_invoke.msg_id; in aiot_app_dm_recv_handler()
359 param->params_len = recv->data.async_service_invoke.params_len; in aiot_app_dm_recv_handler()
361 __amp_strdup(recv->data.async_service_invoke.service_id); in aiot_app_dm_recv_handler()
363 __amp_strdup(recv->data.async_service_invoke.params); in aiot_app_dm_recv_handler()
398 (unsigned long)recv->data.sync_service_invoke.msg_id, in aiot_app_dm_recv_handler()
399 recv->data.sync_service_invoke.rrpc_id, in aiot_app_dm_recv_handler()
400 recv->data.sync_service_invoke.service_id, in aiot_app_dm_recv_handler()
401 recv->data.sync_service_invoke.params_len, in aiot_app_dm_recv_handler()
402 recv->data.sync_service_invoke.params); in aiot_app_dm_recv_handler()
437 recv->data.raw_data.data_len); in aiot_app_dm_recv_handler()
453 param->params_len = recv->data.raw_data.data_len; in aiot_app_dm_recv_handler()
454 param->params = __amp_rawdup(recv->data.raw_data.data, recv->data.raw_data.data_len); in aiot_app_dm_recv_handler()
462 recv->data.raw_service_invoke.rrpc_id, in aiot_app_dm_recv_handler()
463 recv->data.raw_service_invoke.data_len); in aiot_app_dm_recv_handler()
515 amp_debug(MOD_STR, "message->recv.type is %d ", message->recv.type); in aiot_mqtt_message_cb()
516 switch (message->recv.type) { in aiot_mqtt_message_cb()
518 param->ret_code = message->recv.code; in aiot_mqtt_message_cb()
519 param->topic_len = message->recv.topic_len; in aiot_mqtt_message_cb()
520 param->payload_len = message->recv.payload_len; in aiot_mqtt_message_cb()
521 param->topic = __amp_strdup(message->recv.topic); in aiot_mqtt_message_cb()
522 param->payload = __amp_strdup(message->recv.payload); in aiot_mqtt_message_cb()
523 param->recv_type = message->recv.type; in aiot_mqtt_message_cb()