[ARVADOS] updated: 563b588da606aa38cdfd8a35fbc70c7414678747
git at public.curoverse.com
git at public.curoverse.com
Fri Oct 24 09:02:43 EDT 2014
Summary of changes:
services/api/lib/eventbus.rb | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
via 563b588da606aa38cdfd8a35fbc70c7414678747 (commit)
from e3fe23ff86e3f5f19c0a76779f957adf1310b949 (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit 563b588da606aa38cdfd8a35fbc70c7414678747
Author: Peter Amstutz <peter.amstutz at curoverse.com>
Date: Fri Oct 24 09:02:40 2014 -0400
4295: Use EventMachine::schedule when there is potentially more events to send instead of pushing an event to the channel (which wakes up all listeners).
diff --git a/services/api/lib/eventbus.rb b/services/api/lib/eventbus.rb
index 9b15b2c..1754fc0 100644
--- a/services/api/lib/eventbus.rb
+++ b/services/api/lib/eventbus.rb
@@ -124,7 +124,9 @@ class EventBus
# Number of rows returned was capped by limit(), we need to schedule
# another query to get more logs (will start from last_log_id
# reported by current query)
- @channel.push nil
+ EventMachine::schedule do
+ push_events ws, nil
+ end
elsif !notify_id.nil? and (ws.last_log_id.nil? or notify_id > ws.last_log_id)
# Number of rows returned was less than cap, but the notify id is
# higher than the last id visible to the client, so update last_log_id
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list