| /frameworks/av/services/oboeservice/ |
| D | AAudioEndpointManager.cpp | 109 sp<AAudioServiceEndpoint> endpoint; in findExclusiveEndpoint_l() local
114 endpoint = ep; in findExclusiveEndpoint_l()
120 endpoint.get(), configuration.getDeviceId(), configuration.getSessionId()); in findExclusiveEndpoint_l()
121 return endpoint; in findExclusiveEndpoint_l()
127 sp<AAudioServiceEndpointShared> endpoint; in findSharedEndpoint_l() local
132 endpoint = ep; in findSharedEndpoint_l()
138 endpoint.get(), configuration.getDeviceId(), configuration.getSessionId()); in findSharedEndpoint_l()
139 return endpoint; in findSharedEndpoint_l()
160 sp<AAudioServiceEndpoint> endpoint = findExclusiveEndpoint_l(configuration); in openExclusiveEndpoint() local
163 if (endpoint.get() != nullptr) { in openExclusiveEndpoint()
[all …]
|
| D | AAudioServiceStreamMMAP.cpp | 78 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in open() local
79 if (endpoint == nullptr) { in open()
84 result = endpoint->registerStream(keep); in open()
131 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in startClient() local
132 if (endpoint == nullptr) { in startClient()
137 aaudio_result_t result = endpoint->startClient(client, clientHandle); in startClient()
142 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in stopClient() local
143 if (endpoint == nullptr) { in stopClient()
147 aaudio_result_t result = endpoint->stopClient(clientHandle); in stopClient()
154 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in getFreeRunningPosition() local
[all …]
|
| D | AAudioServiceStreamShared.cpp | 136 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in open() local
137 if (endpoint == nullptr) { in open()
154 setSampleRate(endpoint->getSampleRate()); in open()
155 } else if (getSampleRate() != endpoint->getSampleRate()) { in open()
157 __func__, getSampleRate(), endpoint->getSampleRate()); in open()
164 setSamplesPerFrame(endpoint->getSamplesPerFrame()); in open()
165 } else if (getSamplesPerFrame() != endpoint->getSamplesPerFrame()) { in open()
167 __func__, getSamplesPerFrame(), endpoint->getSamplesPerFrame()); in open()
193 result = endpoint->registerStream(keep); in open()
260 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in getHardwareTimestamp() local
[all …]
|
| D | AAudioServiceStreamBase.cpp | 136 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in close() local
137 if (endpoint == nullptr) { in close()
140 endpoint->unregisterStream(this); in close()
142 endpointManager.closeEndpoint(endpoint); in close()
161 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in startDevice() local
162 if (endpoint == nullptr) { in startDevice()
166 return endpoint->startStream(this, &mClientHandle); in startDevice()
221 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in pause() local
222 if (endpoint == nullptr) { in pause()
226 result = endpoint->stopStream(this, mClientHandle); in pause()
[all …]
|
| D | AAudioServiceEndpointShared.cpp | 99 sp<AAudioServiceEndpointShared> endpoint = *endpointForThread; in aaudio_endpoint_thread_proc() local
101 void *result = endpoint->callbackLoop(); in aaudio_endpoint_thread_proc()
103 if (!endpoint->isConnected()) { in aaudio_endpoint_thread_proc()
104 endpoint->close(); in aaudio_endpoint_thread_proc()
|
| /frameworks/native/libs/vr/libpdx/ |
| D | service_tests.cpp | 104 auto endpoint = std::make_unique<testing::StrictMock<MockEndpoint>>(); in ServiceTest() local
105 EXPECT_CALL(*endpoint, SetService(_)) in ServiceTest()
108 service_ = std::make_shared<MockService>("MockSvc", std::move(endpoint)); in ServiceTest()
111 MockEndpoint* endpoint() { in endpoint() function in __anon2a7cbd3b0111::ServiceTest
112 return static_cast<MockEndpoint*>(service_->endpoint()); in endpoint()
135 EXPECT_CALL(*endpoint(), AllocateMessageState()).WillOnce(Return(kState)); in SetupMessageInfoAndDefaultExpectations()
136 EXPECT_CALL(*endpoint(), FreeMessageState(kState)); in SetupMessageInfoAndDefaultExpectations()
140 EXPECT_CALL(*endpoint(), MessageReply(_, -EOPNOTSUPP)) in ExpectDefaultHandleMessage()
176 EXPECT_CALL(*endpoint(), AllocateMessageState()).WillOnce(Return(kState)); in TEST_F()
196 EXPECT_CALL(*endpoint(), FreeMessageState(kState)); in TEST_F()
[all …]
|
| D | service.cpp | 29 state_ = svc->endpoint()->AllocateMessageState();
61 svc->endpoint()->FreeMessageState(state_); in Destroy()
80 return svc->endpoint()->ReadMessageData(this, vector, vector_length); in ReadVector()
91 svc->endpoint()->ReadMessageData(this, vector, vector_length); in ReadVectorAll()
109 return svc->endpoint()->ReadMessageData(this, &vector, 1); in Read()
119 return svc->endpoint()->WriteMessageData(this, vector, vector_length); in WriteVector()
130 svc->endpoint()->WriteMessageData(this, vector, vector_length); in WriteVectorAll()
148 return svc->endpoint()->WriteMessageData(this, &vector, 1); in Write()
157 return svc->endpoint()->PushFileHandle(this, handle); in PushFileHandle()
166 return svc->endpoint()->PushFileHandle(this, handle); in PushFileHandle()
[all …]
|
| D | service_dispatcher.cpp | 78 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, service->endpoint()->epoll_fd(), in AddService()
96 if (epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_DEL, service->endpoint()->epoll_fd(), in RemoveService()
133 service->endpoint()->epoll_fd()); in ReceiveAndDispatch()
165 service->endpoint()->epoll_fd()); in EnterDispatchLoop()
|
| D | mock_tests.cpp | 17 android::pdx::MockEndpoint endpoint; in TEST() local
|
| /frameworks/base/core/java/android/hardware/usb/ |
| D | UsbRequest.java | 97 public boolean initialize(UsbDeviceConnection connection, UsbEndpoint endpoint) { in initialize() argument
98 mEndpoint = endpoint; in initialize()
101 boolean wasInitialized = native_init(connection, endpoint.getAddress(), in initialize()
102 endpoint.getAttributes(), endpoint.getMaxPacketSize(), endpoint.getInterval()); in initialize()
|
| D | UsbDeviceConnection.java | 235 public int bulkTransfer(UsbEndpoint endpoint, in bulkTransfer() argument
237 return bulkTransfer(endpoint, buffer, 0, length, timeout); in bulkTransfer()
255 public int bulkTransfer(UsbEndpoint endpoint, in bulkTransfer() argument
262 return native_bulk_request(endpoint.getAddress(), buffer, offset, length, timeout); in bulkTransfer()
384 private native int native_bulk_request(int endpoint, byte[] buffer, in native_bulk_request() argument
|
| /frameworks/native/libs/vr/libpdx/fuzz/ |
| D | service_dispatcher_fuzzer.cpp | 40 FuzzEndpoint* endpoint = new FuzzEndpoint(&fdp); in LLVMFuzzerTestOneInput() local
45 new Service("FuzzService", std::unique_ptr<Endpoint>(endpoint))); in LLVMFuzzerTestOneInput()
64 eventfd_write(endpoint->epoll_fd(), wakeup_val); in LLVMFuzzerTestOneInput()
|
| D | message_fuzzer.cpp | 35 FuzzEndpoint* endpoint = new FuzzEndpoint(&fdp); in LLVMFuzzerTestOneInput() local
37 new Service("FuzzService", std::unique_ptr<Endpoint>(endpoint))); in LLVMFuzzerTestOneInput()
|
| /frameworks/opt/telephony/src/java/com/android/internal/telephony/test/ |
| D | TestConferenceEventPackageParser.java | 131 String endpoint = ""; in parseParticipant() local
144 endpoint = parser.getText(); in parseParticipant()
153 Log.v(LOG_TAG, "Endpoint: "+endpoint); in parseParticipant()
158 bundle.putString(ImsConferenceState.ENDPOINT, endpoint); in parseParticipant()
|
| /frameworks/native/libs/vr/libpdx_uds/ |
| D | client_channel_tests.cpp | 48 explicit TestService(std::unique_ptr<Endpoint> endpoint) in TestService() argument
49 : ServiceBase{"TestService", std::move(endpoint)} {} in TestService()
82 auto endpoint = Endpoint::CreateFromSocketFd(LocalHandle{}); in TestServiceRunner() local
83 endpoint->RegisterNewChannelForTests(std::move(channel_socket)); in TestServiceRunner()
84 service_ = TestService::Create(std::move(endpoint)); in TestServiceRunner()
|
| /frameworks/base/core/java/com/android/internal/usb/ |
| D | DumpUtils.java | 126 long id, @NonNull UsbEndpoint endpoint) { in writeEndpoint() argument
130 endpoint.getEndpointNumber()); in writeEndpoint()
131 dump.write("direction", UsbEndPointProto.DIRECTION, endpoint.getDirection()); in writeEndpoint()
132 dump.write("address", UsbEndPointProto.ADDRESS, endpoint.getAddress()); in writeEndpoint()
133 dump.write("type", UsbEndPointProto.TYPE, endpoint.getType()); in writeEndpoint()
135 endpoint.getAttributes()); in writeEndpoint()
137 endpoint.getMaxPacketSize()); in writeEndpoint()
138 dump.write("interval", UsbEndPointProto.INTERVAL, endpoint.getInterval()); in writeEndpoint()
|
| /frameworks/av/media/libmedia/ |
| D | IMediaPlayer.cpp | 440 status_t setRetransmitEndpoint(const struct sockaddr_in* endpoint) in setRetransmitEndpoint() argument
446 if (NULL != endpoint) { in setRetransmitEndpoint()
447 data.writeInt32(sizeof(*endpoint)); in setRetransmitEndpoint()
448 data.write(endpoint, sizeof(*endpoint)); in setRetransmitEndpoint()
469 status_t getRetransmitEndpoint(struct sockaddr_in* endpoint) in getRetransmitEndpoint() argument
481 data.read(endpoint, sizeof(*endpoint)); in getRetransmitEndpoint()
892 struct sockaddr_in endpoint; in onTransact() local
893 memset(&endpoint, 0, sizeof(endpoint)); in onTransact()
895 if (amt == sizeof(endpoint)) { in onTransact()
896 data.read(&endpoint, sizeof(struct sockaddr_in)); in onTransact()
[all …]
|
| /frameworks/base/libs/usb/tests/AccessoryChat/accessorychat/ |
| D | accessorychat.c | 35 int endpoint = (int)(uintptr_t)arg; in read_thread() local
41 ret = usb_device_bulk_transfer(sDevice, endpoint, buffer, sizeof(buffer), 1000); in read_thread()
55 int endpoint = (int)(uintptr_t)arg; in write_thread() local
63 ret = usb_device_bulk_transfer(sDevice, endpoint, line, strlen(line), 1000); in write_thread()
|
| /frameworks/opt/net/ims/src/java/com/android/ims/internal/ |
| D | ConferenceParticipant.java | 92 public ConferenceParticipant(Uri handle, String displayName, Uri endpoint, int state, in ConferenceParticipant() argument
96 mEndpoint = endpoint; in ConferenceParticipant()
112 Uri endpoint = source.readParcelable(classLoader);
118 new ConferenceParticipant(handle, displayName, endpoint, state,
|
| /frameworks/base/core/java/android/net/ |
| D | LocalSocket.java | 141 public void connect(LocalSocketAddress endpoint) throws IOException { in connect() argument
148 impl.connect(endpoint, 0); in connect()
292 public void connect(LocalSocketAddress endpoint, int timeout) in connect() argument
|
| D | LocalSocketImpl.java | 272 public void bind(LocalSocketAddress endpoint) throws IOException in bind() argument
278 bindLocal(fd, endpoint.getName(), endpoint.getNamespace().getId()); in bind()
|
| /frameworks/base/services/usb/java/com/android/server/usb/descriptors/ |
| D | UsbInterfaceDescriptor.java | 93 void addEndpointDescriptor(UsbEndpointDescriptor endpoint) { in addEndpointDescriptor() argument
94 mEndpointDescriptors.add(endpoint); in addEndpointDescriptor()
|
| /frameworks/av/media/libmedia/include/media/ |
| D | IMediaPlayer.h | 91 virtual status_t setRetransmitEndpoint(const struct sockaddr_in* endpoint) = 0;
92 virtual status_t getRetransmitEndpoint(struct sockaddr_in* endpoint) = 0;
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/pip/phone/ |
| D | PipMotionHelper.java | 502 Point endpoint = getDismissEndPoint(pipBounds, velX, velY, isFling); in isGestureToDismissArea() local
504 endpoint.x += pipBounds.width() / 2; in isGestureToDismissArea()
505 endpoint.y += pipBounds.height() / 2; in isGestureToDismissArea()
513 return dismissArea.contains(endpoint.x, endpoint.y); in isGestureToDismissArea()
|
| /frameworks/native/libs/vr/libpdx/private/pdx/ |
| D | service.h | 365 Service(const std::string& name, std::unique_ptr<Endpoint> endpoint);
560 Endpoint* endpoint() const { return endpoint_.get(); } in endpoint() function
673 ServiceBase(const std::string& name, std::unique_ptr<Endpoint> endpoint) in ServiceBase() argument
674 : Service(name, std::move(endpoint)) {} in ServiceBase()
|