| /frameworks/native/libs/vr/libpdx_uds/private/uds/ |
| D | ipc_helper.h | 20 virtual ssize_t Send(int socket_fd, const void* data, size_t size,
22 virtual ssize_t SendMessage(int socket_fd, const msghdr* msg, int flags) = 0;
30 virtual ssize_t Receive(int socket_fd, void* data, size_t size,
32 virtual ssize_t ReceiveMessage(int socket_fd, msghdr* msg, int flags) = 0;
40 Status<void> SendAll(SendInterface* sender, const BorrowedHandle& socket_fd,
42 Status<void> SendMsgAll(SendInterface* sender, const BorrowedHandle& socket_fd,
44 Status<void> RecvAll(RecvInterface* receiver, const BorrowedHandle& socket_fd,
47 const BorrowedHandle& socket_fd, msghdr* msg);
61 Status<void> Send(const BorrowedHandle& socket_fd);
62 Status<void> Send(const BorrowedHandle& socket_fd, const ucred* cred,
[all …]
|
| D | service_endpoint.h | 102 static std::unique_ptr<Endpoint> CreateFromSocketFd(LocalHandle socket_fd);
120 explicit Endpoint(LocalHandle socket_fd);
122 void Init(LocalHandle socket_fd);
|
| /frameworks/native/libs/vr/libpdx_uds/ |
| D | ipc_helper.cpp | 30 ssize_t Send(int socket_fd, const void* data, size_t size, in Send() argument
32 return send(socket_fd, data, size, flags); in Send()
34 ssize_t SendMessage(int socket_fd, const msghdr* msg, int flags) override { in SendMessage() argument
35 return sendmsg(socket_fd, msg, flags); in SendMessage()
41 ssize_t Receive(int socket_fd, void* data, size_t size, int flags) override { in Receive() argument
42 return recv(socket_fd, data, size, flags); in Receive()
44 ssize_t ReceiveMessage(int socket_fd, msghdr* msg, int flags) override { in ReceiveMessage() argument
45 return recvmsg(socket_fd, msg, flags); in ReceiveMessage()
54 Status<void> SendAll(SendInterface* sender, const BorrowedHandle& socket_fd, in SendAll() argument
60 RETRY_EINTR(sender->Send(socket_fd.Get(), ptr, size, MSG_NOSIGNAL)); in SendAll()
[all …]
|
| D | client_channel.cpp | 73 Status<void> ReadAndDiscardData(const BorrowedHandle& socket_fd, size_t size) { in ReadAndDiscardData() argument
79 auto status = ReceiveData(socket_fd, buffer, size_to_read); in ReadAndDiscardData()
89 Status<void> SendRequest(const BorrowedHandle& socket_fd, in SendRequest() argument
100 return SendData(socket_fd, transaction_state->request, send_vector, in SendRequest()
104 Status<void> ReceiveResponse(const BorrowedHandle& socket_fd, in ReceiveResponse() argument
108 auto status = ReceiveData(socket_fd, &transaction_state->response); in ReceiveResponse()
131 status = ReceiveDataVector(socket_fd, receive_vector, receive_count); in ReceiveResponse()
133 status = ReadAndDiscardData(socket_fd, size_remaining); in ReceiveResponse()
|
| D | service_endpoint.cpp | 171 Endpoint::Endpoint(LocalHandle socket_fd) { Init(std::move(socket_fd)); } in Endpoint() argument
173 void Endpoint::Init(LocalHandle socket_fd) { in Init() argument
174 if (socket_fd) { in Init()
175 CHECK_EQ(listen(socket_fd.Get(), kMaxBackLogForSocketListen), 0) in Init()
186 if (socket_fd) { in Init()
189 socket_event.data.fd = socket_fd.Get(); in Init()
190 int ret = epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, socket_fd.Get(), in Init()
206 socket_fd_ = std::move(socket_fd); in Init()
770 std::unique_ptr<Endpoint> Endpoint::CreateFromSocketFd(LocalHandle socket_fd) { in CreateFromSocketFd() argument
771 return std::unique_ptr<Endpoint>(new Endpoint(std::move(socket_fd))); in CreateFromSocketFd()
|
| D | ipc_helper_tests.cpp | 34 MOCK_METHOD4(Send, ssize_t(int socket_fd, const void* data, size_t size,
37 ssize_t(int socket_fd, const msghdr* msg, int flags));
43 ssize_t(int socket_fd, void* data, size_t size, int flags));
44 MOCK_METHOD3(ReceiveMessage, ssize_t(int socket_fd, msghdr* msg, int flags));
|
| /frameworks/native/libs/binder/ |
| D | RpcServer.cpp | 565 unique_fd socket_fd(TEMP_FAILURE_RETRY( in setupSocketServer() local
567 if (!socket_fd.ok()) { in setupSocketServer()
576 setsockopt(socket_fd.get(), IPPROTO_TCP, TCP_NODELAY, &noDelay, sizeof(noDelay)); in setupSocketServer()
587 mServerSocketModifier(socket_fd); in setupSocketServer()
591 if (0 != TEMP_FAILURE_RETRY(bind(socket_fd.get(), addr.addr(), addr.addrSize()))) { in setupSocketServer()
597 return setupRawSocketServer(std::move(socket_fd)); in setupSocketServer()
600 status_t RpcServer::setupRawSocketServer(unique_fd socket_fd) { in setupRawSocketServer() argument
601 LOG_ALWAYS_FATAL_IF(!socket_fd.ok(), "Socket must be setup to listen."); in setupRawSocketServer()
607 if (0 != TEMP_FAILURE_RETRY(listen(socket_fd.get(), 50 /*backlog*/))) { in setupRawSocketServer()
612 if (status_t status = setupExternalServer(std::move(socket_fd)); status != OK) { in setupRawSocketServer()
|
| /frameworks/native/libs/binder/rust/rpcbinder/src/server/ |
| D | android.rs | 64 socket_fd: OwnedFd, in new_bound_socket()
74 socket_fd.into_raw_fd(), in new_bound_socket()
|
| /frameworks/native/libs/binder/include/binder/ |
| D | RpcServer.h | 84 [[nodiscard]] LIBBINDER_EXPORTED status_t setupRawSocketServer(binder::unique_fd socket_fd);
|