Searched refs:abort_collective_ops (Results 1 – 5 of 5) sorted by relevance
197 context.context().abort_collective_ops(errors.UNAVAILABLE, "peer down")248 context.context().abort_collective_ops(errors.UNAVAILABLE, "peer down")295 context.context().abort_collective_ops(errors.UNAVAILABLE, "peer down")
405 context.context().abort_collective_ops(errors.UNAVAILABLE, 'peer down')472 context.context().abort_collective_ops(errors.UNAVAILABLE, 'peer down')533 context.context().abort_collective_ops(errors.UNAVAILABLE, 'peer down')
828 context.context().abort_collective_ops(834 context.context().abort_collective_ops(
315 context.context().abort_collective_ops(errors.UNAVAILABLE, 'peer down')
746 def abort_collective_ops(self, code, message): member in Context