diff options
author | Darius Makovsky <traveltissues@protonmail.com> | 2019-09-11 16:17:04 +0100 |
---|---|---|
committer | Darius Makovsky <traveltissues@protonmail.com> | 2019-09-23 17:48:45 +0100 |
commit | 5f9339b18b363efac5976431ccca28f1efaffe1f (patch) | |
tree | 200834724b4b8075446529b29800c5ae6529c85e | |
parent | fc0136c62bf065a94e7fe192a673e708dc0778c7 (diff) | |
download | buildstream-5f9339b18b363efac5976431ccca28f1efaffe1f.tar.gz |
cascache.py: Create `CASCache.close_channel()`
-rw-r--r-- | src/buildstream/_cas/cascache.py | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/src/buildstream/_cas/cascache.py b/src/buildstream/_cas/cascache.py index 2603b13c5..6002adc4a 100644 --- a/src/buildstream/_cas/cascache.py +++ b/src/buildstream/_cas/cascache.py @@ -163,6 +163,16 @@ class CASCache(): def has_open_grpc_channels(self): return bool(self._casd_channel) + # close_channel(): + # + # Close the casd channel if it exists + # + def close_channel(self): + if self._casd_channel: + self._local_cas = None + self._casd_channel.close() + self._casd_channel = None + # release_resources(): # # Release resources used by CASCache. @@ -172,11 +182,7 @@ class CASCache(): self._cache_usage_monitor.release_resources() if self._casd_process: - if self._casd_channel: - self._local_cas = None - self._casd_channel.close() - self._casd_channel = None - + self.close_channel() self._casd_process.terminate() try: # Don't print anything if buildbox-casd terminates quickly |