[ARVADOS] updated: f32e1aadda3cc2cb89ee341e24cc312f42d37505
Git user
git at public.curoverse.com
Tue Jun 14 15:53:28 EDT 2016
Summary of changes:
services/api/lib/eventbus.rb | 3 +++
1 file changed, 3 insertions(+)
via f32e1aadda3cc2cb89ee341e24cc312f42d37505 (commit)
from a340b9c191733087722cd4203bf0b6b76f60cbec (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 f32e1aadda3cc2cb89ee341e24cc312f42d37505
Author: Peter Amstutz <peter.amstutz at curoverse.com>
Date: Tue Jun 14 15:53:21 2016 -0400
9388: Reset sent_ids for consistency
diff --git a/services/api/lib/eventbus.rb b/services/api/lib/eventbus.rb
index eb7750f..b35da1b 100644
--- a/services/api/lib/eventbus.rb
+++ b/services/api/lib/eventbus.rb
@@ -188,6 +188,9 @@ class EventBus
# Set or reset the last_log_id. The event bus only reports events
# for rows that come after last_log_id.
ws.last_log_id = p[:last_log_id].to_i
+ # Reset sent_ids for consistency
+ # (always re-deliver all matching messages following last_log_id)
+ ws.sent_ids = Set.new
end
if ws.filters.length < MAX_FILTERS
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list