| quark |
| Restricted Project |
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | remotefilelog/basestore.py (9 lines) | |||
| M | remotefilelog/contentstore.py (9 lines) | |||
| M | remotefilelog/metadatastore.py (4 lines) |
| removed += 1 | removed += 1 | ||||
| removedexcess += oldpathstat.st_size | removedexcess += oldpathstat.st_size | ||||
| ui.progress(_truncating, None) | ui.progress(_truncating, None) | ||||
| ui.status(_("finished: removed %s of %s files (%0.2f GB to %0.2f GB)\n") | ui.status(_("finished: removed %s of %s files (%0.2f GB to %0.2f GB)\n") | ||||
| % (removed, count, | % (removed, count, | ||||
| float(originalsize) / 1024.0 / 1024.0 / 1024.0, | float(originalsize) / 1024.0 / 1024.0 / 1024.0, | ||||
| float(size) / 1024.0 / 1024.0 / 1024.0)) | float(size) / 1024.0 / 1024.0 / 1024.0)) | ||||
| class baseunionstore(object): | |||||
| def __init__(self, *args, **kwargs): | |||||
| pass | |||||
| def markforrefresh(self): | |||||
| for store in self.stores: | |||||
| if util.safehasattr(store, 'markforrefresh'): | |||||
| store.markforrefresh() | |||||
| # against the original file content). | # against the original file content). | ||||
| BASENAME = 2 | BASENAME = 2 | ||||
| # The mercurial file node for the delta base revision. This is the nullid if | # The mercurial file node for the delta base revision. This is the nullid if | ||||
| # this delta is a full text. | # this delta is a full text. | ||||
| BASENODE = 3 | BASENODE = 3 | ||||
| # The actual delta or full text data. | # The actual delta or full text data. | ||||
| DATA = 4 | DATA = 4 | ||||
| class unioncontentstore(object): | class unioncontentstore(basestore.baseunionstore): | ||||
| def __init__(self, *args, **kwargs): | def __init__(self, *args, **kwargs): | ||||
| super(unioncontentstore, self).__init__(*args, **kwargs) | |||||
| self.stores = args | self.stores = args | ||||
| self.writestore = kwargs.get('writestore') | self.writestore = kwargs.get('writestore') | ||||
| # If allowincomplete==True then the union store can return partial | # If allowincomplete==True then the union store can return partial | ||||
| # delta chains, otherwise it will throw a KeyError if a full | # delta chains, otherwise it will throw a KeyError if a full | ||||
| # deltachain can't be found. | # deltachain can't be found. | ||||
| self.allowincomplete = kwargs.get('allowincomplete', False) | self.allowincomplete = kwargs.get('allowincomplete', False) | ||||
| self.writestore.addremotefilelognode(name, node, data) | self.writestore.addremotefilelognode(name, node, data) | ||||
| else: | else: | ||||
| raise RuntimeError("no writable store configured") | raise RuntimeError("no writable store configured") | ||||
| def markledger(self, ledger, options=None): | def markledger(self, ledger, options=None): | ||||
| for store in self.stores: | for store in self.stores: | ||||
| store.markledger(ledger, options) | store.markledger(ledger, options) | ||||
| def markforrefresh(self): | |||||
| for store in self.stores: | |||||
| if util.safehasattr(store, 'markforrefresh'): | |||||
| store.markforrefresh() | |||||
| class remotefilelogcontentstore(basestore.basestore): | class remotefilelogcontentstore(basestore.basestore): | ||||
| def __init__(self, *args, **kwargs): | def __init__(self, *args, **kwargs): | ||||
| super(remotefilelogcontentstore, self).__init__(*args, **kwargs) | super(remotefilelogcontentstore, self).__init__(*args, **kwargs) | ||||
| self._threaddata = threading.local() | self._threaddata = threading.local() | ||||
| def get(self, name, node): | def get(self, name, node): | ||||
| # return raw revision text | # return raw revision text | ||||
| data = self._getdata(name, node) | data = self._getdata(name, node) | ||||
| import basestore, shallowutil | import basestore, shallowutil | ||||
| from mercurial.node import hex, nullid | from mercurial.node import hex, nullid | ||||
| class unionmetadatastore(object): | class unionmetadatastore(basestore.baseunionstore): | ||||
| def __init__(self, *args, **kwargs): | def __init__(self, *args, **kwargs): | ||||
| super(unionmetadatastore, self).__init__(*args, **kwargs) | |||||
| self.stores = args | self.stores = args | ||||
| self.writestore = kwargs.get('writestore') | self.writestore = kwargs.get('writestore') | ||||
| # If allowincomplete==True then the union store can return partial | # If allowincomplete==True then the union store can return partial | ||||
| # ancestor lists, otherwise it will throw a KeyError if a full | # ancestor lists, otherwise it will throw a KeyError if a full | ||||
| # history can't be found. | # history can't be found. | ||||
| self.allowincomplete = kwargs.get('allowincomplete', False) | self.allowincomplete = kwargs.get('allowincomplete', False) | ||||