| /external/mockito-kotlin/tests/src/test/kotlin/test/ |
| D | Classes.kt | 43 class Closed in stringResult() class
48 fun closed(c: Closed) in stringResult()
49 fun closedArray(a: Array<Closed>) in stringResult()
50 fun closedNullableArray(a: Array<Closed?>) in stringResult()
51 fun closedCollection(c: Collection<Closed>) in stringResult()
52 fun closedList(c: List<Closed>) in stringResult()
53 fun closedStringMap(m: Map<Closed, String>) in stringResult()
54 fun closedSet(s: Set<Closed>) in stringResult()
64 fun closedVararg(vararg c: Closed) in stringResult()
|
| D | MatchersTest.kt | 35 closed(Closed()) in anyClosedClass()
51 closedArray(arrayOf(Closed())) in anyClassArray()
59 closedNullableArray(arrayOf(Closed(), null)) in anyNullableClassArray()
67 closedVararg(Closed(), Closed()) in anyStringVararg()
163 closedList(listOf(Closed(), Closed())) in listArgThat()
175 closedList(listOf(Closed(), Closed())) in listArgForWhich()
187 closedList(listOf(Closed(), Closed())) in listArgWhere()
199 closedList(listOf(Closed(), Closed())) in listArgCheck()
211 closedList(listOf(Closed(), Closed())) in checkProperlyFails()
|
| /external/rust/crates/tokio-util/src/sync/ |
| D | mpsc.rs | 37 Closed, enumerator
78 mem::replace(&mut self.state, State::Closed) in take_state()
109 Poll::Ready(Err(e)) => (Some(Poll::Ready(Err(e))), State::Closed), in poll_reserve()
114 s @ State::Closed => (Some(Poll::Ready(Err(PollSendError(None)))), s), in poll_reserve()
148 State::Closed => (Err(PollSendError(Some(value))), State::Closed), in send_item()
155 State::Closed in send_item()
164 matches!(self.state, State::Closed) || self.sender.is_none() in is_closed()
195 State::Idle(_) => self.state = State::Closed, in close()
198 self.state = State::Closed; in close()
224 None => State::Closed, in abort_send()
[all …]
|
| /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/mpsc/ |
| D | error.rs | 30 Closed(T), enumerator
42 TrySendError::Closed(..) => "channel closed", in fmt()
50 TrySendError::Closed(src.0) in from()
108 Closed(T),
120 SendTimeoutError::Closed(..) => "channel closed",
|
| D | bounded.rs | 584 Err(TryAcquireError::Closed) => return Err(TrySendError::Closed(message)), in try_send()
655 return Err(SendTimeoutError::Closed(value)); in send_timeout()
914 Err(TryAcquireError::Closed) => return Err(TrySendError::Closed(())), in try_reserve()
979 Err(TryAcquireError::Closed) => return Err(TrySendError::Closed(self)), in try_reserve_owned()
|
| D | list.rs | 40 Closed, enumerator
269 Some(block::Read::Closed) => TryPopResult::Closed, in try_pop()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Channel.kt | 436 public val isClosed: Boolean get() = holder is Closed in receiveOrNull()
450 if (holder is Closed && holder.cause != null) throw holder.cause in receiveOrNull()
458 public fun exceptionOrNull(): Throwable? = (holder as? Closed)?.cause in receiveOrNull()
464 internal class Closed(@JvmField val cause: Throwable?): Failed() { in receiveOrNull() class
465 override fun equals(other: Any?): Boolean = other is Closed && cause == other.cause in receiveOrNull()
484 ChannelResult(Closed(cause)) in receiveOrNull()
489 is Closed -> holder.toString() in receiveOrNull()
551 if (holder is ChannelResult.Closed) action(exceptionOrNull()) in onClosed()
|
| /external/rust/crates/tokio/src/sync/ |
| D | broadcast.rs | 240 Closed, enumerator
252 RecvError::Closed => write!(f, "channel closed"), in fmt()
274 Closed, enumerator
288 TryRecvError::Closed => write!(f, "channel closed"), in fmt()
899 return Err(TryRecvError::Closed); in recv_ref()
1107 guard.clone_value().ok_or(TryRecvError::Closed) in try_recv()
1124 Err(TryRecvError::Closed) => break, in drop()
1173 Err(TryRecvError::Closed) => return Poll::Ready(Err(RecvError::Closed)), in poll()
1176 Poll::Ready(guard.clone_value().ok_or(RecvError::Closed)) in poll()
|
| D | oneshot.rs | 346 Closed, enumerator
365 TryRecvError::Closed => write!(fmt, "channel closed"), in fmt()
1016 None => Err(TryRecvError::Closed), in try_recv()
1019 Err(TryRecvError::Closed) in try_recv()
1025 Err(TryRecvError::Closed) in try_recv()
|
| /external/pdfium/testing/resources/ |
| D | bookmarks.in | 113 /Title (A Good Closed Ending)
124 /Title (A Good Closed Ending Descendant)
132 /Title (A Good Closed Ending Descendant 2)
|
| /external/oboe/src/opensles/ |
| D | AudioOutputStreamOpenSLES.cpp | 240 if (getState() == StreamState::Closed){ in close()
282 case StreamState::Closed: in requestStart()
335 case StreamState::Closed: in requestPause_l()
366 if (getState() == StreamState::Closed) { in requestFlush_l()
397 case StreamState::Closed: in requestStop_l()
|
| D | AudioStreamBuffered.cpp | 224 if (getState() == StreamState::Closed){ in write()
240 if (getState() == StreamState::Closed){ in read()
255 if (getState() == StreamState::Closed){ in setBufferSizeInFrames()
|
| D | AudioInputStreamOpenSLES.cpp | 216 if (getState() == StreamState::Closed){ in close()
256 case StreamState::Closed: in requestStart()
310 case StreamState::Closed: in requestStop_l()
|
| /external/pigweed/pw_rpc/nanopb/ |
| D | client_reader_writer_test.cc | 98 TEST(NanopbUnaryReceiver, Closed) { in TEST() argument
118 TEST(NanopbClientWriter, Closed) { in TEST() argument
139 TEST(NanopbClientReader, Closed) { in TEST() argument
161 TEST(NanopbClientReaderWriter, Closed) { in TEST() argument
|
| D | server_reader_writer_test.cc | 120 TEST(NanopbUnaryResponder, Closed) { in TEST() argument
135 TEST(NanopbServerWriter, Closed) { in TEST() argument
152 TEST(NanopbServerReader, Closed) { in TEST() argument
169 TEST(NanopbServerReaderWriter, Closed) { in TEST() argument
|
| /external/pigweed/pw_rpc/pwpb/ |
| D | client_reader_writer_test.cc | 100 TEST(PwpbUnaryReceiver, Closed) { in TEST() argument
119 TEST(PwpbClientWriter, Closed) { in TEST() argument
140 TEST(PwpbClientReader, Closed) { in TEST() argument
162 TEST(PwpbClientReaderWriter, Closed) { in TEST() argument
|
| D | server_reader_writer_test.cc | 120 TEST(PwpbUnaryResponder, Closed) { in TEST() argument
134 TEST(PwpbServerWriter, Closed) { in TEST() argument
150 TEST(PwpbServerReader, Closed) { in TEST() argument
167 TEST(PwpbServerReaderWriter, Closed) { in TEST() argument
|
| /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/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()
|
| /external/libxml2/result/schematron/ |
| D | zvon10_0.err | 3 Pattern: Closed model
|
| D | zvon10_1.err | 3 Pattern: Closed model
|
| /external/rust/crates/zip/src/ |
| D | write.rs | 33 Closed, enumerator
222 let _inner = mem::replace(&mut self.inner, GenericZipWriter::Closed); in write()
747 let inner = mem::replace(&mut self.inner, GenericZipWriter::Closed); in finish()
872 let bare = match mem::replace(self, GenericZipWriter::Closed) { in switch_to()
884 GenericZipWriter::Closed => { in switch_to()
978 GenericZipWriter::Closed => None, in ref_mut()
983 matches!(*self, GenericZipWriter::Closed) in is_closed()
1006 GenericZipWriter::Closed => None, in current_compression()
|