Home
last modified time | relevance | path

Searched refs:fds (Results 1 – 25 of 30) sorted by relevance

12

/packages/modules/adb/
Dsysdeps_test.cpp44 int fds[2]; in TEST() local
45 ASSERT_EQ(0, adb_socketpair(fds)) << strerror(errno); in TEST()
46 ASSERT_TRUE(WriteFdExactly(fds[0], "foo", 4)); in TEST()
47 ASSERT_TRUE(WriteFdExactly(fds[1], "bar", 4)); in TEST()
50 ASSERT_TRUE(ReadFdExactly(fds[1], buf, 4)); in TEST()
52 ASSERT_TRUE(ReadFdExactly(fds[0], buf, 4)); in TEST()
54 ASSERT_EQ(0, adb_close(fds[0])); in TEST()
55 ASSERT_EQ(0, adb_close(fds[1])); in TEST()
59 std::vector<int> fds; in TEST() local
63 fds.push_back(socketpair[0]); in TEST()
[all …]
Dtransport_benchmark.cpp56 int fds[2]; in BM_Connection_Unidirectional() local
57 if (adb_socketpair(fds) != 0) { in BM_Connection_Unidirectional()
61 auto client = MakeConnection<ConnectionType>(unique_fd(fds[0])); in BM_Connection_Unidirectional()
62 auto server = MakeConnection<ConnectionType>(unique_fd(fds[1])); in BM_Connection_Unidirectional()
111 int fds[2]; in BM_Connection_Echo() local
112 if (adb_socketpair(fds) != 0) { in BM_Connection_Echo()
116 auto client = MakeConnection<ConnectionType>(unique_fd(fds[0])); in BM_Connection_Echo()
117 auto server = MakeConnection<ConnectionType>(unique_fd(fds[1])); in BM_Connection_Echo()
Dshell_service_protocol_test.cpp43 int fds[2]; in SetUp() local
44 ASSERT_EQ(0, adb_socketpair(fds)); in SetUp()
45 read_fd_ = fds[0]; in SetUp()
46 write_fd_ = fds[1]; in SetUp()
Dsysdeps.h240 extern int adb_poll(adb_pollfd* fds, size_t nfds, int timeout);
721 static inline int adb_poll(adb_pollfd* fds, size_t nfds, int timeout) { in adb_poll() argument
722 return TEMP_FAILURE_RETRY(poll(fds, nfds, timeout)); in adb_poll()
Dsysdeps_win32.cpp606 extern int adb_poll(adb_pollfd* fds, size_t nfds, int timeout) { in adb_poll() argument
613 FH fh = _fh_from_int(fds[i].fd, __func__); in adb_poll()
615 D("adb_poll received bad FD %d", fds[i].fd); in adb_poll()
616 fds[i].revents = POLLNVAL; in adb_poll()
621 .events = static_cast<short>(fds[i].events) in adb_poll()
624 original.push_back(&fds[i]); in adb_poll()
653 if (fds[i].revents != 0) { in adb_poll()
/packages/modules/NeuralNetworks/common/
DTypes.cpp115 std::vector<base::unique_fd> fds; in create() local
116 fds.push_back(std::move(fd)); in create()
118 .fds = std::move(fds), in create()
125 (syncFence != nullptr && syncFence->fds.size() == 1 && syncFence->ints.empty()); in create()
139 const int fd = mSyncFence->fds.front().get(); in syncWait()
144 struct pollfd fds; in syncWait() local
152 fds.fd = fd; in syncWait()
153 fds.events = POLLIN; in syncWait()
156 ret = poll(&fds, 1, timeout); in syncWait()
158 if (fds.revents & POLLNVAL) { in syncWait()
[all …]
DLegacyUtils.cpp1823 struct pollfd fds; in syncWait() local
1831 fds.fd = fd; in syncWait()
1832 fds.events = POLLIN; in syncWait()
1835 ret = poll(&fds, 1, timeout); in syncWait()
1837 if (fds.revents & POLLNVAL) { in syncWait()
1841 if (fds.revents & POLLERR) { in syncWait()
/packages/modules/DnsResolver/
DDnsTlsSocket.cpp62 pollfd fds = {.fd = fd, .events = POLLIN}; in waitForReading() local
63 return TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in waitForReading()
67 pollfd fds = {.fd = fd, .events = POLLOUT}; in waitForWriting() local
68 return TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in waitForWriting()
323 pollfd fds[2] = { in sslConnectV2() local
331 fds[SSLFD].events = POLLIN; in sslConnectV2()
334 fds[SSLFD].events = POLLOUT; in sslConnectV2()
342 int n = TEMP_FAILURE_RETRY(poll(fds, std::size(fds), mConnectTimeoutMs)); in sslConnectV2()
348 if (fds[EVENTFD].revents & (POLLIN | POLLERR)) { in sslConnectV2()
352 if (fds[SSLFD].revents & POLLERR) { in sslConnectV2()
[all …]
DDnsTlsTransport.cpp124 pollfd fds = {.fd = fd, .events = POLLIN}; in sendUdpQuery() local
126 const int n = TEMP_FAILURE_RETRY(poll(&fds, 1, timeoutMs)); in sendUdpQuery()
133 if (fds.revents & (POLLIN | POLLERR)) { in sendUdpQuery()
Dres_send.cpp907 struct pollfd fds = {.fd = sock, .events = events}; in retrying_poll() local
908 int n = ppoll(&fds, 1, &timeout, /*__mask=*/NULL); in retrying_poll()
919 if (fds.revents & (POLLIN | POLLOUT | POLLERR)) { in retrying_poll()
/packages/modules/adb/daemon/
Dframebuffer_service.cpp66 int fds[2]; in framebuffer_service() local
69 if (pipe2(fds, O_CLOEXEC) < 0) return; in framebuffer_service()
75 dup2(fds[1], STDOUT_FILENO); in framebuffer_service()
76 adb_close(fds[0]); in framebuffer_service()
77 adb_close(fds[1]); in framebuffer_service()
84 adb_close(fds[1]); in framebuffer_service()
85 fd_screencap = fds[0]; in framebuffer_service()
184 adb_close(fds[0]); in framebuffer_service()
Djdwp_service.cpp305 int fds[2]; in create_jdwp_connection_fd() local
307 if (adb_socketpair(fds) < 0) { in create_jdwp_connection_fd()
311 D("socketpair: (%d,%d)", fds[0], fds[1]); in create_jdwp_connection_fd()
313 proc->out_fds.emplace_back(fds[1]); in create_jdwp_connection_fd()
318 return unique_fd{fds[0]}; in create_jdwp_connection_fd()
/packages/modules/adb/fdevent/
Dfdevent_test.cpp144 int fds[2]; in TEST_F() local
145 ASSERT_EQ(0, adb_socketpair(fds)); in TEST_F()
146 read_fds.push_back(fds[0]); in TEST_F()
147 write_fds.push_back(fds[1]); in TEST_F()
242 int fds[2]; in TEST_F() local
243 ASSERT_EQ(0, adb_socketpair(fds)); in TEST_F()
246 test.fde = fdevent_create(fds[0], [](fdevent* fde, unsigned events, void* arg) { in TEST_F()
278 ASSERT_EQ(1, adb_write(fds[1], "", 1)); in TEST_F()
288 adb_close(fds[1]); in TEST_F()
/packages/modules/DnsResolver/tests/dns_responder/
Ddns_tls_frontend.cpp176 pollfd fds[2] = {{.fd = event_fd_.get(), .events = POLLIN}, in requestHandler() local
181 int poll_code = poll(fds, std::size(fds), -1); in requestHandler()
187 if (fds[EVENT_FD].revents & (POLLIN | POLLERR)) { in requestHandler()
191 if (fds[LISTEN_FD].revents & (POLLIN | POLLERR)) { in requestHandler()
240 pollfd fds = {.fd = clientFd, .events = POLLIN}; in handleRequests() local
294 } while (poll(&fds, 1, delayQueriesTimeout_) > 0); in handleRequests()
309 int n = poll(&fds, 1, 50); in handleRequests()
310 if (n > 0 && fds.revents & POLLIN) { in handleRequests()
/packages/modules/NeuralNetworks/common/include/nnapi/
DSharedMemory.h74 std::vector<base::unique_fd> fds; in dupFds() local
75 fds.reserve(std::distance(first, last)); in dupFds()
78 fds.push_back(NN_TRY(dupFd(fd))); in dupFds()
80 return fds; in dupFds()
DTypes.h625 std::vector<base::unique_fd> fds; member
/packages/modules/NeuralNetworks/runtime/
DCompilationBuilder.cpp137 std::vector<base::unique_fd> fds; in createCacheHandle() local
138 fds.push_back(NN_TRY(dupFd(fd))); in createCacheHandle()
140 .fds = std::move(fds), in createCacheHandle()
145 static GeneralResult<std::vector<SharedHandle>> createCacheHandleVec(const int* fds, in createCacheHandleVec() argument
150 handles.push_back(NN_TRY(createCacheHandle(fds[i]))); in createCacheHandleVec()
DManager.cpp354 std::vector<base::unique_fd> fds; in createCacheHandle() local
355 fds.push_back(std::move(fd)); in createCacheHandle()
357 .fds = std::move(fds), in createCacheHandle()
/packages/modules/Virtualization/authfs/fd_server/src/
Dmain.rs253 let fds = result?; in parse_arg_ro_fds() localVariable
254 if fds.len() > 3 { in parse_arg_ro_fds()
258 fds[0], in parse_arg_ro_fds()
260 file: fd_to_file(fds[0])?, in parse_arg_ro_fds()
262 alt_merkle_tree: fds.get(1).map(|fd| fd_to_file(*fd)).transpose()?, in parse_arg_ro_fds()
264 alt_signature: fds.get(2).map(|fd| fd_to_file(*fd)).transpose()?, in parse_arg_ro_fds()
/packages/services/Mtp/tests/src/com/android/mtp/
DMtpManagerTest.java137 final ParcelFileDescriptor[] fds = ParcelFileDescriptor.createPipe(); in testCreateDocumentAndGetPartialObject() local
140 new ParcelFileDescriptor.AutoCloseOutputStream(fds[1])) { in testCreateDocumentAndGetPartialObject()
151 fds[0]); in testCreateDocumentAndGetPartialObject()
/packages/apps/Bluetooth/lib/mapapi/com/android/bluetooth/mapapi/
DBluetoothMapEmailProvider.java371 final ParcelFileDescriptor[] fds = ParcelFileDescriptor.createPipe(); in openInversePipeHelper() local
376 func.readDataFromPipe(fds[0], uri, mimeType, opts, args); in openInversePipeHelper()
378 fds[0].close(); in openInversePipeHelper()
387 return fds[1]; in openInversePipeHelper()
/packages/modules/StatsD/service/java/com/android/server/stats/
DStatsCompanionService.java163 ParcelFileDescriptor[] fds; in informAllUids() local
165 fds = ParcelFileDescriptor.createPipe(); in informAllUids()
186 statsd.informAllUidData(fds[0]); in informAllUids()
191 fds[0].close(); in informAllUids()
195 final ParcelFileDescriptor writeFd = fds[1]; in informAllUids()
/packages/modules/NeuralNetworks/shim_and_sl/
DShimDevice.cpp519 std::vector<int> fds; in getIntFds() local
520 fds.reserve(scopedFds.size()); in getIntFds()
522 fds.push_back(scopedFd.get()); in getIntFds()
524 return fds; in getIntFds()
/packages/modules/NeuralNetworks/runtime/test/
DSupportLibraryTestGenerated.cpp140 std::vector<base::unique_fd> fds; in createCacheFds() local
141 fds.reserve(files.size()); in createCacheFds()
148 fds.push_back(std::move(fd)); in createCacheFds()
150 return fds; in createCacheFds()
/packages/services/Car/cpp/computepipe/proto/
DPacketDescriptor.proto8 repeated int32 fds = 1; field

12