Embedded/pikapython
1
0
Fork 0
mirror of https://gitee.com/Lyon1998/pikapython.git synced 2025-01-29 17:22:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix subscribetopic typo and fix mem leak

Browse Source
This commit is contained in:
lyon 2022-12-18 18:48:16 +08:00
parent 16da150d57
commit cd062ff909
6 changed files with 18 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
examples/mqtt/mqtt_subscribe.py
View File

@ -32,20 +32,20 @@ print("subscribe ret:%d" % ret)
#sleep wait for recv data
T = PikaStdDevice.Time()
T.sleep_s(5)
T.sleep_s(1)
out = client.listSubscribrTopic()
out = client.listSubscribeTopic()
print('out',out)
# client.unsubscribe('topic_pikapy_qos0');
# client.unsubscribe('topic_pikapy_qos1');
# client.unsubscribe('topic_pikapy_qos2');
# T.sleep_s(5)
# client.listSubscribrTopic()
# client.listSubscribeTopic()
# ret = client.setWill(1,'topic_will',1,'lost mqtt connect')
T.sleep_s(10)
T.sleep_s(2)
# exit()
ret = client.disconnect()
print("ret:%d" % ret)

4
package/mqtt/_mqtt.pyi
View File

@ -50,9 +50,9 @@ class _MQTT:
pass
"""unsubscribe to the mqtt-server."""
def listSubscribrTopic(self) -> list:
def listSubscribeTopic(self) -> list:
pass
"""listSubscribrTopic """
"""listSubscribeTopic """
def publish(self,topic: str, qos:int, , payload: str) -> int:
pass

5
package/mqtt/_mqtt__MQTT.c
View File

@ -157,12 +157,12 @@ int _mqtt__MQTT_disconnect(PikaObj* self) {
}
////////////////////////////////////////////////////////////////////
// 函 数 名：_mqtt__MQTT_listSubscribrTopic
// 函 数 名：_mqtt__MQTT_listSubscribeTopic
// 功能说明：罗列出当前订阅的主题
// 输入参数：无
// 返 回 值：对象指针
///////////////////////////////////////////////////////////////////
PikaObj* _mqtt__MQTT_listSubscribrTopic(PikaObj* self) {
PikaObj* _mqtt__MQTT_listSubscribeTopic(PikaObj* self) {
mqtt_client_t* _client = obj_getPtr(self, "_client");
// int i = 0;
mqtt_list_t *curr, *next;
@ -197,6 +197,7 @@ PikaObj* _mqtt__MQTT_listSubscribrTopic(PikaObj* self) {
Arg* str_arg1 = arg_newStr((char*)msg_handler->topic_filter);
/* 添加到 list 对象 */
PikaStdData_List_append(list, str_arg1);
arg_deinit(str_arg1);
}
}
return list;

4
port/linux/package/pikascript/_mqtt.pyi
View File

@ -50,9 +50,9 @@ class _MQTT:
pass
"""unsubscribe to the mqtt-server."""
def listSubscribrTopic(self) -> list:
def listSubscribeTopic(self) -> list:
pass
"""listSubscribrTopic """
"""listSubscribeTopic """
def publish(self,topic: str, qos:int, , payload: str) -> int:
pass

5
port/linux/package/pikascript/pikascript-lib/mqtt/_mqtt__MQTT.c
View File

@ -157,12 +157,12 @@ int _mqtt__MQTT_disconnect(PikaObj* self) {
}
////////////////////////////////////////////////////////////////////
// 函 数 名：_mqtt__MQTT_listSubscribrTopic
// 函 数 名：_mqtt__MQTT_listSubscribeTopic
// 功能说明：罗列出当前订阅的主题
// 输入参数：无
// 返 回 值：对象指针
///////////////////////////////////////////////////////////////////
PikaObj* _mqtt__MQTT_listSubscribrTopic(PikaObj* self) {
PikaObj* _mqtt__MQTT_listSubscribeTopic(PikaObj* self) {
mqtt_client_t* _client = obj_getPtr(self, "_client");
// int i = 0;
mqtt_list_t *curr, *next;
@ -197,6 +197,7 @@ PikaObj* _mqtt__MQTT_listSubscribrTopic(PikaObj* self) {
Arg* str_arg1 = arg_newStr((char*)msg_handler->topic_filter);
/* 添加到 list 对象 */
PikaStdData_List_append(list, str_arg1);
arg_deinit(str_arg1);
}
}
return list;

8
test/python/mqtt/mqtt_subscribe.py
View File

@ -32,20 +32,20 @@ print("subscribe ret:%d" % ret)
#sleep wait for recv data
T = PikaStdDevice.Time()
T.sleep_s(5)
T.sleep_s(1)
out = client.listSubscribrTopic()
out = client.listSubscribeTopic()
print('out',out)
# client.unsubscribe('topic_pikapy_qos0');
# client.unsubscribe('topic_pikapy_qos1');
# client.unsubscribe('topic_pikapy_qos2');
# T.sleep_s(5)
# client.listSubscribrTopic()
# client.listSubscribeTopic()
# ret = client.setWill(1,'topic_will',1,'lost mqtt connect')
T.sleep_s(10)
T.sleep_s(2)
# exit()
ret = client.disconnect()
print("ret:%d" % ret)