From a77108dd0c92de0a548cb0f795b3e9207e1d05dc Mon Sep 17 00:00:00 2001
From: Jakob Ketterl <jakob.ketterl@gmx.de>
Date: Wed, 5 Aug 2020 20:01:57 +0200
Subject: [PATCH] drain subprocess pipes to free up file descriptors, refs #146

---
 csdr/csdr.py | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/csdr/csdr.py b/csdr/csdr.py
index 07be0f3..52e369f 100644
--- a/csdr/csdr.py
+++ b/csdr/csdr.py
@@ -504,12 +504,18 @@ class dsp(object):
         if self.secondary_process_fft:
             try:
                 os.killpg(os.getpgid(self.secondary_process_fft.pid), signal.SIGTERM)
+                # drain any leftover data to free file descriptors
+                self.secondary_process_fft.communicate()
+                self.secondary_process_fft = None
             except ProcessLookupError:
                 # been killed by something else, ignore
                 pass
         if self.secondary_process_demod:
             try:
                 os.killpg(os.getpgid(self.secondary_process_demod.pid), signal.SIGTERM)
+                # drain any leftover data to free file descriptors
+                self.secondary_process_demod.communicate()
+                self.secondary_process_demod = None
             except ProcessLookupError:
                 # been killed by something else, ignore
                 pass
@@ -848,6 +854,8 @@ class dsp(object):
             if self.process is not None:
                 try:
                     os.killpg(os.getpgid(self.process.pid), signal.SIGTERM)
+                    # drain any leftover data to free file descriptors
+                    self.process.communicate()
                     self.process = None
                 except ProcessLookupError:
                     # been killed by something else, ignore