Lines Matching refs:param
149 device_notify_param_t *param = (device_notify_param_t *)pdata; in aiot_device_notify() local
153 if (param->dm_recv) { in aiot_device_notify()
154 switch (param->dm_recv_type) { in aiot_device_notify()
160 mp_obj_new_int(param->ret_code)); in aiot_device_notify()
163 mp_obj_new_int(param->msg_id)); in aiot_device_notify()
166 mp_obj_new_int(param->params_len)); in aiot_device_notify()
169 mp_obj_new_str(param->params, param->params_len)); in aiot_device_notify()
170 if (mp_obj_is_fun(param->iot_device_handle->callback[ON_PROPS])) { in aiot_device_notify()
171 callback_to_python(param->iot_device_handle->callback[ON_PROPS], in aiot_device_notify()
178 aos_free(param->params); in aiot_device_notify()
185 mp_obj_new_int(param->ret_code)); in aiot_device_notify()
188 mp_obj_new_int(param->msg_id)); in aiot_device_notify()
191 mp_obj_new_str(param->service_id, strlen(param->service_id))); in aiot_device_notify()
194 mp_obj_new_int(param->params_len)); in aiot_device_notify()
197 mp_obj_new_str(param->params, param->params_len)); in aiot_device_notify()
198 if (mp_obj_is_fun(param->iot_device_handle->callback[ON_SERVICE])) { in aiot_device_notify()
200 param->iot_device_handle->callback[ON_SERVICE], dict); in aiot_device_notify()
206 aos_free(param->service_id); in aiot_device_notify()
207 aos_free(param->params); in aiot_device_notify()
212 …_store(MP_OBJ_FROM_PTR(dict), mp_obj_new_str("params_len", 10), mp_obj_new_int(param->params_len)); in aiot_device_notify()
213 …OM_PTR(dict), mp_obj_new_str("params", 6), mp_obj_new_bytearray(param->params_len, param->params)); in aiot_device_notify()
214 if (mp_obj_is_fun(param->iot_device_handle->callback[ON_RAWDATA])) in aiot_device_notify()
215 callback_to_python(param->iot_device_handle->callback[ON_RAWDATA], dict); in aiot_device_notify()
217 aos_free(param->params); in aiot_device_notify()
220 aos_free(param); in aiot_device_notify()
223 } else if (param->option == AIOT_MQTTOPT_EVENT_HANDLER) { in aiot_device_notify()
225 switch (param->event_type) { in aiot_device_notify()
230 mp_obj_new_int(param->ret_code)); in aiot_device_notify()
231 if (mp_obj_is_fun(param->iot_device_handle->callback[param->cb_type])) { in aiot_device_notify()
232 callback_to_python(param->iot_device_handle->callback[param->cb_type], in aiot_device_notify()
241 aos_free(param); in aiot_device_notify()
245 switch (param->recv_type) { in aiot_device_notify()
271 aos_free(param); in aiot_device_notify()
276 aos_free(param); in aiot_device_notify()
285 device_notify_param_t *param; in aiot_app_dm_recv_handler() local
289 param = aos_malloc(sizeof(device_notify_param_t)); in aiot_app_dm_recv_handler()
290 if (!param) { in aiot_app_dm_recv_handler()
294 memset(param , 0, sizeof(device_notify_param_t)); in aiot_app_dm_recv_handler()
295 param->dm_recv = 1; in aiot_app_dm_recv_handler()
296 param->dm_recv_type = recv->type; in aiot_app_dm_recv_handler()
297 param->iot_device_handle = iot_device_handle; 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()
325 param->cb_type = AIOT_DEV_JSCALLBACK_ONPROPS_REF; 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()
360 param->service_id = in aiot_app_dm_recv_handler()
362 param->params = in aiot_app_dm_recv_handler()
364 param->cb_type = AIOT_DEV_JSCALLBACK_ONPROPS_REF ; 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()
455 param->cb_type = ON_RAWDATA; in aiot_app_dm_recv_handler()
471 py_task_schedule_call(aiot_device_notify, param); in aiot_app_dm_recv_handler()
478 device_notify_param_t *param; in aiot_mqtt_message_cb() local
485 param = aos_malloc(sizeof(device_notify_param_t)); in aiot_mqtt_message_cb()
486 if (!param) { in aiot_mqtt_message_cb()
490 memset(param, 0, sizeof(device_notify_param_t)); in aiot_mqtt_message_cb()
491 param->iot_device_handle = (iot_device_handle_t *)udata->handle; in aiot_mqtt_message_cb()
493 param->option = message->option; in aiot_mqtt_message_cb()
502 aos_free(param); in aiot_mqtt_message_cb()
506 param->ret_code = message->event.code; in aiot_mqtt_message_cb()
507 param->event_type = message->event.type; in aiot_mqtt_message_cb()
508 param->cb_type = ON_DISCONNECT; in aiot_mqtt_message_cb()
511 aos_free(param); 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()
526 aos_free(param); in aiot_mqtt_message_cb()
530 aos_free(param); in aiot_mqtt_message_cb()
534 py_task_schedule_call(aiot_device_notify, param); in aiot_mqtt_message_cb()
541 device_notify_param_t *param; in aiot_device_connect() local
594 param = aos_malloc(sizeof(device_notify_param_t)); in aiot_device_connect()
595 if (!param) { in aiot_device_connect()
599 memset(param, 0 , sizeof(device_notify_param_t)); in aiot_device_connect()
603 param->ret_code = 0; in aiot_device_connect()
604 param->iot_device_handle = iot_device_handle; in aiot_device_connect()
605 param->cb_type = ON_CONNECT; in aiot_device_connect()
606 param->option = AIOT_MQTTOPT_EVENT_HANDLER; in aiot_device_connect()
607 param->event_type = AIOT_MQTTEVT_CONNECT; in aiot_device_connect()
608 py_task_schedule_call(aiot_device_notify, param); in aiot_device_connect()