YUKI Hiroshi
null+****@clear*****
Fri Nov 21 15:36:32 JST 2014
YUKI Hiroshi 2014-11-21 15:36:32 +0900 (Fri, 21 Nov 2014) New Revision: 6b4618a03b609aef23c73a0a25dcaa66113eba3d https://github.com/droonga/droonga-engine/commit/6b4618a03b609aef23c73a0a25dcaa66113eba3d Message: Restrict inpouring messages per second while absorving Modified files: lib/droonga/data_absorber.rb Modified: lib/droonga/data_absorber.rb (+5 -0) =================================================================== --- lib/droonga/data_absorber.rb 2014-11-21 15:20:26 +0900 (3552397) +++ lib/droonga/data_absorber.rb 2014-11-21 15:36:32 +0900 (850ba2b) @@ -17,6 +17,8 @@ require "open3" module Droonga class DataAbsorber + DEFAULT_MAXIMUM_MESSAGES_PER_SECOND = 100 + class << self def absorb(params) drndump = params[:drndump] || "drndump" @@ -53,6 +55,9 @@ module Droonga server = "#{server}:#{params[:port].to_s}" if params[:port] server = "#{server}/#{params[:tag].to_s}" if params[:tag] client_options += ["--server", server] + #XXX We should restrict the traffic to avoid overflowing! + params[:messages_per_second] ||= DEFAULT_MAXIMUM_MESSAGES_PER_SECOND + client_options += ["--messages-per-second", params[:messages_per_second]] else raise ArgumentError.new("Unknwon type client: #{client}") end -------------- next part -------------- HTML����������������������������...Download