Browse Source

Merge branch 'master' of https://gitee.com/openLuat/LuatOS

alienwalker 1 year ago
parent
commit
2408d4cdf3
2 changed files with 4 additions and 4 deletions
  1. 3 3
      components/network/libemqtt/luat_lib_mqtt.c
  2. 1 1
      script/libs/httpplus.lua

+ 3 - 3
components/network/libemqtt/luat_lib_mqtt.c

@@ -180,14 +180,14 @@ int32_t luatos_mqtt_callback(lua_State *L, void* ptr){
 				if (lua_isfunction(L, -1)) {
 				if (lua_isfunction(L, -1)) {
 					lua_geti(L, LUA_REGISTRYINDEX, mqtt_ctrl->mqtt_ref);
 					lua_geti(L, LUA_REGISTRYINDEX, mqtt_ctrl->mqtt_ref);
 					lua_pushstring(L, "disconnect");
 					lua_pushstring(L, "disconnect");
-					lua_pushnumber(L, mqtt_ctrl->error_state);
+					lua_pushinteger(L, mqtt_ctrl->error_state);
 					lua_call(L, 3, 0);
 					lua_call(L, 3, 0);
 				}
 				}
 				lua_getglobal(L, "sys_pub");
 				lua_getglobal(L, "sys_pub");
 				if (lua_isfunction(L, -1)) {
 				if (lua_isfunction(L, -1)) {
 					lua_pushstring(L, "MQTT_DISCONNECT");
 					lua_pushstring(L, "MQTT_DISCONNECT");
 					lua_geti(L, LUA_REGISTRYINDEX, mqtt_ctrl->mqtt_ref);
 					lua_geti(L, LUA_REGISTRYINDEX, mqtt_ctrl->mqtt_ref);
-					lua_pushnumber(L, mqtt_ctrl->error_state);
+					lua_pushinteger(L, mqtt_ctrl->error_state);
 					lua_call(L, 3, 0);
 					lua_call(L, 3, 0);
 				}
 				}
             }
             }
@@ -316,7 +316,7 @@ mqttc = mqtt.create(nil,"120.55.137.106", 8883, {server_cert=io.readFile("/luadb
 mqttc = mqtt.create(nil,"120.55.137.106", 8883, {
 mqttc = mqtt.create(nil,"120.55.137.106", 8883, {
 					server_cert=io.readFile("/luadb/ca.crt"),
 					server_cert=io.readFile("/luadb/ca.crt"),
 					client_cert=io.readFile("/luadb/client.pem"),
 					client_cert=io.readFile("/luadb/client.pem"),
-					client_key="123456",
+					client_key=io.readFile("/luadb/client.key"),
 					client_password="123456",
 					client_password="123456",
 					})
 					})
 */
 */

+ 1 - 1
script/libs/httpplus.lua

@@ -474,7 +474,7 @@ local function http_exec(opts)
                         socket.tx(netc, fdata)
                         socket.tx(netc, fdata)
                         write_counter = write_counter + #fdata
                         write_counter = write_counter + #fdata
                         -- 注意, 这里要等待TX_OK事件
                         -- 注意, 这里要等待TX_OK事件
-                        sys.waitUntil(opts.topic, 3000)
+                        sys.waitUntil(opts.topic, 300)
                     end
                     end
                     fd:close()
                     fd:close()
                 end
                 end