162 return true; |
162 return true; |
163 end |
163 end |
164 |
164 |
165 function mark_connected(session) |
165 function mark_connected(session) |
166 local sendq, send = session.sendq, session.send; |
166 local sendq, send = session.sendq, session.send; |
|
167 session.log("debug", session.direction.." s2s connection "..session.from_host.."->"..session.to_host.." is now complete"); |
167 if sendq then |
168 if sendq then |
168 session.log("debug", "sending queued stanzas across new connection"); |
169 session.log("debug", "sending queued stanzas across new outgoing connection"); |
169 for i, data in ipairs(sendq) do |
170 for i, data in ipairs(sendq) do |
170 send(data); |
171 send(data); |
171 sendq[i] = nil; |
172 sendq[i] = nil; |
172 end |
173 end |
173 session.sendq = nil; |
174 session.sendq = nil; |