From 789a7edb56501e5e7d95c93e7570bb4fc1197507 Mon Sep 17 00:00:00 2001 From: Itamar Turner-Trauring Date: Thu, 2 Sep 2021 15:21:42 -0400 Subject: [PATCH] Get rid of more callRemoteOnly usage. --- src/allmydata/immutable/downloader/share.py | 4 +++- src/allmydata/storage_client.py | 4 ++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/src/allmydata/immutable/downloader/share.py b/src/allmydata/immutable/downloader/share.py index 86b99e99c..1e751500b 100644 --- a/src/allmydata/immutable/downloader/share.py +++ b/src/allmydata/immutable/downloader/share.py @@ -475,7 +475,9 @@ class Share(object): # there was corruption somewhere in the given range reason = "corruption in share[%d-%d): %s" % (start, start+offset, str(f.value)) - self._rref.callRemoteOnly("advise_corrupt_share", reason.encode("utf-8")) + self._rref.callRemote( + "advise_corrupt_share", reason.encode("utf-8") + ).addErrback(log.err) def _satisfy_block_hash_tree(self, needed_hashes): o_bh = self.actual_offsets["block_hashes"] diff --git a/src/allmydata/storage_client.py b/src/allmydata/storage_client.py index 22dd09bcb..c278abce3 100644 --- a/src/allmydata/storage_client.py +++ b/src/allmydata/storage_client.py @@ -1009,10 +1009,10 @@ class _StorageServer(object): shnum, reason, ): - return self._rref.callRemoteOnly( + self._rref.callRemote( "advise_corrupt_share", share_type, storage_index, shnum, reason, - ) + ).addErrback(log.err)