+ def _check_uploader_count(ign, name, expected):
+ self.failUnlessReallyEqual(self._get_count('uploader.'+name, client=self.alice_magicfolder._client),
+ expected)
+ def _check_downloader_count(ign, name, expected):
+ self.failUnlessReallyEqual(self._get_count('downloader.'+name, client=self.bob_magicfolder._client),
+ expected)
+
+ def _wait_for(ign, something_to_do):
+ downloaded_d = self.bob_magicfolder.downloader.set_hook('processed')
+ uploaded_d = self.alice_magicfolder.uploader.set_hook('processed')
+ something_to_do()
+ print "Waiting for Alice to upload\n"
+ alice_clock.advance(0)
+ def _wait_for_Bob(ign):
+ print "Now waiting for Bob to download\n"
+ bob_clock.advance(0)
+ return downloaded_d
+ uploaded_d.addCallback(_wait_for_Bob)
+ return uploaded_d
+
+ def Alice_to_write_a_file():