Searched refs:sem_closing_blocks_ (Results 1 – 3 of 3) sorted by relevance
132 << " remaining=" << sem_closing_blocks_.value(); in Close()133 sem_closing_blocks_.wait(); in Close()230 sem_closing_blocks_.signal(); in OnStreamBlockOrdered()
208 sem_closing_blocks_.wait(); in Close()310 sem_closing_blocks_.signal(); in OnStreamBlockOrdered()
184 tlx::Semaphore sem_closing_blocks_; member in thrill::data::StreamData