Searched refs:in_transit_ (Results 1 – 10 of 10) sorted by relevance
106 if (is_closed_ || in_transit_) in Watch()116 if (is_closed_ || in_transit_) in CancelWatch()126 if (!shared_ring_buffer_ || in_transit_) in WriteData()194 if (!shared_ring_buffer_ || in_transit_) in BeginWriteData()221 if (is_closed_ || in_transit_) in EndWriteData()269 if (!shared_ring_buffer_ || in_transit_) { in AddAwakable()295 if ((!shared_ring_buffer_ || in_transit_) && signals_state) in RemoveAwakable()306 DCHECK(in_transit_); in StartSerialize()321 DCHECK(in_transit_); in EndSerialize()337 if (in_transit_) in BeginTransit()[all …]
107 if (is_closed_ || in_transit_) in Watch()117 if (is_closed_ || in_transit_) in CancelWatch()129 if (!shared_ring_buffer_ || in_transit_) in ReadData()210 if (!shared_ring_buffer_ || in_transit_) in BeginReadData()248 if (in_transit_) in EndReadData()291 if (!shared_ring_buffer_ || in_transit_) { in AddAwakable()317 if ((!shared_ring_buffer_ || in_transit_) && signals_state) in RemoveAwakable()328 DCHECK(in_transit_); in StartSerialize()343 DCHECK(in_transit_); in EndSerialize()359 if (in_transit_) in BeginTransit()[all …]
29 if (is_closed_ || in_transit_) in Close()56 if (in_transit_) in BeginTransit()58 in_transit_ = !is_closed_; in BeginTransit()59 return in_transit_; in BeginTransit()65 in_transit_ = false; in CompleteTransitAndClose()74 in_transit_ = false; in CancelTransit()99 DCHECK(is_closed_ && !in_transit_); in ~PlatformHandleDispatcher()
165 if (!shared_buffer_ || in_transit_) in PassPlatformSharedBuffer()179 if (in_transit_) in Close()196 if (in_transit_) in DuplicateBufferHandle()229 if (in_transit_ || in MapBuffer()277 if (in_transit_) in BeginTransit()279 in_transit_ = static_cast<bool>(shared_buffer_); in BeginTransit()280 return in_transit_; in BeginTransit()285 in_transit_ = false; in CompleteTransitAndClose()292 in_transit_ = false; in CancelTransit()303 DCHECK(!shared_buffer_ && !in_transit_); in ~SharedBufferDispatcher()
217 if (port_closed_ || in_transit_) in Watch()227 if (port_closed_ || in_transit_) in CancelWatch()236 if (port_closed_ || in_transit_) in WriteMessage()270 if (port_closed_ || in_transit_) in ReadMessage()406 if (port_closed_ || in_transit_) { in AddAwakable()444 if (port_closed_ || in_transit_) { in RemoveAwakable()479 if (in_transit_ || port_closed_) in BeginTransit()481 in_transit_.Set(true); in BeginTransit()482 return in_transit_; in BeginTransit()490 in_transit_.Set(false); in CompleteTransitAndClose()[all …]
51 bool in_transit_ = false; variable
113 bool in_transit_ = false; variable
109 AtomicFlag in_transit_; variable
112 bool in_transit_ = false; variable
114 bool in_transit_ = false; variable