| /aosp12/frameworks/base/packages/SystemUI/src/com/android/systemui/util/concurrency/ |
| H A D | MessageRouterImpl.java | 68 public <T> void cancelMessages(Class<T> messageType) { in cancelMessages() argument
70 if (mDataMessageCancelers.containsKey(messageType)) { in cancelMessages()
71 for (Runnable canceler : mDataMessageCancelers.get(messageType)) { in cancelMessages()
76 mDataMessageCancelers.remove(messageType); in cancelMessages()
90 public <T> void subscribeTo(Class<T> messageType, DataMessageListener<T> listener) { in subscribeTo() argument
92 mDataMessageListenerMap.putIfAbsent(messageType, new ArrayList<>()); in subscribeTo()
107 public <T> void unsubscribeFrom(Class<T> messageType, DataMessageListener<T> listener) { in unsubscribeFrom() argument
109 if (mDataMessageListenerMap.containsKey(messageType)) { in unsubscribeFrom()
110 mDataMessageListenerMap.get(messageType).remove(listener); in unsubscribeFrom()
127 for (Class<?> messageType : mDataMessageListenerMap.keySet()) { in unsubscribeFrom()
[all …]
|
| H A D | MessageRouter.java | 121 <T> void cancelMessages(Class<T> messageType); in cancelMessages() argument
141 <T> void subscribeTo(Class<T> messageType, DataMessageListener<T> listener); in subscribeTo() argument
161 <T> void unsubscribeFrom(Class<T> messageType, DataMessageListener<T> listener); in unsubscribeFrom() argument
|
| /aosp12/system/chre/apps/test/chqts/src/shared/ |
| H A D | send_message.cc | 97 static void *prependMessageType(MessageType messageType, void *memory) { in prependMessageType() argument
102 nanoapp_testing::hostToLittleEndian(static_cast<uint32_t>(messageType)); in prependMessageType()
109 static void internalSendMessage(MessageType messageType, void *data, in internalSendMessage() argument
115 data, dataSize, static_cast<uint32_t>(messageType), in internalSendMessage()
122 void sendMessageToHost(MessageType messageType, const void *data, in sendMessageToHost() argument
130 void *ptr = prependMessageType(messageType, myMessageBase); in sendMessageToHost()
132 internalSendMessage(messageType, myMessageBase, fullMessageSize, ChunkAlloc); in sendMessageToHost()
135 void sendStringToHost(MessageType messageType, const char *message, in sendStringToHost() argument
152 char *ptr = static_cast<char *>(prependMessageType(messageType, fullMessage)); in sendStringToHost()
162 internalSendMessage(messageType, fullMessage, fullMessageLen, ChunkAlloc); in sendStringToHost()
|
| /aosp12/system/chre/apps/test/common/shared/src/ |
| H A D | send_message.cc | 45 void sendTestResultWithMsgToHost(uint16_t hostEndpointId, uint32_t messageType, in sendTestResultWithMsgToHost() argument
77 chreSendMessageToHostEndpoint(bytes, size, messageType, hostEndpointId, in sendTestResultWithMsgToHost()
89 void sendTestResultToHost(uint16_t hostEndpointId, uint32_t messageType, in sendTestResultToHost() argument
91 sendTestResultWithMsgToHost(hostEndpointId, messageType, success, in sendTestResultToHost()
95 void sendEmptyMessageToHost(uint16_t hostEndpointId, uint32_t messageType) { in sendEmptyMessageToHost() argument
105 messageType, hostEndpointId, in sendEmptyMessageToHost()
|
| /aosp12/system/chre/core/ |
| H A D | host_comms_manager.cc | 30 uint32_t messageType, uint16_t hostEndpoint, uint32_t messagePermissions, in sendMessageToHostFromNanoapp() argument
53 msgToHost->toHostData.messageType = messageType; in sendMessageToHostFromNanoapp()
82 uint64_t appId, uint16_t hostEndpoint, uint32_t messageType, in craftNanoappMessageFromHost() argument
92 messageSize, hostEndpoint, messageType); in craftNanoappMessageFromHost()
97 msgFromHost->fromHostData.messageType = messageType; in craftNanoappMessageFromHost()
127 uint32_t messageType, in sendMessageToNanoappFromHost() argument
140 appId, hostEndpoint, messageType, messageData, in sendMessageToNanoappFromHost()
|
| /aosp12/frameworks/base/core/java/android/hardware/location/ |
| H A D | NanoAppMessage.java | 44 long nanoAppId, int messageType, byte[] messageBody, boolean broadcasted) { in NanoAppMessage() argument
46 mMessageType = messageType; in NanoAppMessage()
64 long targetNanoAppId, int messageType, byte[] messageBody) { in createMessageToNanoApp() argument
66 targetNanoAppId, messageType, messageBody, false /* broadcasted */); in createMessageToNanoApp()
83 long sourceNanoAppId, int messageType, byte[] messageBody, boolean broadcasted) { in createMessageFromNanoApp() argument
84 return new NanoAppMessage(sourceNanoAppId, messageType, messageBody, broadcasted); in createMessageFromNanoApp()
|
| /aosp12/system/chre/platform/shared/ |
| H A D | chre_api_core.cc | 69 uint32_t messageType, in chreSendMessageToHost() argument
72 message, static_cast<size_t>(messageSize), messageType, in chreSendMessageToHost()
77 void *message, size_t messageSize, uint32_t messageType, in chreSendMessageWithPermissions() argument
92 nanoapp, message, messageSize, messageType, hostEndpoint, in chreSendMessageWithPermissions()
104 void *message, size_t messageSize, uint32_t messageType, in chreSendMessageToHostEndpoint() argument
107 message, messageSize, messageType, hostEndpoint, in chreSendMessageToHostEndpoint()
|
| H A D | host_protocol_common.cc | 30 FlatBufferBuilder &builder, uint64_t appId, uint32_t messageType, in encodeNanoappMessage() argument
37 builder, appId, messageType, hostEndpoint, messageDataOffset, in encodeNanoappMessage()
49 fbs::ChreMessage messageType, in finalize() argument
54 fbs::CreateMessageContainer(builder, messageType, message, &hostAddr); in finalize()
|
| /aosp12/packages/apps/Bluetooth/src/com/android/bluetooth/mapclient/ |
| H A D | MapUtils.java | 54 int messageType = SystemProperties.getInt(SEND_MESSAGE_TYPE, -1); in sendMessageType() local
55 if (messageType > 0 && messageType < Bmessage.Type.values().length) { in sendMessageType()
56 return Bmessage.Type.values()[messageType]; in sendMessageType()
|
| /aosp12/hardware/interfaces/automotive/vehicle/2.0/utils/ |
| H A D | UserHalHelper.cpp | 189 if (!messageType.ok()) { in toSwitchUserRequest()
190 return Error() << "Invalid SwitchUserMessageType: " << messageType.error(); in toSwitchUserRequest()
192 if (*messageType != SwitchUserMessageType::LEGACY_ANDROID_SWITCH && in toSwitchUserRequest()
193 *messageType != SwitchUserMessageType::ANDROID_SWITCH && in toSwitchUserRequest()
194 *messageType != SwitchUserMessageType::ANDROID_POST_SWITCH) { in toSwitchUserRequest()
195 return Error() << "Invalid " << toString(*messageType) in toSwitchUserRequest()
199 request.messageType = *messageType; in toSwitchUserRequest()
291 if (request.messageType != SwitchUserMessageType::VEHICLE_REQUEST) { in toVehiclePropValue()
293 toString(request.messageType).c_str()); in toVehiclePropValue()
301 propValue->value.int32Values[1] = static_cast<int32_t>(request.messageType); in toVehiclePropValue()
[all …]
|
| /aosp12/system/chre/apps/test/common/ping_test/src/ |
| H A D | ping_test.cc | 38 uint32_t messageType = hostData->messageType; in handleMessageFromHost() local
41 } else if (messageType != ping_test_MessageType_PING_COMMAND) { in handleMessageFromHost()
42 LOGE("Invalid message type %" PRIu32, messageType); in handleMessageFromHost()
|
| /aosp12/hardware/interfaces/automotive/vehicle/2.0/default/impl/vhal_v2_0/ |
| H A D | EmulatedUserHal.cpp | 176 auto messageType = getSwitchUserMessageType(value); in onSetSwitchUserResponse() local
177 if (!messageType.ok()) { in onSetSwitchUserResponse()
179 messageType.error().message().c_str()); in onSetSwitchUserResponse()
180 return messageType.error(); in onSetSwitchUserResponse()
184 if (*messageType == SwitchUserMessageType::VEHICLE_REQUEST) { in onSetSwitchUserResponse()
203 if (*messageType == SwitchUserMessageType::LEGACY_ANDROID_SWITCH || in onSetSwitchUserResponse()
204 *messageType == SwitchUserMessageType::ANDROID_POST_SWITCH) { in onSetSwitchUserResponse()
205 ALOGI("request is %s; ignoring it", toString(*messageType).c_str()); in onSetSwitchUserResponse()
212 .messageType = SwitchUserMessageType::VEHICLE_RESPONSE, in onSetSwitchUserResponse()
|
| /aosp12/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/audio/ |
| H A D | MpegTsMediaCodecAudioTrackRenderer.java | 56 public void handleMessage(int messageType, Object message) throws ExoPlaybackException { in handleMessage() argument
57 if (messageType == MSG_SET_PLAYBACK_PARAMS) { in handleMessage()
59 super.handleMessage(messageType, message); in handleMessage()
67 super.handleMessage(messageType, message); in handleMessage()
|
| /aosp12/system/chre/core/include/chre/core/ |
| H A D | host_comms_manager.h | 53 uint32_t messageType; member
122 size_t messageSize, uint32_t messageType,
141 void sendMessageToNanoappFromHost(uint64_t appId, uint32_t messageType,
205 uint32_t messageType,
|
| /aosp12/system/chre/apps/test/common/shared/inc/ |
| H A D | send_message.h | 30 void sendTestResultToHost(uint16_t hostEndpointId, uint32_t messageType,
43 void sendTestResultWithMsgToHost(uint16_t hostEndpointId, uint32_t messageType,
52 void sendEmptyMessageToHost(uint16_t hostEndpointId, uint32_t messageType);
|
| /aosp12/system/chre/apps/test/common/permission_test/src/ |
| H A D | permission_test.cc | 123 uint32_t messageType = hostData->messageType; in handleMessageFromHost() local
126 } else if (messageType != permission_test_MessageType_TEST_COMMAND) { in handleMessageFromHost()
127 LOGE("Invalid message type %" PRIu32, messageType); in handleMessageFromHost()
|
| /aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/adb/ |
| H A D | AdbDebuggingManagerTestActivity.java | 69 int messageType; in onCreate() local
71 messageType = AdbDebuggingManager.AdbDebuggingHandler.MESSAGE_ADB_ALLOW; in onCreate()
73 messageType = AdbDebuggingManager.AdbDebuggingHandler.MESSAGE_ADB_DENY; in onCreate()
75 Message message = sHandler.obtainMessage(messageType); in onCreate()
|
| /aosp12/system/chre/host/common/ |
| H A D | daemon_base.cc | 168 fbs::ChreMessage messageType; in onMessageReceived() local
170 messageBuffer, messageLen, &hostClientId, &messageType)) { in onMessageReceived()
175 if (messageType == fbs::ChreMessage::LogMessage) { in onMessageReceived()
183 } else if (messageType == fbs::ChreMessage::LogMessageV2) { in onMessageReceived()
192 } else if (messageType == fbs::ChreMessage::TimeSyncRequest) { in onMessageReceived()
194 } else if (messageType == fbs::ChreMessage::LowPowerMicAccessRequest) { in onMessageReceived()
196 } else if (messageType == fbs::ChreMessage::LowPowerMicAccessRelease) { in onMessageReceived()
|
| /aosp12/packages/services/Car/service/src/com/android/car/hal/ |
| H A D | VmsHalService.java | 282 int messageType = vec.get(VmsBaseMessageIntegerValuesIndex.MESSAGE_TYPE); in onHalEvents() local
286 switch (messageType) { in onHalEvents()
321 Slog.e(TAG, "Unexpected message type: " + messageType); in onHalEvents()
623 int messageType = vehicleProp.value.int32Values.get( in setPropertyValue() local
629 + VmsMessageType.toString(messageType)); in setPropertyValue()
716 private static VehiclePropValue createSubscriptionStateMessage(int messageType, in createSubscriptionStateMessage() argument
719 VehiclePropValue vehicleProp = createVmsMessage(messageType); in createSubscriptionStateMessage()
759 private static VehiclePropValue createAvailableLayersMessage(int messageType, in createAvailableLayersMessage() argument
762 VehiclePropValue vehicleProp = createVmsMessage(messageType); in createAvailableLayersMessage()
784 private static VehiclePropValue createVmsMessage(int messageType) { in createVmsMessage() argument
[all …]
|
| /aosp12/system/chre/chre_api/include/chre_api/chre/ |
| H A D | event.h | 311 uint32_t messageType; member
460 uint32_t messageType,
476 uint32_t messageType, uint16_t hostEndpoint,
559 uint32_t messageType, uint16_t hostEndpoint,
|
| /aosp12/packages/services/Telecomm/tests/src/com/android/server/telecom/tests/ |
| H A D | BluetoothRouteTransitionTests.java | 72 private int messageType; field in BluetoothRouteTransitionTests.BluetoothRouteTestParametersBuilder
100 public BluetoothRouteTestParametersBuilder setMessageType(int messageType) { in setMessageType() argument
101 this.messageType = messageType; in setMessageType()
160 messageType, in build()
179 public int messageType; // Any of the commands from the state machine field in BluetoothRouteTransitionTests.BluetoothRouteTestParameters
191 BluetoothDevice initialDevice, int messageType, ListenerUpdate[] in BluetoothRouteTestParameters() argument
200 this.messageType = messageType; in BluetoothRouteTestParameters()
218 ", messageType=" + messageType + in toString()
282 if (mParams.messageType == BluetoothRouteManager.NEW_DEVICE_CONNECTED) { in testTransitions()
286 } else if (mParams.messageType == BluetoothRouteManager.LOST_DEVICE) { in testTransitions()
[all …]
|
| /aosp12/system/chre/chre_api/legacy/v1_1/chre/ |
| H A D | event.h | 215 uint32_t messageType; member
366 uint32_t messageType,
426 uint32_t messageType, uint16_t hostEndpoint,
|
| /aosp12/system/chre/chre_api/legacy/v1_3/chre/ |
| H A D | event.h | 243 uint32_t messageType; member
391 uint32_t messageType,
451 uint32_t messageType, uint16_t hostEndpoint,
|
| /aosp12/system/chre/chre_api/legacy/v1_2/chre/ |
| H A D | event.h | 243 uint32_t messageType; member
394 uint32_t messageType,
454 uint32_t messageType, uint16_t hostEndpoint,
|
| /aosp12/frameworks/opt/telephony/src/java/com/android/internal/telephony/d2d/ |
| H A D | RtpTransport.java | 462 int messageType; in extractMessage() local
471 messageType = type; in extractMessage()
472 switch (messageType) { in extractMessage()
510 messageType = typeValue; in extractMessage()
511 switch (messageType) { in extractMessage()
546 messageType, messageValue); in extractMessage()
547 return new Communicator.Message(messageType, messageValue); in extractMessage()
|