tahoe-lafs/tahoe-lafs
tahoe-lafs
/
tahoe-lafs
2
0
Fork 0
Code Issues Pull Requests 23 Packages Projects Releases 1 Wiki Activity

put the _process_deque into an action too

This commit is contained in:
Jean-Paul Calderone 2019-03-18 15:28:16 -04:00
parent 20150541a7
commit 0ac96e9113
1 changed files with 20 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/allmydata/test/test_magic_folder.py
View File

@ -1100,27 +1100,28 @@ class MagicFolderAliceBobTestMixin(MagicFolderCLITestMixin, ShouldFailMixin, Rea
# now let bob try to do the download. Reach in and call # now let bob try to do the download. Reach in and call
# _process_deque directly because we are already half-way through a # _process_deque directly because we are already half-way through a
# logical iteration thanks to the _perform_scan call above. # logical iteration thanks to the _perform_scan call above.
yield self.bob_magicfolder.downloader._process_deque() with start_action(action_type=u"test:process-deque"):
yield self.bob_magicfolder.downloader._process_deque()
self.eliot_logger.flushTracebacks(UnrecoverableFileError) self.eliot_logger.flushTracebacks(UnrecoverableFileError)
logged = self.eliot_logger.flushTracebacks(NoSharesError) logged = self.eliot_logger.flushTracebacks(NoSharesError)
self.assertEqual( self.assertEqual(
1, 1,
len(logged), len(logged),
"Got other than expected single NoSharesError: {}".format(logged), "Got other than expected single NoSharesError: {}".format(logged),
) )
# ...however Bob shouldn't have downloaded anything # ...however Bob shouldn't have downloaded anything
self._check_version_in_local_db(self.bob_magicfolder, u"blam", 0) self._check_version_in_local_db(self.bob_magicfolder, u"blam", 0)
# bob should *not* have downloaded anything, as we failed all the servers # bob should *not* have downloaded anything, as we failed all the servers
self.failUnlessReallyEqual( self.failUnlessReallyEqual(
self._get_count('downloader.objects_downloaded', client=self.bob_magicfolder._client), self._get_count('downloader.objects_downloaded', client=self.bob_magicfolder._client),
0 0
) )
self.failUnlessReallyEqual( self.failUnlessReallyEqual(
self._get_count('downloader.objects_failed', client=self.bob_magicfolder._client), self._get_count('downloader.objects_failed', client=self.bob_magicfolder._client),
1 1
) )
# now we let Bob try again # now we let Bob try again
yield iterate(self.bob_magicfolder) yield iterate(self.bob_magicfolder)