Searched refs:writers_closed_ (Results 1 – 2 of 2) sorted by relevance
39 ++writers_closed_; in OnWriterClosed()44 << " writers_closed_=" << writers_closed_; in OnWriterClosed()46 die_unless(writers_closed_ <= num_hosts() * workers_per_host()); in OnWriterClosed()50 if (writers_closed_ == num_hosts() * workers_per_host()) { in OnWriterClosed()
187 size_t writers_closed_ = 0; member in thrill::data::StreamData