quoracle\quorum_system.py

"""
Original code available at: https://github.com/mwhittaker/quoracle/blob/d83a811a905a51fc13ebc00ddac036d559463380/quoracle/quorum_system.py#L509
"""
def latency() -> pulp.LpAffineExpression:
    reads = fr * sum(
        v * self._read_quorum_latency(quorum).total_seconds()
        for (rq, v) in zip(read_quorums, read_quorum_vars)
        for quorum in [{self.node(x) for x in rq}]
    )
    writes = (1 - fr) * sum(
        v * self._write_quorum_latency(quorum).total_seconds()
        for (wq, v) in zip(write_quorums, write_quorum_vars)
        for quorum in [{self.node(x) for x in wq}]
    )
    return reads + writes