Kouhei Sutou
null+****@clear*****
Mon Jul 21 19:47:20 JST 2014
Kouhei Sutou 2014-07-21 19:47:20 +0900 (Mon, 21 Jul 2014) New Revision: c297018e9d088bf48ea9485a64ca4f21cb19a7c8 https://github.com/droonga/droonga-engine/commit/c297018e9d088bf48ea9485a64ca4f21cb19a7c8 Message: Fix a bug that the same message may be sent multiple times Modified files: lib/droonga/fluent_message_sender.rb Modified: lib/droonga/fluent_message_sender.rb (+1 -2) =================================================================== --- lib/droonga/fluent_message_sender.rb 2014-07-21 18:03:18 +0900 (8031fa8) +++ lib/droonga/fluent_message_sender.rb 2014-07-21 19:47:20 +0900 (0cd62c9) @@ -57,9 +57,7 @@ module Droonga end def resume - return unless @buffering connect unless connected? - @socket.resume end private @@ -88,6 +86,7 @@ module Droonga data_directory = Path.buffer + "#{@host}:#{@port}" FileUtils.mkdir_p(data_directory.to_s) @socket = BufferedTCPSocket.connect(@host, @port, data_directory) + @socket.resume else @socket = Coolio::TCPSocket.connect(@host, @port) end -------------- next part -------------- HTML����������������������������... 下載