[gnome-continuous-yocto/gnomeostree-3.28-rocko: 4296/8267] bitbake: bb/server/process.py: ProcessEventQueue add close of _writer pipe



commit 509d26f95b0d376f8fc7502b8ffd275a33ffa48f
Author: Aníbal Limón <anibal limon linux intel com>
Date:   Mon Jan 9 10:22:50 2017 -0600

    bitbake: bb/server/process.py: ProcessEventQueue add close of _writer pipe
    
    Call explicity close in _writer to avoid fd leakage because isn't
    called on Queue.close()
    
    [YOCTO #10873]
    
    (Bitbake rev: 12dfac442d2d5674198485fbeb708a01d215c576)
    
    Signed-off-by: Aníbal Limón <anibal limon linux intel com>
    Signed-off-by: Richard Purdie <richard purdie linuxfoundation org>

 bitbake/lib/bb/server/process.py |    4 +++-
 1 files changed, 3 insertions(+), 1 deletions(-)
---
diff --git a/bitbake/lib/bb/server/process.py b/bitbake/lib/bb/server/process.py
index c9dfb4f..c3c1450 100644
--- a/bitbake/lib/bb/server/process.py
+++ b/bitbake/lib/bb/server/process.py
@@ -233,6 +233,9 @@ class BitBakeProcessServerConnection(BitBakeBaseServerConnection):
         self.ui_channel.close()
         self.event_queue.close()
         self.event_queue.setexit()
+        # XXX: Call explicity close in _writer to avoid
+        # fd leakage because isn't called on Queue.close()
+        self.event_queue._writer.close()
 
 # Wrap Queue to provide API which isn't server implementation specific
 class ProcessEventQueue(multiprocessing.queues.Queue):
@@ -264,7 +267,6 @@ class ProcessEventQueue(multiprocessing.queues.Queue):
                 sys.exit(1)
             return None
 
-
 class BitBakeServer(BitBakeBaseServer):
     def initServer(self, single_use=True):
         # establish communication channels.  We use bidirectional pipes for


[Date Prev][Date Next]   [Thread Prev][Thread Next]   [Thread Index] [Date Index] [Author Index]