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

Disconnection test works now.

This commit is contained in:
Itamar Turner-Trauring 2021-09-29 11:17:33 -04:00
parent e64c397fc5
commit 51e8b5e197
1 changed files with 7 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/allmydata/test/test_istorageserver.py
View File

@ -135,9 +135,10 @@ class IStorageServerImmutableAPIsTestsMixin(object):
def test_disconnection(self): def test_disconnection(self):
""" """
If we disconnect in the middle of writing to a bucket, all data is If we disconnect in the middle of writing to a bucket, all data is
wiped, and it's even possible to write different data to the bucket wiped, and it's even possible to write different data to the bucket.
(don't do that though, mostly it's just a good way to test that the
data really was wiped). (In the real world one shouldn't do that, but writing different data is
a good way to test that the original data really was wiped.)
""" """
storage_index, renew_secret, cancel_secret = ( storage_index, renew_secret, cancel_secret = (
new_storage_index(), new_storage_index(),
@ -425,18 +426,9 @@ class _FoolscapMixin(SystemTestMixin):
Disconnect and then reconnect with a new ``IStorageServer``. Disconnect and then reconnect with a new ``IStorageServer``.
""" """
current = self.storage_server current = self.storage_server
self._get_native_server()._rref.tracker.broker.transport.loseConnection() yield self.bounce_client(0)
for i in range(100000): self.storage_server = self._get_native_server().get_storage_server()
yield deferLater(reactor, 0.001) assert self.storage_server is not current
import pdb
pdb.set_trace()
new = self._get_native_server().get_storage_server()
if new is not None and new is not current:
self.storage_server = new
return
raise RuntimeError("Failed to reconnect")
class FoolscapSharedAPIsTests( class FoolscapSharedAPIsTests(