<!DOCTYPE html>
<html>
<head>
</head>
<body>
<dl style="line-height: 1.5; margin-left: 2em">
<dt style="clear: both; float: left; font-weight: bold; width: 8em">Author</dt>
<dd style="margin-left: 8.5em">YUKI Hiroshi <shimo****@clear*****></dd>
<dt style="clear: both; float: left; font-weight: bold; width: 8em">Date</dt>
<dd style="margin-left: 8.5em">2015-01-06 16:18:54 +0900 (Tue, 06 Jan 2015)</dd>
<dt style="clear: both; float: left; font-weight: bold; width: 8em">New Revision</dt>
<dd style="margin-left: 8.5em"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37">f3050b1238014a98afa1e9a930e2d7fdf2108f37</a></dd>
<dt style="clear: both; float: left; font-weight: bold; width: 8em">Message</dt>
<dd style="margin-left: 8.5em"><pre style="border: 1px solid #aaa; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; padding: 0.5em; width: auto">Make EngineState independent from Cluster
Conflicts:
        lib/droonga/dispatcher.rb</pre></dd>
<dt style="clear: both; float: left; font-weight: bold; width: 8em">Modified files</dt>
<dd style="margin-left: 8.5em">
<ul>
<li><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#diff-0">lib/droonga/dispatcher.rb</a></li>
<li><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#diff-1">lib/droonga/engine.rb</a></li>
<li><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#diff-2">lib/droonga/engine_state.rb</a></li>
<li><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#diff-3">lib/droonga/handler_messenger.rb</a></li>
</ul>
</dd>
</dl>
<div class="diff-section" style="clear: both">
<table style="border-collapse: collapse; border: 1px solid #aaa">
<thead>
<tr class="diff-header" style="border: 1px solid #aaa">
<td colspan="3">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre"> Modified: lib/droonga/dispatcher.rb (+22 -13)</span>
<span class="diff-header-mark" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">===================================================================</span>
</pre>
</td>
</tr>
</thead>
<tbody>
<tr>
<th class="diff-line-number" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L45">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L46">46</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L47">47</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L48">48</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L49">49</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L50">50</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L51">51</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L52">52</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L53">53</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L54">54</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L55">55</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L56">56</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L57">57</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L58">58</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L59">59</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L60">60</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L61">61</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L115">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L116">116</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L117">117</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L118">118</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L119">119</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L120">120</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L121">121</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L122">122</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L162">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L163">163</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L164">164</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L165">165</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L166">166</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L167">167</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L168">168</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L169">169</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L186">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L187">187</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L188">188</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L189">189</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L190">190</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L191">191</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L192">192</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L193">193</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L199">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L200">200</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L201">201</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L202">202</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L203">203</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L204">204</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L205">205</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L206">206</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L207">207</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L208">208</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L209">209</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L210">210</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L211">211</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L212">212</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L317">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L318">318</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L319">319</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L320">320</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L321">321</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L322">322</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L323">323</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L324">324</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L325">325</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L360">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L361">361</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L362">362</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L363">363</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L364">364</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L365">365</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L366">366</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L367">367</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L368">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L369">369</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L370">370</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L371">371</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L372">372</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L373">373</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0L374">374</a></span>
</pre>
</th>
<th class="diff-line-number" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R45">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R46">46</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R47">47</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R48">48</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R49">49</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R50">50</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R51">51</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R52">52</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R53">53</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R54">54</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R55">55</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R56">56</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R57">57</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R58">58</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R59">59</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R60">60</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R61">61</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R62">62</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R63">63</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R64">64</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R65">65</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R66">66</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R120">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R121">121</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R122">122</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R123">123</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R124">124</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R125">125</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R126">126</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R127">127</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R167">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R168">168</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R169">169</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R170">170</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R171">171</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R172">172</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R173">173</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R174">174</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R191">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R192">192</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R193">193</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R194">194</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R195">195</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R196">196</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R197">197</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R198">198</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R204">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R205">205</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R206">206</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R207">207</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R208">208</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R209">209</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R210">210</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R211">211</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R212">212</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R213">213</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R318">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R319">319</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R320">320</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R321">321</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R322">322</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R323">323</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R324">324</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R325">325</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R326">326</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R327">327</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R362">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R363">363</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R364">364</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R365">365</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R366">366</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R367">367</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R368">368</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R369">369</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R370">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R371">371</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R372">372</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R373">373</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R374">374</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R375">375</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R376">376</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R377">377</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R378">378</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R379">379</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R380">380</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R381">381</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R382">382</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L0R383">383</a></span>
</pre>
</th>
<td class="diff-content" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -46,16 +46,21 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- attr_reader :engine_state</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ attr_reader :engine_state, :cluster</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- def initialize(engine_state, catalog)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ def initialize(engine_state, cluster, catalog)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @engine_state = engine_state</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster = cluster</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @forwarder = @engine_state.forwarder</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster.on_change = lambda do</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @forwarder.resume</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @replier = @engine_state.replier</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @catalog = catalog</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @adapter_runners = create_adapter_runners</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @farm = Farm.new(@engine_state.name, @catalog, @engine_state.loop,</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> :engine_state => @engine_state,</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ :cluster => @cluster,</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> :dispatcher => self,</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> :forwarder => @forwarder)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @collector_runners = create_collector_runners</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -116,7 +121,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def forward(message, destination)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> logger.trace("forward start")</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> unless local?(destination)</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- return if @engine_state.cluster.forward(message, destination)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ return if @cluster.forward(message, destination)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @forwarder.forward(message, destination)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> logger.trace("forward done")</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -163,7 +168,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> else</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> steps = message["steps"]</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> if steps</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- session_planner = SessionPlanner.new(@engine_state, steps)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ session_planner = SessionPlanner.new(@engine_state, @cluster, steps)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> dataset = message["dataset"] || @message["dataset"]</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> collector_runner = @collector_runners[dataset]</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> session = session_planner.create_session(id, self, collector_runner)</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -187,7 +192,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> "type" => "dispatcher",</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> "to" => destination,</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> }</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @engine_state.cluster.forward(forward_message, forward_destination) ||</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster.forward(forward_message, forward_destination) ||</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @forwarder.forward(forward_message, forward_destination)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -200,13 +205,9 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> dataset = @catalog.dataset(step["dataset"])</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> if dataset</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> if write_step?(step)</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- target_nodes = @engine_state.cluster.writable_nodes</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- logger.trace("dispatch_steps: target_nodes = writable_nodes",</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- :nodes => target_nodes)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ target_nodes = @cluster.writable_nodes</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> else</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- target_nodes = @engine_state.cluster.forwardable_nodes</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- logger.trace("dispatch_steps: target_nodes = forwardable_nodes",</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- :nodes => target_nodes)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ target_nodes = @cluster.forwardable_nodes</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> routes = dataset.compute_routes(step, target_nodes)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> step["routes"] = routes</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -318,8 +319,9 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> class SessionPlanner</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> attr_reader :steps</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- def initialize(engine_state, steps)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ def initialize(engine_state, cluster, steps)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @engine_state = engine_state</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster = cluster</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @steps = steps</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -361,7 +363,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> (step["outputs"] || []).each do |output|</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> descendants[output] = []</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @descendants[output].each do |index|</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- responsive_routes = @engine_state.select_responsive_routes(step["routes"])</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ responsive_routes = select_responsive_routes(step["routes"])</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @steps[index]["n_of_expects"] += responsive_routes.size</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> descendants[output].concat(@steps[index]["routes"])</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -369,6 +371,13 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> step["descendants"] = descendants</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ def select_responsive_routes(routes)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ selected_nodes = @cluster.forwardable_nodes</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ routes.select do |route|</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ selected_nodes.include?(@engine_state.farm_path(route))</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ end</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
</pre>
</td>
</tr>
</tbody>
</table>
<table style="border-collapse: collapse; border: 1px solid #aaa">
<thead>
<tr class="diff-header" style="border: 1px solid #aaa">
<td colspan="3">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre"> Modified: lib/droonga/engine.rb (+7 -5)</span>
<span class="diff-header-mark" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">===================================================================</span>
</pre>
</td>
</tr>
</thead>
<tbody>
<tr>
<th class="diff-line-number" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L19">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L20">20</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L21">21</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L22">22</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L23">23</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L24">24</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L25">25</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L31">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L32">32</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L33">33</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L34">34</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L35">35</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L36">36</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L37">37</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L38">38</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L39">39</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L49">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L50">50</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L51">51</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L52">52</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L53">53</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L54">54</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L55">55</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L56">56</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L57">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L58">58</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L59">59</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L60">60</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L61">61</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L62">62</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L63">63</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L64">64</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L82">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L83">83</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L84">84</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L85">85</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L86">86</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L87">87</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L88">88</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L89">89</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L111">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L112">112</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L113">113</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L114">114</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L115">115</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L116">116</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L117">117</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1L118">118</a></span>
</pre>
</th>
<th class="diff-line-number" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R19">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R20">20</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R21">21</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R22">22</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R23">23</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R24">24</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R25">25</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R26">26</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R32">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R33">33</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R34">34</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R35">35</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R36">36</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R37">37</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R38">38</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R39">39</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R40">40</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R41">41</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R51">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R52">52</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R53">53</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R54">54</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R55">55</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R56">56</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R57">57</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R58">58</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R59">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R60">60</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R61">61</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R62">62</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R63">63</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R64">64</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R65">65</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R66">66</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R84">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R85">85</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R86">86</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R87">87</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R88">88</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R89">89</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R90">90</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R91">91</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R113">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R114">114</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R115">115</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R116">116</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R117">117</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R118">118</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R119">119</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L1R120">120</a></span>
</pre>
</th>
<td class="diff-content" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -20,6 +20,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">require "fileutils"</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/engine/version"</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/loggable"</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/engine_state"</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+require "droonga/cluster"</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/catalog_loader"</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/dispatcher"</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/file_observer"</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -32,8 +33,9 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> attr_writer :on_ready</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def initialize(loop, name, internal_name)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @state = EngineState.new(loop, name, internal_name)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster = Cluster.new(loop)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @catalog = load_catalog</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @state.catalog = @catalog</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @state.catalog = @cluster.catalog = @catalog</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @dispatcher = create_dispatcher</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @node_metadata_observer = FileObserver.new(loop, Path.node_metadata)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @node_metadata_observer.on_change = lambda do</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -50,7 +52,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @on_ready.call if @on_ready</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @state.start</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @state.cluster.start_observe</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster.start_observe</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @node_metadata_observer.start</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @dispatcher.start</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> logger.trace("start: done")</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -58,7 +60,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def stop_gracefully</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> logger.trace("stop_gracefully: start")</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @state.cluster.stop_observe</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster.stop_observe</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @node_metadata_observer.stop</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> on_finish = lambda do</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> logger.trace("stop_gracefully/on_finish: start")</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -83,7 +85,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def stop_immediately</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> logger.trace("stop_immediately: start")</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> save_last_processed_message_timestamp</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @state.cluster.stop_observe</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster.stop_observe</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @node_metadata_observer.stop</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @dispatcher.stop_immediately</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @state.shutdown</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -112,7 +114,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def create_dispatcher</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- Dispatcher.new(@state, @catalog)</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ Dispatcher.new(@state, @cluster, @catalog)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def save_last_processed_message_timestamp</span>
</pre>
</td>
</tr>
</tbody>
</table>
<table style="border-collapse: collapse; border: 1px solid #aaa">
<thead>
<tr class="diff-header" style="border: 1px solid #aaa">
<td colspan="3">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre"> Modified: lib/droonga/engine_state.rb (+1 -18)</span>
<span class="diff-header-mark" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">===================================================================</span>
</pre>
</td>
</tr>
</thead>
<tbody>
<tr>
<th class="diff-line-number" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L20">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L21">21</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L22">22</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L23">23</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L24">24</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L25">25</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L26">26</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L27">27</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L32">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L33">33</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L34">34</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L35">35</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L36">36</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L37">37</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L38">38</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L39">39</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L40">40</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L42">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L43">43</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L44">44</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L45">45</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L46">46</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L47">47</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L48">48</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L49">49</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L50">50</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L51">51</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L52">52</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L53">53</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L54">54</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L55">55</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L56">56</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L57">57</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L58">58</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L59">59</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L60">60</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L61">61</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L62">62</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L63">63</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L117">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L118">118</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L119">119</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L120">120</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L121">121</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L122">122</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L123">123</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L124">124</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L125">125</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L126">126</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L127">127</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L128">128</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L129">129</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2L130">130</a></span>
</pre>
</th>
<th class="diff-line-number" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R20">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R21">21</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R22">22</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R23">23</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R24">24</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R25">25</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R26">26</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R31">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R32">32</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R33">33</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R34">34</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R35">35</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R36">36</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R37">37</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R38">38</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R40">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R41">41</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R42">42</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R43">43</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R44">44</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R45">45</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R46">46</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R47">47</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R48">48</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R49">49</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R50">50</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R51">51</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R52">52</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R53">53</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R107">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R108">108</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R109">109</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R110">110</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R111">111</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R112">112</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L2R113">113</a></span>
</pre>
</th>
<td class="diff-content" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -21,7 +21,6 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">require "droonga/loggable"</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/event_loop"</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/buffered_forwarder"</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> require "droonga/replier"</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">-require "droonga/cluster"</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-not-changed" style="display: block; white-space: pre"> module Droonga</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> class EngineState</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -33,8 +32,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> attr_reader :forwarder</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> attr_reader :replier</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> attr_writer :on_ready</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- attr_reader :catalog</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- attr_reader :cluster</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ attr_accessor :catalog</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> attr_accessor :on_finish</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def initialize(loop, name, internal_name)</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -43,21 +41,13 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @internal_name = internal_name</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @sessions = {}</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @current_id = 0</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @cluster = Cluster.new(@loop)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @forwarder = Forwarder.new(@loop, :buffering => true)</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @cluster.on_change = lambda do</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @forwarder.resume</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @replier = Replier.new(@forwarder)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @on_ready = nil</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @on_finish = nil</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @catalog = nil</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- def catalog=(catalog)</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- @catalog = @cluster.catalog = catalog</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- end</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">-</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def start</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> logger.trace("start start")</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @forwarder.start</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -118,13 +108,6 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @on_ready.call if @on_ready</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- def select_responsive_routes(routes)</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- selected_nodes = @cluster.forwardable_nodes</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- routes.select do |route|</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- selected_nodes.include?(farm_path(route))</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- end</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- end</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">-</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> private</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def log_tag</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> "engine_state"</span>
</pre>
</td>
</tr>
</tbody>
</table>
<table style="border-collapse: collapse; border: 1px solid #aaa">
<thead>
<tr class="diff-header" style="border: 1px solid #aaa">
<td colspan="3">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre"> Modified: lib/droonga/handler_messenger.rb (+2 -1)</span>
<span class="diff-header-mark" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">===================================================================</span>
</pre>
</td>
</tr>
</thead>
<tbody>
<tr>
<th class="diff-line-number" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L17">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L18">18</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L19">19</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L20">20</a></span>
<span class="diff-line-number-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L21">21</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L22">22</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L23">23</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L24">24</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L26">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L27">27</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L28">28</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L29">29</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L30">30</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L31">31</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3L32">32</a></span>
</pre>
</th>
<th class="diff-line-number" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R17">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R18">18</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R19">19</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R20">20</a></span>
<span class="diff-line-number-nothing" style="display: block; white-space: pre"> </span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R21">21</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R22">22</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R23">23</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R24">24</a></span>
<span class="diff-line-number-hunk-header" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R26">...</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R27">27</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R28">28</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R29">29</a></span>
<span class="diff-line-number-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R30">30</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R31">31</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R32">32</a></span>
<span class="diff-line-number-not-changed" style="display: block; white-space: pre"><a href="https://github.com/droonga/droonga-engine/commit/f3050b1238014a98afa1e9a930e2d7fdf2108f37#L3R33">33</a></span>
</pre>
</th>
<td class="diff-content" style="border: 1px solid #aaa">
<pre style="border: 0; font-family: Consolas, Menlo, "Liberation Mono", Courier, monospace; line-height: 1.2; margin: 0; padding: 0.5em; white-space: normal; width: auto"><span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -18,7 +18,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">require "droonga/forwarder"</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-not-changed" style="display: block; white-space: pre"> module Droonga</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> class HandlerMessenger</span>
<span class="diff-deleted" style="background-color: #ffaaaa; color: #000000; display: block; white-space: pre">- attr_reader :database_name, :dispatcher, :engine_state</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ attr_reader :database_name, :dispatcher, :engine_state, :cluster</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
<span class="diff-not-changed" style="display: block; white-space: pre"> def initialize(forwarder, message, options={})</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @forwarder = forwarder</span>
<span class="diff-hunk-header" style="background-color: #eaf2f5; color: #999999; display: block; white-space: pre">@@ -27,6 +27,7 @@ <span class="diff-context" style="background-color: #ffffaa; color: #000000">module Droonga</span></span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @replier = Replier.new(@forwarder)</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @dispatcher = options[:dispatcher]</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @engine_state = options[:engine_state]</span>
<span class="diff-added" style="background-color: #aaffaa; color: #000000; display: block; white-space: pre">+ @cluster = options[:cluster]</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> @database_name = options[:database]</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> end</span>
<span class="diff-not-changed" style="display: block; white-space: pre"> </span>
</pre>
</td>
</tr>
</tbody>
</table>
</div>
</body>
</html>