Mercurial > lxmppd-hg-xmllex / file comparison
comparison: net/httpclient_listener.lua
net/httpclient_listener.lua
- changeset 2126
- fcdcdf00787c
- parent 1522
- 569d58d21612
- child 2674
- a1fdfd7318df
equal
deleted
inserted
replaced
| 2125:f107f0205793 | 2126:fcdcdf00787c |
|---|---|
| 13 local requests = {}; -- Open requests | 13 local requests = {}; -- Open requests |
| 14 local buffers = {}; -- Buffers of partial lines | 14 local buffers = {}; -- Buffers of partial lines |
| 15 | 15 |
| 16 local httpclient = { default_port = 80, default_mode = "*a" }; | 16 local httpclient = { default_port = 80, default_mode = "*a" }; |
| 17 | 17 |
| 18 function httpclient.listener(conn, data) | 18 function httpclient.onincoming(conn, data) |
| 19 local request = requests[conn]; | 19 local request = requests[conn]; |
| 20 | 20 |
| 21 if not request then | 21 if not request then |
| 22 log("warn", "Received response from connection %s with no request attached!", tostring(conn)); | 22 log("warn", "Received response from connection %s with no request attached!", tostring(conn)); |
| 23 return; | 23 return; |
| 26 if data and request.reader then | 26 if data and request.reader then |
| 27 request:reader(data); | 27 request:reader(data); |
| 28 end | 28 end |
| 29 end | 29 end |
| 30 | 30 |
| 31 function httpclient.disconnect(conn, err) | 31 function httpclient.ondisconnect(conn, err) |
| 32 local request = requests[conn]; | 32 local request = requests[conn]; |
| 33 if request then | 33 if request then |
| 34 request:reader(nil); | 34 request:reader(nil); |
| 35 end | 35 end |
| 36 requests[conn] = nil; | 36 requests[conn] = nil; |
