Home
last modified time | relevance | path

Searched refs:marshaller (Results 1 – 25 of 44) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DGrpcUtilTest.java81 GrpcUtil.TimeoutMarshaller marshaller = in timeoutTest() local
84 assertEquals("0n", marshaller.toAsciiString(0L)); in timeoutTest()
85 assertEquals(0L, (long) marshaller.parseAsciiString("0n")); in timeoutTest()
87 assertEquals("99999999n", marshaller.toAsciiString(99999999L)); in timeoutTest()
88 assertEquals(99999999L, (long) marshaller.parseAsciiString("99999999n")); in timeoutTest()
91 assertEquals("100000u", marshaller.toAsciiString(100000000L)); in timeoutTest()
92 assertEquals(100000000L, (long) marshaller.parseAsciiString("100000u")); in timeoutTest()
94 assertEquals("99999999u", marshaller.toAsciiString(99999999999L)); in timeoutTest()
95 assertEquals(99999999000L, (long) marshaller.parseAsciiString("99999999u")); in timeoutTest()
98 assertEquals("100000m", marshaller.toAsciiString(100000000000L)); in timeoutTest()
[all …]
/external/grpc-grpc-java/protobuf-lite/src/test/java/io/grpc/protobuf/lite/
DProtoLiteUtilsTest.java56 private Marshaller<Type> marshaller = ProtoLiteUtils.marshaller(Type.getDefaultInstance()); field in ProtoLiteUtilsTest
61 assertSame(proto, marshaller.parse(marshaller.stream(proto))); in testPassthrough()
66 InputStream is = marshaller.stream(proto); in testRoundtrip()
68 assertEquals(proto, marshaller.parse(is)); in testRoundtrip()
73 InputStream is = marshaller.stream(proto); in testInvalidatedMessage()
83 assertEquals(Type.getDefaultInstance(), marshaller.parse(is)); in testInvalidatedMessage()
90 marshaller.parse(is); in parseInvalid()
100 Marshaller<Enum> enumMarshaller = ProtoLiteUtils.marshaller(Enum.getDefaultInstance()); in testMismatch()
103 assertEquals(proto, marshaller.parse(enumMarshaller.stream(altProto))); in testMismatch()
108 Marshaller<Enum> enumMarshaller = ProtoLiteUtils.marshaller(Enum.getDefaultInstance()); in introspection()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DMetadata.java577 public static <T> Key<T> of(String name, BinaryMarshaller<T> marshaller) { in of() argument
578 return new BinaryKey<T>(name, marshaller); in of()
587 public static <T> Key<T> of(String name, AsciiMarshaller<T> marshaller) { in of() argument
588 return of(name, false, marshaller); in of()
591 static <T> Key<T> of(String name, boolean pseudo, AsciiMarshaller<T> marshaller) { in of() argument
592 return new AsciiKey<T>(name, pseudo, marshaller); in of()
595 static <T> Key<T> of(String name, boolean pseudo, TrustedAsciiMarshaller<T> marshaller) { in of() argument
596 return new TrustedAsciiKey<T>(name, pseudo, marshaller); in of()
710 private final BinaryMarshaller<T> marshaller; field in BinaryKey
713 private BinaryKey(String name, BinaryMarshaller<T> marshaller) { in BinaryKey() argument
[all …]
DInternalMetadata.java47 public static <T> Key<T> keyOf(String name, TrustedAsciiMarshaller<T> marshaller) { in keyOf() argument
49 return Metadata.Key.of(name, isPseudo, marshaller); in keyOf()
53 public static <T> Key<T> keyOf(String name, AsciiMarshaller<T> marshaller) { in keyOf() argument
55 return Metadata.Key.of(name, isPseudo, marshaller); in keyOf()
DServerInterceptors.java140 final MethodDescriptor.Marshaller<InputStream> marshaller = in useInputStreamMessages() local
157 return useMarshalledMessages(serviceDef, marshaller); in useInputStreamMessages()
176 final MethodDescriptor.Marshaller<T> marshaller) { in useMarshalledMessages() argument
185 originalMethodDescriptor.toBuilder(marshaller, marshaller).build(); in useMarshalledMessages()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DMockServiceHelper.cs55 …public MockServiceHelper(string host = null, Marshaller<string> marshaller = null, IEnumerable<Cha… in MockServiceHelper() argument
59 marshaller = marshaller ?? Marshallers.StringMarshaller; in MockServiceHelper()
65 marshaller, in MockServiceHelper()
66 marshaller); in MockServiceHelper()
72 marshaller, in MockServiceHelper()
73 marshaller); in MockServiceHelper()
79 marshaller, in MockServiceHelper()
80 marshaller); in MockServiceHelper()
86 marshaller, in MockServiceHelper()
87 marshaller); in MockServiceHelper()
DMarshallingErrorsTest.cs45 var marshaller = new Marshaller<string>( in Init()
65 helper = new MockServiceHelper(Host, marshaller); in Init()
/external/grpc-grpc-java/protobuf-nano/src/test/java/io/grpc/protobuf/nano/
DNanoUtilsTest.java41 private Marshaller<Message> marshaller = NanoUtils.marshaller(new MessageNanoFactory<Message>() { field in NanoUtilsTest
54 Message m2 = marshaller.parse(marshaller.stream(m)); in testRoundTrip()
66 marshaller.parse(is); in parseInvalid()
79 Message m2 = marshaller.parse(marshaller.stream(m)); in testLarge()
94 InputStream is = marshaller.stream(m); in testAvailable()
105 InputStream is = marshaller.stream(new Message()); in testEmpty()
/external/grpc-grpc-java/protobuf/src/test/java/io/grpc/protobuf/
DProtoUtilsTest.java37 Marshaller<Type> marshaller = ProtoUtils.marshaller(Type.getDefaultInstance()); in testRoundtrip() local
38 InputStream is = marshaller.stream(proto); in testRoundtrip()
40 assertEquals(proto, marshaller.parse(is)); in testRoundtrip()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadServer.java58 private static final Marshaller<ByteBuf> marshaller = new ByteBufOutputMarshaller(); field in LoadServer
63 BenchmarkServiceGrpc.getUnaryCallMethod().toBuilder(marshaller, marshaller)
70 BenchmarkServiceGrpc.getStreamingCallMethod().toBuilder(marshaller, marshaller)
/external/grpc-grpc-java/netty/src/jmh/java/io/grpc/netty/
DMethodDescriptorBenchmark.java39 private static final MethodDescriptor.Marshaller<Void> marshaller = field in MethodDescriptorBenchmark
55 .setRequestMarshaller(marshaller)
56 .setResponseMarshaller(marshaller)
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientStreamTest.java60 @Mock private MethodDescriptor.Marshaller<Void> marshaller; field in OkHttpClientStreamTest
78 .setRequestMarshaller(marshaller) in setUp()
79 .setResponseMarshaller(marshaller) in setUp()
190 .setRequestMarshaller(marshaller) in getUnaryRequest()
191 .setResponseMarshaller(marshaller) in getUnaryRequest()
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java54 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getEmptyCallMethod()
56 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getEmptyCallMethod()
86 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getUnaryCallMethod()
88 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getUnaryCallMethod()
118 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getCacheableUnaryCallMethod()
120 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getCacheableUnaryCallMethod()
150 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingOutputCallMethod()
152 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingOutputCallMethod()
182 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingInputCallMethod()
184 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingInputCallMethod()
[all …]
DReconnectServiceGrpc.java53 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStartMethod()
55 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStartMethod()
85 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStopMethod()
87 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStopMethod()
DMetricsServiceGrpc.java50 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetAllGaugesMethod()
52 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetAllGaugesMethod()
82 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetGaugeMethod()
84 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetGaugeMethod()
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorageGrpc.java86 .setRequestMarshaller(FlatbuffersUtils.marshaller( in getStoreMethod()
88 .setResponseMarshaller(FlatbuffersUtils.marshaller( in getStoreMethod()
119 .setRequestMarshaller(FlatbuffersUtils.marshaller( in getRetrieveMethod()
121 .setResponseMarshaller(FlatbuffersUtils.marshaller( in getRetrieveMethod()
152 .setRequestMarshaller(FlatbuffersUtils.marshaller( in getGetMaxHitPointMethod()
154 .setResponseMarshaller(FlatbuffersUtils.marshaller( in getGetMaxHitPointMethod()
185 .setRequestMarshaller(FlatbuffersUtils.marshaller( in getGetMinMaxHitPointsMethod()
187 .setResponseMarshaller(FlatbuffersUtils.marshaller( in getGetMinMaxHitPointsMethod()
/external/grpc-grpc-java/protobuf/src/main/java/io/grpc/protobuf/
DProtoUtils.java35 public static <T extends Message> Marshaller<T> marshaller(final T defaultInstance) { in marshaller() method in ProtoUtils
36 return ProtoLiteUtils.marshaller(defaultInstance); in marshaller()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/
DChannelzGrpc.java54 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetTopChannelsMethod()
56 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetTopChannelsMethod()
86 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetServersMethod()
88 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetServersMethod()
118 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetServerSocketsMethod()
120 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetServerSocketsMethod()
150 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetChannelMethod()
152 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetChannelMethod()
182 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetSubchannelMethod()
184 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getGetSubchannelMethod()
[all …]
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DBenchmarkServiceGrpc.java50 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getUnaryCallMethod()
52 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getUnaryCallMethod()
82 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingCallMethod()
84 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingCallMethod()
114 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingFromClientMethod()
116 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingFromClientMethod()
146 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingFromServerMethod()
148 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingFromServerMethod()
178 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingBothWaysMethod()
180 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getStreamingBothWaysMethod()
DWorkerServiceGrpc.java50 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getRunServerMethod()
52 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getRunServerMethod()
82 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getRunClientMethod()
84 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getRunClientMethod()
114 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getCoreCountMethod()
116 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getCoreCountMethod()
146 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getQuitWorkerMethod()
148 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getQuitWorkerMethod()
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java53 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getUnaryRpcMethod()
55 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getUnaryRpcMethod()
85 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getClientStreamingRpcMethod()
87 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getClientStreamingRpcMethod()
117 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getServerStreamingRpcMethod()
119 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getServerStreamingRpcMethod()
149 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getBidiStreamingRpcMethod()
151 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( in getBidiStreamingRpcMethod()
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt53 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
55 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
85 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
87 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
117 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
119 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
149 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
151 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
181 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
183 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
[all …]
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt53 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
55 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
84 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
86 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
115 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
117 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
146 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
148 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
177 .setRequestMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
179 .setResponseMarshaller(io.grpc.protobuf.lite.ProtoLiteUtils.marshaller(
[all …]
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestService.java.txt52 …aller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.SimpleRequest>marshaller(
54 …ller(io.grpc.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.SimpleResponse>marshaller(
80 ….protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>marshaller(
82 …protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>marshaller(
108 …c.protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingInputCallRequest>marshaller(
110 ….protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse>marshaller(
136 ….protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>marshaller(
138 …protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>marshaller(
164 ….protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallRequest>marshaller(
166 …protobuf.nano.NanoUtils.<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse>marshaller(
[all …]
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DBinlogHelper.java203 Marshaller<T> marshaller, in logOutboundMessage() argument
208 if (marshaller != BYTEARRAY_MARSHALLER) { in logOutboundMessage()
223 Marshaller<T> marshaller, in logInboundMessage() argument
228 if (marshaller != BYTEARRAY_MARSHALLER) { in logInboundMessage()
292 int seq, Marshaller<T> marshaller, T message, boolean compressed, boolean isServer, in logOutboundMessage() argument
302 int seq, Marshaller<T> marshaller, T message, boolean compressed, boolean isServer, in logInboundMessage() argument

12