Home
last modified time | relevance | path

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

123

/frameworks/av/services/oboeservice/
DAAudioServiceStreamMMAP.cpp70 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in open() local
71 if (endpoint == nullptr) { in open()
76 result = endpoint->registerStream(keep); in open()
123 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in standby_l() local
124 if (endpoint == nullptr) { in standby_l()
128 aaudio_result_t result = endpoint->standby(); in standby_l()
136 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in exitStandby_l() local
137 if (endpoint == nullptr) { in exitStandby_l()
141 aaudio_result_t result = endpoint->exitStandby(parcelable); in exitStandby_l()
157 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in startClient() local
[all …]
DAAudioEndpointManager.cpp112 sp<AAudioServiceEndpoint> endpoint; in findExclusiveEndpoint_l() local
117 endpoint = ep; in findExclusiveEndpoint_l()
123 endpoint.get(), configuration.getDeviceId(), configuration.getSessionId()); in findExclusiveEndpoint_l()
124 return endpoint; in findExclusiveEndpoint_l()
130 sp<AAudioServiceEndpointShared> endpoint; in findSharedEndpoint_l() local
135 endpoint = ep; in findSharedEndpoint_l()
141 endpoint.get(), configuration.getDeviceId(), configuration.getSessionId()); in findSharedEndpoint_l()
142 return endpoint; in findSharedEndpoint_l()
170 sp<AAudioServiceEndpoint> endpoint = findExclusiveEndpoint_l(configuration); in openExclusiveEndpoint() local
173 if (endpoint.get() != nullptr) { in openExclusiveEndpoint()
[all …]
DAAudioServiceStreamShared.cpp141 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in open() local
142 if (endpoint == nullptr) { in open()
159 setSampleRate(endpoint->getSampleRate()); in open()
160 } else if (getSampleRate() != endpoint->getSampleRate()) { in open()
162 __func__, getSampleRate(), endpoint->getSampleRate()); in open()
169 setChannelMask(endpoint->getChannelMask()); in open()
170 } else if (getSamplesPerFrame() != endpoint->getSamplesPerFrame()) { in open()
172 __func__, getSamplesPerFrame(), endpoint->getSamplesPerFrame()); in open()
198 result = endpoint->registerStream(keep); in open()
252 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in getHardwareTimestamp_l() local
[all …]
DAAudioServiceEndpointShared.cpp107 android::sp<AAudioServiceEndpointShared> endpoint(endpointPtr); in aaudio_endpoint_thread_proc() local
109 endpoint->decStrong(nullptr); in aaudio_endpoint_thread_proc()
111 void *result = endpoint->callbackLoop(); in aaudio_endpoint_thread_proc()
113 if (!endpoint->isConnected()) { in aaudio_endpoint_thread_proc()
116 endpoint->getStreamInternal()->safeReleaseCloseInternal(); in aaudio_endpoint_thread_proc()
DAAudioServiceStreamBase.cpp225 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in startDevice_l() local
226 if (endpoint == nullptr) { in startDevice_l()
230 if (!endpoint->isConnected()) { in startDevice_l()
234 return endpoint->startStream(this, &mClientHandle); in startDevice_l()
317 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in pause_l() local
318 if (endpoint == nullptr) { in pause_l()
323 result = endpoint->stopStream(this, mClientHandle); in pause_l()
361 sp<AAudioServiceEndpoint> endpoint = mServiceEndpointWeak.promote(); in stop_l() local
362 if (endpoint == nullptr) { in stop_l()
368 result = endpoint->stopStream(this, mClientHandle); in stop_l()
[all …]
/frameworks/native/libs/vr/libpdx/
Dservice_tests.cpp104 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 __anon01ddaecf0111::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 …]
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()
/frameworks/base/telecomm/java/android/telecom/
DCallEndpoint.java107 public CallEndpoint(CallEndpoint endpoint) { in CallEndpoint() argument
109 if (endpoint.getEndpointName() == null || endpoint.getIdentifier() == null) { in CallEndpoint()
113 mName = endpoint.getEndpointName(); in CallEndpoint()
114 mType = endpoint.getEndpointType(); in CallEndpoint()
115 mIdentifier = endpoint.getIdentifier(); in CallEndpoint()
129 CallEndpoint endpoint = (CallEndpoint) obj; in equals() local
130 return Objects.equals(getEndpointName(), endpoint.getEndpointName()) in equals()
131 && getEndpointType() == endpoint.getEndpointType() in equals()
132 && getIdentifier().equals(endpoint.getIdentifier()); in equals()
DInCallService.java368 CallEndpoint endpoint = (CallEndpoint) msg.obj;
369 if (!Objects.equals(mCallEndpoint, endpoint)) {
370 mCallEndpoint = endpoint;
673 public final void requestCallEndpointChange(@NonNull CallEndpoint endpoint, in requestCallEndpointChange() argument
677 mPhone.requestCallEndpointChange(endpoint, executor, callback); in requestCallEndpointChange()
/frameworks/av/media/libaaudio/src/binding/
DAAudioBinderAdapter.cpp66 Endpoint endpoint; in getStreamDescription() local
68 &endpoint, in getStreamDescription()
73 endpointOut = std::move(endpoint); in getStreamDescription()
160 Endpoint endpoint; in exitStandby() local
161 Status status = mDelegate->exitStandby(streamHandleInfo.getHandle(), &endpoint, &result); in exitStandby()
165 endpointOut = std::move(endpoint); in exitStandby()
DAudioEndpointParcelable.cpp69 void updateSharedMemoryIndex(Endpoint* endpoint, int oldIndex, int newIndex) { in updateSharedMemoryIndex() argument
70 updateSharedMemoryIndex(&endpoint->upMessageQueueParcelable, oldIndex, newIndex); in updateSharedMemoryIndex()
71 updateSharedMemoryIndex(&endpoint->downMessageQueueParcelable, oldIndex, newIndex); in updateSharedMemoryIndex()
72 updateSharedMemoryIndex(&endpoint->upDataQueueParcelable, oldIndex, newIndex); in updateSharedMemoryIndex()
73 updateSharedMemoryIndex(&endpoint->downDataQueueParcelable, oldIndex, newIndex); in updateSharedMemoryIndex()
/frameworks/native/libs/vr/libpdx/fuzz/
Dservice_dispatcher_fuzzer.cpp40 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()
/frameworks/base/core/java/android/hardware/usb/
DUsbRequest.java98 public boolean initialize(UsbDeviceConnection connection, UsbEndpoint endpoint) { in initialize() argument
99 mEndpoint = endpoint; in initialize()
102 boolean wasInitialized = native_init(connection, endpoint.getAddress(), in initialize()
103 endpoint.getAttributes(), endpoint.getMaxPacketSize(), endpoint.getInterval()); in initialize()
DUsbDeviceConnection.java292 public int bulkTransfer(UsbEndpoint endpoint, in bulkTransfer() argument
294 return bulkTransfer(endpoint, buffer, 0, length, timeout); in bulkTransfer()
312 public int bulkTransfer(UsbEndpoint endpoint, in bulkTransfer() argument
319 return native_bulk_request(endpoint.getAddress(), buffer, offset, length, timeout); in bulkTransfer()
441 private native int native_bulk_request(int endpoint, byte[] buffer, in native_bulk_request() argument
/frameworks/opt/telephony/src/java/com/android/internal/telephony/test/
DTestConferenceEventPackageParser.java131 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/
Dclient_channel_tests.cpp48 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/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/av/media/libaaudio/src/binding/aidl/aaudio/
DIAAudioService.aidl46 int getStreamDescription(int streamHandle, out Endpoint endpoint); in getStreamDescription() argument
82 int exitStandby(int streamHandle, out Endpoint endpoint); in exitStandby() argument
/frameworks/av/media/libmedia/
DIMediaPlayer.cpp425 status_t setRetransmitEndpoint(const struct sockaddr_in* endpoint) in setRetransmitEndpoint() argument
431 if (NULL != endpoint) { in setRetransmitEndpoint()
432 data.writeInt32(sizeof(*endpoint)); in setRetransmitEndpoint()
433 data.write(endpoint, sizeof(*endpoint)); in setRetransmitEndpoint()
454 status_t getRetransmitEndpoint(struct sockaddr_in* endpoint) in getRetransmitEndpoint() argument
466 data.read(endpoint, sizeof(*endpoint)); in getRetransmitEndpoint()
883 struct sockaddr_in endpoint; in onTransact() local
884 memset(&endpoint, 0, sizeof(endpoint)); in onTransact()
886 if (amt == sizeof(endpoint)) { in onTransact()
887 data.read(&endpoint, sizeof(struct sockaddr_in)); in onTransact()
[all …]
/frameworks/base/core/java/com/android/internal/usb/
DDumpUtils.java128 long id, @NonNull UsbEndpoint endpoint) { in writeEndpoint() argument
132 endpoint.getEndpointNumber()); in writeEndpoint()
133 dump.write("direction", UsbEndPointProto.DIRECTION, endpoint.getDirection()); in writeEndpoint()
134 dump.write("address", UsbEndPointProto.ADDRESS, endpoint.getAddress()); in writeEndpoint()
135 dump.write("type", UsbEndPointProto.TYPE, endpoint.getType()); in writeEndpoint()
137 endpoint.getAttributes()); in writeEndpoint()
139 endpoint.getMaxPacketSize()); in writeEndpoint()
140 dump.write("interval", UsbEndPointProto.INTERVAL, endpoint.getInterval()); in writeEndpoint()
/frameworks/base/services/usb/java/com/android/server/usb/
DUsbDirectMidiDevice.java248 UsbEndpointDescriptor endpoint = in UsbDirectMidiDevice() local
251 if (endpoint.getDirection() == 0) { in UsbDirectMidiDevice()
252 numOutputs += getNumJacks(endpoint); in UsbDirectMidiDevice()
254 numInputs += getNumJacks(endpoint); in UsbDirectMidiDevice()
285 UsbEndpointDescriptor endpoint = in calculateDefaultMidiProtocol() local
288 if (endpoint.getDirection() == 0) { in calculateDefaultMidiProtocol()
339 UsbEndpointDescriptor endpoint = in openLocked() local
342 if (endpoint.getDirection() == 0) { in openLocked()
343 outputEndpoints.add(endpoint.toAndroid(mParser)); in openLocked()
344 outputEndpointCableCounts.add(getNumJacks(endpoint)); in openLocked()
[all …]
/frameworks/opt/net/ims/src/java/com/android/ims/internal/
DConferenceParticipant.java92 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/telecomm/java/com/android/internal/telecom/
DICallEventCallback.aidl45 void onCallEndpointChanged(String callId, in CallEndpoint endpoint); in onCallEndpointChanged() argument
46 void onAvailableCallEndpointsChanged(String callId, in List<CallEndpoint> endpoint); in onAvailableCallEndpointsChanged() argument
/frameworks/base/core/java/android/net/
DLocalSocket.java155 public void connect(LocalSocketAddress endpoint) throws IOException { in connect() argument
162 impl.connect(endpoint, 0); in connect()
308 public void connect(LocalSocketAddress endpoint, int timeout) in connect() argument

123