obj = self[sha]
return obj
- def _collect_ancestors(self, heads, common = set()):
- """Collect all ancestors of heads up to (excluding) those in common
+ def _collect_ancestors(self, heads, common=set()):
+ """Collect all ancestors of heads up to (excluding) those in common.
+
:param heads: commits to start from
- :param common: commits to end at, or empty set to walk repository completely
+ :param common: commits to end at, or empty set to walk repository
+ completely
:return: a tuple (A, B) where A - all commits reachable
from heads but not present in common, B - common (shared) elements
that are directly reachable from heads
raise NotTreeError(root_sha)
return tree.lookup_path(lookup_obj, path)
+
def _collect_filetree_revs(obj_store, tree_sha, kset):
- """Collect SHA1s of files and directories for specified tree
- (identified by SHA1)
+ """Collect SHA1s of files and directories for specified tree.
+
:param obj_store: Object store to get objects by SHA from
:param tree_sha: tree reference to walk
:param kset: set to fill with references to files and directories
"""
filetree = obj_store[tree_sha]
- for name,mode,sha in filetree.iteritems():
+ for name, mode, sha in filetree.iteritems():
if not S_ISGITLINK(mode) and sha not in kset:
kset.add(sha)
if stat.S_ISDIR(mode):
_collect_filetree_revs(obj_store, sha, kset)
-def _split_commits_and_tags(obj_store, lst, ignore_unknown = False):
- """Split lst into two lists, one with commit SHA1s, another with
- tag SHA1s. Commits referenced by tags are included into commits
- list as well. Only SHA1s known in this repository will get
- through, and unless ignore_unknown argument is True, KeyError
- is thrown for SHA1 missing in the repository
+
+def _split_commits_and_tags(obj_store, lst, ignore_unknown=False):
+ """Split object id list into two list with commit SHA1s and tag SHA1s.
+
+ Commits referenced by tags are included into commits
+ list as well. Only SHA1s known in this repository will get
+ through, and unless ignore_unknown argument is True, KeyError
+ is thrown for SHA1 missing in the repository
+
:param obj_store: Object store to get objects by SHA1 from
:param lst: Collection of commit and tag SHAs
- :param ignore_unknown: True to skip SHA1 missing in the
- repository silently.
+ :param ignore_unknown: True to skip SHA1 missing in the repository
+ silently.
:return: A tuple of (commits, tags) SHA1s
"""
commits = set()
try:
o = obj_store[e]
except KeyError:
- if ignore_unknown:
- pass
- else:
+ if not ignore_unknown:
raise
else:
if isinstance(o, Commit):
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
# MA 02110-1301, USA.
-from dulwich.errors import (
- MissingCommitError,
- )
from dulwich.object_store import (
MemoryObjectStore,
)
from dulwich.objects import (
- Commit,
Blob,
)
from dulwich.tests import TestCase
from utils import (
- F,
make_object,
build_commit_graph,
)
+
class MissingObjectFinderTest(TestCase):
def setUp(self):
self.store = MemoryObjectStore()
self.commits = []
- def __getitem__(self, n):
- # rename for brevity
- return self.commits[n-1]
-
def cmt(self, n):
- return self[n]
+ return self.commits[n-1]
def assertMissingMatch(self, haves, wants, expected):
- for sha,path in self.store.find_missing_objects(haves, wants):
- self.assertTrue(sha in expected, "FAILURE: (%s,%s) erroneously reported as missing" % (sha,path))
+ for sha, path in self.store.find_missing_objects(haves, wants):
+ self.assertTrue(sha in expected,
+ "FAILURE: (%s,%s) erroneously reported as missing" %
+ (sha, path))
expected.remove(sha)
self.assertFalse(len(expected) > 0, "FAILURE: some objects are not reported as missing: %s" % (expected))
+
class MOFLinearRepoTest(MissingObjectFinderTest):
+
def setUp(self):
super(MOFLinearRepoTest, self).setUp()
f1_1 = make_object(Blob, data='f1') # present in 1, removed in 3
def test_1_to_2(self):
- self.assertMissingMatch([self.cmt(1).id], [self.cmt(2).id], self.missing_1_2)
+ self.assertMissingMatch([self.cmt(1).id], [self.cmt(2).id],
+ self.missing_1_2)
def test_2_to_3(self):
- self.assertMissingMatch([self.cmt(2).id], [self.cmt(3).id], self.missing_2_3)
+ self.assertMissingMatch([self.cmt(2).id], [self.cmt(3).id],
+ self.missing_2_3)
def test_1_to_3(self):
- self.assertMissingMatch([self.cmt(1).id], [self.cmt(3).id], self.missing_1_3)
+ self.assertMissingMatch([self.cmt(1).id], [self.cmt(3).id],
+ self.missing_1_3)
def test_bogus_haves_failure(self):
"""Ensure non-existent SHA in haves are not tolerated"""
bogus_sha = self.cmt(2).id[::-1]
haves = [self.cmt(1).id]
wants = [self.cmt(3).id, bogus_sha]
- self.assertRaises(KeyError, self.store.find_missing_objects, self.store, haves, wants)
+ self.assertRaises(KeyError, self.store.find_missing_objects,
+ self.store, haves, wants)
def test_no_changes(self):
self.assertMissingMatch([self.cmt(3).id], [self.cmt(3).id], [])
+
class MOFMergeForkRepoTest(MissingObjectFinderTest):
""" 1 --- 2 --- 4 --- 6 --- 7
\ /
have 5, want 7. Common parent is rev2, hence children of rev2 from
a descent line other than rev5 shall be reported
"""
- # expects f1_4 from rev6. f3_5 is known in rev5;
+ # expects f1_4 from rev6. f3_5 is known in rev5;
# f1_7 shall be the same as f1_2 (known, too)
self.assertMissingMatch([self.cmt(5).id], [self.cmt(7).id], [
self.cmt(7).id, self.cmt(6).id, self.cmt(4).id,
self.cmt(7).tree, self.cmt(6).tree, self.cmt(4).tree,
- self.f1_4_id])
-
+ self.f1_4_id])
git.samba.org / jelmer / dulwich.git / commitdiff