diff options
| -rw-r--r-- | meta/lib/oeqa/utils/qemurunner.py | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/meta/lib/oeqa/utils/qemurunner.py b/meta/lib/oeqa/utils/qemurunner.py index 5c3a8e5999..98a11e1a2c 100644 --- a/meta/lib/oeqa/utils/qemurunner.py +++ b/meta/lib/oeqa/utils/qemurunner.py | |||
| @@ -521,7 +521,6 @@ class QemuRunner: | |||
| 521 | except Exception as e: | 521 | except Exception as e: |
| 522 | self.logger.warning('Extra log data exception %s' % repr(e)) | 522 | self.logger.warning('Extra log data exception %s' % repr(e)) |
| 523 | data = None | 523 | data = None |
| 524 | self.thread.serial_lock.release() | ||
| 525 | return False | 524 | return False |
| 526 | 525 | ||
| 527 | with self.thread.serial_lock: | 526 | with self.thread.serial_lock: |
| @@ -824,10 +823,12 @@ class LoggingThread(threading.Thread): | |||
| 824 | self.logfunc(data, ".stdout") | 823 | self.logfunc(data, ".stdout") |
| 825 | elif self.serialsock and self.serialsock.fileno() == fd: | 824 | elif self.serialsock and self.serialsock.fileno() == fd: |
| 826 | if self.serial_lock.acquire(blocking=False): | 825 | if self.serial_lock.acquire(blocking=False): |
| 827 | data = self.recv(1024, self.serialsock) | 826 | try: |
| 828 | self.logger.debug("Data received serial thread %s" % data.decode('utf-8', 'replace')) | 827 | data = self.recv(1024, self.serialsock) |
| 829 | self.logfunc(data, ".2") | 828 | self.logger.debug("Data received serial thread %s" % data.decode('utf-8', 'replace')) |
| 830 | self.serial_lock.release() | 829 | self.logfunc(data, ".2") |
| 830 | finally: | ||
| 831 | self.serial_lock.release() | ||
| 831 | else: | 832 | else: |
| 832 | serial_registered = False | 833 | serial_registered = False |
| 833 | poll.unregister(self.serialsock.fileno()) | 834 | poll.unregister(self.serialsock.fileno()) |
