Searched refs:to_run (Results 1 – 2 of 2) sorted by relevance
381 Collective* to_run = nullptr; in SignalMultiNodeReady() local388 to_run = CheckReady(collective_key, collective); in SignalMultiNodeReady()392 if (to_run != nullptr) RunCollective(to_run); in SignalMultiNodeReady()399 Collective* to_run = nullptr; in AddParticipant() local466 to_run = CheckReady(context.collective_key, collective); in AddParticipant()469 if (to_run != nullptr) RunCollective(to_run); in AddParticipant()474 Collective* to_run = nullptr; in CheckReady() local479 to_run = collective; in CheckReady()485 return to_run; in CheckReady()
289 to_run = {301 run_result = self.evaluate(to_run)