87
67
def describe(self):
88
68
return "%s is locked" % self.lockable_thing
91
class _AncestryMismatch(Mismatch):
92
"""Ancestry matching mismatch."""
94
def __init__(self, tip_revision, got, expected):
95
self.tip_revision = tip_revision
97
self.expected = expected
100
return "mismatched ancestry for revision %r was %r, expected %r" % (
101
self.tip_revision, self.got, self.expected)
104
class MatchesAncestry(Matcher):
105
"""A matcher that checks the ancestry of a particular revision.
107
:ivar graph: Graph in which to check the ancestry
108
:ivar revision_id: Revision id of the revision
111
def __init__(self, repository, revision_id):
112
Matcher.__init__(self)
113
self.repository = repository
114
self.revision_id = revision_id
117
return ('MatchesAncestry(repository=%r, revision_id=%r)' % (
118
self.repository, self.revision_id))
120
def match(self, expected):
121
with self.repository.lock_read():
122
graph = self.repository.get_graph()
123
got = [r for r, p in graph.iter_ancestry([self.revision_id])]
124
if _mod_revision.NULL_REVISION in got:
125
got.remove(_mod_revision.NULL_REVISION)
126
if sorted(got) != sorted(expected):
127
return _AncestryMismatch(self.revision_id, sorted(got),
131
class HasLayout(Matcher):
132
"""A matcher that checks if a tree has a specific layout.
134
:ivar entries: List of expected entries, as (path, file_id) pairs.
137
def __init__(self, entries):
138
Matcher.__init__(self)
139
self.entries = entries
141
def get_tree_layout(self, tree, include_file_ids):
142
"""Get the (path, file_id) pairs for the current tree."""
143
with tree.lock_read():
144
for path, ie in tree.iter_entries_by_dir():
146
path += ie.kind_character()
148
yield (path, ie.file_id)
153
def _strip_unreferenced_directories(entries):
154
"""Strip all directories that don't (in)directly contain any files.
156
:param entries: List of path strings or (path, ie) tuples to process
159
for entry in entries:
160
if isinstance(entry, (str, text_type)):
164
if not path or path[-1] == "/":
166
directories.append((path, entry))
168
# Yield the referenced parent directories
169
for dirpath, direntry in directories:
170
if osutils.is_inside(dirpath, path):
176
return 'HasLayout(%r)' % self.entries
178
def match(self, tree):
179
include_file_ids = self.entries and not isinstance(
180
self.entries[0], (str, text_type))
181
actual = list(self.get_tree_layout(
182
tree, include_file_ids=include_file_ids))
183
if not tree.has_versioned_directories():
184
entries = list(self._strip_unreferenced_directories(self.entries))
186
entries = self.entries
187
return Equals(entries).match(actual)
190
class HasPathRelations(Matcher):
191
"""Matcher verifies that paths have a relation to those in another tree.
193
:ivar previous_tree: tree to compare to
194
:ivar previous_entries: List of expected entries, as (path, previous_path) pairs.
197
def __init__(self, previous_tree, previous_entries):
198
Matcher.__init__(self)
199
self.previous_tree = previous_tree
200
self.previous_entries = previous_entries
202
def get_path_map(self, tree):
203
"""Get the (path, previous_path) pairs for the current tree."""
204
previous_intertree = InterTree.get(self.previous_tree, tree)
205
with tree.lock_read(), self.previous_tree.lock_read():
206
for path, ie in tree.iter_entries_by_dir():
207
if tree.supports_rename_tracking():
208
previous_path = previous_intertree.find_source_path(path)
210
if self.previous_tree.is_versioned(path):
215
kind = self.previous_tree.kind(previous_path)
216
if kind == 'directory':
219
yield (u"", previous_path)
221
yield (path + ie.kind_character(), previous_path)
224
def _strip_unreferenced_directories(entries):
225
"""Strip all directories that don't (in)directly contain any files.
227
:param entries: List of path strings or (path, previous_path) tuples to process
229
directory_used = set()
231
for (path, previous_path) in entries:
232
if not path or path[-1] == "/":
234
directories.append((path, previous_path))
236
# Yield the referenced parent directories
237
for direntry in directories:
238
if osutils.is_inside(direntry[0], path):
239
directory_used.add(direntry[0])
240
for (path, previous_path) in entries:
241
if (not path.endswith("/")) or path in directory_used:
242
yield (path, previous_path)
245
return 'HasPathRelations(%r, %r)' % (self.previous_tree, self.previous_entries)
247
def match(self, tree):
248
actual = list(self.get_path_map(tree))
249
if not tree.has_versioned_directories():
250
entries = list(self._strip_unreferenced_directories(
251
self.previous_entries))
253
entries = self.previous_entries
254
if not tree.supports_rename_tracking():
256
(path, path if self.previous_tree.is_versioned(path) else None)
257
for (path, previous_path) in entries]
258
return Equals(entries).match(actual)
261
class RevisionHistoryMatches(Matcher):
262
"""A matcher that checks if a branch has a specific revision history.
264
:ivar history: Revision history, as list of revisions. Oldest first.
267
def __init__(self, history):
268
Matcher.__init__(self)
269
self.expected = history
272
return 'RevisionHistoryMatches(%r)' % self.expected
274
def match(self, branch):
275
with branch.lock_read():
276
graph = branch.repository.get_graph()
277
history = list(graph.iter_lefthand_ancestry(
278
branch.last_revision(), [_mod_revision.NULL_REVISION]))
280
return Equals(self.expected).match(history)
283
class _NoVfsCallsMismatch(Mismatch):
284
"""Mismatch describing a list of HPSS calls which includes VFS requests."""
286
def __init__(self, vfs_calls):
287
self.vfs_calls = vfs_calls
290
return "no VFS calls expected, got: %s" % ",".join([
291
"%s(%s)" % (c.method,
292
", ".join([repr(a) for a in c.args])) for c in self.vfs_calls])
295
class ContainsNoVfsCalls(Matcher):
296
"""Ensure that none of the specified calls are HPSS calls."""
299
return 'ContainsNoVfsCalls()'
302
def match(cls, hpss_calls):
304
for call in hpss_calls:
306
request_method = smart_request_handlers.get(call.call.method)
308
# A method we don't know about doesn't count as a VFS method.
310
if issubclass(request_method, vfs.VfsRequest):
311
vfs_calls.append(call.call)
312
if len(vfs_calls) == 0:
314
return _NoVfsCallsMismatch(vfs_calls)