NodeMCU_Lua/DeepSleep/Pet_tracker_3/0_rtelnet1.lua

-- script telnet pour le socat

function telnet_listener(socket)
    print("\n 0_rtelnet1.lua   zf200621.2309   \n")
    
    -- node, table, tmr, uwrite, tostring =
    -- node, table, tmr, uart.write, tostring
    
    print("................telnet_listener")
    -- insert, remove, concat, heap, gc =
    -- table.insert, table.remove, table.concat, node.heap, collectgarbage
    fifo1, fifo1l, fifo2, fifo2l = {}, 0, {}, 0
    -- local s -- s is a copy of the TCP socket if and only if sending is in progress
    
    function flushGarbage()
        if node.heap() < 13440 then collectgarbage() end
    end
    
    function sendLine()
        if not s then return end
        
        if fifo2l + fifo1l == 0 then -- both FIFOs empty, so clear down s
            s = nil
            return
        end
        flushGarbage()
        if #fifo2 < 4 then -- Flush FIFO1 into FIFO2
            table.insert(fifo2,table.concat(fifo1))
            fifo2l, fifo1, fifo1l = fifo2l + fifo1l, {}, 0
        end
        rec =  table.remove(fifo2,1)..(table.remove(fifo2,1) or '') ..(table.remove(fifo2,1) or '') .. (table.remove(fifo2,1) or '')
        fifo2l = fifo2l - #rec
        flushGarbage()
        if srv_rt:getpeer()~=nil then
            s:send(rec)
        end
    end
    
    local F1_SIZE = 256
    
    function queueLine(str)
        while #str > 0 do  -- this is because str might be longer than the packet size!
            k, l = F1_SIZE - fifo1l, #str
            if #fifo1 >= 32 or (k < l and k < 16) then
                table.insert(fifo2, table.concat(fifo1))
                fifo2l, fifo1, fifo1l, k = fifo2l + fifo1l, {}, 0, F1_SIZE
            end
            if l > k+16 then -- also tolerate a size overrun of 16 bytes to avoid a split
                chunk, str = str:sub(1,k), str:sub(k+1)
            else
                chunk, str = str, ''
            end
            table.insert(fifo1, chunk)
            fifo1l = fifo1l + #chunk
        end
        if not s and socket then
            s = socket
            sendLine()
        else
            flushGarbage()
        end
    end
    
    function receiveLine(s, line)
        node.input(line)
    end
    
    function disconnect(_,zerr)
        node.output(nil)
        gpio.write(zLED, gpio.HIGH)
        print("................disconnect")
        
        if socket~=nil then
            -- if http_post~=nil then  http_post(influxdb_url,"energy,memory=srv_rt_no_nil_"..yellow_id.." ram="..node.heap())  end        
            print("................disconnect 2e", socket, socket:getpeer())
            socket:on("connection", nil)
            socket:on("reconnection", nil)
            socket:on("disconnection", nil)
            socket:on("receive", nil)
            socket:on("sent", nil)

            socket=nil
        end
        
        -- fifo1, fifo1l, fifo2, fifo2l, s = nil, nil, nil, nil, nil
        print("disconnected... "..zerr..", "..node.heap())
        -- if debug_rec~=nil then  debug_rec("disconnect, disconnected, "..zerr..", "..node.heap())   end
        
        
        -- node, table, tmr, uwrite, tostring = nil, nil, nil, nil, nil
        -- insert, remove, concat, heap, gc = nil, nil, nil, nil, nil
        -- fifo1, fifo1l, fifo2, fifo2l = nil, nil, nil, nil
        -- rec = nil
        -- s = nil
        -- socket = nil
        -- flushGarbage = nil
        -- sendLine = nil
        -- queueLine = nil
        -- receiveLine = nil
        -- zconnection = nil
        -- disconnect = nil
        -- -- telnet_listener=nil


        
        fifo1, fifo1l, fifo2, fifo2l = nil, nil, nil, nil
        rec = nil
        k = nil
        l = nil
        s = nil
        chunk = nil
        socket = nil
        flushGarbage = nil
        sendLine = nil
        queueLine = nil
        receiveLine = nil
        zconnection = nil
        disconnect = nil
        telnet_listener=nil
        srv_rt=nil
        
        
        -- collectgarbage()   
        rt_connect()
    end    
    
    --zzz
    function zconnection(s)
        print("socket: ",socket)
        if socket~=nil then
            -- if http_post~=nil then  http_post(influxdb_url,"energy,memory=srv_rt_no_nil_"..yellow_id.." ram="..node.heap())  end        
            print(socket:getpeer())
        end
        
        local zstr="zconnection, Oups, on ne devrait jamais passer par là to NodeMCU world."
        print(zstr)   if debug_rec~=nil then  debug_rec(zstr)   end
        socket=nil
    end
    
    socket:on("connection",    zconnection)
    socket:on("receive",       receiveLine)
    socket:on("disconnection", disconnect)
    socket:on("sent",          sendLine)
    
    node.output(queueLine, 0)
    -- print(queueLine, 0)
end