mirror of
https://github.com/nodemcu/nodemcu-firmware.git
synced 2025-01-30 21:12:55 +08:00
dcc1ea2a49
* lua_modules/fifo: a generic queue & socket wrapper One occasionally wants a generic fifo, so here's a plausible implementation that's reasonably flexible in its usage. One possible consumer of this is a variant of TerryE's two-level fifo trick currently in the telnetd example. Factor that out to fifosock for more general use. * lua_examples/telnet: use factored out fifosock * lua_modules/http: improve implementation Switch to fifosock for in-order sending and waiting for everything to be sent before closing. Fix header callback by moving the invocation of the handler higher * fifosock: optimistically cork and delay tx If we just pushed a little bit of data into a fifosock that had idled, wait a tick (1 ms) before transmitting. Hopefully, this means that we let the rest of the system push more data in before we send the first packet. But in a high-throughput situation, where we are streaming data without idling the fifo, there won't be any additional delay and we'll coalesce during operation as usual. The fifosocktest mocks up enough of tmr for this to run, but assumes an arbitrarily slow processor. ;)
38 lines
1.3 KiB
Lua
38 lines
1.3 KiB
Lua
------------------------------------------------------------------------------
|
|
-- HTTP server Hello world example
|
|
--
|
|
-- LICENCE: http://opensource.org/licenses/MIT
|
|
-- Vladimir Dronnikov <dronnikov@gmail.com>
|
|
------------------------------------------------------------------------------
|
|
require("httpserver").createServer(80, function(req, res)
|
|
-- analyse method and url
|
|
print("+R", req.method, req.url, node.heap())
|
|
-- setup handler of headers, if any
|
|
req.onheader = function(self, name, value)
|
|
print("+H", name, value)
|
|
-- E.g. look for "content-type" header,
|
|
-- setup body parser to particular format
|
|
-- if name == "content-type" then
|
|
-- if value == "application/json" then
|
|
-- req.ondata = function(self, chunk) ... end
|
|
-- elseif value == "application/x-www-form-urlencoded" then
|
|
-- req.ondata = function(self, chunk) ... end
|
|
-- end
|
|
-- end
|
|
end
|
|
-- setup handler of body, if any
|
|
req.ondata = function(self, chunk)
|
|
print("+B", chunk and #chunk, node.heap())
|
|
if not chunk then
|
|
-- reply
|
|
res:send(nil, 200)
|
|
res:send_header("Connection", "close")
|
|
res:send("Hello, world!\n")
|
|
res:finish()
|
|
end
|
|
end
|
|
-- or just do something not waiting till body (if any) comes
|
|
--res:finish("Hello, world!")
|
|
--res:finish("Salut, monde!")
|
|
end)
|