Searched refs:waiting_for (Results 1 – 2 of 2) sorted by relevance
465 def reap(self, waiting_for=None, waiting_for_cost=None): argument494 if waiting_for is not None:495 wstr = ' next: %s @ %.2f cpu' % (waiting_for,
162 int waiting_for = partitions_.size(); in RetrieveLogs() local163 if (waiting_for > 0) { in RetrieveLogs()165 BlockingCounter all_done(waiting_for); in RetrieveLogs()