diff options
author | Darius Makovsky <traveltissues@protonmail.com> | 2019-09-11 16:17:04 +0100 |
---|---|---|
committer | bst-marge-bot <marge-bot@buildstream.build> | 2019-09-24 15:58:25 +0000 |
commit | 3247014d07a66b98ac28f1b2a7aa8658661cb4ea (patch) | |
tree | ca3cd9af9dfa661975e800db4ca3a787c4ba81a1 /src | |
parent | bc2acf77186d020d8f42230779a824ab973e135b (diff) | |
download | buildstream-3247014d07a66b98ac28f1b2a7aa8658661cb4ea.tar.gz |
cascache.py: Create `CASCache.close_channel()`
Diffstat (limited to 'src')
-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 |