summaryrefslogtreecommitdiffstats
path: root/bitbake/lib
diff options
context:
space:
mode:
authorRichard Purdie <richard.purdie@linuxfoundation.org>2012-06-22 12:53:16 +0100
committerRichard Purdie <richard.purdie@linuxfoundation.org>2012-06-25 14:57:16 +0100
commitbe98c1fc299a3e5355e1d864c9a3f5d1fdf21d9c (patch)
tree90309fe23922818132270951bff8007832fe8100 /bitbake/lib
parente05b423cc6f9f5193fecc605efc2ad47170fd0c6 (diff)
downloadpoky-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/lib')
-rw-r--r--bitbake/lib/bb/runqueue.py2
-rw-r--r--bitbake/lib/bb/utils.py5
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():
1724 def __init__(self, pipein, pipeout, d): 1724 def __init__(self, pipein, pipeout, d):
1725 self.input = pipein 1725 self.input = pipein
1726 pipeout.close() 1726 pipeout.close()
1727 fcntl.fcntl(self.input, fcntl.F_SETFL, fcntl.fcntl(self.input, fcntl.F_GETFL) | os.O_NONBLOCK) 1727 bb.utils.nonblockingfd(self.input)
1728 self.queue = "" 1728 self.queue = ""
1729 self.d = d 1729 self.d = d
1730 1730
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
26import bb 26import bb
27import bb.msg 27import bb.msg
28import multiprocessing 28import multiprocessing
29import fcntl
29from commands import getstatusoutput 30from commands import getstatusoutput
30from contextlib import contextmanager 31from contextlib import contextmanager
31 32
@@ -754,3 +755,7 @@ def contains(variable, checkvalues, truevalue, falsevalue, d):
754 755
755def cpu_count(): 756def cpu_count():
756 return multiprocessing.cpu_count() 757 return multiprocessing.cpu_count()
758
759def nonblockingfd(fd):
760 fcntl.fcntl(fd, fcntl.F_SETFL, fcntl.fcntl(fd, fcntl.F_GETFL) | os.O_NONBLOCK)
761