49         repo = self.make_repository('.')
50         repo.lock_write()
51         repo.start_write_group()
53             self.assertEqual(set(), set(repo.get_missing_parent_inventories()))
55             repo.commit_write_group()
56             repo.unlock()
66     def make_first_commit(self, repo):  argument
67         trunk = repo.controldir.create_branch()
92             repo = self.make_repository(relpath, format='1.9')
94             repo = dir.open_repository()
96             repo = self.make_repository(relpath)
97         if not repo._format.supports_external_lookups:
99         repo.controldir._format.set_branch_format(bzrbranch.BzrBranchFormat7())
100         return repo
102     def reopen_repo_and_resume_write_group(self, repo):  argument
104             resume_tokens = repo.suspend_write_group()
109             repo.unlock()
111         repo.unlock()
112         reopened_repo = repo.controldir.open_repository()
136         repo = self.make_stackable_repo('stacked')
137         repo.lock_write()
138         repo.start_write_group()
145         repo.texts.insert_record_stream(
148         repo.add_inventory(b'rev-2', inv, [b'rev-1', b'ghost-rev'])
149         repo.revisions.insert_record_stream(
154         self.assertEqual(set(), repo.get_missing_parent_inventories())
157         reopened_repo = self.reopen_repo_and_resume_write_group(repo)
181         repo = self.make_stackable_repo('stacked')
182         repo.lock_write()
183         repo.start_write_group()
186         repo.add_inventory(b'rev-2', inv, [b'rev-1'])
187         repo.revisions.insert_record_stream(
192                          repo.inventories.get_missing_compression_parent_keys())
195             repo.get_missing_parent_inventories())
198         reopened_repo = self.reopen_repo_and_resume_write_group(repo)
219         repo = self.make_repository('test-repo')
220         repo.lock_write()
221         self.addCleanup(repo.unlock)
222         repo.start_write_group()
223         self.addCleanup(repo.abort_write_group)
226         if repo.supports_rich_root():
229         repo.texts.insert_record_stream(b.repository.texts.get_record_stream(
231         repo.add_revision(b'A-id', b.repository.get_revision(b'A-id'),
233         get_missing = repo.get_missing_parent_inventories
234         if repo._format.supports_external_lookups:
246         repo = self.make_repository('test-repo')
247         if (not repo._format.supports_external_lookups or
248                 isinstance(repo, remote.RemoteRepository)):
254         orig = repo.get_missing_parent_inventories
259         repo.get_missing_parent_inventories = get_missing
260         repo.lock_write()
261         self.addCleanup(repo.unlock)
262         sink = repo._get_sink()
263         sink.insert_stream((), repo._format, [])
266         repo.start_write_group()
269         repo.texts.insert_record_stream([versionedfile.FulltextContentFactory(
271         tokens = repo.suspend_write_group()
273         sink.insert_stream((), repo._format, tokens)
277         repo = self.make_repository('test-repo')
278         sink = repo._get_sink()
282                           sink.insert_stream_without_locking, stream, repo._format)
285         repo = self.make_repository('test-repo')
286         self.addCleanup(repo.lock_write().unlock)
287         sink = repo._get_sink()
291                           sink.insert_stream_without_locking, stream, repo._format)
294         repo = self.make_repository('test-repo')
295         self.addCleanup(repo.lock_write().unlock)
296         repo.start_write_group()
297         sink = repo._get_sink()
300         missing_keys = sink.insert_stream_without_locking(stream, repo._format)
301         repo.commit_write_group()
310         repo = self.make_repository(relpath)
311         repo.lock_write()
312         self.addCleanup(repo.unlock)
313         return repo
315     def reopen_repo(self, repo):  argument
316         same_repo = repo.controldir.open_repository()
322         repo = self.make_repository('__suspend_test')
323         repo.lock_write()
324         self.addCleanup(repo.unlock)
325         repo.start_write_group()
327             wg_tokens = repo.suspend_write_group()
329             repo.abort_write_group()
333         repo = self.make_write_locked_repo()
334         repo.start_write_group()
337         repo.texts.add_lines((b'file-id', b'revid'), (), [b'lines'])
339             wg_tokens = repo.suspend_write_group()
345             self.assertTrue(repo.is_in_write_group())
346             repo.abort_write_group()
349             self.assertFalse(repo.is_in_write_group())
357         repo = self.make_write_locked_repo()
358         repo.start_write_group()
362         repo.texts.add_lines(text_key, (), [b'lines'])
364             wg_tokens = repo.suspend_write_group()
368             repo.abort_write_group()
370                 errors.UnsuspendableWriteGroup, repo.resume_write_group, [])
373             same_repo = self.reopen_repo(repo)
378             self.assertEqual([], list(repo.texts.keys()))
384         repo = self.make_write_locked_repo()
385         repo.start_write_group()
389         repo.texts.add_lines(first_key, (), [b'lines'])
390         wg_tokens = repo.suspend_write_group()
391         same_repo = self.reopen_repo(repo)
403         same_repo = self.reopen_repo(repo)
412         repo = self.make_write_locked_repo()
413         repo.start_write_group()
417         repo.texts.add_lines(text_key, (), [b'lines'])
418         wg_tokens = repo.suspend_write_group()
419         same_repo = self.reopen_repo(repo)
423         same_repo = self.reopen_repo(repo)
431         repo = self.make_write_locked_repo()
432         repo.start_write_group()
436         repo.texts.add_lines(text_key, (), [b'lines'])
437         wg_tokens = repo.suspend_write_group()
438         self.assertEqual([], list(repo.texts.keys()))
443         repo = self.make_write_locked_repo()
444         repo.start_write_group()
448         repo.texts.add_lines(text_key, (), [b'lines'])
449         wg_tokens = repo.suspend_write_group()
450         same_repo = self.reopen_repo(repo)
458         repo = self.make_write_locked_repo()
459         repo.start_write_group()
463         repo.texts.add_lines(text_key, (), [b'lines'])
464         wg_tokens = repo.suspend_write_group()
465         same_repo = self.reopen_repo(repo)
473         repo = self.make_write_locked_repo()
474         repo.start_write_group()
478         repo.texts.add_lines(text_key, (), [b'lines'])
479         wg_tokens = repo.suspend_write_group()
480         same_repo = self.reopen_repo(repo)
483         same_repo = self.reopen_repo(repo)
491         repo = self.make_write_locked_repo()
492         repo.start_write_group()
496         repo.texts.add_lines(text_key, (), [b'lines'])
497         wg_tokens = repo.suspend_write_group()
498         same_repo = self.reopen_repo(repo)
512         repo = self.make_write_locked_repo()
513         repo.start_write_group()
517         repo.texts.add_lines(first_key, (), [b'lines'])
518         wg_tokens = repo.suspend_write_group()
519         same_repo = self.reopen_repo(repo)
556         repo = self.make_write_locked_repo()
557         repo.start_write_group()
560         repo.texts.insert_record_stream(stream)
564             repo.commit_write_group()
569             same_repo = self.reopen_repo(repo)
576         wg_tokens = repo.suspend_write_group()
577         same_repo = self.reopen_repo(repo)
590         repo = self.make_write_locked_repo()
591         repo.start_write_group()
595         repo.texts.add_lines(text_key, (), [b'lines'])
597         wg_tokens = repo.suspend_write_group()
598         same_repo = self.reopen_repo(repo)
613             same_repo = self.reopen_repo(repo)
628         repo = self.make_write_locked_repo()
629         repo.start_write_group()
632         repo.texts.insert_record_stream(stream)
634         wg_tokens = repo.suspend_write_group()
635         same_repo = self.reopen_repo(repo)
649         repo = self.make_write_locked_repo()
650         repo.start_write_group()
651         wg_tokens = repo.suspend_write_group()
658         repo = self.make_write_locked_repo()
659         repo.resume_write_group([])
660         repo.abort_write_group()