Show More
@@ -356,7 +356,7 b' def uploadlfiles(ui, rsrc, rdst, files):' | |||||
356 | if not files: |
|
356 | if not files: | |
357 | return |
|
357 | return | |
358 |
|
358 | |||
359 |
store = storefactory. |
|
359 | store = storefactory.openstore(rsrc, rdst, put=True) | |
360 |
|
360 | |||
361 | at = 0 |
|
361 | at = 0 | |
362 | ui.debug("sending statlfile command for %d largefiles\n" % len(files)) |
|
362 | ui.debug("sending statlfile command for %d largefiles\n" % len(files)) | |
@@ -387,7 +387,7 b' def verifylfiles(ui, repo, all=False, co' | |||||
387 | else: |
|
387 | else: | |
388 | revs = ['.'] |
|
388 | revs = ['.'] | |
389 |
|
389 | |||
390 |
store = storefactory. |
|
390 | store = storefactory.openstore(repo) | |
391 | return store.verify(revs, contents=contents) |
|
391 | return store.verify(revs, contents=contents) | |
392 |
|
392 | |||
393 | def cachelfiles(ui, repo, node, filelist=None): |
|
393 | def cachelfiles(ui, repo, node, filelist=None): | |
@@ -413,7 +413,7 b' def cachelfiles(ui, repo, node, filelist' | |||||
413 | toget.append((lfile, expectedhash)) |
|
413 | toget.append((lfile, expectedhash)) | |
414 |
|
414 | |||
415 | if toget: |
|
415 | if toget: | |
416 |
store = storefactory. |
|
416 | store = storefactory.openstore(repo) | |
417 | ret = store.get(toget) |
|
417 | ret = store.get(toget) | |
418 | return ret |
|
418 | return ret | |
419 |
|
419 |
@@ -1123,7 +1123,7 b' def _getoutgoings(repo, other, missing, ' | |||||
1123 | lfhashes.add(lfhash) |
|
1123 | lfhashes.add(lfhash) | |
1124 | lfutil.getlfilestoupload(repo, missing, dedup) |
|
1124 | lfutil.getlfilestoupload(repo, missing, dedup) | |
1125 | if lfhashes: |
|
1125 | if lfhashes: | |
1126 |
lfexists = storefactory. |
|
1126 | lfexists = storefactory.openstore(repo, other).exists(lfhashes) | |
1127 | for fn, lfhash in knowns: |
|
1127 | for fn, lfhash in knowns: | |
1128 | if not lfexists[lfhash]: # lfhash doesn't exist on "other" |
|
1128 | if not lfexists[lfhash]: # lfhash doesn't exist on "other" | |
1129 | addfunc(fn, lfhash) |
|
1129 | addfunc(fn, lfhash) | |
@@ -1352,7 +1352,7 b' def overridecat(orig, ui, repo, file1, *' | |||||
1352 | else: |
|
1352 | else: | |
1353 | hash = lfutil.readstandin(repo, lf, ctx.rev()) |
|
1353 | hash = lfutil.readstandin(repo, lf, ctx.rev()) | |
1354 | if not lfutil.inusercache(repo.ui, hash): |
|
1354 | if not lfutil.inusercache(repo.ui, hash): | |
1355 |
store = storefactory. |
|
1355 | store = storefactory.openstore(repo) | |
1356 | success, missing = store.get([(lf, hash)]) |
|
1356 | success, missing = store.get([(lf, hash)]) | |
1357 | if len(success) != 1: |
|
1357 | if len(success) != 1: | |
1358 | raise error.Abort( |
|
1358 | raise error.Abort( |
@@ -22,7 +22,7 b' from . import (' | |||||
22 | # During clone this function is passed the src's ui object |
|
22 | # During clone this function is passed the src's ui object | |
23 | # but it needs the dest's ui object so it can read out of |
|
23 | # but it needs the dest's ui object so it can read out of | |
24 | # the config file. Use repo.ui instead. |
|
24 | # the config file. Use repo.ui instead. | |
25 |
def |
|
25 | def openstore(repo, remote=None, put=False): | |
26 | ui = repo.ui |
|
26 | ui = repo.ui | |
27 |
|
27 | |||
28 | if not remote: |
|
28 | if not remote: |
General Comments 0
You need to be logged in to leave comments.
Login now