Mercurial > prosody-hg

comparison net/httpclient_listener.lua @ 2129:fcdcdf00787c

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
*_listener: Update for new net.server API, specifically .listener -> .onincoming, .disconnect -> .ondisconnect
author Matthew Wild <mwild1@gmail.com>
date Sun, 22 Nov 2009 04:43:46 +0000
parents 569d58d21612
children a1fdfd7318df
comparison
equal deleted inserted replaced
2128:f107f0205793 2129: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;