169 |
169 |
170 function mark_connected(session) |
170 function mark_connected(session) |
171 local sendq, send = session.sendq, session.send; |
171 local sendq, send = session.sendq, session.send; |
172 if sendq then |
172 if sendq then |
173 session.log("debug", "sending queued stanzas across new connection"); |
173 session.log("debug", "sending queued stanzas across new connection"); |
174 for _, data in ipairs(sendq) do |
174 for i, data in ipairs(sendq) do |
175 session.log("debug", "sending: %s", tostring(data)); |
175 session.log("debug", "sending: %s", tostring(data)); |
176 send(data); |
176 send(data); |
|
177 sendq[i] = nil; |
177 end |
178 end |
|
179 session.sendq = nil; |
178 end |
180 end |
179 end |
181 end |
180 |
182 |
181 return _M; |
183 return _M; |