Kouhei Sutou
null+****@clear*****
Tue May 13 19:00:16 JST 2014
Kouhei Sutou 2014-05-13 19:00:16 +0900 (Tue, 13 May 2014) New Revision: d50bb875131d6544cd52af82bf4360ed36545370 https://github.com/droonga/droonga-engine/commit/d50bb875131d6544cd52af82bf4360ed36545370 Message: dump: send dump.start message Modified files: lib/droonga/plugins/dump.rb Modified: lib/droonga/plugins/dump.rb (+9 -0) =================================================================== --- lib/droonga/plugins/dump.rb 2014-05-12 11:52:55 +0900 (383fe50) +++ lib/droonga/plugins/dump.rb 2014-05-13 19:00:16 +0900 (9c9f47b) @@ -32,6 +32,15 @@ module Droonga return false unless replyTo request = message.request || {} + + dump_start_message = { + "inReplyTo" => id, + "dataset" => dataset, + } + messenger.forward(dump_start_message, + "to" => replyTo, + "type" => "dump.start") + messages_per_seconds = request["messagesPerSecond"] || 10000 messages_per_seconds = [10, messages_per_seconds.to_i].max messages_per_100msec = messages_per_seconds / 10 -------------- next part -------------- HTML����������������������������...Download