Searched refs:shared_ring_buffer_ (Results 1 – 4 of 4) sorted by relevance
83 shared_ring_buffer_(shared_ring_buffer) { in DataPipeConsumerDispatcher()129 if (!shared_ring_buffer_ || in_transit_) in ReadData()210 if (!shared_ring_buffer_ || in_transit_) in BeginReadData()251 CHECK(shared_ring_buffer_); in EndReadData()291 if (!shared_ring_buffer_ || in_transit_) { in AddAwakable()317 if ((!shared_ring_buffer_ || in_transit_) && signals_state) in RemoveAwakable()351 buffer_handle_for_transit_ = shared_ring_buffer_->DuplicatePlatformHandle(); in EndSerialize()435 DCHECK(is_closed_ && !shared_ring_buffer_ && !ring_buffer_mapping_ && in ~DataPipeConsumerDispatcher()442 if (shared_ring_buffer_) { in InitializeNoLock()445 shared_ring_buffer_->Map(0, options_.capacity_num_bytes); in InitializeNoLock()[all …]
82 shared_ring_buffer_(shared_ring_buffer), in DataPipeProducerDispatcher()126 if (!shared_ring_buffer_ || in_transit_) in WriteData()194 if (!shared_ring_buffer_ || in_transit_) in BeginWriteData()227 DCHECK(shared_ring_buffer_); in EndWriteData()269 if (!shared_ring_buffer_ || in_transit_) { in AddAwakable()295 if ((!shared_ring_buffer_ || in_transit_) && signals_state) in RemoveAwakable()329 buffer_handle_for_transit_ = shared_ring_buffer_->DuplicatePlatformHandle(); in EndSerialize()412 DCHECK(is_closed_ && !in_transit_ && !shared_ring_buffer_ && in ~DataPipeProducerDispatcher()419 if (shared_ring_buffer_) { in InitializeNoLock()421 shared_ring_buffer_->Map(0, options_.capacity_num_bytes); in InitializeNoLock()[all …]
110 scoped_refptr<PlatformSharedBuffer> shared_ring_buffer_; variable
105 scoped_refptr<PlatformSharedBuffer> shared_ring_buffer_; variable