ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-05-02 09:03:00 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Don't use real reactor in these tests.

Browse Source
This commit is contained in:
Itamar Turner-Trauring 2022-02-02 11:00:16 -05:00
parent 70d0bd0597
commit aebb5056de
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/allmydata/test/test_storage_http.py
View File

@ -23,6 +23,7 @@ from treq.testing import StubTreq
from klein import Klein from klein import Klein
from hyperlink import DecodedURL from hyperlink import DecodedURL
from collections_extended import RangeMap from collections_extended import RangeMap
from twisted.internet.task import Clock
from .common import SyncTestCase from .common import SyncTestCase
from ..storage.server import StorageServer from ..storage.server import StorageServer
@ -230,8 +231,11 @@ class HttpTestFixture(Fixture):
""" """
def _setUp(self): def _setUp(self):
self.clock = Clock()
self.tempdir = self.useFixture(TempDir()) self.tempdir = self.useFixture(TempDir())
self.storage_server = StorageServer(self.tempdir.path, b"\x00" * 20) self.storage_server = StorageServer(
self.tempdir.path, b"\x00" * 20, clock=self.clock
)
self.http_server = HTTPServer(self.storage_server, SWISSNUM_FOR_TEST) self.http_server = HTTPServer(self.storage_server, SWISSNUM_FOR_TEST)
self.client = StorageClient( self.client = StorageClient(
DecodedURL.from_text("http://127.0.0.1"), DecodedURL.from_text("http://127.0.0.1"),
@ -401,13 +405,15 @@ class ImmutableHTTPAPITests(SyncTestCase):
# Upload shares 1 and 3: # Upload shares 1 and 3:
for share_number in [1, 3]: for share_number in [1, 3]:
progress = result_of(im_client.write_share_chunk( progress = result_of(
im_client.write_share_chunk(
storage_index, storage_index,
share_number, share_number,
upload_secret, upload_secret,
0, 0,
b"0123456789", b"0123456789",
)) )
)
self.assertTrue(progress.finished) self.assertTrue(progress.finished)
# Now shares 1 and 3 exist: # Now shares 1 and 3 exist: