Kouhei Sutou
null+****@clear*****
Sun Sep 7 23:00:39 JST 2014
Kouhei Sutou 2014-09-07 23:00:39 +0900 (Sun, 07 Sep 2014) New Revision: d578d849c9e29105ea69ac6507b024688563b4dd https://github.com/droonga/droonga-engine/commit/d578d849c9e29105ea69ac6507b024688563b4dd Message: Reuse message pack packer instance It improves performance. (I tried it with Droonga::MessagePackPacker on irb but I should measure it with droonga-engine... Sorry...) Modified files: droonga-engine.gemspec lib/droonga/fluent_message_sender.rb Modified: droonga-engine.gemspec (+1 -1) =================================================================== --- droonga-engine.gemspec 2014-09-07 15:54:40 +0900 (0847ca9) +++ droonga-engine.gemspec 2014-09-07 23:00:39 +0900 (e9c1928) @@ -39,7 +39,7 @@ Gem::Specification.new do |gem| gem.add_dependency "cool.io" gem.add_dependency "drndump" gem.add_dependency "droonga-client", ">= 0.1.9" - gem.add_dependency "droonga-message-pack-packer", ">= 1.0.1" + gem.add_dependency "droonga-message-pack-packer", ">= 1.0.2" gem.add_dependency "groonga-command-parser" gem.add_dependency "faraday" gem.add_dependency "faraday_middleware" Modified: lib/droonga/fluent_message_sender.rb (+5 -1) =================================================================== --- lib/droonga/fluent_message_sender.rb 2014-09-07 15:54:40 +0900 (2212036) +++ lib/droonga/fluent_message_sender.rb 2014-09-07 23:00:39 +0900 (526c862) @@ -34,6 +34,7 @@ module Droonga @host = host @port = port @socket = nil + @packer = MessagePackPacker.new @buffering = options[:buffering] end @@ -114,7 +115,10 @@ module Droonga def create_packed_fluent_message(tag, data) fluent_message = [tag, Time.now.to_i, data] - MessagePackPacker.pack(fluent_message) + @packer.pack(fluent_message) + packed_fluent_message =****@packe*****_s + @packer.clear + packed_fluent_message end def log_tag -------------- next part -------------- HTML����������������������������...Descargar
