| /external/okio/okio/src/commonMain/kotlin/okio/ |
| D | SegmentPool.kt | 32 fun take(): Segment method
|
| /external/tensorflow/tensorflow/python/kernel_tests/data_structures/ |
| D | barrier_ops_test.py | 292 def take(): function 326 def take(sess, i, taken): function 533 def take(sess, i, taken): function 619 def take(sess, i, taken): function
|
| /external/okio/okio/src/jvmTest/kotlin/okio/ |
| D | ThrottlerTakeTest.kt | 110 private fun take(byteCount: Long): Long { in take() method in okio.ThrottlerTakeTest
|
| /external/clang/test/CXX/temp/temp.param/ |
| D | p15-cxx0x.cpp | 83 typedef types<typename Take<_>::type...> take; typedef 88 template<unsigned N, typename...Ts> struct take { struct 89 using type = typename takedrop_impl<typename make_places<N>::type>::
|
| /external/rust/crates/tinyvec/src/ |
| D | lib.rs | 105 fn take<T: Default>(from: &mut T) -> T { in take() function
|
| /external/okio/okio/src/nonJvmMain/kotlin/okio/ |
| D | SegmentPool.kt | 23 actual fun take(): Segment = Segment() in take() method
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | ticket.h | 173 Ticket Ticket::Queue::take() { in take() function 180 void Ticket::Queue::take(size_t n, const F& f) { in take() function
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | TestLogHandler.java | 41 public synchronized String take() throws InterruptedException { in take() method in TestLogHandler
|
| /external/rust/crates/bytes/tests/ |
| D | test_take.rs | 19 let mut take = (&mut abcd).take(2); in take_copy_to_bytes() localVariable
|
| /external/rust/crates/bytes/src/buf/ |
| D | mod.rs | 26 mod take; module
|
| /external/okhttp/repackaged/okio/okio/src/main/java/com/android/okhttp/okio/ |
| D | SegmentPool.java | 37 static Segment take() { in take() method in SegmentPool
|
| /external/okhttp/okio/okio/src/main/java/okio/ |
| D | SegmentPool.java | 36 static Segment take() { in take() method in SegmentPool
|
| /external/testng/src/main/java/org/testng/internal/ |
| D | PoolService.java | 48 Future<FutureType> take = m_completionService.take(); in submitTasksAndWait() local
|
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| D | IntQueue.java | 46 int take() { in take() method in IntQueue
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingBlockingQueue.java | 83 public E take() throws InterruptedException { in take() method in ForwardingBlockingQueue
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingBlockingQueue.java | 83 public E take() throws InterruptedException { in take() method in ForwardingBlockingQueue
|
| /external/tensorflow/tensorflow/python/data/kernel_tests/ |
| D | scan_test.py | 54 def dataset_fn(start, step, take): argument 93 def dataset_fn(start, step, take): argument
|
| D | get_single_element_test.py | 45 def testBasic(self, skip, take, error=None, error_msg=None): argument
|
| /external/grpc-grpc/src/cpp/common/ |
| D | completion_queue_cc.cc | 35 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue()
|
| /external/cronet/net/third_party/quiche/src/quiche/spdy/core/ |
| D | spdy_frame_builder.h | 64 SpdySerializedFrame take() { in take() function
|
| /external/cronet/components/cronet/android/java/src/org/chromium/net/urlconnection/ |
| D | MessageLoop.java | 64 private Runnable take(boolean useTimeout, long timeoutNano) throws InterruptedIOException { in take() method in MessageLoop
|
| /external/rust/crates/tokio/tests/ |
| D | io_take.rs | 15 async fn take() { in take() function
|
| /external/rust/crates/async-task/src/ |
| D | header.rs | 46 pub(crate) fn take(&self, current: Option<&Waker>) -> Option<Waker> { in take() method
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | chunks.rs | 35 fn take(self: Pin<&mut Self>) -> Vec<St::Item> { in take() method
|
| /external/rust/crates/tokio/src/util/ |
| D | atomic_cell.rs | 29 pub(crate) fn take(&self) -> Option<Box<T>> { in take() method
|