Searched refs:abort_collective_ops (Results 1 – 5 of 5) sorted by relevance
193 context.context().abort_collective_ops(errors.UNAVAILABLE, "peer down")244 context.context().abort_collective_ops(errors.UNAVAILABLE, "peer down")291 context.context().abort_collective_ops(errors.UNAVAILABLE, "peer down")
747 context.context().abort_collective_ops(errors.UNAVAILABLE, 'peer down')823 context.context().abort_collective_ops(errors.UNAVAILABLE, 'peer down')892 context.context().abort_collective_ops(errors.UNAVAILABLE, 'peer down')
886 context.context().abort_collective_ops(892 context.context().abort_collective_ops(
311 context.context().abort_collective_ops(errors.UNAVAILABLE, 'peer down')
871 def abort_collective_ops(self, code, message): member in Context