Sfoglia il codice sorgente

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>
Richard Purdie 13 anni fa
parent
commit
be98c1fc29
2 ha cambiato i file con 6 aggiunte e 1 eliminazioni
  1. 1 1
      bitbake/lib/bb/runqueue.py
  2. 5 0
      bitbake/lib/bb/utils.py

+ 1 - 1
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
 

+ 5 - 0
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)
+