diff options
| author |   Richard Purdie <richard.purdie@linuxfoundation.org> | 2012-06-22 12:53:16 +0100 |
|---|---|---|
| committer | Richard Purdie <richard.purdie@linuxfoundation.org> | 2012-06-25 14:57:16 +0100 |
| commit | be98c1fc299a3e5355e1d864c9a3f5d1fdf21d9c (patch) | |
| tree | 90309fe23922818132270951bff8007832fe8100 /bitbake | |
| parent | e05b423cc6f9f5193fecc605efc2ad47170fd0c6 (diff) | |
| download | openembedded-core-contrib-be98c1fc299a3e5355e1d864c9a3f5d1fdf21d9c.tar.gz | |
bitbake: utils.py: Add function to set nonblocking operation on a file descriptor
(Bitbake rev: ab6d71ebfcfb7bedc064b25f84647c8815096e5a)
Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
Diffstat (limited to 'bitbake')
| -rw-r--r-- | bitbake/lib/bb/runqueue.py | 2 | ||||
| -rw-r--r-- | bitbake/lib/bb/utils.py | 5 |
2 files changed, 6 insertions, 1 deletions
diff --git a/bitbake/lib/bb/runqueue.py b/bitbake/lib/bb/runqueue.py index 608aff8ad7..bd643ea767 100644 --- a/bitbake/lib/bb/runqueue.py +++ b/bitbake/lib/bb/runqueue.py @@ -1724,7 +1724,7 @@ class runQueuePipe(): def __init__(self, pipein, pipeout, d): self.input = pipein pipeout.close() - fcntl.fcntl(self.input, fcntl.F_SETFL, fcntl.fcntl(self.input, fcntl.F_GETFL) | os.O_NONBLOCK) + bb.utils.nonblockingfd(self.input) self.queue = "" self.d = d diff --git a/bitbake/lib/bb/utils.py b/bitbake/lib/bb/utils.py index fc389a3e2c..77ad39ee86 100644 --- a/bitbake/lib/bb/utils.py +++ b/bitbake/lib/bb/utils.py @@ -26,6 +26,7 @@ import logging import bb import bb.msg import multiprocessing +import fcntl from commands import getstatusoutput from contextlib import contextmanager @@ -754,3 +755,7 @@ def contains(variable, checkvalues, truevalue, falsevalue, d): def cpu_count(): return multiprocessing.cpu_count() + +def nonblockingfd(fd): + fcntl.fcntl(fd, fcntl.F_SETFL, fcntl.fcntl(fd, fcntl.F_GETFL) | os.O_NONBLOCK) + |