Show More
@@ -74,7 +74,7 b' class remotestore(basestore.basestore):' | |||||
74 | return lfutil.copyandhash(lfutil.blockstream(infile), tmpfile) |
|
74 | return lfutil.copyandhash(lfutil.blockstream(infile), tmpfile) | |
75 |
|
75 | |||
76 | def _verify(self, hashes): |
|
76 | def _verify(self, hashes): | |
77 | return self._stat(hashes) |
|
77 | return dict((h, s == 0) for (h, s) in self._stat(hashes).iteritems()) | |
78 |
|
78 | |||
79 | def _verifyfile(self, cctx, cset, contents, standin, verified): |
|
79 | def _verifyfile(self, cctx, cset, contents, standin, verified): | |
80 | filename = lfutil.splitstandin(standin) |
|
80 | filename = lfutil.splitstandin(standin) |
@@ -26,6 +26,8 b' class wirestore(remotestore.remotestore)' | |||||
26 | return self.remote.getlfile(hash) |
|
26 | return self.remote.getlfile(hash) | |
27 |
|
27 | |||
28 | def _stat(self, hashes): |
|
28 | def _stat(self, hashes): | |
|
29 | '''For each hash, return 2 if the largefile is missing, 1 if it has a | |||
|
30 | mismatched checksum, or 0 if it is in good condition''' | |||
29 | batch = self.remote.batch() |
|
31 | batch = self.remote.batch() | |
30 | futures = {} |
|
32 | futures = {} | |
31 | for hash in hashes: |
|
33 | for hash in hashes: | |
@@ -33,5 +35,5 b' class wirestore(remotestore.remotestore)' | |||||
33 | batch.submit() |
|
35 | batch.submit() | |
34 | retval = {} |
|
36 | retval = {} | |
35 | for hash in hashes: |
|
37 | for hash in hashes: | |
36 |
retval[hash] = |
|
38 | retval[hash] = futures[hash].value | |
37 | return retval |
|
39 | return retval |
General Comments 0
You need to be logged in to leave comments.
Login now