143
143
def _create_repo_revisions(repo, basis, delta, invalid_delta):
144
repo.start_write_group()
144
with repository.WriteGroup(repo):
146
145
rev = revision.Revision(b'basis', timestamp=0, timezone=None,
147
146
message="", committer="foo@example.com")
148
147
basis.revision_id = b'basis'
161
160
rev = revision.Revision(b'result', timestamp=0, timezone=None,
162
161
message="", committer="foo@example.com")
163
162
repo.add_revision(b'result', rev, result_inv)
164
repo.commit_write_group()
166
repo.abort_write_group()
168
163
return target_entries
171
166
def _get_basis_entries(tree):
172
167
basis_tree = tree.basis_tree()
173
basis_tree.lock_read()
174
basis_tree_entries = list(basis_tree.inventory.iter_entries_by_dir())
176
return basis_tree_entries
168
with basis_tree.lock_read():
169
return list(basis_tree.inventory.iter_entries_by_dir())
179
172
def _populate_different_tree(tree, basis, delta):
253
246
format = self.format()
254
247
control = self.make_controldir('tree', format=format._matchingcontroldir)
255
248
repo = format.initialize(control)
256
with repo.lock_write():
257
repo.start_write_group()
259
rev = revision.Revision(b'basis', timestamp=0, timezone=None,
260
message="", committer="foo@example.com")
261
basis.revision_id = b'basis'
262
create_texts_for_inv(repo, basis)
263
repo.add_revision(b'basis', rev, basis)
264
repo.commit_write_group()
266
repo.abort_write_group()
268
with repo.lock_write():
269
repo.start_write_group()
271
inv_sha1 = repo.add_inventory_by_delta(b'basis', delta,
272
b'result', [b'basis'])
274
repo.abort_write_group()
277
repo.commit_write_group()
249
with repo.lock_write(), repository.WriteGroup(repo):
250
rev = revision.Revision(
251
b'basis', timestamp=0, timezone=None, message="",
252
committer="foo@example.com")
253
basis.revision_id = b'basis'
254
create_texts_for_inv(repo, basis)
255
repo.add_revision(b'basis', rev, basis)
256
with repo.lock_write(), repository.WriteGroup(repo):
257
inv_sha1 = repo.add_inventory_by_delta(
258
b'basis', delta, b'result', [b'basis'])
278
259
# Fresh lock, reads disk again.
279
260
repo = repo.controldir.open_repository()