aboutsummaryrefslogtreecommitdiffstats
path: root/jobmanager.html
diff options
context:
space:
mode:
Diffstat (limited to 'jobmanager.html')
-rw-r--r--jobmanager.html30
1 files changed, 29 insertions, 1 deletions
diff --git a/jobmanager.html b/jobmanager.html
index aa262fa..7712021 100644
--- a/jobmanager.html
+++ b/jobmanager.html
@@ -61,7 +61,7 @@
61 61
62 62
63 <div class="version"> 63 <div class="version">
64 0.2.1 64 0.2.6.2
65 </div> 65 </div>
66 66
67 67
@@ -263,6 +263,34 @@ of work.</p>
263for another REQUEST message.</p> 263for another REQUEST message.</p>
264</dd></dl> 264</dd></dl>
265 265
266<dl class="method">
267<dt id="eventmq.jobmanager.JobManager.send_reply">
268<code class="descname">send_reply</code><span class="sig-paren">(</span><em>res</em><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.JobManager.send_reply" title="Permalink to this definition">¶</a></dt>
269<dd><p>Sends an REPLY response</p>
270<table class="docutils field-list" frame="void" rules="none">
271<col class="field-name" />
272<col class="field-body" />
273<tbody valign="top">
274<tr class="field-odd field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
275<li><strong>socket</strong> (<a class="reference external" href="https://docs.python.org/library/socket.html#module-socket" title="(in Python v2.7)"><em>socket</em></a>) &#8211; The socket to use for this ack</li>
276<li><strong>recipient</strong> (<a class="reference external" href="https://docs.python.org/library/functions.html#str" title="(in Python v2.7)"><em>str</em></a>) &#8211; The recipient id for the ack</li>
277<li><strong>msgid</strong> &#8211; The unique id that we are acknowledging</li>
278</ul>
279</td>
280</tr>
281</tbody>
282</table>
283</dd></dl>
284
285</dd></dl>
286
287<dl class="function">
288<dt id="eventmq.jobmanager.mp_init">
289<code class="descclassname">eventmq.jobmanager.</code><code class="descname">mp_init</code><span class="sig-paren">(</span><span class="sig-paren">)</span><a class="headerlink" href="#eventmq.jobmanager.mp_init" title="Permalink to this definition">¶</a></dt>
290<dd><p>The instance of Context is copied when python multiprocessing fork()s the
291worker processes, so we need to terminate that Context so a new one can be
292rebuilt. Without doing this, messages sent from functions in those child
293processes will never be delivered.</p>
266</dd></dl> 294</dd></dl>
267 295
268</div> 296</div>