| /aosp_15_r20/device/generic/car/emulator/Conn/CommConn/include/ |
| D | CommConn.h | 38 class MessageProcessor {
40 virtual ~MessageProcessor() = default;
80 CommConn(MessageProcessor* messageProcessor) : mMessageProcessor(messageProcessor) {} in CommConn()
105 MessageProcessor* mMessageProcessor;
|
| /aosp_15_r20/external/nist-sip/java/gov/nist/javax/sip/stack/ |
| H A D | SIPTransactionStack.java | 280 private Collection<MessageProcessor> messageProcessors;
437 messageProcessors = new ArrayList<MessageProcessor>(); in SIPTransactionStack()
486 messageProcessors = new ArrayList<MessageProcessor>(); in reInit()
1342 public MessageChannel createMessageChannel(SIPRequest request, MessageProcessor mp, in createMessageChannel()
1656 MessageProcessor[] processorList; in stopStack()
1889 protected void addMessageProcessor(MessageProcessor newMessageProcessor) throws IOException { in addMessageProcessor()
1909 protected void removeMessageProcessor(MessageProcessor oldMessageProcessor) { in removeMessageProcessor()
1924 protected MessageProcessor[] getMessageProcessors() { in getMessageProcessors()
1926 return (MessageProcessor[]) messageProcessors.toArray(new MessageProcessor[0]); in getMessageProcessors()
1937 protected MessageProcessor createMessageProcessor(InetAddress ipAddress, int port, in createMessageProcessor()
[all …]
|
| H A D | MessageProcessor.java | 52 public abstract class MessageProcessor implements Runnable { class
102 protected MessageProcessor( String transport ) { in MessageProcessor() method in MessageProcessor
113 protected MessageProcessor( InetAddress ipAddress, int port, String transport, in MessageProcessor() method in MessageProcessor
|
| H A D | MessageChannel.java | 85 protected transient MessageProcessor messageProcessor;
205 for (MessageProcessor messageProcessor : getSIPStack().getMessageProcessors()) { in sendMessage()
486 public MessageProcessor getMessageProcessor() { in getMessageProcessor()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/mls-rs/src/group/ |
| D | test_utils.rs | 434 impl MessageProcessor for GroupWithoutKeySchedule {
435 type CipherSuiteProvider = <Group<TestClientConfig> as MessageProcessor>::CipherSuiteProvider;
436 type OutputType = <Group<TestClientConfig> as MessageProcessor>::OutputType;
437 type PreSharedKeyStorage = <Group<TestClientConfig> as MessageProcessor>::PreSharedKeyStorage;
438 type IdentityProvider = <Group<TestClientConfig> as MessageProcessor>::IdentityProvider;
439 type MlsRules = <Group<TestClientConfig> as MessageProcessor>::MlsRules;
519 <Group<TestClientConfig> as MessageProcessor>::self_index(&self.inner) in self_index()
|
| /aosp_15_r20/frameworks/base/apct-tests/perftests/core/src/android/conscrypt/conscrypt/ |
| H A D | ServerEndpoint.java | 44 public interface MessageProcessor { interface in ServerEndpoint
51 public static final class EchoProcessor implements MessageProcessor {
74 private volatile MessageProcessor messageProcessor = new EchoProcessor();
88 void setMessageProcessor(MessageProcessor messageProcessor) { in setMessageProcessor()
|
| H A D | ClientSocketPerfTest.java | 51 import android.conscrypt.ServerEndpoint.MessageProcessor;
148 server.setMessageProcessor(new ServerEndpoint.MessageProcessor() { in setup()
|
| H A D | ServerSocketPerfTest.java | 37 import android.conscrypt.ServerEndpoint.MessageProcessor;
135 server.setMessageProcessor(new MessageProcessor() { in setup()
|
| /aosp_15_r20/external/conscrypt/benchmark-base/src/main/java/org/conscrypt/ |
| H A D | ServerEndpoint.java | 44 public interface MessageProcessor { interface in ServerEndpoint
51 public static final class EchoProcessor implements MessageProcessor {
75 private volatile MessageProcessor messageProcessor = new EchoProcessor();
90 void setMessageProcessor(MessageProcessor messageProcessor) { in setMessageProcessor()
|
| H A D | ServerSocketBenchmark.java | 32 import org.conscrypt.ServerEndpoint.MessageProcessor;
66 server.setMessageProcessor(new MessageProcessor() { in ServerSocketBenchmark()
|
| /aosp_15_r20/external/conscrypt/repackaged/benchmark-base/src/main/java/com/android/org/conscrypt/ |
| H A D | ServerEndpoint.java | 46 public interface MessageProcessor { interface in ServerEndpoint
54 public static final class EchoProcessor implements MessageProcessor {
78 private volatile MessageProcessor messageProcessor = new EchoProcessor();
93 void setMessageProcessor(MessageProcessor messageProcessor) { in setMessageProcessor()
|
| H A D | ServerSocketBenchmark.java | 25 import com.android.org.conscrypt.ServerEndpoint.MessageProcessor;
70 server.setMessageProcessor(new MessageProcessor() { in ServerSocketBenchmark()
|
| /aosp_15_r20/device/generic/car/emulator/Conn/SocketComm/include/ |
| D | SocketComm.h | 41 SocketComm(MessageProcessor* messageProcessor);
56 MessageProcessor* mMessageProcessor;
85 SocketConn(MessageProcessor* messageProcessor, int sfd);
|
| /aosp_15_r20/frameworks/rs/tests/java_api/ScriptGroupTest/src/com/android/rs/sgtest/ |
| H A D | TestBase.java | 48 private class MessageProcessor extends RenderScript.RSMessageHandler { class in TestBase
51 MessageProcessor(ScriptGroupTestActivity act) { in MessageProcessor() method in TestBase.MessageProcessor
68 mRS.setMessageHandler(new MessageProcessor(act)); in createBaseTest()
|
| /aosp_15_r20/frameworks/rs/tests/java_api/ImageProcessing/src/com/android/rs/image/ |
| H A D | TestBase.java | 48 private class MessageProcessor extends RenderScript.RSMessageHandler { class in TestBase
51 MessageProcessor(ImageProcessingActivity act) { in MessageProcessor() method in TestBase.MessageProcessor
108 mRS.setMessageHandler(new MessageProcessor(act)); in createBaseTest()
|
| /aosp_15_r20/external/nist-sip/java/gov/nist/javax/sip/ |
| H A D | DefaultAddressResolver.java | 35 import gov.nist.javax.sip.stack.MessageProcessor;
68 … MessageProcessor.getDefaultPort(inputAddress.getTransport()),inputAddress.getTransport()); in resolveAddress()
|
| H A D | ListeningPointImpl.java | 69 protected MessageProcessor messageProcessor;
221 public MessageProcessor getMessageProcessor() { in getMessageProcessor()
|
| /aosp_15_r20/external/guice/core/src/com/google/inject/internal/ |
| H A D | MessageProcessor.java | 30 final class MessageProcessor extends AbstractProcessor { class
34 MessageProcessor(Errors errors) { in MessageProcessor() method in MessageProcessor
|
| /aosp_15_r20/frameworks/rs/tests/java_api/ImageProcessing2/src/com/android/rs/image/ |
| H A D | ImageProcessingActivity2.java | 122 private class MessageProcessor extends RenderScript.RSMessageHandler { class in ImageProcessingActivity2
123 MessageProcessor() { in MessageProcessor() method in ImageProcessingActivity2.MessageProcessor
200 mRS.setMessageHandler(new MessageProcessor()); in Processor()
242 mRS.setMessageHandler(new MessageProcessor()); in Processor()
|
| /aosp_15_r20/device/generic/car/emulator/Conn/SocketComm/ |
| D | SocketComm.cpp | 38 SocketComm::SocketComm(MessageProcessor* messageProcessor) in SocketComm()
141 SocketConn::SocketConn(MessageProcessor* messageProcessor, int sfd) in SocketConn()
|
| /aosp_15_r20/frameworks/rs/tests/java_api/ImageProcessing_jb/src/com/android/rs/image/ |
| H A D | ImageProcessingActivityJB.java | 129 private class MessageProcessor extends RenderScript.RSMessageHandler { class in ImageProcessingActivityJB
130 MessageProcessor() { in MessageProcessor() method in ImageProcessingActivityJB.MessageProcessor
197 mRS.setMessageHandler(new MessageProcessor()); in Processor()
|
| /aosp_15_r20/device/generic/car/emulator/Conn/PipeComm/include/ |
| D | PipeComm.h | 42 PipeComm(MessageProcessor* messageProcessor);
|
| /aosp_15_r20/device/generic/car/emulator/Conn/PipeComm/ |
| D | PipeComm.cpp | 36 PipeComm::PipeComm(MessageProcessor* messageProcessor) : CommConn(messageProcessor), mPipeFd(-1) {} in PipeComm()
|
| /aosp_15_r20/device/generic/car/emulator/vhal_aidl/VehicleEmulator/include/ |
| D | VehicleEmulator.h | 38 class VehicleEmulator final : public V2_0::impl::MessageProcessor {
|
| /aosp_15_r20/device/generic/car/emulator/vhal_v2_0/ |
| D | VehicleEmulator.h | 76 class VehicleEmulator : public MessageProcessor {
|