Searched refs:Poll (Results 1 - 11 of 11) sorted by relevance
| /base/request/request/services/src/task/ |
| H A D | upload.rs | 19 use std::task::{Context, Poll};
55 ) -> Poll<std::io::Result<()>> { in poll_read()
74 Poll::Ready(Ok(_)) => { in poll_read()
89 Poll::Ready(Ok(())) in poll_read()
91 Poll::Pending => Poll::Pending, in poll_read()
92 Poll::Ready(Err(e)) => Poll::Ready(Err(e)), in poll_read()
97 Poll::Ready(Ok(_)) => { in poll_read()
102 Poll in poll_read()
[all...] |
| H A D | operator.rs | 18 use std::task::{Context, Poll};
57 ) -> Poll<Result<(), HttpClientError>> {
59 return Poll::Ready(Err(HttpClientError::user_aborted()));
114 Poll::Ready(_) => return Poll::Ready(Ok(())),
115 Poll::Pending => return Poll::Pending,
118 Poll::Ready(Ok(()))
126 ) -> Poll<Result<usize, HttpClientError>> {
130 Poll
[all...] |
| H A D | download.rs | 18 use std::task::{Context, Poll};
43 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
52 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
|
| /base/security/security_guard/test/fuzztest/risk_collect/riskcollect_fuzzer/ |
| H A D | risk_collect_fuzzer.cpp | 74 adapter.Poll(&fds, 0, 0); in KernelInterfaceAdapterFuzzTest()
75 adapter.Poll(nullptr, 0, 0); in KernelInterfaceAdapterFuzzTest()
|
| /base/hiviewdfx/hilog/frameworks/libhilog/socket/include/ |
| H A D | socket_server.h | 39 int Poll(short inEvent, short& outEvent, const std::chrono::milliseconds& timeout);
|
| H A D | socket.h | 37 int Poll();
|
| /base/security/security_guard/test/unittest/data_collect/sa/ |
| H A D | kernel_interface_adapter.h | 35 virtual int Poll(struct pollfd* const fds, nfds_t fdCount, int timeout) { return 0; }; in Poll() function in OHOS::Security::SecurityGuard::KernelInterfaceAdapter
|
| /base/hiviewdfx/hilog/frameworks/libhilog/socket/ |
| H A D | socket.cpp | 77 int Socket::Poll() in Poll() function in OHOS::HiviewDFX::Socket
|
| H A D | socket_server.cpp | 88 int SocketServer::Poll(short inEvent, short& outEvent, const std::chrono::milliseconds& timeout) in Poll() function in OHOS::HiviewDFX::SocketServer
|
| H A D | seq_packet_socket_server.cpp | 47 auto pollResult = Poll(POLLIN, outEvent, ms); in AcceptingLoop()
|
| /base/msdp/device_status/rust/modules/scheduler/sys/src/ |
| H A D | scheduler.rs | 29 use std::task::{ Context, Poll, Waker };
383 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> in poll()
387 Poll::Pending in poll()
|
Completed in 4 milliseconds