Searched refs:remaining_closing_blocks_ (Results 1 – 3 of 3) sorted by relevance
36 remaining_closing_blocks_ = num_hosts() * workers_per_host(); in MixStreamData()220 << "remaining_closing_blocks_" << remaining_closing_blocks_; in OnStreamBlockOrdered()224 die_unless(remaining_closing_blocks_ > 0); in OnStreamBlockOrdered()225 if (--remaining_closing_blocks_ == 0) { in OnStreamBlockOrdered()
35 remaining_closing_blocks_ = (num_hosts() - 1) * workers_per_host(); in CatStreamData()300 << "remaining_closing_blocks_" << remaining_closing_blocks_; in OnStreamBlockOrdered()304 die_unless(remaining_closing_blocks_ > 0); in OnStreamBlockOrdered()305 if (--remaining_closing_blocks_ == 0) { in OnStreamBlockOrdered()
181 std::atomic<size_t> remaining_closing_blocks_; member in thrill::data::StreamData