diff options
| author | Kim Alvefur <zash@zash.se> | 2018-11-24 02:25:44 +0100 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2018-11-24 02:25:44 +0100 |
| commit | 7ef5adb448ad36074123a924dc80607e087ed200 (patch) | |
| tree | 68ec4fdd07393bba14e956c23cdbbd03574bf93d /plugins | |
| parent | 3277b108c4f1b772e265d270c52ca2e5c9956879 (diff) | |
| download | prosody-7ef5adb448ad36074123a924dc80607e087ed200.tar.gz prosody-7ef5adb448ad36074123a924dc80607e087ed200.zip | |
mod_csi_simple: Use write locks in net.server if available
Diffstat (limited to 'plugins')
| -rw-r--r-- | plugins/mod_csi_simple.lua | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/plugins/mod_csi_simple.lua b/plugins/mod_csi_simple.lua index da2dd953..abe65fce 100644 --- a/plugins/mod_csi_simple.lua +++ b/plugins/mod_csi_simple.lua @@ -86,7 +86,9 @@ end, -1); module:hook("csi-client-inactive", function (event) local session = event.origin; - if session.pump then + if session.conn and session.conn and session.conn.pause_writes then + session.conn:pause_writes(); + elseif session.pump then session.pump:pause(); else local bare_jid = jid.join(session.username, session.host); @@ -115,6 +117,8 @@ module:hook("csi-client-active", function (event) local session = event.origin; if session.pump then session.pump:resume(); + elseif session.conn and session.conn and session.conn.resume_writes then + session.conn:resume_writes(); end end); |