diff options
Diffstat (limited to 'jobmanager.html')
| -rw-r--r-- | jobmanager.html | 30 |
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> | |||
| 263 | for another REQUEST message.</p> | 263 | for 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>) – 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>) – The recipient id for the ack</li> | ||
| 277 | <li><strong>msgid</strong> – 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 | ||
| 291 | worker processes, so we need to terminate that Context so a new one can be | ||
| 292 | rebuilt. Without doing this, messages sent from functions in those child | ||
| 293 | processes will never be delivered.</p> | ||
| 266 | </dd></dl> | 294 | </dd></dl> |
| 267 | 295 | ||
| 268 | </div> | 296 | </div> |