From a6a2d19ff8012681308057443f577f2163ff8d94 Mon Sep 17 00:00:00 2001 From: Sebastiaan de Schaetzen Date: Sun, 14 Jul 2024 17:35:30 +0200 Subject: [PATCH] Remove debug logs --- controller-host/mqtt/client.lua | 2 -- controller-host/mqtt/luasocket.lua | 24 +++++------------------- controller-host/mqtt/protocol.lua | 5 ----- 3 files changed, 5 insertions(+), 26 deletions(-) diff --git a/controller-host/mqtt/client.lua b/controller-host/mqtt/client.lua index 28b3bde..c385a89 100644 --- a/controller-host/mqtt/client.lua +++ b/controller-host/mqtt/client.lua @@ -1074,7 +1074,6 @@ function client_mt:_apply_network_timeout() -- replace connection recv_func with coroutine-based version local sync_recv_func = conn.recv_func conn.recv_func = function(totalSize, ...) - print("Args: ("..(1+#{...})..")", totalSize, ...) while true do local allData = "" while true do @@ -1178,7 +1177,6 @@ function client_mt:_receive_packet() return false, "network connection is not opened" end -- parse packet - print("Calling ", conn.recv_func) local packet, err = self._parse_packet(conn.recv_func) if not packet then return false, err diff --git a/controller-host/mqtt/luasocket.lua b/controller-host/mqtt/luasocket.lua index 265e2d5..d4334c6 100644 --- a/controller-host/mqtt/luasocket.lua +++ b/controller-host/mqtt/luasocket.lua @@ -25,12 +25,7 @@ end -- Send data to network connection function luasocket.send(conn, data, i, j) conn.sock:settimeout(nil, "t") - print("Sending bytes ", #data, i, j) local ok, err = conn.sock:send(data, i, j) - if err == "timeout" then - print("Oops, got timeout") - print(debug.traceback()) - end conn.sock:settimeout(conn.timeout, "t") -- print(" luasocket.send:", ok, err, require("mqtt.tools").hex(data)) return ok, err @@ -39,25 +34,16 @@ end -- Receive given amount of data from network connection function luasocket.receive(conn, size) local ok, err = conn.sock:receive(size) - if ok then - if #ok ~= size then - assert(false, "bad size") - end - if #ok > 100 then - print(" luasocket.receive good:", size, #ok, "(long)") - else - --print(debug.traceback()) - print(" luasocket.receive good:", size, #ok, require("mqtt.tools").hex(ok)) - end - elseif err ~= "timeout" then - print(" luasocket.receive fail:", ok, err) - end + --if ok then + -- print(" luasocket.receive good:", size, #ok, require("mqtt.tools").hex(ok)) + --elseif err ~= "timeout" then + -- print(" luasocket.receive fail:", ok, err) + --end return ok, err end -- Set connection's socket to non-blocking mode and set a timeout for it function luasocket.settimeout(conn, timeout) - print("Setting timeout to " .. timeout) conn.timeout = timeout conn.sock:settimeout(timeout, "t") end diff --git a/controller-host/mqtt/protocol.lua b/controller-host/mqtt/protocol.lua index 1ca307c..b7e467f 100644 --- a/controller-host/mqtt/protocol.lua +++ b/controller-host/mqtt/protocol.lua @@ -490,16 +490,12 @@ function protocol.start_parse_packet(read_func) len, err = parse_var_length(read_func) if not len then return false, "failed to parse remaining length: "..err - else - print("Variable length is: " .. len) end -- create packet parser instance (aka input) local input = {1, available = 0} -- input data offset and available size if len > 0 then - print("Reading payload body") data, err = read_func(len) - print("Reading payload body done") else data = "" end @@ -520,7 +516,6 @@ function protocol.start_parse_packet(read_func) return res end - print("Available data is: " .. input.available) return ptype, flags, input end