add some processTime() to the send loops to avoid filling the buffer
darcs-hash:20080904213257-84dde-c046a708c6ac9f8f7ed2135f29241d70abe4104f.gz
This commit is contained in:
parent
64fa9034f5
commit
be075ed642
|
@ -221,6 +221,7 @@ function jabber_broadcast_notice($notice) {
|
||||||
'Sending reply notice ' . $notice->id . ' to ' . $user->jabber,
|
'Sending reply notice ' . $notice->id . ' to ' . $user->jabber,
|
||||||
__FILE__);
|
__FILE__);
|
||||||
$conn->message($user->jabber, $msg, 'chat', NULL, $entry);
|
$conn->message($user->jabber, $msg, 'chat', NULL, $entry);
|
||||||
|
$conn->processTime(0);
|
||||||
$sent_to[$user->id] = 1;
|
$sent_to[$user->id] = 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -239,6 +240,8 @@ function jabber_broadcast_notice($notice) {
|
||||||
'Sending notice ' . $notice->id . ' to ' . $user->jabber,
|
'Sending notice ' . $notice->id . ' to ' . $user->jabber,
|
||||||
__FILE__);
|
__FILE__);
|
||||||
$conn->message($user->jabber, $msg, 'chat', NULL, $entry);
|
$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,
|
'Sending notice ' . $notice->id . ' to public listener ' . $address,
|
||||||
__FILE__);
|
__FILE__);
|
||||||
$conn->message($address, $msg, 'chat', NULL, $entry);
|
$conn->message($address, $msg, 'chat', NULL, $entry);
|
||||||
|
$conn->processTime(0);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user