summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorEvan Prodromou <evan@prodromou.name>2008-09-04 17:32:57 -0400
committerEvan Prodromou <evan@prodromou.name>2008-09-04 17:32:57 -0400
commitbe075ed642c1221f12af7269ea92119b83413cbc (patch)
treeeee2701fc0d81e3758db38db792afecaa51bfbef /lib
parent64fa9034f55fddd35afa401fc238579b68615086 (diff)
add some processTime() to the send loops to avoid filling the buffer
darcs-hash:20080904213257-84dde-c046a708c6ac9f8f7ed2135f29241d70abe4104f.gz
Diffstat (limited to 'lib')
-rw-r--r--lib/jabber.php4
1 files changed, 4 insertions, 0 deletions
diff --git a/lib/jabber.php b/lib/jabber.php
index ef99f8f46..a9643f4a6 100644
--- a/lib/jabber.php
+++ b/lib/jabber.php
@@ -221,6 +221,7 @@ function jabber_broadcast_notice($notice) {
'Sending reply notice ' . $notice->id . ' to ' . $user->jabber,
__FILE__);
$conn->message($user->jabber, $msg, 'chat', NULL, $entry);
+ $conn->processTime(0);
$sent_to[$user->id] = 1;
}
@@ -239,6 +240,8 @@ function jabber_broadcast_notice($notice) {
'Sending notice ' . $notice->id . ' to ' . $user->jabber,
__FILE__);
$conn->message($user->jabber, $msg, 'chat', NULL, $entry);
+ # To keep the incoming queue from filling up, we service it after each send.
+ $conn->processTime(0);
}
}
@@ -275,6 +278,7 @@ function jabber_public_notice($notice) {
'Sending notice ' . $notice->id . ' to public listener ' . $address,
__FILE__);
$conn->message($address, $msg, 'chat', NULL, $entry);
+ $conn->processTime(0);
}
}