Home
last modified time | relevance | path

Searched refs:endpoint (Results 1 – 25 of 35) sorted by relevance

12

/frameworks/av/services/oboeservice/
DAAudioEndpointManager.cpp97 sp<AAudioServiceEndpoint> endpoint; in findExclusiveEndpoint_l() local
100 endpoint = ep; in findExclusiveEndpoint_l()
106 endpoint.get(), configuration.getDeviceId()); in findExclusiveEndpoint_l()
107 return endpoint; in findExclusiveEndpoint_l()
113 sp<AAudioServiceEndpointShared> endpoint; in findSharedEndpoint_l() local
116 endpoint = ep; in findSharedEndpoint_l()
122 endpoint.get(), configuration.getDeviceId()); in findSharedEndpoint_l()
123 return endpoint; in findSharedEndpoint_l()
145 sp<AAudioServiceEndpoint> endpoint = findExclusiveEndpoint_l(configuration); in openExclusiveEndpoint() local
148 if (endpoint.get() != nullptr) { in openExclusiveEndpoint()
[all …]
DAAudioServiceStreamMMAP.cpp73 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in open() local
74 if (endpoint == nullptr) { in open()
79 result = endpoint->registerStream(keep); in open()
130 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in startClient() local
131 if (endpoint == nullptr) { in startClient()
136 aaudio_result_t result = endpoint->startClient(client, clientHandle); in startClient()
141 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in stopClient() local
142 if (endpoint == nullptr) { in stopClient()
146 aaudio_result_t result = endpoint->stopClient(clientHandle); in stopClient()
153 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in getFreeRunningPosition() local
[all …]
DAAudioServiceStreamShared.cpp131 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in open() local
132 if (endpoint == nullptr) { in open()
149 setSampleRate(endpoint->getSampleRate()); in open()
150 } else if (getSampleRate() != endpoint->getSampleRate()) { in open()
152 getSampleRate(), endpoint->getSampleRate()); in open()
159 setSamplesPerFrame(endpoint->getSamplesPerFrame()); in open()
160 } else if (getSamplesPerFrame() != endpoint->getSamplesPerFrame()) { in open()
162 getSamplesPerFrame(), endpoint->getSamplesPerFrame()); in open()
189 getSampleRate(), getSamplesPerFrame(), endpoint->getDeviceId()); in open()
191 result = endpoint->registerStream(keep); in open()
[all …]
DAAudioServiceStreamBase.cpp139 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in close() local
140 if (endpoint == nullptr) { in close()
143 endpoint->unregisterStream(this); in close()
145 endpointManager.closeEndpoint(endpoint); in close()
165 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in startDevice() local
166 if (endpoint == nullptr) { in startDevice()
170 return endpoint->startStream(this, &mClientHandle); in startDevice()
222 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in pause() local
223 if (endpoint == nullptr) { in pause()
227 result = endpoint->stopStream(this, mClientHandle); in pause()
[all …]
DAAudioServiceEndpointShared.cpp92 AAudioServiceEndpointShared *endpoint = (AAudioServiceEndpointShared *) context; in aaudio_endpoint_thread_proc() local
93 if (endpoint != NULL) { in aaudio_endpoint_thread_proc()
94 return endpoint->callbackLoop(); in aaudio_endpoint_thread_proc()
/frameworks/native/libs/vr/libpdx/
Dservice_tests.cpp102 auto endpoint = std::make_unique<testing::StrictMock<MockEndpoint>>(); in ServiceTest() local
103 EXPECT_CALL(*endpoint, SetService(_)) in ServiceTest()
106 service_ = std::make_shared<MockService>("MockSvc", std::move(endpoint)); in ServiceTest()
109 MockEndpoint* endpoint() { in endpoint() function in __anon3f8b42fa0111::ServiceTest
110 return static_cast<MockEndpoint*>(service_->endpoint()); in endpoint()
133 EXPECT_CALL(*endpoint(), AllocateMessageState()).WillOnce(Return(kState)); in SetupMessageInfoAndDefaultExpectations()
134 EXPECT_CALL(*endpoint(), FreeMessageState(kState)); in SetupMessageInfoAndDefaultExpectations()
138 EXPECT_CALL(*endpoint(), MessageReply(_, -EOPNOTSUPP)) in ExpectDefaultHandleMessage()
174 EXPECT_CALL(*endpoint(), AllocateMessageState()).WillOnce(Return(kState)); in TEST_F()
194 EXPECT_CALL(*endpoint(), FreeMessageState(kState)); in TEST_F()
[all …]
Dservice.cpp29 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 …]
Dservice_dispatcher.cpp78 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()
Dmock_tests.cpp17 android::pdx::MockEndpoint endpoint; in TEST() local
/frameworks/base/core/java/android/hardware/usb/
DUsbRequest.java92 public boolean initialize(UsbDeviceConnection connection, UsbEndpoint endpoint) { in initialize() argument
93 mEndpoint = endpoint; in initialize()
96 boolean wasInitialized = native_init(connection, endpoint.getAddress(), in initialize()
97 endpoint.getAttributes(), endpoint.getMaxPacketSize(), endpoint.getInterval()); in initialize()
DUsbDeviceConnection.java230 public int bulkTransfer(UsbEndpoint endpoint, in bulkTransfer() argument
232 return bulkTransfer(endpoint, buffer, 0, length, timeout); in bulkTransfer()
247 public int bulkTransfer(UsbEndpoint endpoint, in bulkTransfer() argument
250 return native_bulk_request(endpoint.getAddress(), buffer, offset, length, timeout); in bulkTransfer()
372 private native int native_bulk_request(int endpoint, byte[] buffer, in native_bulk_request() argument
/frameworks/base/telecomm/java/android/telecom/
DConferenceParticipant.java60 public ConferenceParticipant(Uri handle, String displayName, Uri endpoint, int state) { in ConferenceParticipant() argument
63 mEndpoint = endpoint; in ConferenceParticipant()
78 Uri endpoint = source.readParcelable(classLoader);
80 return new ConferenceParticipant(handle, displayName, endpoint, state);
/frameworks/opt/telephony/src/java/com/android/internal/telephony/test/
DTestConferenceEventPackageParser.java132 String endpoint = ""; in parseParticipant() local
145 endpoint = parser.getText(); in parseParticipant()
154 Log.v(LOG_TAG, "Endpoint: "+endpoint); in parseParticipant()
159 bundle.putString(ImsConferenceState.ENDPOINT, endpoint); in parseParticipant()
/frameworks/av/media/libmedia/
DIMediaPlayer.cpp422 status_t setRetransmitEndpoint(const struct sockaddr_in* endpoint) in setRetransmitEndpoint() argument
428 if (NULL != endpoint) { in setRetransmitEndpoint()
429 data.writeInt32(sizeof(*endpoint)); in setRetransmitEndpoint()
430 data.write(endpoint, sizeof(*endpoint)); in setRetransmitEndpoint()
451 status_t getRetransmitEndpoint(struct sockaddr_in* endpoint) in getRetransmitEndpoint() argument
463 data.read(endpoint, sizeof(*endpoint)); in getRetransmitEndpoint()
814 struct sockaddr_in endpoint; in onTransact() local
815 memset(&endpoint, 0, sizeof(endpoint)); in onTransact()
817 if (amt == sizeof(endpoint)) { in onTransact()
818 data.read(&endpoint, sizeof(struct sockaddr_in)); in onTransact()
[all …]
/frameworks/native/libs/vr/libpdx_uds/
Dclient_channel_tests.cpp48 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/libs/usb/tests/AccessoryChat/accessorychat/
Daccessorychat.c35 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/base/services/core/jni/
Dcom_android_server_UsbHostManager.cpp131 struct usb_endpoint_descriptor *endpoint = (struct usb_endpoint_descriptor *)desc; in usb_device_added() local
134 endpoint->bEndpointAddress, endpoint->bmAttributes, in usb_device_added()
135 __le16_to_cpu(endpoint->wMaxPacketSize), endpoint->bInterval); in usb_device_added()
/frameworks/base/core/java/android/net/
DLocalSocket.java138 public void connect(LocalSocketAddress endpoint) throws IOException { in connect() argument
145 impl.connect(endpoint, 0); in connect()
289 public void connect(LocalSocketAddress endpoint, int timeout) in connect() argument
DLocalSocketImpl.java302 public void bind(LocalSocketAddress endpoint) throws IOException in bind() argument
308 bindLocal(fd, endpoint.getName(), endpoint.getNamespace().getId()); in bind()
/frameworks/av/include/media/
DIMediaPlayer.h90 virtual status_t setRetransmitEndpoint(const struct sockaddr_in* endpoint) = 0;
91 virtual status_t getRetransmitEndpoint(struct sockaddr_in* endpoint) = 0;
/frameworks/av/media/libmedia/include/media/
DIMediaPlayer.h90 virtual status_t setRetransmitEndpoint(const struct sockaddr_in* endpoint) = 0;
91 virtual status_t getRetransmitEndpoint(struct sockaddr_in* endpoint) = 0;
/frameworks/base/packages/SystemUI/src/com/android/systemui/pip/phone/
DPipMotionHelper.java489 Point endpoint = getDismissEndPoint(pipBounds, velX, velY, isFling); in isGestureToDismissArea() local
491 endpoint.x += pipBounds.width() / 2; in isGestureToDismissArea()
492 endpoint.y += pipBounds.height() / 2; in isGestureToDismissArea()
500 return dismissArea.contains(endpoint.x, endpoint.y); in isGestureToDismissArea()
/frameworks/native/libs/vr/libpdx/private/pdx/
Dservice.h356 Service(const std::string& name, std::unique_ptr<Endpoint> endpoint);
551 Endpoint* endpoint() const { return endpoint_.get(); } in endpoint() function
656 ServiceBase(const std::string& name, std::unique_ptr<Endpoint> endpoint) in ServiceBase() argument
657 : Service(name, std::move(endpoint)) {} in ServiceBase()
/frameworks/base/core/jni/
Dandroid_hardware_UsbDeviceConnection.cpp200 jint endpoint, jbyteArray buffer, jint start, jint length, jint timeout) in android_hardware_UsbDeviceConnection_bulk_request() argument
213 jint result = usb_device_bulk_transfer(device, endpoint, bufferBytes + start, length, timeout); in android_hardware_UsbDeviceConnection_bulk_request()
/frameworks/av/media/mtp/
DMtpPacket.cpp157 request->endpoint, in transfer()

12