Home
last modified time | relevance | path

Searched refs:AsciiString (Results 1 – 25 of 42) sorted by relevance

12

/aosp_15_r20/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
H A DGrpcHttp2HeadersUtilsTest.java22 import static io.netty.util.AsciiString.of;
43 import io.netty.util.AsciiString;
144 assertThat(http2Headers.get(AsciiString.of(":path"))).isNull(); in grpcHttp2RequestHeaders_pseudoHeaders_notPresent()
145 assertThat(http2Headers.get(AsciiString.of(":authority"))).isNull(); in grpcHttp2RequestHeaders_pseudoHeaders_notPresent()
146 assertThat(http2Headers.get(AsciiString.of(":method"))).isNull(); in grpcHttp2RequestHeaders_pseudoHeaders_notPresent()
147 assertThat(http2Headers.get(AsciiString.of(":scheme"))).isNull(); in grpcHttp2RequestHeaders_pseudoHeaders_notPresent()
148 assertThat(http2Headers.get(AsciiString.of(":status"))).isNull(); in grpcHttp2RequestHeaders_pseudoHeaders_notPresent()
150 assertThat(http2Headers.getAll(AsciiString.of(":path"))).isEmpty(); in grpcHttp2RequestHeaders_pseudoHeaders_notPresent()
151 assertThat(http2Headers.getAll(AsciiString.of(":authority"))).isEmpty(); in grpcHttp2RequestHeaders_pseudoHeaders_notPresent()
152 assertThat(http2Headers.getAll(AsciiString.of(":method"))).isEmpty(); in grpcHttp2RequestHeaders_pseudoHeaders_notPresent()
[all …]
H A DNettyServerStreamTest.java47 import io.netty.util.AsciiString;
149 .status(new AsciiString("200")) in closeBeforeClientHalfCloseShouldSucceed()
150 .set(new AsciiString("content-type"), new AsciiString("application/grpc")) in closeBeforeClientHalfCloseShouldSucceed()
151 .set(new AsciiString("grpc-status"), new AsciiString("0"))); in closeBeforeClientHalfCloseShouldSucceed()
176 .status(new AsciiString("200")) in closeWithErrorBeforeClientHalfCloseShouldSucceed()
177 .set(new AsciiString("content-type"), new AsciiString("application/grpc")) in closeWithErrorBeforeClientHalfCloseShouldSucceed()
178 .set(new AsciiString("grpc-status"), new AsciiString("1"))); in closeWithErrorBeforeClientHalfCloseShouldSucceed()
203 .status(new AsciiString("200")) in closeAfterClientHalfCloseShouldSucceed()
204 .set(new AsciiString("content-type"), new AsciiString("application/grpc")) in closeAfterClientHalfCloseShouldSucceed()
205 .set(new AsciiString("grpc-status"), new AsciiString("0"))); in closeAfterClientHalfCloseShouldSucceed()
[all …]
H A DNettyClientStreamTest.java66 import io.netty.util.AsciiString;
306 headers.status(new AsciiString("500")); in invalidInboundHeadersCancelStream()
334 new AsciiString("application/bad", UTF_8)); in invalidInboundContentTypeShouldCancelStream()
337 .set(new AsciiString("grpc-status", UTF_8), new AsciiString("0", UTF_8)); in invalidInboundContentTypeShouldCancelStream()
420 AsciiString.of("localhost"), in setHttp2StreamShouldNotifyReady()
421 AsciiString.of("http"), in setHttp2StreamShouldNotifyReady()
422 AsciiString.of("agent"), in setHttp2StreamShouldNotifyReady()
451 AsciiString.of("localhost"), in removeUserAgentFromApplicationHeaders()
452 AsciiString.of("http"), in removeUserAgentFromApplicationHeaders()
453 AsciiString.of("good agent"), in removeUserAgentFromApplicationHeaders()
[all …]
H A DNettyServerHandlerTest.java86 import io.netty.util.AsciiString;
119 private static final AsciiString HTTP_FAKE_METHOD = AsciiString.of("FAKE");
477 .set(CONTENT_TYPE_HEADER, new AsciiString("application/bad", UTF_8)) in headersWithInvalidContentTypeShouldFail()
479 .path(new AsciiString("/foo/bar")); in headersWithInvalidContentTypeShouldFail()
504 .path(new AsciiString("/foo/bar")); in headersWithInvalidMethodShouldFail()
553 .path(new AsciiString("foo/bar")); in headersWithInvalidPathShouldFail()
577 .set(CONTENT_TYPE_HEADER, new AsciiString("application/grpc+json", UTF_8)) in headersSupportExtensionContentType()
579 .path(new AsciiString("/foo/bar")); in headersSupportExtensionContentType()
597 .set(AsciiString.of("connection"), CONTENT_TYPE_GRPC) in headersWithConnectionHeaderShouldFail()
598 .path(new AsciiString("/foo/bar")); in headersWithConnectionHeaderShouldFail()
[all …]
H A DUtilsTest.java44 import io.netty.util.AsciiString;
93 new AsciiString(scheme), in convertClientHeaders_sanitizes()
94 new AsciiString(path), in convertClientHeaders_sanitizes()
95 new AsciiString(authority), in convertClientHeaders_sanitizes()
96 new AsciiString(method), in convertClientHeaders_sanitizes()
97 new AsciiString(userAgent)); in convertClientHeaders_sanitizes()
H A DGrpcHttp2InboundHeadersTest.java20 import static io.netty.util.AsciiString.of;
29 import io.netty.util.AsciiString;
78 assertEquals(of("foo-bin"), new AsciiString(namesAndValues[0])); in binaryHeadersShouldBeBase64Decoded()
H A DNettyClientHandlerTest.java90 import io.netty.util.AsciiString;
159 AsciiString.of("localhost"), in stream()
160 AsciiString.of("http"), in stream()
161 AsciiString.of("agent"), in stream()
964 private AsciiString as(String string) { in as()
965 return new AsciiString(string); in as()
/aosp_15_r20/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
H A DGrpcHttp2HeadersUtils.java39 import static io.netty.util.AsciiString.isUpperCase;
47 import io.netty.util.AsciiString;
96 private static final AsciiString binaryHeaderSuffix =
97 new AsciiString(Metadata.BINARY_HEADER_SUFFIX.getBytes(US_ASCII));
100 private AsciiString[] values;
107 values = new AsciiString[numHeadersGuess]; in GrpcHttp2InboundHeaders()
110 protected Http2Headers add(AsciiString name, AsciiString value) { in add()
122 endPos = indexOfComma == AsciiString.INDEX_NOT_FOUND ? value.length() : indexOfComma; in add()
123 AsciiString curVal = value.subSequence(startPos, endPos, false); in add()
131 private void addHeader(AsciiString value, byte[] nameBytes, byte[] valueBytes) { in addHeader()
[all …]
H A DGrpcHttp2OutboundHeaders.java20 import io.netty.util.AsciiString;
30 private final AsciiString[] normalHeaders;
31 private final AsciiString[] preHeaders;
32 private static final AsciiString[] EMPTY = new AsciiString[]{};
35 AsciiString authority, AsciiString path, AsciiString method, AsciiString scheme, in clientRequestHeaders()
36 AsciiString userAgent) { in clientRequestHeaders()
37 AsciiString[] preHeaders = new AsciiString[] { in clientRequestHeaders()
50 AsciiString[] preHeaders = new AsciiString[] { in serverResponseHeaders()
61 private GrpcHttp2OutboundHeaders(AsciiString[] preHeaders, byte[][] serializedMetadata) { in GrpcHttp2OutboundHeaders()
62 normalHeaders = new AsciiString[serializedMetadata.length]; in GrpcHttp2OutboundHeaders()
[all …]
H A DUtils.java56 import io.netty.util.AsciiString;
78 public static final AsciiString STATUS_OK = AsciiString.of("200");
79 public static final AsciiString HTTP_METHOD = AsciiString.of(GrpcUtil.HTTP_METHOD);
80 public static final AsciiString HTTP_GET_METHOD = AsciiString.of("GET");
81 public static final AsciiString HTTPS = AsciiString.of("https");
82 public static final AsciiString HTTP = AsciiString.of("http");
83 public static final AsciiString CONTENT_TYPE_HEADER = AsciiString.of(CONTENT_TYPE_KEY.name());
84 public static final AsciiString CONTENT_TYPE_GRPC = AsciiString.of(GrpcUtil.CONTENT_TYPE_GRPC);
85 public static final AsciiString TE_HEADER = AsciiString.of(GrpcUtil.TE_HEADER.name());
86 public static final AsciiString TE_TRAILERS = AsciiString.of(GrpcUtil.TE_TRAILERS);
[all …]
H A DNettyClientStream.java46 import io.netty.util.AsciiString;
66 private AsciiString authority;
67 private final AsciiString scheme;
68 private final AsciiString userAgent;
75 AsciiString authority, in NettyClientStream()
76 AsciiString scheme, in NettyClientStream()
77 AsciiString userAgent, in NettyClientStream()
109 this.authority = AsciiString.of(checkNotNull(authority, "authority")); in setAuthority()
129 AsciiString defaultPath = (AsciiString) methodDescriptorAccessor.geRawMethodName(method); in writeHeadersInternal()
131 defaultPath = new AsciiString("/" + method.getFullMethodName()); in writeHeadersInternal()
[all …]
H A DInternalProtocolNegotiators.java25 import io.netty.util.AsciiString;
44 public AsciiString scheme() { in tls()
72 public AsciiString scheme() { in serverTls()
96 public AsciiString scheme() { in plaintext()
120 public AsciiString scheme() { in serverPlaintext()
H A DNettyClientTransport.java58 import io.netty.util.AsciiString;
80 private final AsciiString authority;
81 private final AsciiString userAgent;
90 private final AsciiString negotiationScheme;
133 this.authority = new AsciiString(authority); in NettyClientTransport()
134 this.userAgent = new AsciiString(GrpcUtil.getGrpcUserAgent("netty", userAgent)); in NettyClientTransport()
H A DProtocolNegotiator.java21 import io.netty.util.AsciiString;
32 AsciiString scheme(); in scheme()
H A DProtocolNegotiators.java68 import io.netty.util.AsciiString;
389 public AsciiString scheme() { in serverTls()
472 final AsciiString scheme = negotiator.scheme();
484 public AsciiString scheme() {
559 public AsciiString scheme() {
758 public AsciiString scheme() {
972 public AsciiString scheme() {
H A DInternalProtocolNegotiator.java23 import io.netty.util.AsciiString;
45 public AsciiString scheme() { in scheme()
H A DNettyServerHandler.java92 import io.netty.util.AsciiString;
140 private AsciiString lastKnownAuthority;
479 String authority = getOrUpdateAuthority((AsciiString) headers.authority()); in onHeadersRead()
498 private String getOrUpdateAuthority(AsciiString authority) { in getOrUpdateAuthority()
788 headers.add(new AsciiString(serialized[i], false), new AsciiString(serialized[i + 1], false)); in respondWithHttpError()
/aosp_15_r20/external/grpc-grpc-java/netty/src/jmh/java/io/grpc/netty/
H A DInboundHeadersBenchmark.java26 import io.netty.util.AsciiString;
43 private static AsciiString[] requestHeaders;
44 private static AsciiString[] responseHeaders;
53 requestHeaders = new AsciiString[18]; in setupRequestHeaders()
55 requestHeaders[i++] = AsciiString.of(":method"); in setupRequestHeaders()
56 requestHeaders[i++] = AsciiString.of("POST"); in setupRequestHeaders()
57 requestHeaders[i++] = AsciiString.of(":scheme"); in setupRequestHeaders()
58 requestHeaders[i++] = AsciiString.of("http"); in setupRequestHeaders()
59 requestHeaders[i++] = AsciiString.of(":path"); in setupRequestHeaders()
60 requestHeaders[i++] = AsciiString.of("/google.pubsub.v2.PublisherService/CreateTopic"); in setupRequestHeaders()
[all …]
H A DMethodDescriptorBenchmark.java22 import io.netty.util.AsciiString;
61 byte[] directBytes = new AsciiString("/" + method.getFullMethodName()).toByteArray();
67 public AsciiString old() { in old()
68 return new AsciiString("/" + method.getFullMethodName()); in old()
75 public AsciiString transportSpecific() { in transportSpecific()
76 AsciiString path; in transportSpecific()
77 if ((path = (AsciiString) imd.geRawMethodName(method)) != null) { in transportSpecific()
78 path = new AsciiString("/" + method.getFullMethodName()); in transportSpecific()
88 public AsciiString direct() { in direct()
89 return new AsciiString(directBytes, false); in direct()
H A DOutboundHeadersBenchmark.java26 import io.netty.util.AsciiString;
59 private final AsciiString scheme = new AsciiString("https");
60 private final AsciiString defaultPath = new AsciiString("/Service.MethodMethodMethod");
61 private final AsciiString authority = new AsciiString("authority.googleapis.bogus");
62 private final AsciiString userAgent = new AsciiString("grpc-java-netty");
/aosp_15_r20/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
H A DAltsChannelCredentials.java34 import io.netty.util.AsciiString;
133 private static final AsciiString SCHEME = AsciiString.of("https");
143 public AsciiString scheme() { in scheme()
/aosp_15_r20/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
H A DAltsProtocolNegotiator.java41 import io.netty.util.AsciiString;
71 private static final AsciiString SCHEME = AsciiString.of("https");
121 public AsciiString scheme() { in scheme()
182 public AsciiString scheme() { in scheme()
288 public AsciiString scheme() { in scheme()
/aosp_15_r20/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/internal/security/
H A DSecurityProtocolNegotiators.java37 import io.netty.util.AsciiString;
60 private static final AsciiString SCHEME = AsciiString.of("http");
125 public AsciiString scheme() { in scheme()
256 public AsciiString scheme() { in scheme()
/aosp_15_r20/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/
H A DFilterChainMatchingProtocolNegotiators.java51 import io.netty.util.AsciiString;
76 private static final AsciiString SCHEME = AsciiString.of("http");
380 public AsciiString scheme() { in newNegotiator()
/aosp_15_r20/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
H A DNettyFlowControlTest.java41 import io.netty.util.AsciiString;
254 public AsciiString scheme() { in scheme()

12