Home
last modified time | relevance | path

Searched refs:LocalHandle (Results 1 – 25 of 58) sorted by relevance

123

/frameworks/native/libs/vr/libpdx_uds/private/uds/
Dchannel_event_set.h30 LocalHandle pollin_event_fd_;
31 LocalHandle pollhup_event_fd_;
41 ChannelEventReceiver(LocalHandle data_fd, LocalHandle pollin_event_fd,
42 LocalHandle pollhup_event_fd);
59 std::tuple<LocalHandle, LocalHandle, LocalHandle> TakeFds() { in TakeFds()
71 LocalHandle data_fd_;
72 LocalHandle pollin_event_fd_;
73 LocalHandle pollhup_event_fd_;
74 LocalHandle epoll_fd_;
Dchannel_parcelable.h14 ChannelParcelable(LocalHandle data_fd, LocalHandle pollin_event_fd,
15 LocalHandle pollhup_event_fd);
26 LocalHandle data_fd_;
27 LocalHandle pollin_event_fd_;
28 LocalHandle pollhup_event_fd_;
Dservice_endpoint.h66 const LocalHandle& handle) override;
77 LocalHandle GetFileHandle(Message* message, FileReference ref) const override;
102 static std::unique_ptr<Endpoint> CreateFromSocketFd(LocalHandle socket_fd);
106 Status<void> RegisterNewChannelForTests(LocalHandle channel_fd);
112 LocalHandle data_fd;
120 explicit Endpoint(LocalHandle socket_fd);
122 void Init(LocalHandle socket_fd);
136 Status<void> OnNewChannel(LocalHandle channel_fd);
138 LocalHandle channel_fd, Channel* channel_state);
146 Status<void> CreateChannelSocketPair(LocalHandle* local_socket,
[all …]
Dchannel_manager.h19 LocalChannelHandle CreateHandle(LocalHandle data_fd,
20 LocalHandle pollin_event_fd,
21 LocalHandle pollhup_event_fd);
Dclient_channel_factory.h16 static std::unique_ptr<pdx::ClientChannelFactory> Create(LocalHandle socket);
26 explicit ClientChannelFactory(LocalHandle socket);
28 mutable LocalHandle socket_;
Dclient_channel.h57 Status<LocalHandle> SendWithFileHandle(void* transaction_state, int opcode,
68 const LocalHandle& handle) override;
76 LocalHandle* handle) const override;
/frameworks/native/libs/vr/libbufferhub/include/private/dvr/
Dconsumer_buffer.h29 int Acquire(LocalHandle* ready_fence);
36 int Acquire(LocalHandle* ready_fence, void* meta, size_t user_metadata_size);
39 int AcquireAsync(DvrNativeBufferMetadata* out_meta, LocalHandle* out_fence);
44 int Release(const LocalHandle& release_fence);
52 const LocalHandle& release_fence);
65 int LocalAcquire(DvrNativeBufferMetadata* out_meta, LocalHandle* out_fence);
67 const LocalHandle& release_fence);
Dproducer_buffer.h30 const LocalHandle& ready_fence);
36 int Post(const LocalHandle& ready_fence, const void* meta,
39 int Post(const LocalHandle& ready_fence) { in Post()
52 int Gain(LocalHandle* release_fence, bool gain_posted_buffer = false);
64 int GainAsync(DvrNativeBufferMetadata* out_meta, LocalHandle* out_fence,
94 int LocalGain(DvrNativeBufferMetadata* out_meta, LocalHandle* out_fence,
97 const LocalHandle& ready_fence);
Dbuffer_hub_base.h15 using LocalHandle = pdx::LocalHandle;
33 LocalHandle GetBlobFd() const { in GetBlobFd()
39 return LocalHandle(dup(native_handle()->data[0])); in GetBlobFd()
118 int UpdateSharedFence(const LocalHandle& new_fence,
119 const LocalHandle& shared_fence);
140 LocalHandle shared_acquire_fence_;
141 LocalHandle shared_release_fence_;
145 LocalHandle pending_fence_fd_;
/frameworks/native/libs/vr/libbufferhub/
Dconsumer_buffer.cpp4 using android::pdx::LocalHandle;
34 LocalHandle* out_fence) { in LocalAcquire()
88 int ConsumerBuffer::Acquire(LocalHandle* ready_fence) { in Acquire()
92 int ConsumerBuffer::Acquire(LocalHandle* ready_fence, void* meta, in Acquire()
120 LocalHandle* out_fence) { in AcquireAsync()
133 const LocalHandle& release_fence) { in LocalRelease()
171 int ConsumerBuffer::Release(const LocalHandle& release_fence) { in Release()
184 return ReleaseAsync(&meta, LocalHandle()); in ReleaseAsync()
188 const LocalHandle& release_fence) { in ReleaseAsync()
198 int ConsumerBuffer::Discard() { return Release(LocalHandle()); } in Discard()
Dbuffer_hub-test.cpp32 using android::pdx::LocalHandle;
79 EXPECT_EQ(0, p->Post(LocalHandle())); in TEST_F()
86 LocalHandle fence; in TEST_F()
95 EXPECT_EQ(0, c1->Release(LocalHandle())); in TEST_F()
114 LocalHandle epoll_fd{epoll_create1(EPOLL_CLOEXEC)}; in TEST_F()
215 LocalHandle fence; in TEST_F()
222 EXPECT_EQ(0, p->Post(LocalHandle())); in TEST_F()
225 EXPECT_EQ(-EBUSY, p->Post(LocalHandle())); in TEST_F()
233 EXPECT_EQ(-EBUSY, p->Post(LocalHandle())); in TEST_F()
237 EXPECT_EQ(0, c->Release(LocalHandle())); in TEST_F()
[all …]
Dproducer_buffer.cpp4 using android::pdx::LocalHandle;
78 const LocalHandle& ready_fence) { in LocalPost()
126 int ProducerBuffer::Post(const LocalHandle& ready_fence, const void* meta, in Post()
143 const LocalHandle& ready_fence) { in PostAsync()
153 LocalHandle* out_fence, bool gain_posted_buffer) { in LocalGain()
228 int ProducerBuffer::Gain(LocalHandle* release_fence, bool gain_posted_buffer) { in Gain()
242 LocalHandle* release_fence, in GainAsync()
254 LocalHandle fence; in GainAsync()
/frameworks/native/libs/vr/libpdx_uds/
Dremote_method_tests.cpp28 using android::pdx::LocalHandle;
82 LocalHandle fd;
85 TestFdType(int a, LocalHandle fd) : a(a), fd(std::move(fd)) {} in TestFdType()
169 PDX_REMOTE_METHOD(SendFile, kOpSendFile, int(const LocalHandle& fd));
170 PDX_REMOTE_METHOD(GetFile, kOpGetFile, LocalHandle(const std::string&, int));
174 std::vector<LocalHandle>(
268 int SendFile(const LocalHandle& fd) { in SendFile()
272 LocalHandle GetFile(const std::string& path, int mode) { in GetFile()
273 Status<LocalHandle> status = in GetFile()
276 return LocalHandle(-status.error()); in GetFile()
[all …]
Dclient_channel_factory.cpp42 ClientChannelFactory::ClientChannelFactory(LocalHandle socket) in ClientChannelFactory()
52 LocalHandle socket) { in Create()
126 ChannelConnectionInfo<LocalHandle> connection_info; in Connect()
147 ResponseHeader<LocalHandle> response; in Connect()
154 LocalHandle pollin_event_fd = std::move(response.channels[0].pollin_event_fd); in Connect()
155 LocalHandle pollhup_event_fd = in Connect()
Dservice_endpoint.cpp29 using android::pdx::LocalHandle;
35 bool GetLocalFileHandle(int index, LocalHandle* handle) { in GetLocalFileHandle()
120 android::pdx::uds::RequestHeader<LocalHandle> request;
122 std::vector<LocalHandle> sockets_to_close;
138 LocalHandle fd;
171 Endpoint::Endpoint(LocalHandle socket_fd) { Init(std::move(socket_fd)); } in Endpoint()
173 void Endpoint::Init(LocalHandle socket_fd) { in Init()
221 LocalHandle connection_fd{accept4(socket_fd_.Get(), in AcceptConnection()
230 LocalHandle local_socket; in AcceptConnection()
231 LocalHandle remote_socket; in AcceptConnection()
[all …]
Dchannel_event_set.cpp34 LocalHandle pollin_event_fd, pollhup_event_fd; in ChannelEventSet()
71 ChannelEventReceiver::ChannelEventReceiver(LocalHandle data_fd, in ChannelEventReceiver()
72 LocalHandle pollin_event_fd, in ChannelEventReceiver()
73 LocalHandle pollhup_event_fd) { in ChannelEventReceiver()
74 LocalHandle epoll_fd; in ChannelEventReceiver()
Dchannel_manager.cpp24 LocalChannelHandle ChannelManager::CreateHandle(LocalHandle data_fd, in CreateHandle()
25 LocalHandle pollin_event_fd, in CreateHandle()
26 LocalHandle pollhup_event_fd) { in CreateHandle()
Dclient_channel_tests.cpp26 using android::pdx::LocalHandle;
81 explicit TestServiceRunner(LocalHandle channel_socket) { in TestServiceRunner()
82 auto endpoint = Endpoint::CreateFromSocketFd(LocalHandle{}); in TestServiceRunner()
109 LocalHandle service_channel{channel_sockets[0]}; in SetUp()
110 LocalHandle client_channel{channel_sockets[1]}; in SetUp()
Dchannel_parcelable.cpp16 ChannelParcelable::ChannelParcelable(LocalHandle data_fd, in ChannelParcelable()
17 LocalHandle pollin_event_fd, in ChannelParcelable()
18 LocalHandle pollhup_event_fd) in ChannelParcelable()
Dclient_channel.cpp20 bool GetLocalFileHandle(int index, LocalHandle* handle) { in GetLocalFileHandle()
70 ResponseHeader<LocalHandle> response;
219 Status<LocalHandle> ClientChannel::SendWithFileHandle( in SendWithFileHandle()
225 Status<LocalHandle> status; in SendWithFileHandle()
230 LocalHandle handle; in SendWithFileHandle()
260 const LocalHandle& handle) { in PushFileHandle()
284 LocalHandle* handle) const { in GetFileHandle()
/frameworks/native/libs/vr/libbufferhubqueue/tests/
Dbuffer_hub_queue-test.cpp21 using pdx::LocalHandle;
101 LocalHandle fence; in TEST_F()
112 EXPECT_EQ(p1->PostAsync(&mi, LocalHandle()), 0); in TEST_F()
123 EXPECT_EQ(c1->ReleaseAsync(&mi, LocalHandle()), 0); in TEST_F()
139 LocalHandle fence; in TEST_F()
160 EXPECT_EQ(0, p1->PostAsync(&mi, LocalHandle())); in TEST_F()
173 EXPECT_EQ(c1->ReleaseAsync(&mi, LocalHandle()), 0); in TEST_F()
189 EXPECT_EQ(0, p1->PostAsync(&mi, LocalHandle())); in TEST_F()
204 EXPECT_EQ(0, p1->PostAsync(&mi, LocalHandle())); in TEST_F()
222 LocalHandle fence; in TEST_F()
[all …]
/frameworks/native/libs/vr/libbufferhubqueue/include/private/dvr/
Dbuffer_hub_queue_client.h180 std::unique_ptr<uint8_t[]> in_metadata, pdx::LocalHandle in_fence, in Entry()
191 pdx::LocalHandle fence;
359 int timeout, size_t* slot, pdx::LocalHandle* release_fence);
380 pdx::LocalHandle* release_fence, bool gain_posted_buffer = false);
443 int timeout, size_t* slot, Meta* meta, pdx::LocalHandle* acquire_fence) { in Dequeue()
447 int timeout, size_t* slot, pdx::LocalHandle* acquire_fence) { in Dequeue()
453 pdx::LocalHandle* acquire_fence);
456 pdx::LocalHandle* acquire_fence);
/frameworks/native/libs/vr/libpdx/private/pdx/
Dmock_client_channel.h27 Status<LocalHandle>(void* transaction_state, int opcode,
38 const LocalHandle& handle));
49 LocalHandle* handle));
Dclient_channel.h47 virtual Status<LocalHandle> SendWithFileHandle(
55 const LocalHandle& handle) = 0;
63 LocalHandle* handle) const = 0;
/frameworks/native/libs/vr/libpdx/
Dclient_tests.cpp17 using android::pdx::LocalHandle;
52 PDX_REMOTE_METHOD(SendFile, kOpSendFile, void(const LocalHandle& fd));
53 PDX_REMOTE_METHOD(GetFile, kOpGetFile, LocalHandle(const std::string&, int));
246 .WillOnce(Return(ByMove(LocalHandle{fd}))); in TEST_F()
248 Status<LocalHandle> status = in TEST_F()
263 Status<LocalHandle> status = in TEST_F()
304 LocalHandle fd{eventfd(0, 0)}; in TEST_F()
308 PushFileHandle(kTransactionState, A<const LocalHandle&>())) in TEST_F()
320 LocalHandle fd{eventfd(0, 0)}; in TEST_F()
324 PushFileHandle(kTransactionState, A<const LocalHandle&>())) in TEST_F()
[all …]

123