mod_s2s: Fire 's2s-ondrain' event, mirroring mod_c2s
authorKim Alvefur <zash@zash.se>
Mon, 16 Aug 2021 11:37:51 +0200
changeset 11744 b92f2abe0bda
parent 11743 e0d0680e04cc
child 11745 dcf38ac6a38c
mod_s2s: Fire 's2s-ondrain' event, mirroring mod_c2s Signals that any pending outgoing stanzas that were in the write buffer have at least been sent off to the Kernel and maybe even sent out over the network. See 7a703af90c9c for mod_c2s commit
plugins/mod_s2s.lua
--- a/plugins/mod_s2s.lua	Sun Aug 15 12:28:58 2021 +0200
+++ b/plugins/mod_s2s.lua	Mon Aug 16 11:37:51 2021 +0200
@@ -853,6 +853,13 @@
 	end
 end
 
+function listener.ondrain(conn)
+	local session = sessions[conn];
+	if session then
+		return (hosts[session.host] or prosody).events.fire_event("s2s-ondrain", { session = session });
+	end
+end
+
 function listener.register_outgoing(conn, session)
 	sessions[conn] = session;
 	initialize_session(session);