| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | AbstractChannel.kt | 83 …protected val closedForSend: Closed<*>? get() = (queue.prevNode as? Closed<*>)?.also { helpClose(i… in <lambda>()
89 …protected val closedForReceive: Closed<*>? get() = (queue.nextNode as? Closed<*>)?.also { helpClos… in <lambda>()
96 queue.removeFirstIfIsInstanceOfOrPeekIf<Send> { it is Closed<*> } in <lambda>()
121 is Closed<*> -> affected in <lambda>()
150 result is Closed<*> -> { in <lambda>()
157 private fun helpCloseAndGetSendException(element: E, closed: Closed<*>): Throwable { in <lambda>()
182 enqueueResult is Closed<*> -> { in <lambda>()
199 offerResult is Closed<*> -> { in <lambda>()
208 private fun Continuation<*>.helpCloseAndResumeWithSendException(element: E, closed: Closed<*>) { in <lambda>()
242 val closed = Closed<E>(cause) in <lambda>()
[all …]
|
| D | ConflatedBroadcastChannel.kt | 50 private val CLOSED = Closed(null) in <lambda>()
60 private class Closed(@JvmField val closeCause: Throwable?) { in <lambda>() class
76 is Closed -> throw state.valueException in <lambda>()
91 is Closed -> null in <lambda>()
96 public override val isClosedForSend: Boolean get() = _state.value is Closed in <lambda>()
104 is Closed -> { in <lambda>()
124 is Closed -> return in <lambda>()
163 is Closed -> return false in <lambda>()
165 val update = if (cause == null) CLOSED else Closed(cause) in <lambda>()
197 if (state is Closed && onCloseHandler.compareAndSet(handler, HANDLER_INVOKED)) { in <lambda>()
[all …]
|
| D | Channel.kt | 347 public val isClosed: Boolean get() = holder is Closed
363 get() = if (holder is Closed) error(DEFAULT_CLOSE_MESSAGE) else holder as T
372 get() = if (holder is Closed) null else holder as T
391 if (holder is Closed) holder.cause else error("Channel was not closed")
398 is Closed -> holder.toString() in toString()
402 internal class Closed(@JvmField val cause: Throwable?) { class in kotlinx.coroutines.channels.ValueOrClosed
405 override fun equals(other: Any?): Boolean = other is Closed && cause == other.cause in equals()
420 ValueOrClosed(Closed(cause)) in equals()
|
| D | ArrayBroadcastChannel.kt | 173 if (send is Closed<*>) break // break when closed for send in updateHead()
239 var closed: Closed<*>? = null in elementAt()
251 result is Closed<*> -> { in elementAt()
258 if (receive is Closed<*>) break // noting more to do if this sub already closed in elementAt()
280 result is Closed<*> -> { /* just bail out of lock */ } in elementAt()
292 (result as? Closed<*>)?.also { close(cause = it.closeCause) } in elementAt()
309 result is Closed<*> -> { /* just bail out of lock */ } in elementAt()
326 (result as? Closed<*>)?.also { close(cause = it.closeCause) } in elementAt()
|
| D | LinkedListChannel.kt | 35 is Closed<*> -> return sendResult in offerInternal()
39 result is Closed<*> -> return result in offerInternal()
56 result is Closed<*> -> return result in offerSelectInternal()
|
| D | ArrayChannel.kt | 68 if (receive is Closed) { in offerInternal()
109 failure === ALREADY_SELECTED || failure is Closed<*> -> { in offerSelectInternal()
205 if (replacement !== POLL_FAILED && replacement !is Closed<*>) { in pollInternal()
249 failure is Closed<*> -> { in pollSelectInternal()
259 if (replacement !== POLL_FAILED && replacement !is Closed<*>) { in pollSelectInternal()
|
| D | ConflatedChannel.kt | 42 if (receive is Closed) { in offerInternal()
76 failure === ALREADY_SELECTED || failure is Closed<*> -> return failure in offerSelectInternal()
|
| /external/rust/crates/tokio/src/sync/mpsc/ |
| D | error.rs | 30 Closed(T), enumerator
42 TrySendError::Closed(..) => "channel closed", in fmt()
50 TrySendError::Closed(src.0) in from()
80 Closed(T),
92 SendTimeoutError::Closed(..) => "channel closed",
|
| D | bounded.rs | 453 Err(TryAcquireError::Closed) => return Err(TrySendError::Closed(message)), in try_send()
519 return Err(SendTimeoutError::Closed(value)); in send_timeout()
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_broadcast.rs | 2 use crate::sync::broadcast::error::RecvError::{Closed, Lagged};
37 Err(Closed) => break, in broadcast_send()
65 Closed => {} in broadcast_two()
80 Closed => {} in broadcast_two()
108 Err(Closed) => break, in broadcast_wrap()
124 Err(Closed) => break, in broadcast_wrap()
162 Closed => {} in drop_rx()
|
| /external/rust/crates/tokio/src/sync/ |
| D | broadcast.rs | 237 Closed, enumerator
249 RecvError::Closed => write!(f, "channel closed"), in fmt()
271 Closed, enumerator
285 TryRecvError::Closed => write!(f, "channel closed"), in fmt()
804 return Err(TryRecvError::Closed); in recv_ref()
924 guard.clone_value().ok_or(TryRecvError::Closed) in try_recv()
941 Err(TryRecvError::Closed) => break, in drop()
990 Err(TryRecvError::Closed) => return Poll::Ready(Err(RecvError::Closed)), in poll()
993 Poll::Ready(guard.clone_value().ok_or(RecvError::Closed)) in poll()
|
| D | oneshot.rs | 144 Closed, enumerator
163 TryRecvError::Closed => write!(fmt, "channel closed"), in fmt()
666 None => Err(TryRecvError::Closed), in try_recv()
669 Err(TryRecvError::Closed) in try_recv()
675 Err(TryRecvError::Closed) in try_recv()
|
| D | rwlock.rs | 433 Err(TryAcquireError::Closed) => unreachable!(), in try_read()
485 Err(TryAcquireError::Closed) => unreachable!(), in try_read_owned()
601 Err(TryAcquireError::Closed) => unreachable!(), in try_write()
646 Err(TryAcquireError::Closed) => unreachable!(), in try_write_owned()
|
| D | batch_semaphore.rs | 52 Closed, enumerator
215 return Err(TryAcquireError::Closed); in try_acquire()
543 matches!(self, TryAcquireError::Closed) in is_closed()
557 TryAcquireError::Closed => write!(fmt, "semaphore closed"), in fmt()
|
| /external/oboe/src/opensles/ |
| D | AudioOutputStreamOpenSLES.cpp | 249 if (getState() == StreamState::Closed){ in close()
288 case StreamState::Closed: in requestStart()
329 case StreamState::Closed: in requestPause_l()
360 if (getState() == StreamState::Closed) { in requestFlush_l()
386 case StreamState::Closed: in requestStop()
|
| D | AudioStreamBuffered.cpp | 222 if (getState() == StreamState::Closed){ in write()
238 if (getState() == StreamState::Closed){ in read()
253 if (getState() == StreamState::Closed){ in setBufferSizeInFrames()
|
| D | AudioInputStreamOpenSLES.cpp | 225 if (getState() == StreamState::Closed){ in close()
262 case StreamState::Closed: in requestStart()
311 case StreamState::Closed: in requestStop_l()
|
| /external/rust/crates/zip/src/ |
| D | write.rs | 26 Closed, enumerator
465 let inner = mem::replace(&mut self.inner, GenericZipWriter::Closed); in finish()
522 let bare = match mem::replace(self, GenericZipWriter::Closed) { in switch_to()
532 GenericZipWriter::Closed => { in switch_to()
578 GenericZipWriter::Closed => None, in ref_mut()
584 GenericZipWriter::Closed => true, in is_closed()
607 GenericZipWriter::Closed => None, in current_compression()
|
| /external/llvm-project/clang/lib/StaticAnalyzer/Checkers/ |
| D | SimpleStreamChecker.cpp | 32 enum Kind { Opened, Closed } K; enumerator
37 bool isClosed() const { return K == Closed; } in isClosed()
40 static StreamState getClosed() { return StreamState(Closed); } in getClosed()
|
| /external/clang/lib/StaticAnalyzer/Checkers/ |
| D | SimpleStreamChecker.cpp | 33 enum Kind { Opened, Closed } K; enumerator
38 bool isClosed() const { return K == Closed; } in isClosed()
41 static StreamState getClosed() { return StreamState(Closed); } in getClosed()
|
| /external/brotli/csharp/org/brotli/dec/ |
| D | State.cs | 163 if (state.runningState == Org.Brotli.Dec.RunningState.Closed) in Close()
167 state.runningState = Org.Brotli.Dec.RunningState.Closed; in Close()
|
| D | RunningState.cs | 33 internal const int Closed = 11; field in Org.Brotli.Dec.RunningState
|
| /external/llvm-project/llvm/test/Other/ |
| D | opt-Os-pipeline.ll | 94 ; CHECK-NEXT: Loop-Closed SSA Form Pass
117 ; CHECK-NEXT: Loop-Closed SSA Form Pass
159 ; CHECK-NEXT: Loop-Closed SSA Form Pass
197 ; CHECK-NEXT: Loop-Closed SSA Form Pass
251 ; CHECK-NEXT: Loop-Closed SSA Form Pass
262 ; CHECK-NEXT: Loop-Closed SSA Form Pass
288 ; CHECK-NEXT: Loop-Closed SSA Form Pass
|
| D | opt-O2-pipeline.ll | 108 ; CHECK-NEXT: Loop-Closed SSA Form Pass
131 ; CHECK-NEXT: Loop-Closed SSA Form Pass
173 ; CHECK-NEXT: Loop-Closed SSA Form Pass
211 ; CHECK-NEXT: Loop-Closed SSA Form Pass
265 ; CHECK-NEXT: Loop-Closed SSA Form Pass
276 ; CHECK-NEXT: Loop-Closed SSA Form Pass
302 ; CHECK-NEXT: Loop-Closed SSA Form Pass
|
| /external/rust/crates/walkdir/src/ |
| D | lib.rs | 653 Closed(vec::IntoIter<Result<DirEntry>>), enumerator
895 list = DirList::Closed(entries.into_iter()); in push()
982 *self = DirList::Closed(self.collect::<Vec<_>>().into_iter()); in close()
993 DirList::Closed(ref mut it) => it.next(), in next()
|