diff options
| author | Liguros - Gitlab CI/CD [master] <gitlab@liguros.net> | 2020-12-16 00:00:18 +0000 |
|---|---|---|
| committer | Liguros - Gitlab CI/CD [master] <gitlab@liguros.net> | 2020-12-16 00:00:18 +0000 |
| commit | c16790af2c9b4cbc38e565d4311252193ff85484 (patch) | |
| tree | 4f43ee770507dee235d6b4f9433d9f807781fcc8 /dev-python/eventlet/files | |
| parent | fddf516add4924cfe9d698f116342e30b27d67b8 (diff) | |
| download | baldeagleos-repo-21.1.1.tar.gz baldeagleos-repo-21.1.1.tar.xz baldeagleos-repo-21.1.1.zip | |
Updating liguros repo21.1.1
Diffstat (limited to 'dev-python/eventlet/files')
| -rw-r--r-- | dev-python/eventlet/files/eventlet-0.29.1-tests.patch | 71 | ||||
| -rw-r--r-- | dev-python/eventlet/files/eventlet-0.30.0-tests-socket.patch | 13 |
2 files changed, 13 insertions, 71 deletions
diff --git a/dev-python/eventlet/files/eventlet-0.29.1-tests.patch b/dev-python/eventlet/files/eventlet-0.29.1-tests.patch deleted file mode 100644 index 3cd20823899d..000000000000 --- a/dev-python/eventlet/files/eventlet-0.29.1-tests.patch +++ /dev/null @@ -1,71 +0,0 @@ -https://github.com/eventlet/eventlet/issues/646 -From 087ba743c7af8a40ac1e4e2ec89409eee3b4233e Mon Sep 17 00:00:00 2001 -From: Tim Burke <tim.burke@gmail.com> -Date: Mon, 2 Nov 2020 16:09:46 -0800 -Subject: [PATCH] py39: Add _at_fork_reinit method to Semaphores - -CPython expects to be able to call such a method on RLocks, Conditions, -and Events in threading; since we may monkey-patch threading to use -Semaphores as locks, they need the method, too. - -Addresses #646 ---- - eventlet/semaphore.py | 5 +++++ - tests/semaphore_test.py | 21 +++++++++++++++++++++ - 2 files changed, 26 insertions(+) - -diff --git a/eventlet/semaphore.py b/eventlet/semaphore.py -index 18b5b05f4..5e2b5e32f 100644 ---- a/eventlet/semaphore.py -+++ b/eventlet/semaphore.py -@@ -39,6 +39,7 @@ def __init__(self, value=1): - if value < 0: - msg = 'Semaphore() expect value >= 0, actual: {0}'.format(repr(value)) - raise ValueError(msg) -+ self._original_value = value - self.counter = value - self._waiters = collections.deque() - -@@ -51,6 +52,10 @@ def __str__(self): - params = (self.__class__.__name__, self.counter, len(self._waiters)) - return '<%s c=%s _w[%s]>' % params - -+ def _at_fork_reinit(self): -+ self.counter = self._original_value -+ self._waiters.clear() -+ - def locked(self): - """Returns true if a call to acquire would block. - """ -diff --git a/tests/semaphore_test.py b/tests/semaphore_test.py -index d6c11d1f6..cf6a29daf 100644 ---- a/tests/semaphore_test.py -+++ b/tests/semaphore_test.py -@@ -42,6 +42,27 @@ def test_timeout_non_blocking(self): - sem = eventlet.Semaphore() - self.assertRaises(ValueError, sem.acquire, blocking=False, timeout=1) - -+ def test_reinit(self): -+ # py39+ expects locks to have a _at_fork_reinit() method; since we -+ # patch in Semaphores in eventlet.green.thread, they need it, too -+ sem = eventlet.Semaphore() -+ sem.acquire() -+ sem._at_fork_reinit() -+ self.assertEqual(sem.acquire(blocking=False), True) -+ self.assertEqual(sem.acquire(blocking=False), False) -+ -+ sem = eventlet.Semaphore(0) -+ sem.release() -+ sem._at_fork_reinit() -+ self.assertEqual(sem.acquire(blocking=False), False) -+ -+ sem = eventlet.Semaphore(2) -+ sem.acquire() -+ sem._at_fork_reinit() -+ self.assertEqual(sem.acquire(blocking=False), True) -+ self.assertEqual(sem.acquire(blocking=False), True) -+ self.assertEqual(sem.acquire(blocking=False), False) -+ - - def test_semaphore_contention(): - g_mutex = eventlet.Semaphore() diff --git a/dev-python/eventlet/files/eventlet-0.30.0-tests-socket.patch b/dev-python/eventlet/files/eventlet-0.30.0-tests-socket.patch new file mode 100644 index 000000000000..4dd309c68a38 --- /dev/null +++ b/dev-python/eventlet/files/eventlet-0.30.0-tests-socket.patch @@ -0,0 +1,13 @@ +Let's use TMPDIR as the base for this test's unix socket to help it pass. +We set TMPDIR in the ebuild to ${T}. +--- a/tests/backdoor_test.py ++++ b/tests/backdoor_test.py +@@ -47,7 +47,7 @@ class BackdoorTest(tests.LimitedTestCase): + self._run_test_on_client_and_server(client, serv) + + def test_server_on_unix_socket(self): +- SOCKET_PATH = '/tmp/eventlet_backdoor_test.socket' ++ SOCKET_PATH = os.getenv('TMPDIR', '/tmp') + '/eventlet_backdoor_test.socket' + if os.path.exists(SOCKET_PATH): + os.unlink(SOCKET_PATH) + listener = socket.socket(socket.AF_UNIX) |
