author | Idan Kamara <idankk86@gmail.com> |
Mon, 08 Oct 2012 15:35:16 +0200 | |
changeset 17712 | c4717f44c1f1 |
parent 17127 | 9e1616307c4c |
child 18481 | ed647c59753b |
permissions | -rw-r--r-- |
15168 | 1 |
# Copyright 2010-2011 Fog Creek Software |
2 |
# |
|
3 |
# This software may be used and distributed according to the terms of the |
|
4 |
# GNU General Public License version 2 or any later version. |
|
5 |
||
15252
6e809bb4f969
largefiles: improve comments, internal docstrings
Greg Ward <greg@gerg.ca>
parents:
15168
diff
changeset
|
6 |
'''largefile store working over Mercurial's wire protocol''' |
15168 | 7 |
|
8 |
import lfutil |
|
9 |
import remotestore |
|
10 |
||
11 |
class wirestore(remotestore.remotestore): |
|
12 |
def __init__(self, ui, repo, remote): |
|
13 |
cap = remote.capable('largefiles') |
|
14 |
if not cap: |
|
15 |
raise lfutil.storeprotonotcapable([]) |
|
16 |
storetypes = cap.split(',') |
|
16686
67964cda8701
cleanup: "not x in y" -> "x not in y"
Brodie Rao <brodie@sf.io>
parents:
15252
diff
changeset
|
17 |
if 'serve' not in storetypes: |
15168 | 18 |
raise lfutil.storeprotonotcapable(storetypes) |
19 |
self.remote = remote |
|
20 |
super(wirestore, self).__init__(ui, repo, remote.url()) |
|
21 |
||
22 |
def _put(self, hash, fd): |
|
23 |
return self.remote.putlfile(hash, fd) |
|
24 |
||
25 |
def _get(self, hash): |
|
26 |
return self.remote.getlfile(hash) |
|
27 |
||
17127
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
28 |
def _stat(self, hashes): |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
29 |
batch = self.remote.batch() |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
30 |
futures = {} |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
31 |
for hash in hashes: |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
32 |
futures[hash] = batch.statlfile(hash) |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
33 |
batch.submit() |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
34 |
retval = {} |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
35 |
for hash in hashes: |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
36 |
retval[hash] = not futures[hash].value |
9e1616307c4c
largefiles: batch statlfile requests when pushing a largefiles repo (issue3386)
Na'Tosha Bard <natosha@unity3d.com>
parents:
16686
diff
changeset
|
37 |
return retval |