Navigation Menu

Skip to content

Commit

Permalink
Get "last processed message timestamp" before starting of absorb-data.
Browse files Browse the repository at this point in the history
Because dump messages sent by system.absorb-data updates the last processed message timestamp.
  • Loading branch information
piroor committed Apr 23, 2015
1 parent cad8109 commit e817588
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
3 changes: 2 additions & 1 deletion bin/droonga-engine-absorb-data
Expand Up @@ -43,10 +43,11 @@ module Droonga
puts ""
puts "Absorbing..."

update_accept_messages_newer_than_timestamp

succeeded = absorb

if succeeded
update_accept_messages_newer_than_timestamp
puts "Done."
else
do_cancel
Expand Down
2 changes: 1 addition & 1 deletion bin/droonga-engine-join
Expand Up @@ -67,12 +67,12 @@ module Droonga
register_to_existing_nodes
set_source_node_role
if should_copy?
update_accept_messages_newer_than_timestamp
successed = copy_data
unless successed
do_cancel
return false
end
update_accept_messages_newer_than_timestamp
end
reset_source_node_role
reset_joining_node_role
Expand Down

0 comments on commit e817588

Please sign in to comment.