YUKI Hiroshi
null+****@clear*****
Thu Apr 23 16:13:33 JST 2015
YUKI Hiroshi 2015-04-23 16:13:33 +0900 (Thu, 23 Apr 2015) New Revision: 9775902fcb73f4c5de53c5c50fecdb2cada38745 https://github.com/droonga/droonga-engine/commit/9775902fcb73f4c5de53c5c50fecdb2cada38745 Message: Make displayed messages more meaningful Modified files: bin/droonga-engine-absorb-data bin/droonga-engine-join Modified: bin/droonga-engine-absorb-data (+2 -2) =================================================================== --- bin/droonga-engine-absorb-data 2015-04-23 16:05:25 +0900 (bfbd809) +++ bin/droonga-engine-absorb-data 2015-04-23 16:13:33 +0900 (009ab61) @@ -245,7 +245,7 @@ module Droonga timestamp = source_node_serf.latest_last_processed_message_timestamp 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..." + puts "Setting the destination node to ignore messages older than the timestamp..." destination_node_serf.ensure_restarted do destination_node_serf.send_query("accept_messages_newer_than", "node" => destination_node.to_s, @@ -254,7 +254,7 @@ module Droonga 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.") + "Any message will be forwarded to the destination node.") end end Modified: bin/droonga-engine-join (+5 -5) =================================================================== --- bin/droonga-engine-join 2015-04-23 16:05:25 +0900 (d370c9f) +++ bin/droonga-engine-join 2015-04-23 16:13:33 +0900 (ddc7bdf) @@ -285,7 +285,7 @@ module Droonga end def do_join - puts("Joining new replica to the cluster...") + puts("Configuring the joining node as a new replica for the cluster...") joining_node_serf.ensure_restarted do joining_node_serf.send_query("join", "node" => joining_node.to_s, @@ -320,8 +320,8 @@ module Droonga def update_accept_messages_newer_than_timestamp timestamp = source_node_serf.latest_last_processed_message_timestamp 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..." + puts "The timestamp of the last processed message at the source node: #{timestamp}" + puts "Setting new node to ignore messages older than the timestamp..." joining_node_serf.ensure_restarted do joining_node_serf.send_query("accept_messages_newer_than", "node" => joining_node.to_s, @@ -335,7 +335,7 @@ module Droonga end def register_to_existing_nodes - puts("Register new node to existing hosts in the cluster...") + puts("Registering new node to existing nodes...") source_node_serf.ensure_restarted(*existing_nodes) do source_node_serf.send_query("add_replicas", "cluster_id" => source_cluster_id, @@ -346,7 +346,7 @@ module Droonga end def unregister_from_existing_nodes - puts("Unregister new node from existing hosts in the cluster...") + puts("Unregistering new node from existing nodes...") source_node_serf.ensure_restarted(*existing_nodes) do source_node_serf.send_query("remove_replicas", "cluster_id" => source_cluster_id, -------------- next part -------------- HTML����������������������������...Descargar
