Commencé une nouvelle version de pet tracker qui n'utilise pas le module rtc-mem
J'utilisais la possibilité de sauvegarder le flag de dsleep dans la rtc-mem afin de pouvoir différencier lors du boot si c'est un reset ou une sortie de sommeil profond. Maintenant je vais partir du principe que quand il y a un *hardware RESET* c'est forcément une sortie de dsleep. Si on veut avoir la *seconde chance* lors de la procédure de boot, il faudra utiliser le *power on RESET*
This commit is contained in:
148
DeepSleep/Pet_tracker_3/0_rtelnet1.lua
Normal file
148
DeepSleep/Pet_tracker_3/0_rtelnet1.lua
Normal file
@@ -0,0 +1,148 @@
|
||||
-- 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
|
||||
|
||||
Reference in New Issue
Block a user