equal
deleted
inserted
replaced
126 end |
126 end |
127 flush_reasons[why or "important"](); |
127 flush_reasons[why or "important"](); |
128 session.log("debug", "Flushing buffer (%s; queue size is %d)", why or "important", session.csi_counter); |
128 session.log("debug", "Flushing buffer (%s; queue size is %d)", why or "important", session.csi_counter); |
129 session.conn:resume_writes(); |
129 session.conn:resume_writes(); |
130 session.state = "flushing"; |
130 session.state = "flushing"; |
|
131 module:fire_event("csi-flushing", { session = session }); |
131 else |
132 else |
132 session.log("debug", "Holding buffer (%s; queue size is %d)", why or "unimportant", session.csi_counter); |
133 session.log("debug", "Holding buffer (%s; queue size is %d)", why or "unimportant", session.csi_counter); |
133 stanza = with_timestamp(stanza, jid.join(session.username, session.host)) |
134 stanza = with_timestamp(stanza, jid.join(session.username, session.host)) |
134 end |
135 end |
135 session.csi_counter = ctr + 1; |
136 session.csi_counter = ctr + 1; |