Searched refs:ElementOrEOF (Results 1 – 3 of 3) sorted by relevance
302 struct ElementOrEOF { struct337 void Consume(ElementOrEOF* be) TF_LOCKS_EXCLUDED(mu_);344 std::deque<ElementOrEOF> deque_ TF_GUARDED_BY(mu_);
954 ElementOrEOF element; in Write()961 ElementOrEOF be; in SignalEOF()966 void AsyncWriter::Consume(ElementOrEOF* be) { in Consume()987 ElementOrEOF be; in WriterThread()
2067 snapshot_util::ElementOrEOF elem; in FillBuffer()2101 snapshot_util::ElementOrEOF elem_copy = next_elem_; in FillBuffer()2120 snapshot_util::ElementOrEOF elem; in ProcessOneElement()2283 snapshot_util::ElementOrEOF next_elem_ TF_GUARDED_BY(mu_);2296 std::deque<snapshot_util::ElementOrEOF> buffer_ TF_GUARDED_BY(mu_);