Home
last modified time | relevance | path

Searched refs:amp_mqtt_handle (Results 1 – 5 of 5) sorted by relevance

/AliOS-Things-master/components/py_engine/modules/mqtt/
A Dmodule_mqtt.c28 duk_push_pointer(ctx, amp_mqtt_handle); in mqtt_handle_notify()
35 if (amp_mqtt_handle->res < 0) { in mqtt_handle_notify()
38 aos_free(amp_mqtt_handle); in mqtt_handle_notify()
51 if (amp_mqtt_handle == NULL) { in mqtt_connect_task()
64 aos_free(amp_mqtt_handle); in mqtt_connect_task()
68 amp_mqtt_handle->res = ret; in mqtt_connect_task()
78 aos_free(amp_mqtt_handle); in mqtt_connect_task()
170 if (amp_mqtt_handle == NULL) { in native_mqtt_subscribe()
218 if (amp_mqtt_handle == NULL) { in native_mqtt_unsubscribe()
260 if (amp_mqtt_handle == NULL) { in native_mqtt_publish()
[all …]
A Dmodule_mqtt.h52 typedef struct amp_mqtt_handle { struct
/AliOS-Things-master/components/amp/engine/duktape_engine/addons/network/mqtt/
A Dmodule_mqtt.c26 duk_push_pointer(ctx, amp_mqtt_handle); in mqtt_handle_notify()
33 if(amp_mqtt_handle->res < 0){ in mqtt_handle_notify()
35 aos_free(amp_mqtt_handle); in mqtt_handle_notify()
48 if (amp_mqtt_handle == NULL) { in mqtt_connect_task()
60 aos_free(amp_mqtt_handle); in mqtt_connect_task()
64 amp_mqtt_handle->res = ret; in mqtt_connect_task()
74 aos_free(amp_mqtt_handle); in mqtt_connect_task()
164 if (amp_mqtt_handle == NULL) { in native_mqtt_subscribe()
212 if (amp_mqtt_handle == NULL) { in native_mqtt_unsubscribe()
253 if (amp_mqtt_handle == NULL) { in native_mqtt_publish()
[all …]
A Dmodule_mqtt.h52 typedef struct amp_mqtt_handle{ struct
/AliOS-Things-master/components/amp/engine/quickjs_engine/addons/network/mqtt/
A Dmodule_mqtt.c302 aos_mqtt_handle_t *amp_mqtt_handle = NULL; in native_mqtt_subscribe() local
307 amp_mqtt_handle = JS_GetOpaque2(ctx, argv[0], js_mqtt_class_id); in native_mqtt_subscribe()
308 if (amp_mqtt_handle == NULL) { in native_mqtt_subscribe()
331 aos_mqtt_handle_t *amp_mqtt_handle = NULL; in native_mqtt_unsubscribe() local
337 if (amp_mqtt_handle == NULL) { in native_mqtt_unsubscribe()
346 res = aiot_mqtt_unsub(amp_mqtt_handle->mqtt_handle, topic); in native_mqtt_unsubscribe()
360 aos_mqtt_handle_t *amp_mqtt_handle = NULL; in native_mqtt_publish() local
368 if (amp_mqtt_handle == NULL) { in native_mqtt_publish()
395 aos_mqtt_handle_t *amp_mqtt_handle = NULL; in native_mqtt_close() local
398 if (amp_mqtt_handle == NULL) { in native_mqtt_close()
[all …]

Completed in 7 milliseconds