69 	session.csi_counter = ctr + 1;

    69 	session.csi_counter = ctr + 1;

    70 	return stanza;

    70 	return stanza;

    71 end

    71 end

    72 

    72 

    73 local function flush_buffer(data, session)

    73 local function flush_buffer(data, session)

    74 	session.conn:resume_writes();

    75 	session.conn:resume_writes();

    75 	return data;

    76 	return data;

    76 end

    77 end

    77 

    78 

    78 function enable_optimizations(session)

    79 function enable_optimizations(session)

   107 module:hook("c2s-ondrain", function (event)

   108 module:hook("c2s-ondrain", function (event)

   108 	local session = event.session;

   109 	local session = event.session;

   109 	if session.state == "inactive" and session.conn and session.conn and session.conn.pause_writes then

   110 	if session.state == "inactive" and session.conn and session.conn and session.conn.pause_writes then

   110 		session.csi_counter = 0;

   111 		session.csi_counter = 0;

   111 		session.conn:pause_writes();

   112 		session.conn:pause_writes();

   112 	end

   114 	end

   113 end);

   115 end);

   114 

   116 

   115 function module.load()

   117 function module.load()

   116 	for _, user_session in pairs(prosody.hosts[module.host].sessions) do

   118 	for _, user_session in pairs(prosody.hosts[module.host].sessions) do