/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()
|