Navigation Menu

Skip to content

Commit

Permalink
Allow to absorb data even if the source node has no "last processed m…
Browse files Browse the repository at this point in the history
…essage" information
  • Loading branch information
piroor committed Apr 23, 2015
1 parent f28e745 commit 991f90b
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 10 deletions.
9 changes: 4 additions & 5 deletions bin/droonga-engine-absorb-data
Expand Up @@ -249,11 +249,6 @@ module Droonga

def update_accept_messages_newer_than_timestamp
timestamp = source_node_serf.last_processed_message_timestamp
unless timestamp
$stderr.puts("Couldn't get the time stamp of " +
"the last processed message from the source node.")
return false
end
if timestamp and not timestamp.empty?
puts "The timestamp of the last processed message in the source node: #{timestamp}"
puts "Setting effective message timestamp for the destination node..."
Expand All @@ -262,6 +257,10 @@ module Droonga
"node" => destination_node.to_s,
"timestamp" => timestamp)
end
else
$stderr.puts("WARNING: Couldn't get the time stamp of " +
"the last processed message from the source node. " +
"Any message will be forwarded to the joining node.")
end
true
end
Expand Down
9 changes: 4 additions & 5 deletions bin/droonga-engine-join
Expand Up @@ -323,11 +323,6 @@ module Droonga

def update_accept_messages_newer_than_timestamp
timestamp = source_node_serf.last_processed_message_timestamp
unless timestamp
$stderr.puts("Couldn't get the time stamp of " +
"the last processed message from the source node.")
return false
end
if timestamp and not timestamp.empty?
puts "The timestamp of the last processed message in the source node: #{timestamp}"
puts "Setting effective message timestamp for the destination node..."
Expand All @@ -336,6 +331,10 @@ module Droonga
"node" => joining_node.to_s,
"timestamp" => timestamp)
end
else
$stderr.puts("WARNING: Couldn't get the time stamp of " +
"the last processed message from the source node. " +
"Any message will be forwarded to the joining node.")
end
true
end
Expand Down

0 comments on commit 991f90b

Please sign in to comment.