greg/quoracle
1
0
Fork 0
Code Issues 1 Pull requests 1 Projects Releases Packages Wiki Activity Actions

Raise error if there are no f-resilient quorums.

Browse source
This commit is contained in:
Michael Whittaker 2021-01-22 12:10:43 -08:00
parent 6193204c7d
commit 2d4bcc1a09
1 changed files with 25 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
quorums/quorums.py
View file

@ -326,10 +326,13 @@ class QuorumSystem(Generic[T]):
d) d)
else: else:
xs = [node.x for node in self.nodes()] xs = [node.x for node in self.nodes()]
return self._load_optimal_strategy( read_quorums = list(self._f_resilient_quorums(f, xs, self.reads))
list(self._f_resilient_quorums(f, xs, self.reads)), write_quorums = list(self._f_resilient_quorums(f, xs, self.reads))
list(self._f_resilient_quorums(f, xs, self.writes)), if len(read_quorums) == 0:
d) raise ValueError(f'There are no {f}-resilient read quorums')
if len(write_quorums) == 0:
raise ValueError(f'There are no {f}-resilient write quorums')
return self._load_optimal_strategy(read_quorums, write_quorums, d)
def _f_resilient_quorums(self, def _f_resilient_quorums(self,
f: int, f: int,
@ -524,25 +527,26 @@ class ExplicitStrategy(Strategy[T]):
a = Node('a') # a = Node('a')
b = Node('b') # b = Node('b')
c = Node('c') # c = Node('c')
d = Node('d') # d = Node('d')
e = Node('e') # e = Node('e')
f = Node('f') # f = Node('f')
g = Node('g') # g = Node('g')
h = Node('h') # h = Node('h')
i = Node('i') # i = Node('i')
walls = QuorumSystem(reads=a*b + c*d*e) # walls = QuorumSystem(reads=a*b + c*d*e)
paths = QuorumSystem(reads=a*b + a*c*e + d*e + d*c*b) # paths = QuorumSystem(reads=a*b + a*c*e + d*e + d*c*b)
maj = QuorumSystem(reads=majority([a, b, c, d, e])) # maj = QuorumSystem(reads=majority([a, b, c, d, e]))
#
# for qs in [walls, paths, maj]:
# sigma_0 = qs.strategy(read_fraction=0.5)
# sigma_1 = qs.strategy(read_fraction=0.5, f=1)
# print(sigma_0.load(read_fraction=0.5), sigma_1.load(read_fraction=0.5))
# print(sigma_1)
for qs in [walls, paths, maj]:
sigma_0 = qs.strategy(read_fraction=0.5)
sigma_1 = qs.strategy(read_fraction=0.5, f=1)
print(sigma_0.load(read_fraction=0.5), sigma_1.load(read_fraction=0.5))
print(sigma_1)
# #
# qs = QuorumSystem(reads = a*b + a*c) # qs = QuorumSystem(reads = a*b + a*c)