]> git.mxchange.org Git - quix0rs-gnu-social.git/commitdiff
add some processTime() to the send loops to avoid filling the buffer
authorEvan Prodromou <evan@prodromou.name>
Thu, 4 Sep 2008 21:32:57 +0000 (17:32 -0400)
committerEvan Prodromou <evan@prodromou.name>
Thu, 4 Sep 2008 21:32:57 +0000 (17:32 -0400)
darcs-hash:20080904213257-84dde-c046a708c6ac9f8f7ed2135f29241d70abe4104f.gz

lib/jabber.php

index ef99f8f467165df8e7b280737499185c132e0a97..a9643f4a67ea28ee6c4a68d3d1dbb562d93405fd 100644 (file)
@@ -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);
                }
        }