Software / code / prosody
Changeset
4313:42d7d09fdda0
Backout commit d6366294f618 which I was testing and didn't mean to push to 0.8
| author | Matthew Wild <mwild1@gmail.com> |
|---|---|
| date | Sun, 05 Jun 2011 12:28:49 +0100 |
| parents | 4312:bcdff2b1d3ec |
| children | 4314:1e1110840965 |
| files | plugins/mod_bosh.lua |
| diffstat | 1 files changed, 10 insertions(+), 20 deletions(-) [+] |
line wrap: on
line diff
--- a/plugins/mod_bosh.lua Sun Jun 05 12:18:24 2011 +0100 +++ b/plugins/mod_bosh.lua Sun Jun 05 12:28:49 2011 +0100 @@ -162,13 +162,7 @@ end end - if session.bosh_terminate then - session.log("debug", "Closing session with %d requests open", #session.requests); - session:close(); - return nil; - else - return true; -- Inform httpserver we shall reply later - end + return true; -- Inform httpserver we shall reply later end end @@ -208,6 +202,7 @@ local session_close_response = { headers = default_headers, body = tostring(close_reply) }; + --FIXME: Quite sure we shouldn't reply to all requests with the error for _, held_request in ipairs(session.requests) do held_request:send(session_close_response); held_request:destroy(); @@ -260,13 +255,7 @@ local oldest_request = r[1]; if oldest_request then log("debug", "We have an open request, so sending on that"); - response.body = t_concat({ - "<body xmlns='http://jabber.org/protocol/httpbind' ", - session.bosh_terminate and "type='terminate' " or "", - "sid='", sid, "' xmlns:stream = 'http://etherx.jabber.org/streams'>", - tostring(s), - "</body>" - }); + response.body = t_concat{"<body xmlns='http://jabber.org/protocol/httpbind' sid='", sid, "' xmlns:stream = 'http://etherx.jabber.org/streams'>", tostring(s), "</body>" }; oldest_request:send(response); --log("debug", "Sent"); if oldest_request.stayopen then @@ -338,6 +327,13 @@ session.rid = rid; end + if attr.type == "terminate" then + -- Client wants to end this session + session:close(); + request.notopen = nil; + return; + end + if session.notopen then local features = st.stanza("stream:features"); hosts[session.host].events.fire_event("stream-features", { origin = session, features = features }); @@ -346,12 +342,6 @@ session.notopen = nil; end - if attr.type == "terminate" then - -- Client wants to end this session, which we'll do - -- after processing any stanzas in this request - session.bosh_terminate = true; - end - request.notopen = nil; -- Signals that we accept this opening tag t_insert(session.requests, request); request.sid = sid;
