diff options
Diffstat (limited to 'bitbake/lib')
| -rw-r--r-- | bitbake/lib/bb/__init__.py | 20 | ||||
| -rw-r--r-- | bitbake/lib/bb/asyncrpc/client.py | 3 | ||||
| -rw-r--r-- | bitbake/lib/bb/asyncrpc/serv.py | 3 | ||||
| -rw-r--r-- | bitbake/lib/bb/cooker.py | 9 | ||||
| -rw-r--r-- | bitbake/lib/hashserv/tests.py | 3 |
5 files changed, 6 insertions, 32 deletions
diff --git a/bitbake/lib/bb/__init__.py b/bitbake/lib/bb/__init__.py index b04d4c8a83..574e0de5be 100644 --- a/bitbake/lib/bb/__init__.py +++ b/bitbake/lib/bb/__init__.py | |||
| @@ -104,26 +104,6 @@ class BBLoggerAdapter(logging.LoggerAdapter, BBLoggerMixin): | |||
| 104 | self.setup_bblogger(logger.name) | 104 | self.setup_bblogger(logger.name) |
| 105 | super().__init__(logger, *args, **kwargs) | 105 | super().__init__(logger, *args, **kwargs) |
| 106 | 106 | ||
| 107 | if sys.version_info < (3, 6): | ||
| 108 | # These properties were added in Python 3.6. Add them in older versions | ||
| 109 | # for compatibility | ||
| 110 | @property | ||
| 111 | def manager(self): | ||
| 112 | return self.logger.manager | ||
| 113 | |||
| 114 | @manager.setter | ||
| 115 | def manager(self, value): | ||
| 116 | self.logger.manager = value | ||
| 117 | |||
| 118 | @property | ||
| 119 | def name(self): | ||
| 120 | return self.logger.name | ||
| 121 | |||
| 122 | def __repr__(self): | ||
| 123 | logger = self.logger | ||
| 124 | level = logger.getLevelName(logger.getEffectiveLevel()) | ||
| 125 | return '<%s %s (%s)>' % (self.__class__.__name__, logger.name, level) | ||
| 126 | |||
| 127 | logging.LoggerAdapter = BBLoggerAdapter | 107 | logging.LoggerAdapter = BBLoggerAdapter |
| 128 | 108 | ||
| 129 | logger = logging.getLogger("BitBake") | 109 | logger = logging.getLogger("BitBake") |
diff --git a/bitbake/lib/bb/asyncrpc/client.py b/bitbake/lib/bb/asyncrpc/client.py index b49de99313..f81ad92f48 100644 --- a/bitbake/lib/bb/asyncrpc/client.py +++ b/bitbake/lib/bb/asyncrpc/client.py | |||
| @@ -249,8 +249,7 @@ class Client(object): | |||
| 249 | def close(self): | 249 | def close(self): |
| 250 | if self.loop: | 250 | if self.loop: |
| 251 | self.loop.run_until_complete(self.client.close()) | 251 | self.loop.run_until_complete(self.client.close()) |
| 252 | if sys.version_info >= (3, 6): | 252 | self.loop.run_until_complete(self.loop.shutdown_asyncgens()) |
| 253 | self.loop.run_until_complete(self.loop.shutdown_asyncgens()) | ||
| 254 | self.loop.close() | 253 | self.loop.close() |
| 255 | self.loop = None | 254 | self.loop = None |
| 256 | 255 | ||
diff --git a/bitbake/lib/bb/asyncrpc/serv.py b/bitbake/lib/bb/asyncrpc/serv.py index 46d54fb511..667217c5c1 100644 --- a/bitbake/lib/bb/asyncrpc/serv.py +++ b/bitbake/lib/bb/asyncrpc/serv.py | |||
| @@ -388,8 +388,7 @@ class AsyncServer(object): | |||
| 388 | 388 | ||
| 389 | self._serve_forever(tasks) | 389 | self._serve_forever(tasks) |
| 390 | 390 | ||
| 391 | if sys.version_info >= (3, 6): | 391 | self.loop.run_until_complete(self.loop.shutdown_asyncgens()) |
| 392 | self.loop.run_until_complete(self.loop.shutdown_asyncgens()) | ||
| 393 | self.loop.close() | 392 | self.loop.close() |
| 394 | 393 | ||
| 395 | queue = multiprocessing.Queue() | 394 | queue = multiprocessing.Queue() |
diff --git a/bitbake/lib/bb/cooker.py b/bitbake/lib/bb/cooker.py index 673af8daec..6754f986bf 100644 --- a/bitbake/lib/bb/cooker.py +++ b/bitbake/lib/bb/cooker.py | |||
| @@ -1812,8 +1812,8 @@ class CookerCollectFiles(object): | |||
| 1812 | bb.event.fire(CookerExit(), eventdata) | 1812 | bb.event.fire(CookerExit(), eventdata) |
| 1813 | 1813 | ||
| 1814 | # We need to track where we look so that we can know when the cache is invalid. There | 1814 | # We need to track where we look so that we can know when the cache is invalid. There |
| 1815 | # is no nice way to do this, this is horrid. We intercept the os.listdir() | 1815 | # is no nice way to do this, this is horrid. We intercept the os.listdir() and os.scandir() |
| 1816 | # (or os.scandir() for python 3.6+) calls while we run glob(). | 1816 | # calls while we run glob(). |
| 1817 | origlistdir = os.listdir | 1817 | origlistdir = os.listdir |
| 1818 | if hasattr(os, 'scandir'): | 1818 | if hasattr(os, 'scandir'): |
| 1819 | origscandir = os.scandir | 1819 | origscandir = os.scandir |
| @@ -2224,9 +2224,8 @@ class CookerParser(object): | |||
| 2224 | 2224 | ||
| 2225 | for process in self.processes: | 2225 | for process in self.processes: |
| 2226 | process.join() | 2226 | process.join() |
| 2227 | # Added in 3.7, cleans up zombies | 2227 | # clean up zombies |
| 2228 | if hasattr(process, "close"): | 2228 | process.close() |
| 2229 | process.close() | ||
| 2230 | 2229 | ||
| 2231 | bb.codeparser.parser_cache_save() | 2230 | bb.codeparser.parser_cache_save() |
| 2232 | bb.codeparser.parser_cache_savemerge() | 2231 | bb.codeparser.parser_cache_savemerge() |
diff --git a/bitbake/lib/hashserv/tests.py b/bitbake/lib/hashserv/tests.py index 5349cd5867..cf74d9de7e 100644 --- a/bitbake/lib/hashserv/tests.py +++ b/bitbake/lib/hashserv/tests.py | |||
| @@ -94,9 +94,6 @@ class HashEquivalenceTestSetup(object): | |||
| 94 | return self.start_client(self.auth_server_address, user["username"], user["token"]) | 94 | return self.start_client(self.auth_server_address, user["username"], user["token"]) |
| 95 | 95 | ||
| 96 | def setUp(self): | 96 | def setUp(self): |
| 97 | if sys.version_info < (3, 5, 0): | ||
| 98 | self.skipTest('Python 3.5 or later required') | ||
| 99 | |||
| 100 | self.temp_dir = tempfile.TemporaryDirectory(prefix='bb-hashserv') | 97 | self.temp_dir = tempfile.TemporaryDirectory(prefix='bb-hashserv') |
| 101 | self.addCleanup(self.temp_dir.cleanup) | 98 | self.addCleanup(self.temp_dir.cleanup) |
| 102 | 99 | ||
