Attachment 1102282 Details for Bug 1279502 – selector.patch

[patch] selector.patch

selector.patch (text/plain), 1.11 KB, created by Brian Bouterse on 2015-12-04 14:08:55 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Brian Bouterse

Created: 2015-12-04 14:08:55 UTC

Size: 1.11 KB

patch

obsolete

>--- selector.py.ORIG    2015-12-04 00:47:07.484000000 +0000
>+++ selector.py 2015-12-04 01:17:51.027000000 +0000
>@@ -47,6 +47,7 @@
>   lock = Lock()
>   DEFAULT = None
>   _current_pid = None
>+  process_forked = False
>
>   @staticmethod
>   def default():
>@@ -58,6 +59,7 @@
>         sel.start()
>         Selector.DEFAULT = sel
>         Selector._current_pid = os.getpid()
>+        Selector.process_forked = True
>       return Selector.DEFAULT
>     finally:
>       Selector.lock.release()
>@@ -109,6 +111,7 @@
>   def run(self):
>     try:
>       while not self.stopped:
>+        loop_count = 0
>         wakeup = None
>         for sel in self.selectables.copy():
>           t = self._update(sel)
>@@ -129,6 +132,9 @@
>             else:
>               timeout = max(0, wakeup - time.time())
>             rd, wr, ex = select(self.reading, self.writing, (), timeout)
>+            if Selector.process_forked and loop_count > 20:
>+                raise Exception("This exception should be logged")
>+            loop_count = loop_count + 1
>             break
>           except SelectError, e:
>             # Repeat the select call if we were interrupted.

Actions: View | Diff

Attachments on bug 1279502: 1101566 | 1101732 | 1102282 | 1103324