Home
last modified time | relevance | path

Searched refs:socket_fd (Results 1 – 6 of 6) sorted by relevance

/frameworks/native/libs/vr/libpdx_uds/private/uds/
Dipc_helper.h20 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 …]
Dservice_endpoint.h102 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/
Dipc_helper.cpp30 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 …]
Dclient_channel.cpp73 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()
Dservice_endpoint.cpp171 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()
Dipc_helper_tests.cpp34 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));