mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-02-18 17:00:24 +00:00
put the _perform_scan into an eliot action
This commit is contained in:
parent
e1de96486c
commit
20150541a7
@ -1084,15 +1084,16 @@ class MagicFolderAliceBobTestMixin(MagicFolderCLITestMixin, ShouldFailMixin, Rea
|
||||
# now, we ONLY want to do the scan, not a full iteration of
|
||||
# the process loop. So we do just the scan part "by hand" in
|
||||
# Bob's downloader
|
||||
yield self.bob_magicfolder.downloader._perform_scan()
|
||||
# while we're delving into internals, I guess we might as well
|
||||
# confirm that we did queue up an item to download
|
||||
self.assertEqual(1, len(self.bob_magicfolder.downloader._deque))
|
||||
|
||||
# break all the servers so the download fails. the count is 2
|
||||
# because the "full iteration" will do a scan (downloading the
|
||||
# metadata file) and then process the deque (trying to
|
||||
# download the item we queued up already)
|
||||
with start_action(action_type=u"test:perform-scan"):
|
||||
yield self.bob_magicfolder.downloader._perform_scan()
|
||||
# while we're delving into internals, I guess we might as well
|
||||
# confirm that we did queue up an item to download
|
||||
self.assertEqual(1, len(self.bob_magicfolder.downloader._deque))
|
||||
for server_id in self.g.get_all_serverids():
|
||||
self.g.break_server(server_id, count=2)
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user