Home
last modified time | relevance | path

Searched refs:reply (Results 1 – 25 of 83) sorted by relevance

1234

/packages/modules/Connectivity/tests/unit/java/com/android/server/connectivity/mdns/
DMdnsReplySenderTest.kt141 private fun queueReply(sender: MdnsReplySender, reply: MdnsReplyInfo): in queueReply()
142 Unit = runningOnHandlerAndReturn { sender.queueReply(reply) } in queueReply()
171 for (reply in replies) { in verifyMessageQueued() constant
172 queueReply(sender, reply) in verifyMessageQueued()
174 handlerCaptor.capture(), messageCaptor.capture(), eq(reply.sendDelayMs)) in verifyMessageQueued()
197 val reply = MdnsReplyInfo(answers, additionalAnswers, 20L /* sendDelayMs */, in testQueueReply() constant
199 val (handler, message) = verifyMessageQueued(replySender, listOf(reply)) in testQueueReply()
206 val reply = MdnsReplyInfo(answers, additionalAnswers, 20L /* sendDelayMs */, in testQueueReply_KnownAnswerSuppressionEnabled() constant
208 val (handler, message) = verifyMessageQueued(replySender, listOf(reply)) in testQueueReply_KnownAnswerSuppressionEnabled()
215 val reply = MdnsReplyInfo(answers, additionalAnswers, 400L /* sendDelayMs */, in testQueueReply_MultiplePacket() constant
[all …]
DMdnsRecordRepositoryTest.kt245 val reply = repository.getReply(query, src) in testAddAndUpdates() constant
247 assertNotNull(reply) in testAddAndUpdates()
260 ), reply.answers) in testAddAndUpdates()
614 val reply = repository.getReply(query, src) in testGetReply_singlePtrQuestion_returnsSrvTxtAddressNsecRecords() constant
616 assertNotNull(reply) in testGetReply_singlePtrQuestion_returnsSrvTxtAddressNsecRecords()
620 reply.answers) in testGetReply_singlePtrQuestion_returnsSrvTxtAddressNsecRecords()
634 ), reply.additionalAnswers) in testGetReply_singlePtrQuestion_returnsSrvTxtAddressNsecRecords()
647 val reply = repository.getReply(query, src) in testGetReply_ptrQuestionForServiceWithCustomHost_customHostUsedInAdditionalAnswers() constant
649 assertNotNull(reply) in testGetReply_ptrQuestionForServiceWithCustomHost_customHostUsedInAdditionalAnswers()
654 reply.answers) in testGetReply_ptrQuestionForServiceWithCustomHost_customHostUsedInAdditionalAnswers()
[all …]
/packages/services/Car/libs/procfs-inspector/server/
Dserver.cpp44 Parcel data, reply; in readProcessTable() local
45 remote()->transact((uint32_t)IProcfsInspector::Call::READ_PROCESS_TABLE, data, &reply); in readProcessTable()
48 reply.readParcelableVector(&result); in readProcessTable()
56 const Parcel& data, Parcel* reply, uint32_t flags) { in onTransact() argument
59 CHECK_INTERFACE(IProcfsInspector, data, reply); in onTransact()
61 reply->writeNoException(); in onTransact()
62 reply->writeParcelableVector(readProcessTable()); in onTransact()
69 return BBinder::onTransact(code, data, reply, flags); in onTransact()
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/mapclient/
DMnsObexServerTest.java64 HeaderSet reply = new HeaderSet(); in onConnect_whenUuidIsWrong() local
66 assertThat(mServer.onConnect(request, reply)) in onConnect_whenUuidIsWrong()
74 HeaderSet reply = new HeaderSet(); in onConnect_withCorrectUuid() local
76 assertThat(mServer.onConnect(request, reply)).isEqualTo(ResponseCodes.OBEX_HTTP_OK); in onConnect_withCorrectUuid()
77 assertThat(reply.getHeader(HeaderSet.WHO)).isEqualTo(MnsObexServer.MNS_TARGET); in onConnect_withCorrectUuid()
83 HeaderSet reply = new HeaderSet(); in onDisconnect_callsStateMachineDisconnect() local
85 mServer.onDisconnect(request, reply); in onDisconnect_callsStateMachineDisconnect()
143 HeaderSet reply = new HeaderSet(); in onAbort_returnsNotImplemented() local
145 assertThat(mServer.onAbort(request, reply)) in onAbort_returnsNotImplemented()
152 HeaderSet reply = new HeaderSet(); in onSetPath_returnsBadRequest() local
[all …]
/packages/modules/Media/apex/framework/java/android/media/
DBaseMediaParceledListSlice.java100 Parcel reply = Parcel.obtain(); in BaseMediaParceledListSlice() local
103 retriever.transact(IBinder.FIRST_CALL_TRANSACTION, data, reply, 0); in BaseMediaParceledListSlice()
108 while (i < N && reply.readInt() != 0) { in BaseMediaParceledListSlice()
109 final T parcelable = readCreator(creator, reply, loader); in BaseMediaParceledListSlice()
121 reply.recycle(); in BaseMediaParceledListSlice()
184 protected boolean onTransact(int code, Parcel data, Parcel reply, int flags) in writeToParcel()
187 return super.onTransact(code, data, reply, flags); in writeToParcel()
191 while (i < N && reply.dataSize() < MAX_IPC_SIZE) { in writeToParcel()
192 reply.writeInt(1); in writeToParcel()
196 writeElement(parcelable, reply, callFlags); in writeToParcel()
[all …]
/packages/modules/OnDevicePersonalization/framework/java/com/android/ondevicepersonalization/internal/util/
DBaseOdpParceledListSlice.java99 Parcel reply = Parcel.obtain(); in BaseOdpParceledListSlice() local
102 retriever.transact(IBinder.FIRST_CALL_TRANSACTION, data, reply, 0); in BaseOdpParceledListSlice()
107 while (i < numItems && reply.readInt() != 0) { in BaseOdpParceledListSlice()
108 final T parcelable = readCreator(creator, reply, loader); in BaseOdpParceledListSlice()
116 reply.recycle(); in BaseOdpParceledListSlice()
179 protected boolean onTransact(int code, Parcel data, Parcel reply, int flags) in writeToParcel()
182 return super.onTransact(code, data, reply, flags); in writeToParcel()
186 while (i < numItems && reply.dataSize() < MAX_IPC_SIZE) { in writeToParcel()
187 reply.writeInt(1); in writeToParcel()
191 writeElement(parcelable, reply, callFlags); in writeToParcel()
[all …]
/packages/apps/Settings/src/com/android/settings/development/
DHardwareOverlaysPreferenceController.java91 final Parcel reply = Parcel.obtain(); in updateHardwareOverlaysSetting() local
93 mSurfaceFlinger.transact(SURFACE_FLINGER_READ_CODE, data, reply, 0 /* flags */); in updateHardwareOverlaysSetting()
94 @SuppressWarnings("unused") final int showCpu = reply.readInt(); in updateHardwareOverlaysSetting()
95 @SuppressWarnings("unused") final int enableGL = reply.readInt(); in updateHardwareOverlaysSetting()
96 @SuppressWarnings("unused") final int showUpdates = reply.readInt(); in updateHardwareOverlaysSetting()
97 @SuppressWarnings("unused") final int showBackground = reply.readInt(); in updateHardwareOverlaysSetting()
98 final int disableOverlays = reply.readInt(); in updateHardwareOverlaysSetting()
100 reply.recycle(); in updateHardwareOverlaysSetting()
DShowSurfaceUpdatesPreferenceController.java90 final Parcel reply = Parcel.obtain(); in updateShowUpdatesSetting() local
92 mSurfaceFlinger.transact(SURFACE_FLINGER_READ_CODE, data, reply, 0 /* flags */); in updateShowUpdatesSetting()
93 @SuppressWarnings("unused") final int showCpu = reply.readInt(); in updateShowUpdatesSetting()
94 @SuppressWarnings("unused") final int enableGL = reply.readInt(); in updateShowUpdatesSetting()
95 final int showUpdates = reply.readInt(); in updateShowUpdatesSetting()
97 reply.recycle(); in updateShowUpdatesSetting()
DShowRefreshRatePreferenceController.java93 final Parcel reply = Parcel.obtain(); in updateShowRefreshRateSetting() local
96 mSurfaceFlinger.transact(SURFACE_FLINGER_CODE, data, reply, 0 /* flags */); in updateShowRefreshRateSetting()
97 final boolean enabled = reply.readBoolean(); in updateShowRefreshRateSetting()
99 reply.recycle(); in updateShowRefreshRateSetting()
DShowHdrSdrRatioPreferenceController.java113 final Parcel reply = Parcel.obtain(); in updateShowHdrSdrRatioSetting() local
116 mSurfaceFlinger.transact(SURFACE_FLINGER_CODE, data, reply, 0 /* flags */); in updateShowHdrSdrRatioSetting()
117 final boolean enabled = reply.readBoolean(); in updateShowHdrSdrRatioSetting()
119 reply.recycle(); in updateShowHdrSdrRatioSetting()
/packages/modules/Connectivity/service-t/src/com/android/server/connectivity/mdns/
DMdnsReplySender.java145 public void queueReply(@NonNull MdnsReplyInfo reply) { in queueReply() argument
149 mDependencies.removeMessages(mHandler, MSG_SEND, reply.source); in queueReply()
151 final MdnsReplyInfo queuingReply = mSrcReplies.remove(reply.source); in queueReply()
160 answers.addAll(reply.answers); in queueReply()
161 additionalAnswers.addAll(reply.additionalAnswers); in queueReply()
162 knownAnswers.addAll(reply.knownAnswers); in queueReply()
181 reply.sendDelayMs, in queueReply()
182 queuingReply == null ? reply.destination in queueReply()
183 : getReplyDestination(queuingReply.destination, reply.destination), in queueReply()
184 reply.source, in queueReply()
[all …]
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/pbap/
DBluetoothPbapObexServerTest.java129 HeaderSet reply = new HeaderSet(); in testOnConnect_whenIoExceptionIsThrownFromGettingTargetHeader() local
133 assertThat(mServer.onConnect(request, reply)) in testOnConnect_whenIoExceptionIsThrownFromGettingTargetHeader()
141 HeaderSet reply = new HeaderSet(); in testOnConnect_whenUuidIsNull() local
143 assertThat(mServer.onConnect(request, reply)) in testOnConnect_whenUuidIsNull()
151 HeaderSet reply = new HeaderSet(); in testOnConnect_whenUuidLengthIsWrong() local
153 assertThat(mServer.onConnect(request, reply)) in testOnConnect_whenUuidLengthIsWrong()
161 HeaderSet reply = new HeaderSet(); in testOnConnect_whenUuidIsWrong() local
163 assertThat(mServer.onConnect(request, reply)) in testOnConnect_whenUuidIsWrong()
171 HeaderSet reply = new HeaderSet(); in testOnConnect_whenIoExceptionIsThrownFromGettingWhoHeader() local
175 assertThat(mServer.onConnect(request, reply)) in testOnConnect_whenIoExceptionIsThrownFromGettingWhoHeader()
[all …]
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/obex/
DFakeObexServer.java56 HeaderSet request, HeaderSet reply, boolean backup, boolean create); in onSetPathValidator() argument
61 public int onConnect(final HeaderSet request, HeaderSet reply) { in onConnect() argument
66 public void onDisconnect(final HeaderSet request, HeaderSet reply) {} in onDisconnect() argument
79 public int onAbort(final HeaderSet request, HeaderSet reply) { in onAbort() argument
86 HeaderSet reply, in onSetPath() argument
89 return onSetPathValidator(request, reply, backup, create); in onSetPath()
/packages/apps/DocumentsUI/src/com/android/documentsui/base/
DEventHandler.java27 public static <T> EventHandler<T> createStub(boolean reply) { in createStub() argument
28 return new Stub<T>(reply); in createStub()
35 private Stub(boolean reply) { in Stub() argument
36 mReply = reply;} in Stub()
/packages/services/Car/tools/emulator/
Dprop_event_simulator.py73 reply = v.rxMsg()
74 print(reply)
76 value = parseVal(args.value, reply.config[0].value_type)
80 reply = v.rxMsg()
81 print(reply)
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/mapclient/
DMnsObexServer.java66 public int onConnect(final HeaderSet request, HeaderSet reply) { in onConnect() argument
80 reply.setHeader(HeaderSet.WHO, MNS_TARGET); in onConnect()
85 public void onDisconnect(final HeaderSet request, HeaderSet reply) { in onDisconnect() argument
128 public int onAbort(final HeaderSet request, HeaderSet reply) { in onAbort() argument
135 final HeaderSet request, HeaderSet reply, final boolean backup, final boolean create) { in onSetPath() argument
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/pbap/
DBluetoothPbapObexServer.java251 public int onConnect(final HeaderSet request, HeaderSet reply) { in onConnect() argument
282 reply.setHeader(HeaderSet.WHO, uuid); in onConnect()
297 reply.setHeader(HeaderSet.TARGET, remote); in onConnect()
340 public int onAbort(HeaderSet request, HeaderSet reply) { in onAbort() argument
355 public int onDelete(final HeaderSet request, final HeaderSet reply) { in onDelete() argument
364 final HeaderSet reply, in onSetPath() argument
436 HeaderSet reply = new HeaderSet(); in onGet() local
603 return pullVcardListing(appParamValue, reply, op, name); in onGet()
606 return pullVcardEntry(appParamValue, op, reply, name); in onGet()
609 return pullPhonebook(appParamValue, reply, op, name); in onGet()
[all …]
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/sap/
DSapServer.java404 SapMessage reply = in run() local
406 sendClientMessage(reply); in run()
569 SapMessage reply = new SapMessage(SapMessage.ID_CONNECT_RESP); in onConnectRequest() local
575 reply = null; in onConnectRequest()
581 reply.setConnectionStatus(SapMessage.CON_STATUS_ERROR_CONNECTION); in onConnectRequest()
589 reply.setConnectionStatus(SapMessage.CON_STATUS_OK_ONGOING_CALL); in onConnectRequest()
600 reply = null; in onConnectRequest()
602 reply = new SapMessage(SapMessage.ID_CONNECT_RESP); in onConnectRequest()
603 reply.setConnectionStatus(SapMessage.CON_STATUS_ERROR_CONNECTION); in onConnectRequest()
604 sendClientMessage(reply); in onConnectRequest()
[all …]
/packages/modules/Bluetooth/tools/rootcanal/rust/src/lmp/procedure/
Dsecure_simple_pairing.rs343 Either::Left(reply) => { in initiate()
355 io_capabilities: reply.get_io_capability().into(), in initiate()
356 oob_authentication_data: reply.get_oob_present().into(), in initiate()
357 authentication_requirement: reply in initiate()
364 io_capability: reply.get_io_capability(), in initiate()
365 oob_data_present: reply.get_oob_present(), in initiate()
366 authentication_requirements: reply.get_authentication_requirements(), in initiate()
621 Either::Left(reply) => { in respond()
633 io_capabilities: reply.get_io_capability().into(), in respond()
634 oob_authentication_data: reply.get_oob_present().into(), in respond()
[all …]
/packages/apps/Settings/src/com/android/settings/notification/zen/
DZenModeEventRuleSettings.java160 final int reply = Integer.parseInt((String) newValue); in onCreateInternal()
161 if (reply == mEvent.reply) return false; in onCreateInternal()
162 mEvent.reply = reply; in onCreateInternal()
177 if (!Objects.equals(mReply.getValue(), Integer.toString(mEvent.reply))) { in updateControlsInternal()
178 mReply.setValue(Integer.toString(mEvent.reply)); in updateControlsInternal()
/packages/apps/Settings/src/com/android/settings/notification/modes/
DZenModeSetCalendarPreferenceController.java153 final int reply = Integer.parseInt((String) newValue);
154 if (reply == mEvent.reply) return false;
155 mEvent.reply = reply;
165 if (!Objects.equals(mReply.getValue(), Integer.toString(mEvent.reply))) { in updatePrefValues()
166 mReply.setValue(Integer.toString(mEvent.reply)); in updatePrefValues()
/packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/hotword/
DHotwordServiceManager.java108 String reply; in HotwordServiceManager()
112 reply = "No reply msg.what " + msg.what; in HotwordServiceManager()
114 reply = data.getString(ConcurrentHotwordDetectionService.MESSAGE_REPLY); in HotwordServiceManager()
120 mServiceUpdatedCallback.onRecordingStarted(reply); in HotwordServiceManager()
125 mServiceUpdatedCallback.onServiceStopped(reply); in HotwordServiceManager()
/packages/modules/DnsResolver/tests/dns_responder/
Ddns_tls_frontend.cpp231 std::vector<uint8_t> reply; in handleRequests() local
280 reply.insert(reply.end(), responseHeader, responseHeader + 2); in handleRequests()
281 reply.insert(reply.end(), recv_buffer, recv_buffer + rlen); in handleRequests()
297 const int replyLen = reply.size(); in handleRequests()
299 if (SSL_write(ssl, reply.data(), replyLen) != replyLen) { in handleRequests()
/packages/services/Car/tests/ConcurrentHotwordDetector/src/com/android/car/test/concurrent/hotword/
DConcurrentHotwordDetectionService.java222 private void sendReply(@Nullable Messenger messenger, @Nullable Message reply) { in sendReply() argument
228 if (reply == null) { in sendReply()
234 messenger.send(reply); in sendReply()
235 Log.i(TAG, "reply message sent " + reply); in sendReply()
314 String reply = results.stream().collect(Collectors.joining(" ")); in startRecognizer()
316 sendReply(replyTo, createMessage(reply, MSG_START_RECOGNIZER_REPLY)); in startRecognizer()
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/opp/
DBluetoothOppObexServerSessionTest.java318 HeaderSet reply = new HeaderSet(); in onConnect_withNonNullTargetInHeader_returnsHttpNotAcceptable() local
321 assertThat(mServerSession.onConnect(request, reply)) in onConnect_withNonNullTargetInHeader_returnsHttpNotAcceptable()
328 HeaderSet reply = new HeaderSet(); in onConnect_returnsObexHttpOk() local
338 assertThat(mServerSession.onConnect(request, reply)).isEqualTo(ResponseCodes.OBEX_HTTP_OK); in onConnect_returnsObexHttpOk()
345 HeaderSet reply = new HeaderSet(); in onDisconnect_repliesObexHttpOk() local
346 mServerSession.onDisconnect(request, reply); in onDisconnect_repliesObexHttpOk()
347 assertThat(reply.responseCode).isEqualTo(ResponseCodes.OBEX_HTTP_OK); in onDisconnect_repliesObexHttpOk()

1234