diff options
| author | Jürg Billeter <j@bitron.ch> | 2019-04-01 13:26:17 +0200 |
|---|---|---|
| committer | Jürg Billeter <j@bitron.ch> | 2019-04-12 11:17:33 +0200 |
| commit | 4ea1ae62a42ebbaa0b8ba9fbee2c1629b2f73b28 (patch) | |
| tree | 9125c7f427a05e3160100bd907b086439ff1b219 | |
| parent | 5780868547efc0db143cb54cbe97d646259331a4 (diff) | |
| download | buildstream-4ea1ae62a42ebbaa0b8ba9fbee2c1629b2f73b28.tar.gz | |
cascache.py: Add remote_missing_blobs() method
Extracted from remote_missing_blobs_for_directory().
| -rw-r--r-- | buildstream/_cas/cascache.py | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/buildstream/_cas/cascache.py b/buildstream/_cas/cascache.py index 8c64e76d2..3a621fbb1 100644 --- a/buildstream/_cas/cascache.py +++ b/buildstream/_cas/cascache.py @@ -649,9 +649,21 @@ class CASCache(): def remote_missing_blobs_for_directory(self, remote, digest): required_blobs = self.required_blobs_for_directory(digest) + return self.remote_missing_blobs(remote, required_blobs) + + # remote_missing_blobs(): + # + # Determine which blobs are missing on the remote. + # + # Args: + # blobs (Digest): The directory digest + # + # Returns: List of missing Digest objects + # + def remote_missing_blobs(self, remote, blobs): missing_blobs = dict() # Limit size of FindMissingBlobs request - for required_blobs_group in _grouper(required_blobs, 512): + for required_blobs_group in _grouper(blobs, 512): request = remote_execution_pb2.FindMissingBlobsRequest(instance_name=remote.spec.instance_name) for required_digest in required_blobs_group: |