127 lines
2.4 KiB
Lua
127 lines
2.4 KiB
Lua
--[[
|
|
|
|
HTTP server implementation for LuCI - core
|
|
(c) 2008 Freifunk Leipzig / Jo-Philipp Wich <xm@leipzig.freifunk.net>
|
|
(c) 2008 Steven Barth <steven@midlink.org>
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
$Id: httpd.lua 2974 2008-08-27 17:45:58Z Cyrus $
|
|
|
|
]]--
|
|
|
|
module("luci.httpd", package.seeall)
|
|
require("socket")
|
|
|
|
THREAD_IDLEWAIT = 0.01
|
|
THREAD_TIMEOUT = 90
|
|
THREAD_LIMIT = nil
|
|
|
|
local reading = {}
|
|
local clhandler = {}
|
|
local erhandler = {}
|
|
|
|
local threadc = 0
|
|
local threads = {}
|
|
local threadm = {}
|
|
local threadi = {}
|
|
|
|
local _meta = {__mode = "k"}
|
|
setmetatable(threadm, _meta)
|
|
setmetatable(threadi, _meta)
|
|
|
|
|
|
function Socket(ip, port)
|
|
local sock, err = socket.bind( ip, port )
|
|
|
|
if sock then
|
|
sock:settimeout( 0, "t" )
|
|
end
|
|
|
|
return sock, err
|
|
end
|
|
|
|
function corecv(socket, ...)
|
|
threadi[socket] = true
|
|
|
|
while true do
|
|
local chunk, err, part = socket:receive(...)
|
|
|
|
if err ~= "timeout" then
|
|
threadi[socket] = false
|
|
return chunk, err, part
|
|
end
|
|
|
|
coroutine.yield()
|
|
end
|
|
end
|
|
|
|
function cosend(socket, chunk, i, ...)
|
|
threadi[socket] = true
|
|
i = i or 1
|
|
|
|
while true do
|
|
local stat, err, sent = socket:send(chunk, i, ...)
|
|
|
|
if err ~= "timeout" then
|
|
threadi[socket] = false
|
|
return stat, err, sent
|
|
else
|
|
i = sent and (sent + 1) or i
|
|
end
|
|
|
|
coroutine.yield()
|
|
end
|
|
end
|
|
|
|
function register(socket, s_clhandler, s_errhandler)
|
|
table.insert(reading, socket)
|
|
clhandler[socket] = s_clhandler
|
|
erhandler[socket] = s_errhandler
|
|
end
|
|
|
|
function run()
|
|
while true do
|
|
step()
|
|
end
|
|
end
|
|
|
|
function step()
|
|
local idle = true
|
|
if not THREAD_LIMIT or threadc < THREAD_LIMIT then
|
|
local now = os.time()
|
|
for i, server in ipairs(reading) do
|
|
local client = server:accept()
|
|
if client then
|
|
threadm[client] = now
|
|
threadc = threadc + 1
|
|
threads[client] = coroutine.create(clhandler[server])
|
|
end
|
|
end
|
|
end
|
|
|
|
for client, thread in pairs(threads) do
|
|
coroutine.resume(thread, client)
|
|
local now = os.time()
|
|
if coroutine.status(thread) == "dead" then
|
|
threadc = threadc - 1
|
|
threads[client] = nil
|
|
elseif threadm[client] and threadm[client] + THREAD_TIMEOUT < now then
|
|
threads[client] = nil
|
|
threadc = threadc - 1
|
|
client:close()
|
|
elseif not threadi[client] then
|
|
threadm[client] = now
|
|
idle = false
|
|
end
|
|
end
|
|
|
|
if idle then
|
|
socket.sleep(THREAD_IDLEWAIT)
|
|
end
|
|
end
|