YUKI Hiroshi
null+****@clear*****
Thu Apr 23 13:30:52 JST 2015
YUKI Hiroshi 2015-04-23 13:30:52 +0900 (Thu, 23 Apr 2015) New Revision: 991f90b383e8f50ad8d8b18664c3b7b4d359b1f2 https://github.com/droonga/droonga-engine/commit/991f90b383e8f50ad8d8b18664c3b7b4d359b1f2 Message: Allow to absorb data even if the source node has no "last processed message" information Modified files: bin/droonga-engine-absorb-data bin/droonga-engine-join Modified: bin/droonga-engine-absorb-data (+4 -5) =================================================================== --- bin/droonga-engine-absorb-data 2015-04-23 13:00:44 +0900 (6fbce11) +++ bin/droonga-engine-absorb-data 2015-04-23 13:30:52 +0900 (931227c) @@ -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..." @@ -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 Modified: bin/droonga-engine-join (+4 -5) =================================================================== --- bin/droonga-engine-join 2015-04-23 13:00:44 +0900 (5924e15) +++ bin/droonga-engine-join 2015-04-23 13:30:52 +0900 (a6d698a) @@ -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..." @@ -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 -------------- next part -------------- HTML����������������������������...Download