Home
last modified time | relevance | path

Searched refs:requestHeaders (Results 1 – 25 of 63) sorted by relevance

123

/external/grpc-grpc-java/netty/src/jmh/java/io/grpc/netty/
DInboundHeadersBenchmark.java44 private static AsciiString[] requestHeaders; field in InboundHeadersBenchmark
54 requestHeaders = new AsciiString[18]; in setupRequestHeaders()
56 requestHeaders[i++] = of(":method"); in setupRequestHeaders()
57 requestHeaders[i++] = of("POST"); in setupRequestHeaders()
58 requestHeaders[i++] = of(":scheme"); in setupRequestHeaders()
59 requestHeaders[i++] = of("http"); in setupRequestHeaders()
60 requestHeaders[i++] = of(":path"); in setupRequestHeaders()
61 requestHeaders[i++] = of("/google.pubsub.v2.PublisherService/CreateTopic"); in setupRequestHeaders()
62 requestHeaders[i++] = of(":authority"); in setupRequestHeaders()
63 requestHeaders[i++] = of("pubsub.googleapis.com"); in setupRequestHeaders()
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core/
DServerCallContext.cs36 private readonly Metadata requestHeaders; field in Grpc.Core.ServerCallContext
48 … callHandle, string method, string host, DateTime deadline, Metadata requestHeaders, CancellationT… in ServerCallContext() argument
50 …: this(callHandle, method, host, deadline, requestHeaders, cancellationToken, writeHeadersFunc, wr… in ServerCallContext()
55 … callHandle, string method, string host, DateTime deadline, Metadata requestHeaders, CancellationT… in ServerCallContext() argument
63 this.requestHeaders = requestHeaders; in ServerCallContext()
145 return this.requestHeaders;
/external/oauth/core/src/main/java/net/oauth/client/
DURLConnectionResponse.java43 public URLConnectionResponse(HttpMessage request, String requestHeaders, in URLConnectionResponse() argument
46 this.requestHeaders = requestHeaders; in URLConnectionResponse()
53 private final String requestHeaders; field in URLConnectionResponse
99 StringBuilder request = new StringBuilder(requestHeaders); in dump()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java412 Metadata requestHeaders = new Metadata(); in methodNotFound() local
415 streamTracerFactories, "Waiter/nonexist", requestHeaders); in methodNotFound()
417 transportListener.streamCreated(stream, "Waiter/nonexist", requestHeaders); in methodNotFound()
427 verify(streamTracerFactory).newServerStreamTracer(eq("Waiter/nonexist"), same(requestHeaders)); in methodNotFound()
439 Metadata requestHeaders = new Metadata(); in decompressorNotFound() local
440 requestHeaders.put(MESSAGE_ENCODING_KEY, decompressorName); in decompressorNotFound()
443 streamTracerFactories, "Waiter/nonexist", requestHeaders); in decompressorNotFound()
446 transportListener.streamCreated(stream, "Waiter/nonexist", requestHeaders); in decompressorNotFound()
493 Metadata requestHeaders = new Metadata(); in basicExchangeHelper() local
494 requestHeaders.put(metadataKey, "value"); in basicExchangeHelper()
[all …]
DServerCallImplTest.java86 private final Metadata requestHeaders = new Metadata(); field in ServerCallImplTest
92 call = new ServerCallImpl<Long, Long>(stream, UNARY_METHOD, requestHeaders, context, in setUp()
115 call = new ServerCallImpl<Long, Long>(stream, UNARY_METHOD, requestHeaders, context, in callTracer0()
224 requestHeaders, in sendMessage_serverSendsOne_closeOnSecondCall()
258 requestHeaders, in sendMessage_serverSendsOne_closeOnSecondCall_appRunToCompletion()
295 requestHeaders, in serverSendsOne_okFailsOnMissingResponse()
/external/volley/src/test/java/com/android/volley/toolbox/
DHttpStackConformanceTest.java149 Map<String, String> requestHeaders = new HashMap<>(); in headerPrecedence() local
150 requestHeaders.put("A", "RequestA"); in headerPrecedence()
151 requestHeaders.put("C", "RequestC"); in headerPrecedence()
152 when(mMockRequest.getHeaders()).thenReturn(requestHeaders); in headerPrecedence()
176 requestHeaders.put(HttpHeaderParser.HEADER_CONTENT_TYPE, "RequestContentType"); in headerPrecedence()
183 requestHeaders.remove(HttpHeaderParser.HEADER_CONTENT_TYPE); in headerPrecedence()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DFramedConnection.java232 public FramedStream pushStream(int associatedStreamId, List<Header> requestHeaders, boolean out) in pushStream() argument
236 return newStream(associatedStreamId, requestHeaders, out, false); in pushStream()
247 public FramedStream newStream(List<Header> requestHeaders, boolean out, boolean in) in newStream() argument
249 return newStream(0, requestHeaders, out, in); in newStream()
252 private FramedStream newStream(int associatedStreamId, List<Header> requestHeaders, boolean out, in newStream() argument
266 stream = new FramedStream(streamId, this, outFinished, inFinished, requestHeaders); in newStream()
274 requestHeaders); in newStream()
278 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders); in newStream()
817 public void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) { in pushPromise() argument
818 pushRequestLater(promisedStreamId, requestHeaders); in pushPromise()
[all …]
DFramedStream.java59 private final List<Header> requestHeaders; field in FramedStream
77 List<Header> requestHeaders) { in FramedStream() argument
79 if (requestHeaders == null) throw new NullPointerException("requestHeaders == null"); in FramedStream()
89 this.requestHeaders = requestHeaders; in FramedStream()
129 return requestHeaders; in getRequestHeaders()
DPushObserver.java49 boolean onRequest(int streamId, List<Header> requestHeaders); in onRequest() argument
78 @Override public boolean onRequest(int streamId, List<Header> requestHeaders) {
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DFramedConnection.java234 public FramedStream pushStream(int associatedStreamId, List<Header> requestHeaders, boolean out) in pushStream() argument
238 return newStream(associatedStreamId, requestHeaders, out, false); in pushStream()
249 public FramedStream newStream(List<Header> requestHeaders, boolean out, boolean in) in newStream() argument
251 return newStream(0, requestHeaders, out, in); in newStream()
254 private FramedStream newStream(int associatedStreamId, List<Header> requestHeaders, boolean out, in newStream() argument
268 stream = new FramedStream(streamId, this, outFinished, inFinished, requestHeaders); in newStream()
276 requestHeaders); in newStream()
280 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders); in newStream()
822 public void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) { in pushPromise() argument
823 pushRequestLater(promisedStreamId, requestHeaders); in pushPromise()
[all …]
DFramedStream.java61 private final List<Header> requestHeaders; field in FramedStream
79 List<Header> requestHeaders) { in FramedStream() argument
81 if (requestHeaders == null) throw new NullPointerException("requestHeaders == null"); in FramedStream()
91 this.requestHeaders = requestHeaders; in FramedStream()
131 return requestHeaders; in getRequestHeaders()
DPushObserver.java51 boolean onRequest(int streamId, List<Header> requestHeaders); in onRequest() argument
80 @Override public boolean onRequest(int streamId, List<Header> requestHeaders) {
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java513 final Metadata requestHeaders,
518 responseHeaders.merge(requestHeaders, keySet);
524 trailers.merge(requestHeaders, keySet);
527 }, requestHeaders);
541 final Metadata requestHeaders,
546 responseHeaders.merge(requestHeaders, keySet);
554 }, requestHeaders);
568 final Metadata requestHeaders,
578 trailers.merge(requestHeaders, keySet);
581 }, requestHeaders);
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderServerInterceptor.java42 final Metadata requestHeaders, in interceptCall() argument
44 logger.info("header received from client:" + requestHeaders); in interceptCall()
51 }, requestHeaders); in interceptCall()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/http/
DOkHeaders.java197 Headers requestHeaders = response.networkResponse().request().headers(); in varyHeaders() local
199 return varyHeaders(requestHeaders, responseHeaders); in varyHeaders()
206 public static Headers varyHeaders(Headers requestHeaders, Headers responseHeaders) { in varyHeaders() argument
211 for (int i = 0, size = requestHeaders.size(); i < size; i++) { in varyHeaders()
212 String fieldName = requestHeaders.name(i); in varyHeaders()
214 result.add(fieldName, requestHeaders.value(i)); in varyHeaders()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
DOkHeaders.java195 Headers requestHeaders = response.networkResponse().request().headers(); in varyHeaders() local
197 return varyHeaders(requestHeaders, responseHeaders); in varyHeaders()
204 public static Headers varyHeaders(Headers requestHeaders, Headers responseHeaders) { in varyHeaders() argument
209 for (int i = 0, size = requestHeaders.size(); i < size; i++) { in varyHeaders()
210 String fieldName = requestHeaders.name(i); in varyHeaders()
212 result.add(fieldName, requestHeaders.value(i)); in varyHeaders()
/external/okhttp/repackaged/okhttp-urlconnection/src/main/java/com/android/okhttp/internal/huc/
DHttpURLConnectionImpl.java92 private Headers.Builder requestHeaders = new Headers.Builder(); field in HttpURLConnectionImpl
240 return OkHeaders.toMultimap(requestHeaders.build(), null); in getRequestProperties()
290 return requestHeaders.get(field); in getRequestProperty()
355 Headers headers = requestHeaders.build(); in newHttpEngine()
429 requestHeaders = followUp.headers().newBuilder(); in getResponse()
566 requestHeaders.set(field, newValue); in setRequestProperty()
573 requestHeaders.set("If-Modified-Since", HttpDate.format(new Date(ifModifiedSince))); in setIfModifiedSince()
575 requestHeaders.removeAll("If-Modified-Since"); in setIfModifiedSince()
600 requestHeaders.add(field, value); in addRequestProperty()
/external/okhttp/okhttp-urlconnection/src/main/java/com/squareup/okhttp/internal/huc/
DHttpURLConnectionImpl.java89 private Headers.Builder requestHeaders = new Headers.Builder(); field in HttpURLConnectionImpl
236 return OkHeaders.toMultimap(requestHeaders.build(), null); in getRequestProperties()
286 return requestHeaders.get(field); in getRequestProperty()
351 Headers headers = requestHeaders.build(); in newHttpEngine()
425 requestHeaders = followUp.headers().newBuilder(); in getResponse()
562 requestHeaders.set(field, newValue); in setRequestProperty()
569 requestHeaders.set("If-Modified-Since", HttpDate.format(new Date(ifModifiedSince))); in setIfModifiedSince()
571 requestHeaders.removeAll("If-Modified-Since"); in setIfModifiedSince()
596 requestHeaders.add(field, value); in addRequestProperty()
/external/grpc-grpc/src/objective-c/GRPCClient/
DGRPCCall+OAuth2.m31 NSString *headerValue = self.requestHeaders[kAuthorizationHeader];
41 self.requestHeaders[kAuthorizationHeader] = [kBearerPrefix stringByAppendingString:token];
43 [self.requestHeaders removeObjectForKey:kAuthorizationHeader];
/external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/
DTestUtils.java58 Metadata requestHeaders, in recordRequestHeadersInterceptor()
60 headersCapture.set(requestHeaders); in recordRequestHeadersInterceptor()
61 return next.startCall(call, requestHeaders); in recordRequestHeadersInterceptor()
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/internal/framed/
DFramedServer.java95 List<Header> requestHeaders = stream.getRequestHeaders(); in onStream() local
97 for (int i = 0, size = requestHeaders.size(); i < size; i++) { in onStream()
98 if (requestHeaders.get(i).name.equals(Header.TARGET_PATH)) { in onStream()
99 path = requestHeaders.get(i).value.utf8(); in onStream()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java186 private List<Header> requestHeaders; field in OkHttpClientStream.TransportState
228 frameWriter.synStream(useGet, false, id, 0, requestHeaders); in start()
230 requestHeaders = null; in start()
347 requestHeaders = null; in cancel()
379 requestHeaders = Headers.createRequestHeaders(metadata, path, authority, userAgent, useGet); in streamReady()
/external/grpc-grpc/src/csharp/Grpc.Core.Testing/
DTestServerCallContext.cs35 …ntext Create(string method, string host, DateTime deadline, Metadata requestHeaders, CancellationT… in Create() argument
39 … return new ServerCallContext(null, method, host, deadline, requestHeaders, cancellationToken, in Create()
/external/grpc-grpc/src/objective-c/examples/SwiftSample/
DViewController.swift62 RPC.requestHeaders["My-Header"] = "My value" in viewDidLoad()
75 call.requestHeaders["My-Header"] = "My value" in viewDidLoad()
/external/okhttp/okhttp-android-support/src/main/java/com/squareup/okhttp/
DAndroidShimResponseCache.java59 Map<String, List<String>> requestHeaders) throws IOException { in get() argument
60 Request okRequest = JavaApiConverter.createOkRequest(uri, requestMethod, requestHeaders); in get()

123