[Groonga-commit] droonga/droonga-engine at c297018 [master] Fix a bug that the same message may be sent multiple times

Back to archive index

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����������������������������...
下載 



More information about the Groonga-commit mailing list
Back to archive index