/external/grpc-grpc-java/netty/src/jmh/java/io/grpc/netty/ |
D | InboundHeadersBenchmark.java | 44 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/ |
D | ServerCallContext.cs | 36 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/ |
D | URLConnectionResponse.java | 43 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/volley/src/test/java/com/android/volley/toolbox/ |
D | HttpStackConformanceTest.java | 149 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/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/ |
D | HeaderServerInterceptor.java | 42 final Metadata requestHeaders, in interceptCall() argument 44 logger.info("header received from client:" + requestHeaders); in interceptCall() 51 }, requestHeaders); in interceptCall()
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
D | ServerImplTest.java | 412 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 …]
|
/external/exoplayer/tree/extensions/cast/src/main/java/com/google/android/exoplayer2/ext/cast/ |
D | DefaultMediaItemConverter.java | 102 HashMap<String, String> requestHeaders = new HashMap<>(); in populateDrmConfiguration() local 105 requestHeaders.put(key, requestHeadersJson.getString(key)); in populateDrmConfiguration() 107 builder.setDrmLicenseRequestHeaders(requestHeaders); in populateDrmConfiguration() 145 json.put(KEY_REQUEST_HEADERS, new JSONObject(drmConfiguration.requestHeaders)); in getDrmConfigurationJson() 172 if (!drmConfiguration.requestHeaders.isEmpty()) { in getPlayerConfigJson() 173 exoPlayerConfigJson.put("headers", new JSONObject(drmConfiguration.requestHeaders)); in getPlayerConfigJson()
|
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
D | TestServiceImpl.java | 513 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/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
D | FramedConnection.java | 232 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 …]
|
D | FramedStream.java | 59 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()
|
D | PushObserver.java | 49 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/ |
D | FramedConnection.java | 234 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 …]
|
D | FramedStream.java | 61 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()
|
D | PushObserver.java | 51 boolean onRequest(int streamId, List<Header> requestHeaders); in onRequest() argument 80 @Override public boolean onRequest(int streamId, List<Header> requestHeaders) {
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
D | OkHeaders.java | 195 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/src/main/java/com/android/okhttp/internal/http/ |
D | OkHeaders.java | 197 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/grpc-grpc/src/objective-c/GRPCClient/ |
D | GRPCCall+OAuth2.m | 31 NSString *headerValue = self.requestHeaders[kAuthorizationHeader]; 41 self.requestHeaders[kAuthorizationHeader] = [kBearerPrefix stringByAppendingString:token]; 43 [self.requestHeaders removeObjectForKey:kAuthorizationHeader];
|
/external/okhttp/okhttp-urlconnection/src/main/java/com/squareup/okhttp/internal/huc/ |
D | HttpURLConnectionImpl.java | 89 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/okhttp/repackaged/okhttp-urlconnection/src/main/java/com/android/okhttp/internal/huc/ |
D | HttpURLConnectionImpl.java | 92 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/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
D | TestUtils.java | 58 Metadata requestHeaders, in recordRequestHeadersInterceptor() 60 headersCapture.set(requestHeaders); in recordRequestHeadersInterceptor() 61 return next.startCall(call, requestHeaders); in recordRequestHeadersInterceptor()
|
/external/grpc-grpc/src/csharp/Grpc.Core.Testing/ |
D | TestServerCallContext.cs | 35 …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/ |
D | ViewController.swift | 62 RPC.requestHeaders["My-Header"] = "My value" in viewDidLoad() 75 call.requestHeaders["My-Header"] = "My value" in viewDidLoad()
|
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/internal/framed/ |
D | FramedServer.java | 95 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/exoplayer/tree/library/common/src/main/java/com/google/android/exoplayer2/ |
D | MediaItem.java | 109 drmLicenseRequestHeaders = drmConfiguration.requestHeaders; in Builder() 469 public final Map<String, String> requestHeaders; field in MediaItem.DrmConfiguration 488 Map<String, String> requestHeaders, in DrmConfiguration() argument 495 this.requestHeaders = requestHeaders; in DrmConfiguration() 520 && Util.areEqual(requestHeaders, other.requestHeaders) in equals() 531 result = 31 * result + requestHeaders.hashCode(); in hashCode()
|
/external/exoplayer/tree/library/common/src/test/java/com/google/android/exoplayer2/ |
D | MediaItemTest.java | 92 Map<String, String> requestHeaders = new HashMap<>(); in builderSetDrmConfig_setsAllProperties() local 93 requestHeaders.put("Referer", "http://www.google.com"); in builderSetDrmConfig_setsAllProperties() 100 .setDrmLicenseRequestHeaders(requestHeaders) in builderSetDrmConfig_setsAllProperties() 110 assertThat(mediaItem.playbackProperties.drmConfiguration.requestHeaders) in builderSetDrmConfig_setsAllProperties() 111 .isEqualTo(requestHeaders); in builderSetDrmConfig_setsAllProperties()
|