From: Evan Prodromou <evan@prodromou.name>
Date: Thu, 4 Sep 2008 21:32:57 +0000 (-0400)
Subject: add some processTime() to the send loops to avoid filling the buffer
X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=be075ed642c1221f12af7269ea92119b83413cbc;p=quix0rs-gnu-social.git

add some processTime() to the send loops to avoid filling the buffer

darcs-hash:20080904213257-84dde-c046a708c6ac9f8f7ed2135f29241d70abe4104f.gz
---

diff --git a/lib/jabber.php b/lib/jabber.php
index ef99f8f467..a9643f4a67 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);
 		}
 	}