| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | ConcurrentStatefulActorBenchmark.kt | 90 var received = 0 in requestorActorUnfair() variable
116 val received = hashMapOf(*computations.map { it to 0 }.toTypedArray()) in requestorActorFair() constant
|
| D | CycledActorsBenchmark.kt | 92 var received = 0 in <lambda>() variable
|
| D | StatefulActorBenchmark.kt | 83 var received = 0 in requestorActor() variable
|
| /external/ukey2/src/main/javatest/com/google/security/cryptauth/lib/securegcm/ |
| D | TransportCryptoOpsTest.java | 63 Payload received = TransportCryptoOps.verifydecryptServerMessage(signcryptedMessage, masterKey); in testServerMessage() local
103 Payload received = TransportCryptoOps.verifydecryptClientMessage( in doTestClientMessageWith() local
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherCompletionStressTest.kt | 26 var received = 0 in <lambda>() variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableCompletionStressTest.kt | 26 var received = 0 in <lambda>() variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherCompletionStressTest.kt | 26 var received = 0 in <lambda>() variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableCompletionStressTest.kt | 26 var received = 0 in <lambda>() variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FluxCompletionStressTest.kt | 27 var received = 0 in <lambda>() variable
|
| /external/libchrome/dbus/ |
| D | dbus_statistics_unittest.cc | 59 int sent = 0, received = 0, block = 0; in TEST_F() local
88 int sent = 0, received = 0, block = 0; in TEST_F() local
|
| /external/tensorflow/tensorflow/compiler/xla/python/ |
| D | outfeed_receiver_test.cc | 68 std::vector<Data> received() { in received() function in xla::__anon9e6d69230111::Accumulator
135 std::vector<Accumulator::Data> received = receiver->received(); in TEST() local
178 std::vector<Accumulator::Data> received = receiver->received(); in TEST() local
221 std::vector<Accumulator::Data> received = receiver->received(); in TEST() local
316 std::vector<Accumulator::Data> received = receiver->received(); in TEST() local
|
| D | outfeed_receiver.cc | 312 auto received = absl::make_unique<OutfeedData>(device, consumer_id, shape); in DeviceListenerThreadLoop() local
332 uint32_t device_idx, std::unique_ptr<OutfeedData> received) in EnqueueReceivedData()
359 std::unique_ptr<OutfeedData> received; in CallbackThreadLoop() local
|
| /external/libchrome/ipc/ |
| D | sync_socket_unittest.cc | 208 size_t length, size_t* received) { in BlockingRead()
226 size_t received = 1U; // Initialize to an unexpected value. in TEST_F() local
257 size_t received = 1U; // Initialize to an unexpected value. in TEST_F() local
|
| /external/ppp/pppd/plugins/radius/ |
| D | buildreq.c | 162 int rc_auth(UINT4 client_port, VALUE_PAIR *send, VALUE_PAIR **received, in rc_auth()
189 VALUE_PAIR **received, in rc_auth_using_server()
247 int rc_auth_proxy(VALUE_PAIR *send, VALUE_PAIR **received, char *msg) in rc_auth_proxy()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ProduceConsumeJvmTest.kt | 48 val received = CompletableDeferred<Int>() in <lambda>() constant
|
| D | ChannelSelectStressTest.kt | 20 private val received = atomic(0) constant in kotlinx.coroutines.channels.ChannelSelectStressTest
|
| D | ConflatedChannelCloseStressTest.kt | 19 val received = AtomicInteger() in <lambda>() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/concurrent/test/channels/ |
| D | ChannelCancelUndeliveredElementStressTest.kt | 90 val received = when (Random.nextInt(3)) { in receiveOne() constant
|
| /external/tensorflow/tensorflow/core/data/ |
| D | dataset_utils.cc | 198 Status VerifyTypeMatch(const DataType& expected, const DataType& received, in VerifyTypeMatch()
209 const DataTypeVector& received) { in VerifyTypesMatch()
222 const std::vector<Tensor>& received) { in VerifyTypesMatch()
235 const PartialTensorShape& received, int index) { in VerifyShapeCompatible()
245 const std::vector<PartialTensorShape>& received) { in VerifyShapesCompatible()
259 const std::vector<Tensor>& received) { in VerifyShapesCompatible()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | Ping.java | 27 private long received = -1; field in Ping
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | Ping.java | 29 private long received = -1; field in Ping
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/akka/ |
| D | StatefulActorAkkaBenchmark.kt | 127 private var received = 0 variable in benchmarks.akka.StatefulActorAkkaBenchmark.RequestorActor
|
| /external/autotest/client/cros/cellular/pseudomodem/ |
| D | messaging.py | 70 def Added(self, path, received): argument
|
| /external/testng/src/test/java/test/remote/ |
| D | RemoteTest.java | 68 List<String> received = Lists.newArrayList(); in runTest() local
|
| /external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/ |
| D | ConnectorTest.java | 102 Message received = mReceiver.messages.get(0); in testReceivingMessage() local
|