| /base/request/request/services/src/manage/events/ |
| H A D | mod.rs | 25 use crate::utils::Recv;
48 pub(crate) fn construct(config: TaskConfig) -> (Self, Recv<Result<u32, ErrorCode>>) {
55 Recv::new(rx),
59 pub(crate) fn pause(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) {
63 Recv::new(rx),
67 pub(crate) fn start(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) {
71 Recv::new(rx),
75 pub(crate) fn stop(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) {
79 Recv::new(rx),
83 pub(crate) fn remove(uid: u64, task_id: u32) -> (Self, Recv<ErrorCod
[all...] |
| /base/hiviewdfx/hilog/frameworks/libhilog/socket/ |
| H A D | dgram_socket_server.cpp | 25 if (auto status = Recv(&packetLen, sizeof(packetLen)); status < 0) { in RecvPacket()
29 Recv(&packetLen, sizeof(packetLen), 0); // skip too long packet in RecvPacket()
53 ret = Recv(buffer.data(), packetLen, 0); in RecvPacket()
|
| H A D | seq_packet_socket_client.cpp | 44 return Recv(buffer, len, 0); in RecvMsg()
|
| H A D | socket.cpp | 124 int Socket::Recv(void *buffer, unsigned int bufferLen, int flags) in Recv() function in OHOS::HiviewDFX::Socket
|
| H A D | socket_server.cpp | 73 int SocketServer::Recv(void *buffer, unsigned int bufferLen, int flags) in Recv() function in OHOS::HiviewDFX::SocketServer
|
| /base/security/security_guard/test/fuzztest/risk_collect/riskcollect_fuzzer/ |
| H A D | risk_collect_fuzzer.cpp | 78 adapter.Recv(0, buffer, sizeof(buffer), 0); in KernelInterfaceAdapterFuzzTest()
79 adapter.Recv(0, nullptr, 0, 0); in KernelInterfaceAdapterFuzzTest()
|
| /base/hiviewdfx/hilog/frameworks/libhilog/socket/include/ |
| H A D | socket_server.h | 36 int Recv(void *buffer, unsigned int bufferLen, int flags = MSG_PEEK);
|
| H A D | socket.h | 42 int Recv(void *buffer, unsigned int bufferLen, int flags = MSG_PEEK);
|
| /base/security/security_guard/test/unittest/data_collect/sa/ |
| H A D | kernel_interface_adapter.h | 36 virtual ssize_t Recv(int socket, void* const buf, size_t len, int flags) { return 0; }; in Recv() function in OHOS::Security::SecurityGuard::KernelInterfaceAdapter
|
| /base/request/request/services/src/utils/ |
| H A D | mod.rs | 37 pub(crate) struct Recv<T> {
41 impl<T> Recv<T> { impls
|
| /base/request/request/services/src/service/client/ |
| H A D | mod.rs | 28 use crate::utils::{runtime_spawn, Recv};
58 let rx = Recv::new(rx);
74 let rx = Recv::new(rx);
90 let rx = Recv::new(rx);
111 let rx = Recv::new(rx);
|
| /base/request/request/services/src/service/ |
| H A D | notification_bar.rs | 26 use crate::utils::{get_current_timestamp, Recv};
182 F: Fn(u64, u32) -> (TaskManagerEvent, Recv<ErrorCode>), in event_inner()
|