YUKI Hiroshi
null+****@clear*****
Tue Apr 14 16:31:41 JST 2015
YUKI Hiroshi 2015-04-14 16:31:41 +0900 (Tue, 14 Apr 2015) New Revision: 8fc3d7b5f85e3aed004b58f12e6a7fe816088ad3 https://github.com/droonga/droonga-engine/commit/8fc3d7b5f85e3aed004b58f12e6a7fe816088ad3 Message: Use private methods directly Modified files: lib/droonga/planner.rb Modified: lib/droonga/planner.rb (+4 -6) =================================================================== --- lib/droonga/planner.rb 2015-04-14 16:31:23 +0900 (1a87f02) +++ lib/droonga/planner.rb 2015-04-14 16:31:41 +0900 (226d5e6) @@ -33,8 +33,6 @@ module Droonga def plan(message, params={}) options = { - :write => write?, - :random => random?, :record => params[:record], } if @collector_class @@ -67,10 +65,10 @@ module Droonga def scatter(message, options={}) planner = DistributedCommandPlanner.new(@dataset, message) scatter_options = { - :write => options[:write], + :write => write?, :record => options[:record], } - scatter_options[:replica] = "random" if options[:random] + scatter_options[:replica] = "random" if random? planner.scatter(scatter_options) planner.reduce(options[:reduce]) planner.plan @@ -79,9 +77,9 @@ module Droonga def broadcast(message, options={}) planner = DistributedCommandPlanner.new(@dataset, message) broadcast_options = { - :write => options[:write], + :write => write?, } - broadcast_options[:replica] = "all" if options[:write] + broadcast_options[:replica] = "all" if write? planner.broadcast(broadcast_options) planner.reduce(options[:reduce]) planner.plan -------------- next part -------------- HTML����������������������������...Download