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

IStorageServer test for overlapping writes.

Browse Source
This commit is contained in:
Itamar Turner-Trauring 2021-09-24 12:02:30 -04:00
parent 6ef3811112
commit c1f8e9f8c7
1 changed files with 23 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -24,7 +24,7 @@ from testtools import skipIf
from twisted.internet.defer import inlineCallbacks from twisted.internet.defer import inlineCallbacks
from foolscap.api import Referenceable from foolscap.api import Referenceable, RemoteException
from allmydata.interfaces import IStorageServer from allmydata.interfaces import IStorageServer
from .common_system import SystemTestMixin from .common_system import SystemTestMixin
@ -248,11 +248,31 @@ class IStorageServerImmutableAPIsTestsMixin(object):
(yield buckets[2].callRemote("read", 0, 1024)), b"3" * 512 + b"4" * 512 (yield buckets[2].callRemote("read", 0, 1024)), b"3" * 512 + b"4" * 512
) )
@inlineCallbacks
def test_overlapping_writes(self): def test_overlapping_writes(self):
""" """
Overlapping writes in immutable uploads fail with ``OverlappingWriteError``. Overlapping, non-identical writes in immutable uploads fail.
""" """
1/0 storage_index, renew_secret, cancel_secret = (
new_storage_index(),
new_secret(),
new_secret(),
)
(_, allocated) = yield self.storage_server.allocate_buckets(
storage_index,
renew_secret,
cancel_secret,
sharenums={0},
allocated_size=30,
canary=Referenceable(),
)
yield allocated[0].callRemote("write", 0, b"1" * 10)
# Overlapping write that matches:
yield allocated[0].callRemote("write", 5, b"1" * 20)
# Overlapping write that doesn't match:
with self.assertRaises(RemoteException):
yield allocated[0].callRemote("write", 20, b"2" * 10)
class _FoolscapMixin(SystemTestMixin): class _FoolscapMixin(SystemTestMixin):