-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathtangled.core-pysrc.html
548 lines (538 loc) · 108 KB
/
tangled.core-pysrc.html
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
<?xml version="1.0" encoding="ascii"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
"DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
<head>
<title>tangled.core</title>
<link rel="stylesheet" href="epydoc.css" type="text/css" />
<script type="text/javascript" src="epydoc.js"></script>
</head>
<body bgcolor="white" text="black" link="blue" vlink="#204080"
alink="#204080">
<!-- ==================== NAVIGATION BAR ==================== -->
<table class="navbar" border="0" width="100%" cellpadding="0"
bgcolor="#a0c0ff" cellspacing="0">
<tr valign="middle">
<!-- Tree link -->
<th> <a
href="module-tree.html">Trees</a> </th>
<!-- Index link -->
<th> <a
href="identifier-index.html">Indices</a> </th>
<!-- Help link -->
<th> <a
href="help.html">Help</a> </th>
<!-- Project homepage -->
<th class="navbar" align="right" width="100%">
<table border="0" cellpadding="0" cellspacing="0">
<tr><th class="navbar" align="center"
><a class="navbar" target="_top" href="http://bitbucket.org/rogueops/vinzclortho">Vinz Clortho</a></th>
</tr></table></th>
</tr>
</table>
<table width="100%" cellpadding="0" cellspacing="0">
<tr valign="top">
<td width="100%">
<span class="breadcrumbs">
<a href="tangled-module.html">Package tangled</a> ::
Module core
</span>
</td>
<td>
<table cellpadding="0" cellspacing="0">
<!-- hide/show private -->
<tr><td align="right"><span class="options">[<a href="javascript:void(0);" class="privatelink"
onclick="toggle_private();">hide private</a>]</span></td></tr>
<tr><td align="right"><span class="options"
>[<a href="frames.html" target="_top">frames</a
>] | <a href="tangled.core-pysrc.html"
target="_top">no frames</a>]</span></td></tr>
</table>
</td>
</tr>
</table>
<h1 class="epydoc">Source Code for <a href="tangled.core-module.html">Module tangled.core</a></h1>
<pre class="py-src">
<a name="L1"></a><tt class="py-lineno"> 1</tt> <tt class="py-line"><tt class="py-comment"># -*- coding: utf-8 -*-</tt> </tt>
<a name="L2"></a><tt class="py-lineno"> 2</tt> <tt class="py-line"><tt class="py-comment">#</tt> </tt>
<a name="L3"></a><tt class="py-lineno"> 3</tt> <tt class="py-line"><tt class="py-comment"># Copyright (c) 2001-2010 Pär Bohrarper.</tt> </tt>
<a name="L4"></a><tt class="py-lineno"> 4</tt> <tt class="py-line"><tt class="py-comment"># See LICENSE for details.</tt> </tt>
<a name="L5"></a><tt class="py-lineno"> 5</tt> <tt class="py-line"> </tt>
<a name="L6"></a><tt class="py-lineno"> 6</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">asynchat</tt> </tt>
<a name="L7"></a><tt class="py-lineno"> 7</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">asyncore</tt> </tt>
<a name="L8"></a><tt class="py-lineno"> 8</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">socket</tt> </tt>
<a name="L9"></a><tt class="py-lineno"> 9</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">threading</tt> </tt>
<a name="L10"></a><tt class="py-lineno"> 10</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">functools</tt> </tt>
<a name="L11"></a><tt class="py-lineno"> 11</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">Queue</tt> </tt>
<a name="L12"></a><tt class="py-lineno"> 12</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">sys</tt> </tt>
<a name="L13"></a><tt class="py-lineno"> 13</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">time</tt> </tt>
<a name="L14"></a><tt class="py-lineno"> 14</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">heapq</tt> </tt>
<a name="L15"></a><tt class="py-lineno"> 15</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">select</tt> </tt>
<a name="L16"></a><tt class="py-lineno"> 16</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">traceback</tt> </tt>
<a name="L17"></a><tt class="py-lineno"> 17</tt> <tt class="py-line"> </tt>
<a name="L18"></a><tt class="py-lineno"> 18</tt> <tt class="py-line"><tt class="py-keyword">import</tt> <tt class="py-name">logging</tt> </tt>
<a name="L19"></a><tt class="py-lineno"> 19</tt> <tt class="py-line"><tt id="link-0" class="py-name" targets="Variable tangled.client.log=tangled.client-module.html#log,Variable tangled.core.log=tangled.core-module.html#log,Variable tangled.server.log=tangled.server-module.html#log,Variable vinzclortho.consistenthashing.log=vinzclortho.consistenthashing-module.html#log,Variable vinzclortho.core.log=vinzclortho.core-module.html#log"><a title="tangled.client.log
tangled.core.log
tangled.server.log
vinzclortho.consistenthashing.log
vinzclortho.core.log" class="py-name" href="#" onclick="return doclink('link-0', 'log', 'link-0');">log</a></tt> <tt class="py-op">=</tt> <tt class="py-name">logging</tt><tt class="py-op">.</tt><tt class="py-name">getLogger</tt><tt class="py-op">(</tt><tt class="py-string">"tangled.core"</tt><tt class="py-op">)</tt> </tt>
<a name="L20"></a><tt class="py-lineno"> 20</tt> <tt class="py-line"> </tt>
<a name="L21"></a><tt class="py-lineno"> 21</tt> <tt class="py-line"><tt class="py-name">__version__</tt> <tt class="py-op">=</tt> <tt class="py-string">"0.1.1.1"</tt> </tt>
<a name="L22"></a><tt class="py-lineno"> 22</tt> <tt class="py-line"> </tt>
<a name="succeed"></a><div id="succeed-def"><a name="L23"></a><tt class="py-lineno"> 23</tt> <a class="py-toggle" href="#" id="succeed-toggle" onclick="return toggle('succeed');">-</a><tt class="py-line"><tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core-module.html#succeed">succeed</a><tt class="py-op">(</tt><tt class="py-param">r</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="succeed-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="succeed-expanded"><a name="L24"></a><tt class="py-lineno"> 24</tt> <tt class="py-line"> <tt class="py-docstring">"""Syntactic sugar for making a synchronous call look asynchronous"""</tt> </tt>
<a name="L25"></a><tt class="py-lineno"> 25</tt> <tt class="py-line"> <tt class="py-name">d</tt> <tt class="py-op">=</tt> <tt id="link-1" class="py-name" targets="Class tangled.core.Deferred=tangled.core.Deferred-class.html"><a title="tangled.core.Deferred" class="py-name" href="#" onclick="return doclink('link-1', 'Deferred', 'link-1');">Deferred</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L26"></a><tt class="py-lineno"> 26</tt> <tt class="py-line"> <tt class="py-name">d</tt><tt class="py-op">.</tt><tt id="link-2" class="py-name" targets="Method tangled.core.Deferred.callback()=tangled.core.Deferred-class.html#callback"><a title="tangled.core.Deferred.callback" class="py-name" href="#" onclick="return doclink('link-2', 'callback', 'link-2');">callback</a></tt><tt class="py-op">(</tt><tt class="py-name">r</tt><tt class="py-op">)</tt> </tt>
<a name="L27"></a><tt class="py-lineno"> 27</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">d</tt> </tt>
</div><a name="L28"></a><tt class="py-lineno"> 28</tt> <tt class="py-line"> </tt>
<a name="fail"></a><div id="fail-def"><a name="L29"></a><tt class="py-lineno"> 29</tt> <a class="py-toggle" href="#" id="fail-toggle" onclick="return toggle('fail');">-</a><tt class="py-line"><tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core-module.html#fail">fail</a><tt class="py-op">(</tt><tt class="py-param">r</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="fail-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="fail-expanded"><a name="L30"></a><tt class="py-lineno"> 30</tt> <tt class="py-line"> <tt class="py-docstring">"""Syntactic sugar for making a synchronous call look asynchronous, failure version"""</tt> </tt>
<a name="L31"></a><tt class="py-lineno"> 31</tt> <tt class="py-line"> <tt class="py-name">d</tt> <tt class="py-op">=</tt> <tt id="link-3" class="py-name"><a title="tangled.core.Deferred" class="py-name" href="#" onclick="return doclink('link-3', 'Deferred', 'link-1');">Deferred</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L32"></a><tt class="py-lineno"> 32</tt> <tt class="py-line"> <tt class="py-name">d</tt><tt class="py-op">.</tt><tt id="link-4" class="py-name"><a title="tangled.core.Deferred.callback" class="py-name" href="#" onclick="return doclink('link-4', 'callback', 'link-2');">callback</a></tt><tt class="py-op">(</tt><tt class="py-name">r</tt><tt class="py-op">)</tt> </tt>
<a name="L33"></a><tt class="py-lineno"> 33</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">d</tt> </tt>
</div><a name="L34"></a><tt class="py-lineno"> 34</tt> <tt class="py-line"> </tt>
<a name="passthru"></a><div id="passthru-def"><a name="L35"></a><tt class="py-lineno"> 35</tt> <a class="py-toggle" href="#" id="passthru-toggle" onclick="return toggle('passthru');">-</a><tt class="py-line"><tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core-module.html#passthru">passthru</a><tt class="py-op">(</tt><tt class="py-param">r</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="passthru-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="passthru-expanded"><a name="L36"></a><tt class="py-lineno"> 36</tt> <tt class="py-line"> <tt class="py-docstring">"""A callback/errback that doesn't do anything"""</tt> </tt>
<a name="L37"></a><tt class="py-lineno"> 37</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">r</tt> </tt>
</div><a name="L38"></a><tt class="py-lineno"> 38</tt> <tt class="py-line"> </tt>
<a name="Worker"></a><div id="Worker-def"><a name="L39"></a><tt class="py-lineno"> 39</tt> <a class="py-toggle" href="#" id="Worker-toggle" onclick="return toggle('Worker');">-</a><tt class="py-line"><tt class="py-keyword">class</tt> <a class="py-def-name" href="tangled.core.Worker-class.html">Worker</a><tt class="py-op">(</tt><tt class="py-base-class">threading</tt><tt class="py-op">.</tt><tt class="py-base-class">Thread</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Worker-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="Worker-expanded"><a name="L40"></a><tt class="py-lineno"> 40</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L41"></a><tt class="py-lineno"> 41</tt> <tt class="py-line"><tt class="py-docstring"> This is a worker thread which executes a function and calls a callback on completion</tt> </tt>
<a name="L42"></a><tt class="py-lineno"> 42</tt> <tt class="py-line"><tt class="py-docstring"></tt> </tt>
<a name="L43"></a><tt class="py-lineno"> 43</tt> <tt class="py-line"><tt class="py-docstring"> @param reactor: The reactor this is a worker for.</tt> </tt>
<a name="L44"></a><tt class="py-lineno"> 44</tt> <tt class="py-line"><tt class="py-docstring"> @type reactor: L{Reactor}</tt> </tt>
<a name="L45"></a><tt class="py-lineno"> 45</tt> <tt class="py-line"><tt class="py-docstring"> @param autostart: If true, the worker thread starts immediately. Otherwise start() has to be called.</tt> </tt>
<a name="L46"></a><tt class="py-lineno"> 46</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="Worker.__init__"></a><div id="Worker.__init__-def"><a name="L47"></a><tt class="py-lineno"> 47</tt> <a class="py-toggle" href="#" id="Worker.__init__-toggle" onclick="return toggle('Worker.__init__');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Worker-class.html#__init__">__init__</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">reactor</tt><tt class="py-op">,</tt> <tt class="py-param">autostart</tt><tt class="py-op">=</tt><tt class="py-name">False</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Worker.__init__-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Worker.__init__-expanded"><a name="L48"></a><tt class="py-lineno"> 48</tt> <tt class="py-line"> <tt class="py-name">threading</tt><tt class="py-op">.</tt><tt class="py-name">Thread</tt><tt class="py-op">.</tt><tt id="link-5" class="py-name" targets="Method tangled.client.AsyncHTTPClient.__init__()=tangled.client.AsyncHTTPClient-class.html#__init__,Method tangled.client.Response.__init__()=tangled.client.Response-class.html#__init__,Method tangled.core.Deferred.__init__()=tangled.core.Deferred-class.html#__init__,Method tangled.core.Failure.__init__()=tangled.core.Failure-class.html#__init__,Method tangled.core.Reactor.__init__()=tangled.core.Reactor-class.html#__init__,Method tangled.core.Trigger.__init__()=tangled.core.Trigger-class.html#__init__,Method tangled.core.Worker.__init__()=tangled.core.Worker-class.html#__init__,Method tangled.server.AsyncHTTPRequestHandler.Pusher.__init__()=tangled.server.AsyncHTTPRequestHandler.Pusher-class.html#__init__,Method tangled.server.AsyncHTTPRequestHandler.__init__()=tangled.server.AsyncHTTPRequestHandler-class.html#__init__,Method tangled.server.AsyncHTTPServer.__init__()=tangled.server.AsyncHTTPServer-class.html#__init__,Method tangled.server.Request.__init__()=tangled.server.Request-class.html#__init__,Method tangled.server.Response.__init__()=tangled.server.Response-class.html#__init__,Method vinzclortho.consistenthashing.Node.__init__()=vinzclortho.consistenthashing.Node-class.html#__init__,Method vinzclortho.consistenthashing.Ring.__init__()=vinzclortho.consistenthashing.Ring-class.html#__init__,Method vinzclortho.core.AdminHandler.__init__()=vinzclortho.core.AdminHandler-class.html#__init__,Method vinzclortho.core.HandoffHandler.__init__()=vinzclortho.core.HandoffHandler-class.html#__init__,Method vinzclortho.core.LocalStorage.__init__()=vinzclortho.core.LocalStorage-class.html#__init__,Method vinzclortho.core.LocalStoreHandler.__init__()=vinzclortho.core.LocalStoreHandler-class.html#__init__,Method vinzclortho.core.MetaDataHandler.__init__()=vinzclortho.core.MetaDataHandler-class.html#__init__,Method vinzclortho.core.RemoteStorage.__init__()=vinzclortho.core.RemoteStorage-class.html#__init__,Method vinzclortho.core.StoreHandler.__init__()=vinzclortho.core.StoreHandler-class.html#__init__,Method vinzclortho.core.VinzClortho.__init__()=vinzclortho.core.VinzClortho-class.html#__init__,Method vinzclortho.store.BerkeleyDBStore.__init__()=vinzclortho.store.BerkeleyDBStore-class.html#__init__,Method vinzclortho.store.DictStore.__init__()=vinzclortho.store.DictStore-class.html#__init__,Method vinzclortho.store.SQLiteStore.__init__()=vinzclortho.store.SQLiteStore-class.html#__init__,Method vinzclortho.vectorclock.VectorClock.__init__()=vinzclortho.vectorclock.VectorClock-class.html#__init__"><a title="tangled.client.AsyncHTTPClient.__init__
tangled.client.Response.__init__
tangled.core.Deferred.__init__
tangled.core.Failure.__init__
tangled.core.Reactor.__init__
tangled.core.Trigger.__init__
tangled.core.Worker.__init__
tangled.server.AsyncHTTPRequestHandler.Pusher.__init__
tangled.server.AsyncHTTPRequestHandler.__init__
tangled.server.AsyncHTTPServer.__init__
tangled.server.Request.__init__
tangled.server.Response.__init__
vinzclortho.consistenthashing.Node.__init__
vinzclortho.consistenthashing.Ring.__init__
vinzclortho.core.AdminHandler.__init__
vinzclortho.core.HandoffHandler.__init__
vinzclortho.core.LocalStorage.__init__
vinzclortho.core.LocalStoreHandler.__init__
vinzclortho.core.MetaDataHandler.__init__
vinzclortho.core.RemoteStorage.__init__
vinzclortho.core.StoreHandler.__init__
vinzclortho.core.VinzClortho.__init__
vinzclortho.store.BerkeleyDBStore.__init__
vinzclortho.store.DictStore.__init__
vinzclortho.store.SQLiteStore.__init__
vinzclortho.vectorclock.VectorClock.__init__" class="py-name" href="#" onclick="return doclink('link-5', '__init__', 'link-5');">__init__</a></tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">,</tt> <tt class="py-name">target</tt><tt class="py-op">=</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-6" class="py-name" targets="Method tangled.core.Worker._runner()=tangled.core.Worker-class.html#_runner"><a title="tangled.core.Worker._runner" class="py-name" href="#" onclick="return doclink('link-6', '_runner', 'link-6');">_runner</a></tt><tt class="py-op">)</tt> </tt>
<a name="L49"></a><tt class="py-lineno"> 49</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_queue</tt> <tt class="py-op">=</tt> <tt class="py-name">Queue</tt><tt class="py-op">.</tt><tt class="py-name">Queue</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L50"></a><tt class="py-lineno"> 50</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">reactor</tt> <tt class="py-op">=</tt> <tt class="py-name">reactor</tt> </tt>
<a name="L51"></a><tt class="py-lineno"> 51</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_running</tt> <tt class="py-op">=</tt> <tt class="py-name">True</tt> </tt>
<a name="L52"></a><tt class="py-lineno"> 52</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">daemon</tt> <tt class="py-op">=</tt> <tt class="py-name">True</tt> </tt>
<a name="L53"></a><tt class="py-lineno"> 53</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">autostart</tt><tt class="py-op">:</tt> </tt>
<a name="L54"></a><tt class="py-lineno"> 54</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">start</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
</div><a name="L55"></a><tt class="py-lineno"> 55</tt> <tt class="py-line"> </tt>
<a name="Worker.stop"></a><div id="Worker.stop-def"><a name="L56"></a><tt class="py-lineno"> 56</tt> <a class="py-toggle" href="#" id="Worker.stop-toggle" onclick="return toggle('Worker.stop');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Worker-class.html#stop">stop</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Worker.stop-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Worker.stop-expanded"><a name="L57"></a><tt class="py-lineno"> 57</tt> <tt class="py-line"> <tt class="py-docstring">"""Stops the worker"""</tt> </tt>
<a name="L58"></a><tt class="py-lineno"> 58</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_running</tt> <tt class="py-op">=</tt> <tt class="py-name">False</tt> </tt>
</div><a name="L59"></a><tt class="py-lineno"> 59</tt> <tt class="py-line"> </tt>
<a name="Worker._runner"></a><div id="Worker._runner-def"><a name="L60"></a><tt class="py-lineno"> 60</tt> <a class="py-toggle" href="#" id="Worker._runner-toggle" onclick="return toggle('Worker._runner');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Worker-class.html#_runner">_runner</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Worker._runner-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Worker._runner-expanded"><a name="L61"></a><tt class="py-lineno"> 61</tt> <tt class="py-line"> <tt class="py-docstring">"""The message pump of the worker"""</tt> </tt>
<a name="L62"></a><tt class="py-lineno"> 62</tt> <tt class="py-line"> <tt class="py-keyword">while</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_running</tt><tt class="py-op">:</tt> </tt>
<a name="L63"></a><tt class="py-lineno"> 63</tt> <tt class="py-line"> <tt class="py-keyword">try</tt><tt class="py-op">:</tt> </tt>
<a name="L64"></a><tt class="py-lineno"> 64</tt> <tt class="py-line"> <tt class="py-name">func</tt><tt class="py-op">,</tt> <tt class="py-name">oncomplete</tt> <tt class="py-op">=</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_queue</tt><tt class="py-op">.</tt><tt id="link-7" class="py-name" targets="Method vinzclortho.core.LocalStorage.get()=vinzclortho.core.LocalStorage-class.html#get,Method vinzclortho.core.RemoteStorage.get()=vinzclortho.core.RemoteStorage-class.html#get,Method vinzclortho.store.BerkeleyDBStore.get()=vinzclortho.store.BerkeleyDBStore-class.html#get,Method vinzclortho.store.DictStore.get()=vinzclortho.store.DictStore-class.html#get,Method vinzclortho.store.SQLiteStore.get()=vinzclortho.store.SQLiteStore-class.html#get,Method vinzclortho.store.Store.get()=vinzclortho.store.Store-class.html#get"><a title="vinzclortho.core.LocalStorage.get
vinzclortho.core.RemoteStorage.get
vinzclortho.store.BerkeleyDBStore.get
vinzclortho.store.DictStore.get
vinzclortho.store.SQLiteStore.get
vinzclortho.store.Store.get" class="py-name" href="#" onclick="return doclink('link-7', 'get', 'link-7');">get</a></tt><tt class="py-op">(</tt><tt class="py-name">block</tt><tt class="py-op">=</tt><tt class="py-name">True</tt><tt class="py-op">,</tt> <tt class="py-name">timeout</tt><tt class="py-op">=</tt><tt class="py-number">1</tt><tt class="py-op">)</tt> </tt>
<a name="L65"></a><tt class="py-lineno"> 65</tt> <tt class="py-line"> <tt class="py-keyword">except</tt> <tt class="py-name">Queue</tt><tt class="py-op">.</tt><tt class="py-name">Empty</tt><tt class="py-op">:</tt> </tt>
<a name="L66"></a><tt class="py-lineno"> 66</tt> <tt class="py-line"> <tt class="py-keyword">pass</tt> </tt>
<a name="L67"></a><tt class="py-lineno"> 67</tt> <tt class="py-line"> <tt class="py-keyword">else</tt><tt class="py-op">:</tt> </tt>
<a name="L68"></a><tt class="py-lineno"> 68</tt> <tt class="py-line"> <tt class="py-name">res</tt> <tt class="py-op">=</tt> <tt class="py-name">None</tt> </tt>
<a name="L69"></a><tt class="py-lineno"> 69</tt> <tt class="py-line"> <tt class="py-keyword">try</tt><tt class="py-op">:</tt> </tt>
<a name="L70"></a><tt class="py-lineno"> 70</tt> <tt class="py-line"> <tt class="py-name">res</tt> <tt class="py-op">=</tt> <tt class="py-name">func</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L71"></a><tt class="py-lineno"> 71</tt> <tt class="py-line"> <tt class="py-keyword">except</tt><tt class="py-op">:</tt> </tt>
<a name="L72"></a><tt class="py-lineno"> 72</tt> <tt class="py-line"> <tt class="py-name">res</tt> <tt class="py-op">=</tt> <tt id="link-8" class="py-name" targets="Class tangled.core.Failure=tangled.core.Failure-class.html"><a title="tangled.core.Failure" class="py-name" href="#" onclick="return doclink('link-8', 'Failure', 'link-8');">Failure</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L73"></a><tt class="py-lineno"> 73</tt> <tt class="py-line"> <tt class="py-name">oncomplete</tt><tt class="py-op">(</tt><tt class="py-name">res</tt><tt class="py-op">)</tt> </tt>
</div><a name="L74"></a><tt class="py-lineno"> 74</tt> <tt class="py-line"> </tt>
<a name="Worker.execute"></a><div id="Worker.execute-def"><a name="L75"></a><tt class="py-lineno"> 75</tt> <a class="py-toggle" href="#" id="Worker.execute-toggle" onclick="return toggle('Worker.execute');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Worker-class.html#execute">execute</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">func</tt><tt class="py-op">,</tt> <tt class="py-param">oncomplete</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Worker.execute-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Worker.execute-expanded"><a name="L76"></a><tt class="py-lineno"> 76</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L77"></a><tt class="py-lineno"> 77</tt> <tt class="py-line"><tt class="py-docstring"> Executes func in the worker thread, which then calls oncomplete</tt> </tt>
<a name="L78"></a><tt class="py-lineno"> 78</tt> <tt class="py-line"><tt class="py-docstring"></tt> </tt>
<a name="L79"></a><tt class="py-lineno"> 79</tt> <tt class="py-line"><tt class="py-docstring"> @type func: callable</tt> </tt>
<a name="L80"></a><tt class="py-lineno"> 80</tt> <tt class="py-line"><tt class="py-docstring"> @type oncomplete: callable</tt> </tt>
<a name="L81"></a><tt class="py-lineno"> 81</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L82"></a><tt class="py-lineno"> 82</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_queue</tt><tt class="py-op">.</tt><tt id="link-9" class="py-name" targets="Method vinzclortho.core.LocalStorage.put()=vinzclortho.core.LocalStorage-class.html#put,Method vinzclortho.core.RemoteStorage.put()=vinzclortho.core.RemoteStorage-class.html#put,Method vinzclortho.store.BerkeleyDBStore.put()=vinzclortho.store.BerkeleyDBStore-class.html#put,Method vinzclortho.store.DictStore.put()=vinzclortho.store.DictStore-class.html#put,Method vinzclortho.store.SQLiteStore.put()=vinzclortho.store.SQLiteStore-class.html#put,Method vinzclortho.store.Store.put()=vinzclortho.store.Store-class.html#put"><a title="vinzclortho.core.LocalStorage.put
vinzclortho.core.RemoteStorage.put
vinzclortho.store.BerkeleyDBStore.put
vinzclortho.store.DictStore.put
vinzclortho.store.SQLiteStore.put
vinzclortho.store.Store.put" class="py-name" href="#" onclick="return doclink('link-9', 'put', 'link-9');">put</a></tt><tt class="py-op">(</tt><tt class="py-op">(</tt><tt class="py-name">func</tt><tt class="py-op">,</tt> <tt class="py-name">oncomplete</tt><tt class="py-op">)</tt><tt class="py-op">)</tt> </tt>
</div><a name="L83"></a><tt class="py-lineno"> 83</tt> <tt class="py-line"> </tt>
<a name="Worker.defer"></a><div id="Worker.defer-def"><a name="L84"></a><tt class="py-lineno"> 84</tt> <a class="py-toggle" href="#" id="Worker.defer-toggle" onclick="return toggle('Worker.defer');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Worker-class.html#defer">defer</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">func</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Worker.defer-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Worker.defer-expanded"><a name="L85"></a><tt class="py-lineno"> 85</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L86"></a><tt class="py-lineno"> 86</tt> <tt class="py-line"><tt class="py-docstring"> Defers the call to func to this worker</tt> </tt>
<a name="L87"></a><tt class="py-lineno"> 87</tt> <tt class="py-line"><tt class="py-docstring"></tt> </tt>
<a name="L88"></a><tt class="py-lineno"> 88</tt> <tt class="py-line"><tt class="py-docstring"> @param func: The function you want the worker to call</tt> </tt>
<a name="L89"></a><tt class="py-lineno"> 89</tt> <tt class="py-line"><tt class="py-docstring"> @type func: callable</tt> </tt>
<a name="L90"></a><tt class="py-lineno"> 90</tt> <tt class="py-line"><tt class="py-docstring"> @return: A L{Deferred} object that will eventually get the result of func</tt> </tt>
<a name="L91"></a><tt class="py-lineno"> 91</tt> <tt class="py-line"><tt class="py-docstring"> @rtype: L{Deferred}</tt> </tt>
<a name="L92"></a><tt class="py-lineno"> 92</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L93"></a><tt class="py-lineno"> 93</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">reactor</tt><tt class="py-op">.</tt><tt id="link-10" class="py-name" targets="Method tangled.core.Reactor.defer_to_worker()=tangled.core.Reactor-class.html#defer_to_worker"><a title="tangled.core.Reactor.defer_to_worker" class="py-name" href="#" onclick="return doclink('link-10', 'defer_to_worker', 'link-10');">defer_to_worker</a></tt><tt class="py-op">(</tt><tt class="py-name">func</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">)</tt> </tt>
</div></div><a name="L94"></a><tt class="py-lineno"> 94</tt> <tt class="py-line"> </tt>
<a name="Failure"></a><div id="Failure-def"><a name="L95"></a><tt class="py-lineno"> 95</tt> <a class="py-toggle" href="#" id="Failure-toggle" onclick="return toggle('Failure');">-</a><tt class="py-line"><tt class="py-keyword">class</tt> <a class="py-def-name" href="tangled.core.Failure-class.html">Failure</a><tt class="py-op">(</tt><tt class="py-base-class">object</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Failure-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="Failure-expanded"><a name="L96"></a><tt class="py-lineno"> 96</tt> <tt class="py-line"> <tt class="py-docstring">"""Like Twisted's Failure object, but with no features"""</tt> </tt>
<a name="Failure.__init__"></a><div id="Failure.__init__-def"><a name="L97"></a><tt class="py-lineno"> 97</tt> <a class="py-toggle" href="#" id="Failure.__init__-toggle" onclick="return toggle('Failure.__init__');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Failure-class.html#__init__">__init__</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">type_</tt><tt class="py-op">=</tt><tt class="py-name">None</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Failure.__init__-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Failure.__init__-expanded"><a name="L98"></a><tt class="py-lineno"> 98</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">type_</tt> <tt class="py-keyword">is</tt> <tt class="py-name">None</tt><tt class="py-op">:</tt> </tt>
<a name="L99"></a><tt class="py-lineno"> 99</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">type</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">value</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">tb</tt> <tt class="py-op">=</tt> <tt class="py-name">sys</tt><tt class="py-op">.</tt><tt class="py-name">exc_info</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L100"></a><tt class="py-lineno">100</tt> <tt class="py-line"> <tt class="py-keyword">else</tt><tt class="py-op">:</tt> </tt>
<a name="L101"></a><tt class="py-lineno">101</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">type</tt> <tt class="py-op">=</tt> <tt class="py-name">type_</tt> </tt>
<a name="L102"></a><tt class="py-lineno">102</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">value</tt> <tt class="py-op">=</tt> <tt class="py-name">None</tt> </tt>
<a name="L103"></a><tt class="py-lineno">103</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">tb</tt> <tt class="py-op">=</tt> <tt class="py-name">None</tt> </tt>
</div><a name="L104"></a><tt class="py-lineno">104</tt> <tt class="py-line"> </tt>
<a name="Failure.__str__"></a><div id="Failure.__str__-def"><a name="L105"></a><tt class="py-lineno">105</tt> <a class="py-toggle" href="#" id="Failure.__str__-toggle" onclick="return toggle('Failure.__str__');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Failure-class.html#__str__">__str__</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Failure.__str__-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Failure.__str__-expanded"><a name="L106"></a><tt class="py-lineno">106</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">repr</tt><tt class="py-op">(</tt><tt class="py-name">traceback</tt><tt class="py-op">.</tt><tt class="py-name">format_exception</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">type</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">value</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">tb</tt><tt class="py-op">)</tt><tt class="py-op">)</tt> </tt>
</div><a name="L107"></a><tt class="py-lineno">107</tt> <tt class="py-line"> </tt>
<a name="Failure.raise_exception"></a><div id="Failure.raise_exception-def"><a name="L108"></a><tt class="py-lineno">108</tt> <a class="py-toggle" href="#" id="Failure.raise_exception-toggle" onclick="return toggle('Failure.raise_exception');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Failure-class.html#raise_exception">raise_exception</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Failure.raise_exception-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Failure.raise_exception-expanded"><a name="L109"></a><tt class="py-lineno">109</tt> <tt class="py-line"> <tt class="py-docstring">"""Re-raises the exception"""</tt> </tt>
<a name="L110"></a><tt class="py-lineno">110</tt> <tt class="py-line"> <tt class="py-keyword">raise</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">type</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">value</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">tb</tt> </tt>
</div><a name="L111"></a><tt class="py-lineno">111</tt> <tt class="py-line"> </tt>
<a name="Failure.check"></a><div id="Failure.check-def"><a name="L112"></a><tt class="py-lineno">112</tt> <a class="py-toggle" href="#" id="Failure.check-toggle" onclick="return toggle('Failure.check');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Failure-class.html#check">check</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-op">*</tt><tt class="py-param">exceptions</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Failure.check-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Failure.check-expanded"><a name="L113"></a><tt class="py-lineno">113</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L114"></a><tt class="py-lineno">114</tt> <tt class="py-line"><tt class="py-docstring"> This can be used to have try/except like blocks in your errback</tt> </tt>
<a name="L115"></a><tt class="py-lineno">115</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L116"></a><tt class="py-lineno">116</tt> <tt class="py-line"> <tt class="py-keyword">for</tt> <tt class="py-name">e</tt> <tt class="py-keyword">in</tt> <tt class="py-name">exceptions</tt><tt class="py-op">:</tt> </tt>
<a name="L117"></a><tt class="py-lineno">117</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">isinstance</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">type</tt><tt class="py-op">,</tt> <tt class="py-name">e</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
<a name="L118"></a><tt class="py-lineno">118</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">True</tt> </tt>
<a name="L119"></a><tt class="py-lineno">119</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">False</tt> </tt>
</div></div><a name="L120"></a><tt class="py-lineno">120</tt> <tt class="py-line"> </tt>
<a name="L121"></a><tt class="py-lineno">121</tt> <tt class="py-line"> </tt>
<a name="Deferred"></a><div id="Deferred-def"><a name="L122"></a><tt class="py-lineno">122</tt> <a class="py-toggle" href="#" id="Deferred-toggle" onclick="return toggle('Deferred');">-</a><tt class="py-line"><tt class="py-keyword">class</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html">Deferred</a><tt class="py-op">(</tt><tt class="py-base-class">object</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="Deferred-expanded"><a name="L123"></a><tt class="py-lineno">123</tt> <tt class="py-line"> <tt class="py-docstring">"""Very similar to Twisted's Deferred object, but with less features"""</tt> </tt>
<a name="Deferred.__init__"></a><div id="Deferred.__init__-def"><a name="L124"></a><tt class="py-lineno">124</tt> <a class="py-toggle" href="#" id="Deferred.__init__-toggle" onclick="return toggle('Deferred.__init__');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#__init__">__init__</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.__init__-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.__init__-expanded"><a name="L125"></a><tt class="py-lineno">125</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">callbacks</tt> <tt class="py-op">=</tt> <tt class="py-op">[</tt><tt class="py-op">]</tt> </tt>
<a name="L126"></a><tt class="py-lineno">126</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">called</tt> <tt class="py-op">=</tt> <tt class="py-name">False</tt> </tt>
<a name="L127"></a><tt class="py-lineno">127</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">paused</tt> <tt class="py-op">=</tt> <tt class="py-number">0</tt> </tt>
</div><a name="L128"></a><tt class="py-lineno">128</tt> <tt class="py-line"> </tt>
<a name="Deferred._start_callbacks"></a><div id="Deferred._start_callbacks-def"><a name="L129"></a><tt class="py-lineno">129</tt> <a class="py-toggle" href="#" id="Deferred._start_callbacks-toggle" onclick="return toggle('Deferred._start_callbacks');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#_start_callbacks">_start_callbacks</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">result</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred._start_callbacks-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred._start_callbacks-expanded"><a name="L130"></a><tt class="py-lineno">130</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-keyword">not</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">called</tt><tt class="py-op">:</tt> </tt>
<a name="L131"></a><tt class="py-lineno">131</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">called</tt> <tt class="py-op">=</tt> <tt class="py-name">True</tt> </tt>
<a name="L132"></a><tt class="py-lineno">132</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt> <tt class="py-op">=</tt> <tt class="py-name">result</tt> </tt>
<a name="L133"></a><tt class="py-lineno">133</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-11" class="py-name" targets="Method tangled.core.Deferred._run_callbacks()=tangled.core.Deferred-class.html#_run_callbacks"><a title="tangled.core.Deferred._run_callbacks" class="py-name" href="#" onclick="return doclink('link-11', '_run_callbacks', 'link-11');">_run_callbacks</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
</div><a name="L134"></a><tt class="py-lineno">134</tt> <tt class="py-line"> </tt>
<a name="Deferred._run_callbacks"></a><div id="Deferred._run_callbacks-def"><a name="L135"></a><tt class="py-lineno">135</tt> <a class="py-toggle" href="#" id="Deferred._run_callbacks-toggle" onclick="return toggle('Deferred._run_callbacks');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#_run_callbacks">_run_callbacks</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred._run_callbacks-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred._run_callbacks-expanded"><a name="L136"></a><tt class="py-lineno">136</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-keyword">not</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">paused</tt><tt class="py-op">:</tt> </tt>
<a name="L137"></a><tt class="py-lineno">137</tt> <tt class="py-line"> <tt class="py-keyword">while</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">callbacks</tt><tt class="py-op">:</tt> </tt>
<a name="L138"></a><tt class="py-lineno">138</tt> <tt class="py-line"> <tt class="py-keyword">try</tt><tt class="py-op">:</tt> </tt>
<a name="L139"></a><tt class="py-lineno">139</tt> <tt class="py-line"> <tt class="py-name">cb</tt><tt class="py-op">,</tt> <tt class="py-name">eb</tt> <tt class="py-op">=</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">callbacks</tt><tt class="py-op">.</tt><tt class="py-name">pop</tt><tt class="py-op">(</tt><tt class="py-number">0</tt><tt class="py-op">)</tt> </tt>
<a name="L140"></a><tt class="py-lineno">140</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">isinstance</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt><tt class="py-op">,</tt> <tt id="link-12" class="py-name"><a title="tangled.core.Failure" class="py-name" href="#" onclick="return doclink('link-12', 'Failure', 'link-8');">Failure</a></tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
<a name="L141"></a><tt class="py-lineno">141</tt> <tt class="py-line"> <tt class="py-name">cb</tt> <tt class="py-op">=</tt> <tt class="py-name">eb</tt> </tt>
<a name="L142"></a><tt class="py-lineno">142</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt> <tt class="py-op">=</tt> <tt class="py-name">cb</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt><tt class="py-op">)</tt> </tt>
<a name="L143"></a><tt class="py-lineno">143</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">isinstance</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt><tt class="py-op">,</tt> <tt id="link-13" class="py-name"><a title="tangled.core.Deferred" class="py-name" href="#" onclick="return doclink('link-13', 'Deferred', 'link-1');">Deferred</a></tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
<a name="L144"></a><tt class="py-lineno">144</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-14" class="py-name" targets="Method tangled.core.Deferred.pause()=tangled.core.Deferred-class.html#pause"><a title="tangled.core.Deferred.pause" class="py-name" href="#" onclick="return doclink('link-14', 'pause', 'link-14');">pause</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L145"></a><tt class="py-lineno">145</tt> <tt class="py-line"> <tt class="py-comment"># This will cause the callback chain to resume later,</tt> </tt>
<a name="L146"></a><tt class="py-lineno">146</tt> <tt class="py-line"> <tt class="py-comment"># or immediately (recursively) if result is already</tt> </tt>
<a name="L147"></a><tt class="py-lineno">147</tt> <tt class="py-line"> <tt class="py-comment"># available</tt> </tt>
<a name="L148"></a><tt class="py-lineno">148</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-15" class="py-name" targets="Method tangled.core.Deferred.add_both()=tangled.core.Deferred-class.html#add_both"><a title="tangled.core.Deferred.add_both" class="py-name" href="#" onclick="return doclink('link-15', 'add_both', 'link-15');">add_both</a></tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-16" class="py-name" targets="Method tangled.core.Deferred._continue()=tangled.core.Deferred-class.html#_continue"><a title="tangled.core.Deferred._continue" class="py-name" href="#" onclick="return doclink('link-16', '_continue', 'link-16');">_continue</a></tt><tt class="py-op">)</tt> </tt>
<a name="L149"></a><tt class="py-lineno">149</tt> <tt class="py-line"> <tt class="py-keyword">except</tt><tt class="py-op">:</tt> </tt>
<a name="L150"></a><tt class="py-lineno">150</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt> <tt class="py-op">=</tt> <tt id="link-17" class="py-name"><a title="tangled.core.Failure" class="py-name" href="#" onclick="return doclink('link-17', 'Failure', 'link-8');">Failure</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L151"></a><tt class="py-lineno">151</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">isinstance</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt><tt class="py-op">,</tt> <tt id="link-18" class="py-name"><a title="tangled.core.Failure" class="py-name" href="#" onclick="return doclink('link-18', 'Failure', 'link-8');">Failure</a></tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
<a name="L152"></a><tt class="py-lineno">152</tt> <tt class="py-line"> <tt id="link-19" class="py-name"><a title="tangled.client.log
tangled.core.log
tangled.server.log
vinzclortho.consistenthashing.log
vinzclortho.core.log" class="py-name" href="#" onclick="return doclink('link-19', 'log', 'link-0');">log</a></tt><tt class="py-op">.</tt><tt class="py-name">error</tt><tt class="py-op">(</tt><tt class="py-string">"Unhandled Failure: %s"</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt><tt class="py-op">)</tt> </tt>
</div><a name="L153"></a><tt class="py-lineno">153</tt> <tt class="py-line"> </tt>
<a name="Deferred.add_callback"></a><div id="Deferred.add_callback-def"><a name="L154"></a><tt class="py-lineno">154</tt> <a class="py-toggle" href="#" id="Deferred.add_callback-toggle" onclick="return toggle('Deferred.add_callback');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#add_callback">add_callback</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">cb</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.add_callback-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.add_callback-expanded"><a name="L155"></a><tt class="py-lineno">155</tt> <tt class="py-line"> <tt class="py-docstring">"""See L{add_callbacks}"""</tt> </tt>
<a name="L156"></a><tt class="py-lineno">156</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-20" class="py-name" targets="Method tangled.core.Deferred.add_callbacks()=tangled.core.Deferred-class.html#add_callbacks"><a title="tangled.core.Deferred.add_callbacks" class="py-name" href="#" onclick="return doclink('link-20', 'add_callbacks', 'link-20');">add_callbacks</a></tt><tt class="py-op">(</tt><tt class="py-name">cb</tt><tt class="py-op">)</tt> </tt>
</div><a name="L157"></a><tt class="py-lineno">157</tt> <tt class="py-line"> </tt>
<a name="Deferred.add_errback"></a><div id="Deferred.add_errback-def"><a name="L158"></a><tt class="py-lineno">158</tt> <a class="py-toggle" href="#" id="Deferred.add_errback-toggle" onclick="return toggle('Deferred.add_errback');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#add_errback">add_errback</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">eb</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.add_errback-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.add_errback-expanded"><a name="L159"></a><tt class="py-lineno">159</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L160"></a><tt class="py-lineno">160</tt> <tt class="py-line"><tt class="py-docstring"> Adds errback only (a passthru will be used for the callback, so the result is not lost)</tt> </tt>
<a name="L161"></a><tt class="py-lineno">161</tt> <tt class="py-line"><tt class="py-docstring"></tt> </tt>
<a name="L162"></a><tt class="py-lineno">162</tt> <tt class="py-line"><tt class="py-docstring"> @param eb: errback</tt> </tt>
<a name="L163"></a><tt class="py-lineno">163</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L164"></a><tt class="py-lineno">164</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-21" class="py-name"><a title="tangled.core.Deferred.add_callbacks" class="py-name" href="#" onclick="return doclink('link-21', 'add_callbacks', 'link-20');">add_callbacks</a></tt><tt class="py-op">(</tt><tt id="link-22" class="py-name" targets="Function tangled.core.passthru()=tangled.core-module.html#passthru"><a title="tangled.core.passthru" class="py-name" href="#" onclick="return doclink('link-22', 'passthru', 'link-22');">passthru</a></tt><tt class="py-op">,</tt> <tt class="py-name">eb</tt><tt class="py-op">)</tt> </tt>
</div><a name="L165"></a><tt class="py-lineno">165</tt> <tt class="py-line"> </tt>
<a name="Deferred.add_both"></a><div id="Deferred.add_both-def"><a name="L166"></a><tt class="py-lineno">166</tt> <a class="py-toggle" href="#" id="Deferred.add_both-toggle" onclick="return toggle('Deferred.add_both');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#add_both">add_both</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">cb</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.add_both-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.add_both-expanded"><a name="L167"></a><tt class="py-lineno">167</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L168"></a><tt class="py-lineno">168</tt> <tt class="py-line"><tt class="py-docstring"> Adds one function as both callback and errback</tt> </tt>
<a name="L169"></a><tt class="py-lineno">169</tt> <tt class="py-line"><tt class="py-docstring"></tt> </tt>
<a name="L170"></a><tt class="py-lineno">170</tt> <tt class="py-line"><tt class="py-docstring"> @param cb: callback and errback</tt> </tt>
<a name="L171"></a><tt class="py-lineno">171</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L172"></a><tt class="py-lineno">172</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-23" class="py-name"><a title="tangled.core.Deferred.add_callbacks" class="py-name" href="#" onclick="return doclink('link-23', 'add_callbacks', 'link-20');">add_callbacks</a></tt><tt class="py-op">(</tt><tt class="py-name">cb</tt><tt class="py-op">,</tt> <tt class="py-name">cb</tt><tt class="py-op">)</tt> </tt>
</div><a name="L173"></a><tt class="py-lineno">173</tt> <tt class="py-line"> </tt>
<a name="Deferred.add_callbacks"></a><div id="Deferred.add_callbacks-def"><a name="L174"></a><tt class="py-lineno">174</tt> <a class="py-toggle" href="#" id="Deferred.add_callbacks-toggle" onclick="return toggle('Deferred.add_callbacks');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#add_callbacks">add_callbacks</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">cb</tt><tt class="py-op">,</tt> <tt class="py-param">eb</tt><tt class="py-op">=</tt><tt class="py-name">None</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.add_callbacks-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.add_callbacks-expanded"><a name="L175"></a><tt class="py-lineno">175</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L176"></a><tt class="py-lineno">176</tt> <tt class="py-line"><tt class="py-docstring"> Adds callback and errback</tt> </tt>
<a name="L177"></a><tt class="py-lineno">177</tt> <tt class="py-line"><tt class="py-docstring"></tt> </tt>
<a name="L178"></a><tt class="py-lineno">178</tt> <tt class="py-line"><tt class="py-docstring"> @param cb: callback</tt> </tt>
<a name="L179"></a><tt class="py-lineno">179</tt> <tt class="py-line"><tt class="py-docstring"> @param eb: errback</tt> </tt>
<a name="L180"></a><tt class="py-lineno">180</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L181"></a><tt class="py-lineno">181</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">callbacks</tt><tt class="py-op">.</tt><tt class="py-name">append</tt><tt class="py-op">(</tt><tt class="py-op">(</tt><tt class="py-name">cb</tt><tt class="py-op">,</tt> <tt class="py-name">eb</tt> <tt class="py-keyword">or</tt> <tt id="link-24" class="py-name"><a title="tangled.core.passthru" class="py-name" href="#" onclick="return doclink('link-24', 'passthru', 'link-22');">passthru</a></tt><tt class="py-op">)</tt><tt class="py-op">)</tt> </tt>
<a name="L182"></a><tt class="py-lineno">182</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">called</tt><tt class="py-op">:</tt> </tt>
<a name="L183"></a><tt class="py-lineno">183</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-25" class="py-name"><a title="tangled.core.Deferred._run_callbacks" class="py-name" href="#" onclick="return doclink('link-25', '_run_callbacks', 'link-11');">_run_callbacks</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
</div><a name="L184"></a><tt class="py-lineno">184</tt> <tt class="py-line"> </tt>
<a name="Deferred.pause"></a><div id="Deferred.pause-def"><a name="L185"></a><tt class="py-lineno">185</tt> <a class="py-toggle" href="#" id="Deferred.pause-toggle" onclick="return toggle('Deferred.pause');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#pause">pause</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.pause-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.pause-expanded"><a name="L186"></a><tt class="py-lineno">186</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">paused</tt> <tt class="py-op">=</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">paused</tt> <tt class="py-op">+</tt> <tt class="py-number">1</tt> </tt>
</div><a name="L187"></a><tt class="py-lineno">187</tt> <tt class="py-line"> </tt>
<a name="Deferred.unpause"></a><div id="Deferred.unpause-def"><a name="L188"></a><tt class="py-lineno">188</tt> <a class="py-toggle" href="#" id="Deferred.unpause-toggle" onclick="return toggle('Deferred.unpause');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#unpause">unpause</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.unpause-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.unpause-expanded"><a name="L189"></a><tt class="py-lineno">189</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">paused</tt> <tt class="py-op">=</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">paused</tt> <tt class="py-op">-</tt> <tt class="py-number">1</tt> </tt>
<a name="L190"></a><tt class="py-lineno">190</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">paused</tt> <tt class="py-op">></tt> <tt class="py-number">0</tt><tt class="py-op">:</tt> </tt>
<a name="L191"></a><tt class="py-lineno">191</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> </tt>
<a name="L192"></a><tt class="py-lineno">192</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">called</tt><tt class="py-op">:</tt> </tt>
<a name="L193"></a><tt class="py-lineno">193</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-26" class="py-name"><a title="tangled.core.Deferred._run_callbacks" class="py-name" href="#" onclick="return doclink('link-26', '_run_callbacks', 'link-11');">_run_callbacks</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
</div><a name="L194"></a><tt class="py-lineno">194</tt> <tt class="py-line"> </tt>
<a name="Deferred._continue"></a><div id="Deferred._continue-def"><a name="L195"></a><tt class="py-lineno">195</tt> <a class="py-toggle" href="#" id="Deferred._continue-toggle" onclick="return toggle('Deferred._continue');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#_continue">_continue</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">result</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred._continue-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred._continue-expanded"><a name="L196"></a><tt class="py-lineno">196</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">result</tt> <tt class="py-op">=</tt> <tt class="py-name">result</tt> </tt>
<a name="L197"></a><tt class="py-lineno">197</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-27" class="py-name" targets="Method tangled.core.Deferred.unpause()=tangled.core.Deferred-class.html#unpause"><a title="tangled.core.Deferred.unpause" class="py-name" href="#" onclick="return doclink('link-27', 'unpause', 'link-27');">unpause</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
</div><a name="L198"></a><tt class="py-lineno">198</tt> <tt class="py-line"> </tt>
<a name="Deferred.callback"></a><div id="Deferred.callback-def"><a name="L199"></a><tt class="py-lineno">199</tt> <a class="py-toggle" href="#" id="Deferred.callback-toggle" onclick="return toggle('Deferred.callback');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#callback">callback</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">result</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.callback-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.callback-expanded"><a name="L200"></a><tt class="py-lineno">200</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-28" class="py-name" targets="Method tangled.core.Deferred._start_callbacks()=tangled.core.Deferred-class.html#_start_callbacks"><a title="tangled.core.Deferred._start_callbacks" class="py-name" href="#" onclick="return doclink('link-28', '_start_callbacks', 'link-28');">_start_callbacks</a></tt><tt class="py-op">(</tt><tt class="py-name">result</tt><tt class="py-op">)</tt> </tt>
</div><a name="L201"></a><tt class="py-lineno">201</tt> <tt class="py-line"> </tt>
<a name="Deferred.errback"></a><div id="Deferred.errback-def"><a name="L202"></a><tt class="py-lineno">202</tt> <a class="py-toggle" href="#" id="Deferred.errback-toggle" onclick="return toggle('Deferred.errback');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Deferred-class.html#errback">errback</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">fail</tt><tt class="py-op">=</tt><tt class="py-name">None</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Deferred.errback-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Deferred.errback-expanded"><a name="L203"></a><tt class="py-lineno">203</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-keyword">not</tt> <tt class="py-name">isinstance</tt><tt class="py-op">(</tt><tt id="link-29" class="py-name" targets="Function tangled.core.fail()=tangled.core-module.html#fail"><a title="tangled.core.fail" class="py-name" href="#" onclick="return doclink('link-29', 'fail', 'link-29');">fail</a></tt><tt class="py-op">,</tt> <tt id="link-30" class="py-name"><a title="tangled.core.Failure" class="py-name" href="#" onclick="return doclink('link-30', 'Failure', 'link-8');">Failure</a></tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
<a name="L204"></a><tt class="py-lineno">204</tt> <tt class="py-line"> <tt id="link-31" class="py-name"><a title="tangled.core.fail" class="py-name" href="#" onclick="return doclink('link-31', 'fail', 'link-29');">fail</a></tt> <tt class="py-op">=</tt> <tt id="link-32" class="py-name"><a title="tangled.core.Failure" class="py-name" href="#" onclick="return doclink('link-32', 'Failure', 'link-8');">Failure</a></tt><tt class="py-op">(</tt><tt id="link-33" class="py-name"><a title="tangled.core.fail" class="py-name" href="#" onclick="return doclink('link-33', 'fail', 'link-29');">fail</a></tt><tt class="py-op">)</tt> </tt>
<a name="L205"></a><tt class="py-lineno">205</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-34" class="py-name"><a title="tangled.core.Deferred._start_callbacks" class="py-name" href="#" onclick="return doclink('link-34', '_start_callbacks', 'link-28');">_start_callbacks</a></tt><tt class="py-op">(</tt><tt id="link-35" class="py-name"><a title="tangled.core.fail" class="py-name" href="#" onclick="return doclink('link-35', 'fail', 'link-29');">fail</a></tt><tt class="py-op">)</tt> </tt>
</div></div><a name="L206"></a><tt class="py-lineno">206</tt> <tt class="py-line"> </tt>
<a name="L207"></a><tt class="py-lineno">207</tt> <tt class="py-line"> </tt>
<a name="set_reuse_addr"></a><div id="set_reuse_addr-def"><a name="L208"></a><tt class="py-lineno">208</tt> <a class="py-toggle" href="#" id="set_reuse_addr-toggle" onclick="return toggle('set_reuse_addr');">-</a><tt class="py-line"><tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core-module.html#set_reuse_addr">set_reuse_addr</a><tt class="py-op">(</tt><tt class="py-param">s</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="set_reuse_addr-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="set_reuse_addr-expanded"><a name="L209"></a><tt class="py-lineno">209</tt> <tt class="py-line"> <tt class="py-docstring">"""Try to re-use a server port if possible. Useful in development."""</tt> </tt>
<a name="L210"></a><tt class="py-lineno">210</tt> <tt class="py-line"> <tt class="py-keyword">try</tt><tt class="py-op">:</tt> </tt>
<a name="L211"></a><tt class="py-lineno">211</tt> <tt class="py-line"> <tt class="py-name">s</tt><tt class="py-op">.</tt><tt class="py-name">setsockopt</tt><tt class="py-op">(</tt> </tt>
<a name="L212"></a><tt class="py-lineno">212</tt> <tt class="py-line"> <tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">SOL_SOCKET</tt><tt class="py-op">,</tt> <tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">SO_REUSEADDR</tt><tt class="py-op">,</tt> </tt>
<a name="L213"></a><tt class="py-lineno">213</tt> <tt class="py-line"> <tt class="py-name">s</tt><tt class="py-op">.</tt><tt class="py-name">getsockopt</tt><tt class="py-op">(</tt><tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">SOL_SOCKET</tt><tt class="py-op">,</tt> </tt>
<a name="L214"></a><tt class="py-lineno">214</tt> <tt class="py-line"> <tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">SO_REUSEADDR</tt><tt class="py-op">)</tt> <tt class="py-op">|</tt> <tt class="py-number">1</tt> </tt>
<a name="L215"></a><tt class="py-lineno">215</tt> <tt class="py-line"> <tt class="py-op">)</tt> </tt>
<a name="L216"></a><tt class="py-lineno">216</tt> <tt class="py-line"> <tt class="py-keyword">except</tt> <tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">error</tt><tt class="py-op">:</tt> </tt>
<a name="L217"></a><tt class="py-lineno">217</tt> <tt class="py-line"> <tt class="py-keyword">pass</tt> </tt>
</div><a name="L218"></a><tt class="py-lineno">218</tt> <tt class="py-line"> </tt>
<a name="BindError"></a><div id="BindError-def"><a name="L219"></a><tt class="py-lineno">219</tt> <a class="py-toggle" href="#" id="BindError-toggle" onclick="return toggle('BindError');">-</a><tt class="py-line"><tt class="py-keyword">class</tt> <a class="py-def-name" href="tangled.core.BindError-class.html">BindError</a><tt class="py-op">(</tt><tt class="py-base-class">Exception</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="BindError-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="BindError-expanded"><a name="L220"></a><tt class="py-lineno">220</tt> <tt class="py-line"> <tt class="py-keyword">pass</tt> </tt>
</div><a name="L221"></a><tt class="py-lineno">221</tt> <tt class="py-line"> </tt>
<a name="Trigger"></a><div id="Trigger-def"><a name="L222"></a><tt class="py-lineno">222</tt> <a class="py-toggle" href="#" id="Trigger-toggle" onclick="return toggle('Trigger');">-</a><tt class="py-line"><tt class="py-keyword">class</tt> <a class="py-def-name" href="tangled.core.Trigger-class.html">Trigger</a><tt class="py-op">(</tt><tt class="py-base-class">asyncore</tt><tt class="py-op">.</tt><tt class="py-base-class">dispatcher</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Trigger-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="Trigger-expanded"><a name="L223"></a><tt class="py-lineno">223</tt> <tt class="py-line"> <tt class="py-docstring">"""Used to trigger the event loop with external stuff,</tt> </tt>
<a name="L224"></a><tt class="py-lineno">224</tt> <tt class="py-line"><tt class="py-docstring"> also from Medusa"""</tt> </tt>
<a name="L225"></a><tt class="py-lineno">225</tt> <tt class="py-line"> </tt>
<a name="Trigger.__init__"></a><div id="Trigger.__init__-def"><a name="L226"></a><tt class="py-lineno">226</tt> <a class="py-toggle" href="#" id="Trigger.__init__-toggle" onclick="return toggle('Trigger.__init__');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Trigger-class.html#__init__">__init__</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Trigger.__init__-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Trigger.__init__-expanded"><a name="L227"></a><tt class="py-lineno">227</tt> <tt class="py-line"> <tt class="py-name">a</tt> <tt class="py-op">=</tt> <tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">socket</tt><tt class="py-op">(</tt><tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">AF_INET</tt><tt class="py-op">,</tt> <tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">SOCK_STREAM</tt><tt class="py-op">)</tt> </tt>
<a name="L228"></a><tt class="py-lineno">228</tt> <tt class="py-line"> <tt class="py-name">w</tt> <tt class="py-op">=</tt> <tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">socket</tt><tt class="py-op">(</tt><tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">AF_INET</tt><tt class="py-op">,</tt> <tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">SOCK_STREAM</tt><tt class="py-op">)</tt> </tt>
<a name="L229"></a><tt class="py-lineno">229</tt> <tt class="py-line"> <tt id="link-36" class="py-name" targets="Function tangled.core.set_reuse_addr()=tangled.core-module.html#set_reuse_addr"><a title="tangled.core.set_reuse_addr" class="py-name" href="#" onclick="return doclink('link-36', 'set_reuse_addr', 'link-36');">set_reuse_addr</a></tt><tt class="py-op">(</tt><tt class="py-name">a</tt><tt class="py-op">)</tt> </tt>
<a name="L230"></a><tt class="py-lineno">230</tt> <tt class="py-line"> <tt id="link-37" class="py-name"><a title="tangled.core.set_reuse_addr" class="py-name" href="#" onclick="return doclink('link-37', 'set_reuse_addr', 'link-36');">set_reuse_addr</a></tt><tt class="py-op">(</tt><tt class="py-name">w</tt><tt class="py-op">)</tt> </tt>
<a name="L231"></a><tt class="py-lineno">231</tt> <tt class="py-line"> </tt>
<a name="L232"></a><tt class="py-lineno">232</tt> <tt class="py-line"> <tt class="py-comment"># set TCP_NODELAY to true to avoid buffering</tt> </tt>
<a name="L233"></a><tt class="py-lineno">233</tt> <tt class="py-line"> <tt class="py-name">w</tt><tt class="py-op">.</tt><tt class="py-name">setsockopt</tt><tt class="py-op">(</tt><tt class="py-name">socket</tt><tt class="py-op">.</tt><tt class="py-name">IPPROTO_TCP</tt><tt class="py-op">,</tt> <tt class="py-number">1</tt><tt class="py-op">,</tt> <tt class="py-number">1</tt><tt class="py-op">)</tt> </tt>
<a name="L234"></a><tt class="py-lineno">234</tt> <tt class="py-line"> </tt>
<a name="L235"></a><tt class="py-lineno">235</tt> <tt class="py-line"> <tt class="py-comment"># tricky: get a pair of connected sockets</tt> </tt>
<a name="L236"></a><tt class="py-lineno">236</tt> <tt class="py-line"> <tt class="py-name">host</tt><tt class="py-op">=</tt><tt class="py-string">'127.0.0.1'</tt> </tt>
<a name="L237"></a><tt class="py-lineno">237</tt> <tt class="py-line"> <tt class="py-name">port</tt><tt class="py-op">=</tt><tt class="py-number">19999</tt> </tt>
<a name="L238"></a><tt class="py-lineno">238</tt> <tt class="py-line"> <tt class="py-keyword">while</tt> <tt class="py-number">1</tt><tt class="py-op">:</tt> </tt>
<a name="L239"></a><tt class="py-lineno">239</tt> <tt class="py-line"> <tt class="py-keyword">try</tt><tt class="py-op">:</tt> </tt>
<a name="L240"></a><tt class="py-lineno">240</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">address</tt> <tt class="py-op">=</tt> <tt class="py-op">(</tt><tt class="py-name">host</tt><tt class="py-op">,</tt> <tt class="py-name">port</tt><tt class="py-op">)</tt> </tt>
<a name="L241"></a><tt class="py-lineno">241</tt> <tt class="py-line"> <tt class="py-name">a</tt><tt class="py-op">.</tt><tt class="py-name">bind</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">address</tt><tt class="py-op">)</tt> </tt>
<a name="L242"></a><tt class="py-lineno">242</tt> <tt class="py-line"> <tt class="py-keyword">break</tt> </tt>
<a name="L243"></a><tt class="py-lineno">243</tt> <tt class="py-line"> <tt class="py-keyword">except</tt><tt class="py-op">:</tt> </tt>
<a name="L244"></a><tt class="py-lineno">244</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">port</tt> <tt class="py-op"><=</tt> <tt class="py-number">19950</tt><tt class="py-op">:</tt> </tt>
<a name="L245"></a><tt class="py-lineno">245</tt> <tt class="py-line"> <tt class="py-keyword">raise</tt> <tt id="link-38" class="py-name" targets="Class tangled.core.BindError=tangled.core.BindError-class.html"><a title="tangled.core.BindError" class="py-name" href="#" onclick="return doclink('link-38', 'BindError', 'link-38');">BindError</a></tt> </tt>
<a name="L246"></a><tt class="py-lineno">246</tt> <tt class="py-line"> <tt class="py-name">port</tt> <tt class="py-op">=</tt> <tt class="py-name">port</tt> <tt class="py-op">-</tt> <tt class="py-number">1</tt> </tt>
<a name="L247"></a><tt class="py-lineno">247</tt> <tt class="py-line"> </tt>
<a name="L248"></a><tt class="py-lineno">248</tt> <tt class="py-line"> <tt class="py-name">a</tt><tt class="py-op">.</tt><tt class="py-name">listen</tt><tt class="py-op">(</tt><tt class="py-number">1</tt><tt class="py-op">)</tt> </tt>
<a name="L249"></a><tt class="py-lineno">249</tt> <tt class="py-line"> <tt class="py-name">w</tt><tt class="py-op">.</tt><tt class="py-name">setblocking</tt><tt class="py-op">(</tt><tt class="py-number">0</tt><tt class="py-op">)</tt> </tt>
<a name="L250"></a><tt class="py-lineno">250</tt> <tt class="py-line"> <tt class="py-keyword">try</tt><tt class="py-op">:</tt> </tt>
<a name="L251"></a><tt class="py-lineno">251</tt> <tt class="py-line"> <tt class="py-name">w</tt><tt class="py-op">.</tt><tt class="py-name">connect</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">address</tt><tt class="py-op">)</tt> </tt>
<a name="L252"></a><tt class="py-lineno">252</tt> <tt class="py-line"> <tt class="py-keyword">except</tt><tt class="py-op">:</tt> </tt>
<a name="L253"></a><tt class="py-lineno">253</tt> <tt class="py-line"> <tt class="py-keyword">pass</tt> </tt>
<a name="L254"></a><tt class="py-lineno">254</tt> <tt class="py-line"> <tt class="py-name">r</tt><tt class="py-op">,</tt> <tt class="py-name">addr</tt> <tt class="py-op">=</tt> <tt class="py-name">a</tt><tt class="py-op">.</tt><tt class="py-name">accept</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L255"></a><tt class="py-lineno">255</tt> <tt class="py-line"> <tt class="py-name">a</tt><tt class="py-op">.</tt><tt id="link-39" class="py-name" targets="Method tangled.client.Response.close()=tangled.client.Response-class.html#close"><a title="tangled.client.Response.close" class="py-name" href="#" onclick="return doclink('link-39', 'close', 'link-39');">close</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L256"></a><tt class="py-lineno">256</tt> <tt class="py-line"> <tt class="py-name">w</tt><tt class="py-op">.</tt><tt class="py-name">setblocking</tt><tt class="py-op">(</tt><tt class="py-number">1</tt><tt class="py-op">)</tt> </tt>
<a name="L257"></a><tt class="py-lineno">257</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">trigger</tt> <tt class="py-op">=</tt> <tt class="py-name">w</tt> </tt>
<a name="L258"></a><tt class="py-lineno">258</tt> <tt class="py-line"> </tt>
<a name="L259"></a><tt class="py-lineno">259</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">lock</tt> <tt class="py-op">=</tt> <tt class="py-name">threading</tt><tt class="py-op">.</tt><tt class="py-name">Lock</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L260"></a><tt class="py-lineno">260</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">funcs</tt> <tt class="py-op">=</tt> <tt class="py-op">[</tt><tt class="py-op">]</tt> </tt>
<a name="L261"></a><tt class="py-lineno">261</tt> <tt class="py-line"> </tt>
<a name="L262"></a><tt class="py-lineno">262</tt> <tt class="py-line"> <tt class="py-name">asyncore</tt><tt class="py-op">.</tt><tt class="py-name">dispatcher</tt><tt class="py-op">.</tt><tt id="link-40" class="py-name"><a title="tangled.client.AsyncHTTPClient.__init__
tangled.client.Response.__init__
tangled.core.Deferred.__init__
tangled.core.Failure.__init__
tangled.core.Reactor.__init__
tangled.core.Trigger.__init__
tangled.core.Worker.__init__
tangled.server.AsyncHTTPRequestHandler.Pusher.__init__
tangled.server.AsyncHTTPRequestHandler.__init__
tangled.server.AsyncHTTPServer.__init__
tangled.server.Request.__init__
tangled.server.Response.__init__
vinzclortho.consistenthashing.Node.__init__
vinzclortho.consistenthashing.Ring.__init__
vinzclortho.core.AdminHandler.__init__
vinzclortho.core.HandoffHandler.__init__
vinzclortho.core.LocalStorage.__init__
vinzclortho.core.LocalStoreHandler.__init__
vinzclortho.core.MetaDataHandler.__init__
vinzclortho.core.RemoteStorage.__init__
vinzclortho.core.StoreHandler.__init__
vinzclortho.core.VinzClortho.__init__
vinzclortho.store.BerkeleyDBStore.__init__
vinzclortho.store.DictStore.__init__
vinzclortho.store.SQLiteStore.__init__
vinzclortho.vectorclock.VectorClock.__init__" class="py-name" href="#" onclick="return doclink('link-40', '__init__', 'link-5');">__init__</a></tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">,</tt> <tt class="py-name">r</tt><tt class="py-op">)</tt> </tt>
</div><a name="L263"></a><tt class="py-lineno">263</tt> <tt class="py-line"> </tt>
<a name="Trigger.readable"></a><div id="Trigger.readable-def"><a name="L264"></a><tt class="py-lineno">264</tt> <a class="py-toggle" href="#" id="Trigger.readable-toggle" onclick="return toggle('Trigger.readable');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Trigger-class.html#readable">readable</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Trigger.readable-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Trigger.readable-expanded"><a name="L265"></a><tt class="py-lineno">265</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-number">1</tt> </tt>
</div><a name="L266"></a><tt class="py-lineno">266</tt> <tt class="py-line"> </tt>
<a name="Trigger.writable"></a><div id="Trigger.writable-def"><a name="L267"></a><tt class="py-lineno">267</tt> <a class="py-toggle" href="#" id="Trigger.writable-toggle" onclick="return toggle('Trigger.writable');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Trigger-class.html#writable">writable</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Trigger.writable-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Trigger.writable-expanded"><a name="L268"></a><tt class="py-lineno">268</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-number">0</tt> </tt>
</div><a name="L269"></a><tt class="py-lineno">269</tt> <tt class="py-line"> </tt>
<a name="Trigger.handle_connect"></a><div id="Trigger.handle_connect-def"><a name="L270"></a><tt class="py-lineno">270</tt> <a class="py-toggle" href="#" id="Trigger.handle_connect-toggle" onclick="return toggle('Trigger.handle_connect');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Trigger-class.html#handle_connect">handle_connect</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Trigger.handle_connect-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Trigger.handle_connect-expanded"><a name="L271"></a><tt class="py-lineno">271</tt> <tt class="py-line"> <tt class="py-keyword">pass</tt> </tt>
</div><a name="L272"></a><tt class="py-lineno">272</tt> <tt class="py-line"> </tt>
<a name="Trigger.pull_trigger"></a><div id="Trigger.pull_trigger-def"><a name="L273"></a><tt class="py-lineno">273</tt> <a class="py-toggle" href="#" id="Trigger.pull_trigger-toggle" onclick="return toggle('Trigger.pull_trigger');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Trigger-class.html#pull_trigger">pull_trigger</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">func</tt><tt class="py-op">=</tt><tt class="py-name">None</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Trigger.pull_trigger-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Trigger.pull_trigger-expanded"><a name="L274"></a><tt class="py-lineno">274</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">func</tt><tt class="py-op">:</tt> </tt>
<a name="L275"></a><tt class="py-lineno">275</tt> <tt class="py-line"> <tt class="py-keyword">try</tt><tt class="py-op">:</tt> </tt>
<a name="L276"></a><tt class="py-lineno">276</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">lock</tt><tt class="py-op">.</tt><tt class="py-name">acquire</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L277"></a><tt class="py-lineno">277</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">funcs</tt><tt class="py-op">.</tt><tt class="py-name">append</tt><tt class="py-op">(</tt><tt class="py-name">func</tt><tt class="py-op">)</tt> </tt>
<a name="L278"></a><tt class="py-lineno">278</tt> <tt class="py-line"> <tt class="py-keyword">finally</tt><tt class="py-op">:</tt> </tt>
<a name="L279"></a><tt class="py-lineno">279</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">lock</tt><tt class="py-op">.</tt><tt class="py-name">release</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L280"></a><tt class="py-lineno">280</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">trigger</tt><tt class="py-op">.</tt><tt class="py-name">send</tt><tt class="py-op">(</tt><tt class="py-string">'x'</tt><tt class="py-op">)</tt> </tt>
</div><a name="L281"></a><tt class="py-lineno">281</tt> <tt class="py-line"> </tt>
<a name="Trigger.handle_read"></a><div id="Trigger.handle_read-def"><a name="L282"></a><tt class="py-lineno">282</tt> <a class="py-toggle" href="#" id="Trigger.handle_read-toggle" onclick="return toggle('Trigger.handle_read');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Trigger-class.html#handle_read">handle_read</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Trigger.handle_read-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Trigger.handle_read-expanded"><a name="L283"></a><tt class="py-lineno">283</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">recv</tt><tt class="py-op">(</tt><tt class="py-number">8192</tt><tt class="py-op">)</tt> </tt>
<a name="L284"></a><tt class="py-lineno">284</tt> <tt class="py-line"> <tt class="py-keyword">try</tt><tt class="py-op">:</tt> </tt>
<a name="L285"></a><tt class="py-lineno">285</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">lock</tt><tt class="py-op">.</tt><tt class="py-name">acquire</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L286"></a><tt class="py-lineno">286</tt> <tt class="py-line"> <tt class="py-keyword">for</tt> <tt class="py-name">func</tt> <tt class="py-keyword">in</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">funcs</tt><tt class="py-op">:</tt> </tt>
<a name="L287"></a><tt class="py-lineno">287</tt> <tt class="py-line"> <tt class="py-name">func</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L288"></a><tt class="py-lineno">288</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">funcs</tt> <tt class="py-op">=</tt> <tt class="py-op">[</tt><tt class="py-op">]</tt> </tt>
<a name="L289"></a><tt class="py-lineno">289</tt> <tt class="py-line"> <tt class="py-keyword">finally</tt><tt class="py-op">:</tt> </tt>
<a name="L290"></a><tt class="py-lineno">290</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">lock</tt><tt class="py-op">.</tt><tt class="py-name">release</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
</div></div><a name="L291"></a><tt class="py-lineno">291</tt> <tt class="py-line"> </tt>
<a name="Reactor"></a><div id="Reactor-def"><a name="L292"></a><tt class="py-lineno">292</tt> <a class="py-toggle" href="#" id="Reactor-toggle" onclick="return toggle('Reactor');">-</a><tt class="py-line"><tt class="py-keyword">class</tt> <a class="py-def-name" href="tangled.core.Reactor-class.html">Reactor</a><tt class="py-op">(</tt><tt class="py-base-class">object</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Reactor-collapsed" style="display:none;" pad="+++" indent="++++"></div><div id="Reactor-expanded"><a name="L293"></a><tt class="py-lineno">293</tt> <tt class="py-line"> <tt class="py-docstring">"""The reactor is the engine of your asynchronous application."""</tt> </tt>
<a name="L294"></a><tt class="py-lineno">294</tt> <tt class="py-line"> <tt class="py-comment"># trigger object to wake the loop</tt> </tt>
<a name="L295"></a><tt class="py-lineno">295</tt> <tt class="py-line"> <tt id="link-41" class="py-name" targets="Variable tangled.core.Reactor._trigger=tangled.core.Reactor-class.html#_trigger"><a title="tangled.core.Reactor._trigger" class="py-name" href="#" onclick="return doclink('link-41', '_trigger', 'link-41');">_trigger</a></tt> <tt class="py-op">=</tt> <tt id="link-42" class="py-name" targets="Class tangled.core.Trigger=tangled.core.Trigger-class.html"><a title="tangled.core.Trigger" class="py-name" href="#" onclick="return doclink('link-42', 'Trigger', 'link-42');">Trigger</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L296"></a><tt class="py-lineno">296</tt> <tt class="py-line"> <tt id="link-43" class="py-name" targets="Variable tangled.core.Reactor.use_poll=tangled.core.Reactor-class.html#use_poll"><a title="tangled.core.Reactor.use_poll" class="py-name" href="#" onclick="return doclink('link-43', 'use_poll', 'link-43');">use_poll</a></tt> <tt class="py-op">=</tt> <tt class="py-name">False</tt> </tt>
<a name="L297"></a><tt class="py-lineno">297</tt> <tt class="py-line"> </tt>
<a name="Reactor.__init__"></a><div id="Reactor.__init__-def"><a name="L298"></a><tt class="py-lineno">298</tt> <a class="py-toggle" href="#" id="Reactor.__init__-toggle" onclick="return toggle('Reactor.__init__');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Reactor-class.html#__init__">__init__</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Reactor.__init__-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Reactor.__init__-expanded"><a name="L299"></a><tt class="py-lineno">299</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_pending_calls</tt> <tt class="py-op">=</tt> <tt class="py-op">[</tt><tt class="py-op">]</tt> </tt>
</div><a name="L300"></a><tt class="py-lineno">300</tt> <tt class="py-line"> </tt>
<a name="Reactor.wake"></a><div id="Reactor.wake-def"><a name="L301"></a><tt class="py-lineno">301</tt> <a class="py-toggle" href="#" id="Reactor.wake-toggle" onclick="return toggle('Reactor.wake');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Reactor-class.html#wake">wake</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Reactor.wake-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Reactor.wake-expanded"><a name="L302"></a><tt class="py-lineno">302</tt> <tt class="py-line"> <tt class="py-docstring">"""Uses the trigger to wake the async loop"""</tt> </tt>
<a name="L303"></a><tt class="py-lineno">303</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-44" class="py-name"><a title="tangled.core.Reactor._trigger" class="py-name" href="#" onclick="return doclink('link-44', '_trigger', 'link-41');">_trigger</a></tt><tt class="py-op">.</tt><tt id="link-45" class="py-name" targets="Method tangled.core.Trigger.pull_trigger()=tangled.core.Trigger-class.html#pull_trigger"><a title="tangled.core.Trigger.pull_trigger" class="py-name" href="#" onclick="return doclink('link-45', 'pull_trigger', 'link-45');">pull_trigger</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
</div><a name="L304"></a><tt class="py-lineno">304</tt> <tt class="py-line"> </tt>
<a name="Reactor.run_in_main"></a><div id="Reactor.run_in_main-def"><a name="L305"></a><tt class="py-lineno">305</tt> <a class="py-toggle" href="#" id="Reactor.run_in_main-toggle" onclick="return toggle('Reactor.run_in_main');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Reactor-class.html#run_in_main">run_in_main</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">func</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Reactor.run_in_main-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Reactor.run_in_main-expanded"><a name="L306"></a><tt class="py-lineno">306</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L307"></a><tt class="py-lineno">307</tt> <tt class="py-line"><tt class="py-docstring"> Wakes the async loop, and calls func in it</tt> </tt>
<a name="L308"></a><tt class="py-lineno">308</tt> <tt class="py-line"><tt class="py-docstring"></tt> </tt>
<a name="L309"></a><tt class="py-lineno">309</tt> <tt class="py-line"><tt class="py-docstring"> @param func: The function to call from the main loop</tt> </tt>
<a name="L310"></a><tt class="py-lineno">310</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L311"></a><tt class="py-lineno">311</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-46" class="py-name"><a title="tangled.core.Reactor._trigger" class="py-name" href="#" onclick="return doclink('link-46', '_trigger', 'link-41');">_trigger</a></tt><tt class="py-op">.</tt><tt id="link-47" class="py-name"><a title="tangled.core.Trigger.pull_trigger" class="py-name" href="#" onclick="return doclink('link-47', 'pull_trigger', 'link-45');">pull_trigger</a></tt><tt class="py-op">(</tt><tt class="py-name">func</tt><tt class="py-op">)</tt> </tt>
</div><a name="L312"></a><tt class="py-lineno">312</tt> <tt class="py-line"> </tt>
<a name="Reactor.defer_to_worker"></a><div id="Reactor.defer_to_worker-def"><a name="L313"></a><tt class="py-lineno">313</tt> <a class="py-toggle" href="#" id="Reactor.defer_to_worker-toggle" onclick="return toggle('Reactor.defer_to_worker');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Reactor-class.html#defer_to_worker">defer_to_worker</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">func</tt><tt class="py-op">,</tt> <tt class="py-param">worker</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Reactor.defer_to_worker-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Reactor.defer_to_worker-expanded"><a name="L314"></a><tt class="py-lineno">314</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L315"></a><tt class="py-lineno">315</tt> <tt class="py-line"><tt class="py-docstring"> Calls a function in a worker, and return the result as a L{Deferred}</tt> </tt>
<a name="L316"></a><tt class="py-lineno">316</tt> <tt class="py-line"><tt class="py-docstring"></tt> </tt>
<a name="L317"></a><tt class="py-lineno">317</tt> <tt class="py-line"><tt class="py-docstring"> @param func: The function to call in the worker</tt> </tt>
<a name="L318"></a><tt class="py-lineno">318</tt> <tt class="py-line"><tt class="py-docstring"> @param worker: The worker that should handle the call</tt> </tt>
<a name="L319"></a><tt class="py-lineno">319</tt> <tt class="py-line"><tt class="py-docstring"> @type worker: L{Worker}</tt> </tt>
<a name="L320"></a><tt class="py-lineno">320</tt> <tt class="py-line"><tt class="py-docstring"> @return: A L{Deferred} objeft that will eventually contain the result</tt> </tt>
<a name="L321"></a><tt class="py-lineno">321</tt> <tt class="py-line"><tt class="py-docstring"> @rtype: L{Deferred}</tt> </tt>
<a name="L322"></a><tt class="py-lineno">322</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L323"></a><tt class="py-lineno">323</tt> <tt class="py-line"> <tt class="py-name">d</tt> <tt class="py-op">=</tt> <tt id="link-48" class="py-name"><a title="tangled.core.Deferred" class="py-name" href="#" onclick="return doclink('link-48', 'Deferred', 'link-1');">Deferred</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L324"></a><tt class="py-lineno">324</tt> <tt class="py-line"> <tt class="py-keyword">def</tt> <tt class="py-def-name">callback</tt><tt class="py-op">(</tt><tt class="py-param">result</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
<a name="L325"></a><tt class="py-lineno">325</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">isinstance</tt><tt class="py-op">(</tt><tt class="py-name">result</tt><tt class="py-op">,</tt> <tt id="link-49" class="py-name"><a title="tangled.core.Failure" class="py-name" href="#" onclick="return doclink('link-49', 'Failure', 'link-8');">Failure</a></tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
<a name="L326"></a><tt class="py-lineno">326</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-50" class="py-name" targets="Method tangled.core.Reactor.run_in_main()=tangled.core.Reactor-class.html#run_in_main"><a title="tangled.core.Reactor.run_in_main" class="py-name" href="#" onclick="return doclink('link-50', 'run_in_main', 'link-50');">run_in_main</a></tt><tt class="py-op">(</tt><tt class="py-name">functools</tt><tt class="py-op">.</tt><tt class="py-name">partial</tt><tt class="py-op">(</tt><tt class="py-name">d</tt><tt class="py-op">.</tt><tt id="link-51" class="py-name" targets="Method tangled.core.Deferred.errback()=tangled.core.Deferred-class.html#errback"><a title="tangled.core.Deferred.errback" class="py-name" href="#" onclick="return doclink('link-51', 'errback', 'link-51');">errback</a></tt><tt class="py-op">,</tt> <tt class="py-name">result</tt><tt class="py-op">)</tt><tt class="py-op">)</tt> </tt>
<a name="L327"></a><tt class="py-lineno">327</tt> <tt class="py-line"> <tt class="py-keyword">else</tt><tt class="py-op">:</tt> </tt>
<a name="L328"></a><tt class="py-lineno">328</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-52" class="py-name"><a title="tangled.core.Reactor.run_in_main" class="py-name" href="#" onclick="return doclink('link-52', 'run_in_main', 'link-50');">run_in_main</a></tt><tt class="py-op">(</tt><tt class="py-name">functools</tt><tt class="py-op">.</tt><tt class="py-name">partial</tt><tt class="py-op">(</tt><tt class="py-name">d</tt><tt class="py-op">.</tt><tt id="link-53" class="py-name"><a title="tangled.core.Deferred.callback" class="py-name" href="#" onclick="return doclink('link-53', 'callback', 'link-2');">callback</a></tt><tt class="py-op">,</tt> <tt class="py-name">result</tt><tt class="py-op">)</tt><tt class="py-op">)</tt> </tt>
</div><a name="L329"></a><tt class="py-lineno">329</tt> <tt class="py-line"> <tt class="py-name">worker</tt><tt class="py-op">.</tt><tt id="link-54" class="py-name" targets="Method tangled.core.Worker.execute()=tangled.core.Worker-class.html#execute"><a title="tangled.core.Worker.execute" class="py-name" href="#" onclick="return doclink('link-54', 'execute', 'link-54');">execute</a></tt><tt class="py-op">(</tt><tt class="py-name">func</tt><tt class="py-op">,</tt> <tt id="link-55" class="py-name"><a title="tangled.core.Deferred.callback" class="py-name" href="#" onclick="return doclink('link-55', 'callback', 'link-2');">callback</a></tt><tt class="py-op">)</tt> </tt>
<a name="L330"></a><tt class="py-lineno">330</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">d</tt> </tt>
</div><a name="L331"></a><tt class="py-lineno">331</tt> <tt class="py-line"> </tt>
<a name="Reactor.call_later"></a><div id="Reactor.call_later-def"><a name="L332"></a><tt class="py-lineno">332</tt> <a class="py-toggle" href="#" id="Reactor.call_later-toggle" onclick="return toggle('Reactor.call_later');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Reactor-class.html#call_later">call_later</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">,</tt> <tt class="py-param">func</tt><tt class="py-op">,</tt> <tt class="py-param">timeout</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Reactor.call_later-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Reactor.call_later-expanded"><a name="L333"></a><tt class="py-lineno">333</tt> <tt class="py-line"> <tt class="py-docstring">"""</tt> </tt>
<a name="L334"></a><tt class="py-lineno">334</tt> <tt class="py-line"><tt class="py-docstring"> Call a function at a later time in the main loop</tt> </tt>
<a name="L335"></a><tt class="py-lineno">335</tt> <tt class="py-line"><tt class="py-docstring"> </tt> </tt>
<a name="L336"></a><tt class="py-lineno">336</tt> <tt class="py-line"><tt class="py-docstring"> @param func: The function to call</tt> </tt>
<a name="L337"></a><tt class="py-lineno">337</tt> <tt class="py-line"><tt class="py-docstring"> @param timeout: How long (in seconds) to the call shall be made</tt> </tt>
<a name="L338"></a><tt class="py-lineno">338</tt> <tt class="py-line"><tt class="py-docstring"> """</tt> </tt>
<a name="L339"></a><tt class="py-lineno">339</tt> <tt class="py-line"> <tt class="py-name">heapq</tt><tt class="py-op">.</tt><tt class="py-name">heappush</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_pending_calls</tt><tt class="py-op">,</tt> <tt class="py-op">(</tt><tt class="py-name">time</tt><tt class="py-op">.</tt><tt class="py-name">time</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> <tt class="py-op">+</tt> <tt class="py-name">timeout</tt><tt class="py-op">,</tt> <tt class="py-name">func</tt><tt class="py-op">)</tt><tt class="py-op">)</tt> </tt>
<a name="L340"></a><tt class="py-lineno">340</tt> <tt class="py-line"> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-56" class="py-name" targets="Method tangled.core.Reactor.wake()=tangled.core.Reactor-class.html#wake"><a title="tangled.core.Reactor.wake" class="py-name" href="#" onclick="return doclink('link-56', 'wake', 'link-56');">wake</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
</div><a name="L341"></a><tt class="py-lineno">341</tt> <tt class="py-line"> </tt>
<a name="Reactor._timeout"></a><div id="Reactor._timeout-def"><a name="L342"></a><tt class="py-lineno">342</tt> <a class="py-toggle" href="#" id="Reactor._timeout-toggle" onclick="return toggle('Reactor._timeout');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Reactor-class.html#_timeout">_timeout</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Reactor._timeout-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Reactor._timeout-expanded"><a name="L343"></a><tt class="py-lineno">343</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-keyword">not</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_pending_calls</tt><tt class="py-op">:</tt> </tt>
<a name="L344"></a><tt class="py-lineno">344</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">None</tt> </tt>
<a name="L345"></a><tt class="py-lineno">345</tt> <tt class="py-line"> <tt class="py-keyword">return</tt> <tt class="py-name">max</tt><tt class="py-op">(</tt><tt class="py-number">0</tt><tt class="py-op">,</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_pending_calls</tt><tt class="py-op">[</tt><tt class="py-number">0</tt><tt class="py-op">]</tt><tt class="py-op">[</tt><tt class="py-number">0</tt><tt class="py-op">]</tt> <tt class="py-op">-</tt> <tt class="py-name">time</tt><tt class="py-op">.</tt><tt class="py-name">time</tt><tt class="py-op">(</tt><tt class="py-op">)</tt><tt class="py-op">)</tt> </tt>
</div><a name="L346"></a><tt class="py-lineno">346</tt> <tt class="py-line"> </tt>
<a name="Reactor.loop"></a><div id="Reactor.loop-def"><a name="L347"></a><tt class="py-lineno">347</tt> <a class="py-toggle" href="#" id="Reactor.loop-toggle" onclick="return toggle('Reactor.loop');">-</a><tt class="py-line"> <tt class="py-keyword">def</tt> <a class="py-def-name" href="tangled.core.Reactor-class.html#loop">loop</a><tt class="py-op">(</tt><tt class="py-param">self</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
</div><div id="Reactor.loop-collapsed" style="display:none;" pad="+++" indent="++++++++"></div><div id="Reactor.loop-expanded"><a name="L348"></a><tt class="py-lineno">348</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-57" class="py-name"><a title="tangled.core.Reactor.use_poll" class="py-name" href="#" onclick="return doclink('link-57', 'use_poll', 'link-43');">use_poll</a></tt> <tt class="py-keyword">and</tt> <tt class="py-name">hasattr</tt><tt class="py-op">(</tt><tt class="py-name">select</tt><tt class="py-op">,</tt> <tt class="py-string">'poll'</tt><tt class="py-op">)</tt><tt class="py-op">:</tt> </tt>
<a name="L349"></a><tt class="py-lineno">349</tt> <tt class="py-line"> <tt class="py-name">poll_fun</tt> <tt class="py-op">=</tt> <tt class="py-name">asyncore</tt><tt class="py-op">.</tt><tt class="py-name">poll2</tt> </tt>
<a name="L350"></a><tt class="py-lineno">350</tt> <tt class="py-line"> <tt class="py-keyword">else</tt><tt class="py-op">:</tt> </tt>
<a name="L351"></a><tt class="py-lineno">351</tt> <tt class="py-line"> <tt class="py-name">poll_fun</tt> <tt class="py-op">=</tt> <tt class="py-name">asyncore</tt><tt class="py-op">.</tt><tt class="py-name">poll</tt> </tt>
<a name="L352"></a><tt class="py-lineno">352</tt> <tt class="py-line"> </tt>
<a name="L353"></a><tt class="py-lineno">353</tt> <tt class="py-line"> <tt class="py-keyword">while</tt> <tt class="py-name">asyncore</tt><tt class="py-op">.</tt><tt class="py-name">socket_map</tt><tt class="py-op">:</tt> </tt>
<a name="L354"></a><tt class="py-lineno">354</tt> <tt class="py-line"> <tt class="py-name">timeout</tt> <tt class="py-op">=</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt id="link-58" class="py-name" targets="Method tangled.core.Reactor._timeout()=tangled.core.Reactor-class.html#_timeout"><a title="tangled.core.Reactor._timeout" class="py-name" href="#" onclick="return doclink('link-58', '_timeout', 'link-58');">_timeout</a></tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L355"></a><tt class="py-lineno">355</tt> <tt class="py-line"> <tt class="py-name">poll_fun</tt><tt class="py-op">(</tt><tt class="py-name">timeout</tt><tt class="py-op">,</tt> <tt class="py-name">asyncore</tt><tt class="py-op">.</tt><tt class="py-name">socket_map</tt><tt class="py-op">)</tt> </tt>
<a name="L356"></a><tt class="py-lineno">356</tt> <tt class="py-line"> <tt class="py-comment"># check expired timeouts</tt> </tt>
<a name="L357"></a><tt class="py-lineno">357</tt> <tt class="py-line"> <tt class="py-name">t</tt> <tt class="py-op">=</tt> <tt class="py-name">time</tt><tt class="py-op">.</tt><tt class="py-name">time</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L358"></a><tt class="py-lineno">358</tt> <tt class="py-line"> <tt class="py-keyword">while</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_pending_calls</tt><tt class="py-op">:</tt> </tt>
<a name="L359"></a><tt class="py-lineno">359</tt> <tt class="py-line"> <tt class="py-name">timeout</tt><tt class="py-op">,</tt> <tt class="py-name">func</tt> <tt class="py-op">=</tt> <tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_pending_calls</tt><tt class="py-op">[</tt><tt class="py-number">0</tt><tt class="py-op">]</tt> </tt>
<a name="L360"></a><tt class="py-lineno">360</tt> <tt class="py-line"> <tt class="py-keyword">if</tt> <tt class="py-name">timeout</tt> <tt class="py-op"><</tt> <tt class="py-name">t</tt><tt class="py-op">:</tt> </tt>
<a name="L361"></a><tt class="py-lineno">361</tt> <tt class="py-line"> <tt class="py-name">func</tt><tt class="py-op">(</tt><tt class="py-op">)</tt> </tt>
<a name="L362"></a><tt class="py-lineno">362</tt> <tt class="py-line"> <tt class="py-name">heapq</tt><tt class="py-op">.</tt><tt class="py-name">heappop</tt><tt class="py-op">(</tt><tt class="py-name">self</tt><tt class="py-op">.</tt><tt class="py-name">_pending_calls</tt><tt class="py-op">)</tt> </tt>
<a name="L363"></a><tt class="py-lineno">363</tt> <tt class="py-line"> <tt class="py-keyword">else</tt><tt class="py-op">:</tt> </tt>
<a name="L364"></a><tt class="py-lineno">364</tt> <tt class="py-line"> <tt class="py-comment"># No timeout</tt> </tt>
<a name="L365"></a><tt class="py-lineno">365</tt> <tt class="py-line"> <tt class="py-keyword">break</tt> </tt>
</div></div><a name="L366"></a><tt class="py-lineno">366</tt> <tt class="py-line"> </tt><script type="text/javascript">
<!--
expandto(location.href);
// -->
</script>
</pre>
<br />
<!-- ==================== NAVIGATION BAR ==================== -->
<table class="navbar" border="0" width="100%" cellpadding="0"
bgcolor="#a0c0ff" cellspacing="0">
<tr valign="middle">
<!-- Tree link -->
<th> <a
href="module-tree.html">Trees</a> </th>
<!-- Index link -->
<th> <a
href="identifier-index.html">Indices</a> </th>
<!-- Help link -->
<th> <a
href="help.html">Help</a> </th>
<!-- Project homepage -->
<th class="navbar" align="right" width="100%">
<table border="0" cellpadding="0" cellspacing="0">
<tr><th class="navbar" align="center"
><a class="navbar" target="_top" href="http://bitbucket.org/rogueops/vinzclortho">Vinz Clortho</a></th>
</tr></table></th>
</tr>
</table>
<table border="0" cellpadding="0" cellspacing="0" width="100%%">
<tr>
<td align="left" class="footer">
Generated by Epydoc 3.0.1 on Wed Jul 28 14:52:15 2010
</td>
<td align="right" class="footer">
<a target="mainFrame" href="http://epydoc.sourceforge.net"
>http://epydoc.sourceforge.net</a>
</td>
</tr>
</table>
<script type="text/javascript">
<!--
// Private objects are initially displayed (because if
// javascript is turned off then we want them to be
// visible); but by default, we want to hide them. So hide
// them unless we have a cookie that says to show them.
checkCookie();
// -->
</script>
</body>
</html>