Home
last modified time | relevance | path

Searched refs:recv (Results 1 – 22 of 22) sorted by relevance

/frameworks/libs/modules-utils/javatests/com/android/modules/utils/
DSynchronousResultReceiverTest.java38 final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get(); in testSimpleData() local
39 recv.send(true); in testSimpleData()
40 final boolean result = recv.awaitResultNoInterrupt(OK_TIME).getValue(false); in testSimpleData()
46 final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get(); in testDoubleComplete() local
47 recv.send(true); in testDoubleComplete()
49 () -> recv.send(true)); in testDoubleComplete()
54 final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get(); in testDefaultValue() local
55 recv.send(null); in testDefaultValue()
56 assertTrue(recv.awaitResultNoInterrupt(OK_TIME).getValue(true)); in testDefaultValue()
61 final SynchronousResultReceiver<Boolean> recv = SynchronousResultReceiver.get(); in testPropagateException() local
[all …]
/frameworks/base/media/tests/mediatestutils/java/com/android/media/mediatestutils/
DTestUtils.java52 (recv) -> in getFutureForIntent()
54 recv, new IntentFilter(action), Context.RECEIVER_EXPORTED), in getFutureForIntent()
55 (recv) -> { in getFutureForIntent()
57 context.unregisterReceiver(recv); in getFutureForIntent()
/frameworks/base/tests/AmSlam/src/test/amslam/
DMainActivity.java118 public void onPingPongResponse(long send, long bounce, long recv, String remote) { in onPingPongResponse() argument
121 Log.e(TAG, "send " + send + ", bounce " + bounce + ", recv " + recv in onPingPongResponse()
127 mTotalTime += (recv - send); in onPingPongResponse()
129 mTotalPongTime += (recv - bounce); in onPingPongResponse()
DPongReceiver.java29 void onPingPongResponse(long send, long bounce, long recv, String remote); in onPingPongResponse() argument
/frameworks/native/libs/binder/
DRpcTransportRaw.cpp44 ::recv(mSocket.fd.get(), &buf, sizeof(buf), MSG_PEEK | MSG_DONTWAIT)); in pollRead()
79 auto recv = [&](iovec* iovs, int niovs) -> ssize_t { in interruptableReadFully() local
82 return interruptableReadOrWrite(mSocket, fdTrigger, iovs, niovs, recv, "recvmsg", POLLIN, in interruptableReadFully()
DRpcTransportTls.cpp63 int ret = TEMP_FAILURE_RETRY(::recv(fd.get(), buf, size, MSG_NOSIGNAL)); in socketRead()
/frameworks/rs/
DrsFifoSocket.cpp71 size_t ret = ::recv(sv[0], retData, retBytes, MSG_WAITALL); in writeWaitReturn()
82 size_t ret = ::recv(sv[1], data, bytes, MSG_WAITALL); in read()
/frameworks/native/libs/vr/libpdx/
Dclient_tests.cpp485 iovec recv[4] = {}; in TEST_F() local
495 EXPECT_CALL(*mock_channel(), SendWithInt(nullptr, 2, send, 3, recv, 4)) in TEST_F()
497 EXPECT_TRUE(transaction_.SendVector<void>(2, send, 3, recv, 4)); in TEST_F()
503 EXPECT_CALL(*mock_channel(), SendWithInt(nullptr, 4, nullptr, 0, recv, 4)) in TEST_F()
505 EXPECT_TRUE(transaction_.SendVector<void>(4, nullptr, recv)); in TEST_F()
507 EXPECT_CALL(*mock_channel(), SendWithInt(nullptr, 5, send, 3, recv, 4)) in TEST_F()
509 EXPECT_TRUE(transaction_.SendVector<void>(5, send, recv)); in TEST_F()
/frameworks/opt/net/voip/src/jni/rtp/
DAudioGroup.cpp368 recv(mSocket, &c, 1, MSG_DONTWAIT); in decode()
402 recv(mSocket, &c, 1, MSG_DONTWAIT); in decode()
410 count = recv(mSocket, samples, sizeof(samples), in decode()
848 while (recv(deviceSocket, &c, 1, MSG_DONTWAIT) == 1); in threadLoop()
888 if (recv(deviceSocket, output, sizeof(output), 0) <= 0) { in threadLoop()
933 while (recv(deviceSocket, &c, 1, MSG_DONTWAIT) == 1); in threadLoop()
/frameworks/native/libs/sensor/
DBitTube.cpp120 len = ::recv(mReceiveFd, vaddr, size, MSG_DONTWAIT); in read()
/frameworks/native/libs/gui/
DBitTube.cpp106 len = ::recv(mReceiveFd, vaddr, size, MSG_DONTWAIT); in read()
/frameworks/native/libs/binder/tests/
DbinderThroughputTest.cpp168 void recv(ProcResults& v) { in recv() function in Pipe
342 pipes[i].recv(tmp_results); in run_main()
Dschd-dbg.cpp187 void recv(T& v) { in recv() function in Pipe
/frameworks/av/media/libstagefright/rtsp/fuzzer/
Drtsp_connection_fuzzer.cpp266 if (checkSocket(newSocket) == 1 && recv(newSocket, buffer, kBufferSize, MSG_DONTWAIT) > 0) { in handleConnection()
280 if (recv(newSocket, buffer, kBufferSize, MSG_DONTWAIT) > 0) { in handleConnection()
DREADME.md77 |`kFmtp`| <br/>0. `br=`<br/>1. `bw=`<br/>2. `ch-aw-recv=`<br/>3. `mode-change-capability=`<br/>4. `…
/frameworks/base/packages/SystemUI/src/com/android/systemui/demomode/
DDemoModeController.kt220 receiverMap.entries.forEach { (comm, recv) -> in <lambda>() method
/frameworks/ex/common/java/com/android/common/
DGoogleLogTags.logtags50 203001 sync_details (authority|3),(send|1|2),(recv|1|2),(details|3)
/frameworks/native/libs/vr/libpdx_uds/
Dipc_helper.cpp42 return recv(socket_fd, data, size, flags); in Receive()
/frameworks/native/services/sensorservice/
DSensorEventConnection.cpp847 ssize_t numBytesRead = ::recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in handleEvent()
/frameworks/av/media/libstagefright/rtsp/
DARTSPConnection.cpp538 ssize_t n = recv(mSocket, (uint8_t *)data + offset, size - offset, 0); in receive()
/frameworks/native/libs/input/
DInputTransport.cpp430 nRead = ::recv(getFd(), msg, sizeof(InputMessage), MSG_DONTWAIT); in receiveMessage()
/frameworks/base/tools/aapt2/integration-tests/CommandTests/
Dandroid-33.jarAndroidManifest.xml META-INF/ META-INF/MANIFEST.MF NOTICES/ NOTICES/libcore ...