Mercurial > prosody-hg
comparison plugins/mod_c2s.lua @ 11514:11186af62c87
Merge 0.11->trunk
| author | Kim Alvefur <zash@zash.se> |
|---|---|
| date | Sat, 10 Apr 2021 16:45:44 +0200 |
| parents | c90ef8745779 cab64a0aad49 |
| children | f7275c2c58fa |
comparison
equal
deleted
inserted
replaced
| 11506:9a3ebdd65f9c | 11514:11186af62c87 |
|---|---|
| 208 -- Grace time to process data from authenticated cleanly-closed stream | 208 -- Grace time to process data from authenticated cleanly-closed stream |
| 209 add_task(stream_close_timeout, function () | 209 add_task(stream_close_timeout, function () |
| 210 if not session.destroyed then | 210 if not session.destroyed then |
| 211 session.log("warn", "Failed to receive a stream close response, closing connection anyway..."); | 211 session.log("warn", "Failed to receive a stream close response, closing connection anyway..."); |
| 212 sm_destroy_session(session, reason_text); | 212 sm_destroy_session(session, reason_text); |
| 213 conn:close(); | 213 if conn then conn:close(); end |
| 214 end | 214 end |
| 215 end); | 215 end); |
| 216 else | 216 else |
| 217 sm_destroy_session(session, reason_text); | 217 sm_destroy_session(session, reason_text); |
| 218 conn:close(); | 218 if conn then conn:close(); end |
| 219 end | 219 end |
| 220 else | 220 else |
| 221 local reason_text = (reason and (reason.name or reason.text or reason.condition)) or reason; | 221 local reason_text = (reason and (reason.name or reason.text or reason.condition)) or reason; |
| 222 sm_destroy_session(session, reason_text); | 222 sm_destroy_session(session, reason_text); |
| 223 end | 223 end |
| 244 end | 244 end |
| 245 end | 245 end |
| 246 end, 200); | 246 end, 200); |
| 247 | 247 |
| 248 function runner_callbacks:ready() | 248 function runner_callbacks:ready() |
| 249 self.data.conn:resume(); | 249 if self.data.conn then |
| 250 self.data.conn:resume(); | |
| 251 else | |
| 252 (self.data.log or log)("debug", "Session has no connection to resume"); | |
| 253 end | |
| 250 end | 254 end |
| 251 | 255 |
| 252 function runner_callbacks:waiting() | 256 function runner_callbacks:waiting() |
| 253 self.data.conn:pause(); | 257 if self.data.conn then |
| 258 self.data.conn:pause(); | |
| 259 else | |
| 260 (self.data.log or log)("debug", "Session has no connection to pause while waiting"); | |
| 261 end | |
| 254 end | 262 end |
| 255 | 263 |
| 256 function runner_callbacks:error(err) | 264 function runner_callbacks:error(err) |
| 257 (self.data.log or log)("error", "Traceback[c2s]: %s", err); | 265 (self.data.log or log)("error", "Traceback[c2s]: %s", err); |
| 258 end | 266 end |
