| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | FramedStream.java | 62 private List<Header> responseHeaders; field in FramedStream
112 && responseHeaders != null) { in isOpen()
139 while (responseHeaders == null && errorCode == null) { in getResponseHeaders()
145 if (responseHeaders != null) return responseHeaders; in getResponseHeaders()
163 public void reply(List<Header> responseHeaders, boolean out) throws IOException { in reply() argument
167 if (responseHeaders == null) { in reply()
170 if (this.responseHeaders != null) { in reply()
173 this.responseHeaders = responseHeaders; in reply()
179 connection.writeSynReply(id, outFinished, responseHeaders); in reply()
207 if (responseHeaders == null && !isLocallyInitiated()) { in getSink()
[all …]
|
| D | PushObserver.java | 59 boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last); in onHeaders() argument
82 @Override public boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last) {
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | ResponseHeadersTest.cs | 74 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_UnaryCall()
76 Assert.AreEqual(headers.Count, responseHeaders.Count); in ResponseHeadersAsync_UnaryCall()
77 Assert.AreEqual("ascii-header", responseHeaders[0].Key); in ResponseHeadersAsync_UnaryCall()
78 Assert.AreEqual("abcdefg", responseHeaders[0].Value); in ResponseHeadersAsync_UnaryCall()
94 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ClientStreamingCall()
96 Assert.AreEqual("ascii-header", responseHeaders[0].Key); in ResponseHeadersAsync_ClientStreamingCall()
110 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ServerStreamingCall()
112 Assert.AreEqual("ascii-header", responseHeaders[0].Key); in ResponseHeadersAsync_ServerStreamingCall()
129 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_DuplexStreamingCall()
134 Assert.AreEqual("ascii-header", responseHeaders[0].Key); in ResponseHeadersAsync_DuplexStreamingCall()
|
| /external/grpc-grpc-java/netty/src/jmh/java/io/grpc/netty/ |
| D | InboundHeadersBenchmark.java | 45 private static AsciiString[] responseHeaders; field in InboundHeadersBenchmark
77 responseHeaders = new AsciiString[4]; in setupResponseHeaders()
79 responseHeaders[i++] = of(":status"); in setupResponseHeaders()
80 responseHeaders[i++] = of("200"); in setupResponseHeaders()
81 responseHeaders[i++] = of("grpc-encoding"); in setupResponseHeaders()
82 responseHeaders[i] = of("gzip"); in setupResponseHeaders()
145 bh.consume(headers.add(responseHeaders[0], responseHeaders[1])); in clientHandler()
146 bh.consume(headers.add(responseHeaders[2], responseHeaders[3])); in clientHandler()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| D | OkHeaders.java | 159 public static boolean hasVaryAll(Headers responseHeaders) { in hasVaryAll() argument
160 return varyFields(responseHeaders).contains("*"); in hasVaryAll()
171 public static Set<String> varyFields(Headers responseHeaders) { in varyFields() argument
173 for (int i = 0, size = responseHeaders.size(); i < size; i++) { in varyFields()
174 if (!"Vary".equalsIgnoreCase(responseHeaders.name(i))) continue; in varyFields()
176 String value = responseHeaders.value(i); in varyFields()
196 Headers responseHeaders = response.headers(); in varyHeaders() local
197 return varyHeaders(requestHeaders, responseHeaders); in varyHeaders()
204 public static Headers varyHeaders(Headers requestHeaders, Headers responseHeaders) { in varyHeaders() argument
205 Set<String> varyFields = varyFields(responseHeaders); in varyHeaders()
[all …]
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/http/ |
| D | OkHeaders.java | 161 public static boolean hasVaryAll(Headers responseHeaders) { in hasVaryAll() argument
162 return varyFields(responseHeaders).contains("*"); in hasVaryAll()
173 public static Set<String> varyFields(Headers responseHeaders) { in varyFields() argument
175 for (int i = 0, size = responseHeaders.size(); i < size; i++) { in varyFields()
176 if (!"Vary".equalsIgnoreCase(responseHeaders.name(i))) continue; in varyFields()
178 String value = responseHeaders.value(i); in varyFields()
198 Headers responseHeaders = response.headers(); in varyHeaders() local
199 return varyHeaders(requestHeaders, responseHeaders); in varyHeaders()
206 public static Headers varyHeaders(Headers requestHeaders, Headers responseHeaders) { in varyHeaders() argument
207 Set<String> varyFields = varyFields(responseHeaders); in varyHeaders()
[all …]
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | FramedStream.java | 64 private List<Header> responseHeaders; field in FramedStream
114 && responseHeaders != null) { in isOpen()
141 while (responseHeaders == null && errorCode == null) { in getResponseHeaders()
147 if (responseHeaders != null) return responseHeaders; in getResponseHeaders()
165 public void reply(List<Header> responseHeaders, boolean out) throws IOException { in reply() argument
169 if (responseHeaders == null) { in reply()
172 if (this.responseHeaders != null) { in reply()
175 this.responseHeaders = responseHeaders; in reply()
181 connection.writeSynReply(id, outFinished, responseHeaders); in reply()
209 if (responseHeaders == null && !isLocallyInitiated()) { in getSink()
[all …]
|
| D | PushObserver.java | 61 boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last); in onHeaders() argument
84 @Override public boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last) {
|
| /external/ksoap2/ksoap2-j2se/src/main/java/org/ksoap2/transport/ |
| D | HttpResponseException.java | 16 private List responseHeaders; field in HttpResponseException
28 public HttpResponseException(String detailMessage, int statusCode, List responseHeaders) { in HttpResponseException() argument
31 this.responseHeaders = responseHeaders; in HttpResponseException()
59 return responseHeaders; in getResponseHeaders()
|
| /external/volley/src/main/java/com/android/volley/toolbox/ |
| D | BasicNetwork.java | 118 List<Header> responseHeaders = Collections.emptyList(); in performRequest() local
126 responseHeaders = httpResponse.getHeaders(); in performRequest()
136 responseHeaders); in performRequest()
139 List<Header> combinedHeaders = combineHeaders(responseHeaders, entry); in performRequest()
171 responseHeaders); in performRequest()
192 responseHeaders); in performRequest()
336 private static List<Header> combineHeaders(List<Header> responseHeaders, Entry entry) { in combineHeaders() argument
340 if (!responseHeaders.isEmpty()) { in combineHeaders()
341 for (Header header : responseHeaders) { in combineHeaders()
348 List<Header> combinedHeaders = new ArrayList<>(responseHeaders); in combineHeaders()
[all …]
|
| /external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/recipes/ |
| D | SynchronousGet.java | 35 Headers responseHeaders = response.headers(); in run() local
36 for (int i = 0; i < responseHeaders.size(); i++) { in run()
37 System.out.println(responseHeaders.name(i) + ": " + responseHeaders.value(i)); in run()
|
| D | AsynchronousGet.java | 41 Headers responseHeaders = response.headers(); in run()
42 for (int i = 0, size = responseHeaders.size(); i < size; i++) { in run()
43 System.out.println(responseHeaders.name(i) + ": " + responseHeaders.value(i)); in run()
|
| D | CustomTrust.java | 53 Headers responseHeaders = response.headers(); in run() local
54 for (int i = 0; i < responseHeaders.size(); i++) { in run()
55 System.out.println(responseHeaders.name(i) + ": " + responseHeaders.value(i)); in run()
|
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | FramedServer.java | 124 List<Header> responseHeaders = Arrays.asList( in send404() local
129 stream.reply(responseHeaders, true); in send404()
136 List<Header> responseHeaders = Arrays.asList( in serveDirectory() local
141 stream.reply(responseHeaders, true); in serveDirectory()
151 List<Header> responseHeaders = Arrays.asList( in serveFile() local
156 stream.reply(responseHeaders, true); in serveFile()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | AsyncCall.cs | 531 private void HandleReceivedResponseHeaders(bool success, Metadata responseHeaders) in HandleReceivedResponseHeaders() argument
534 responseHeadersTcs.SetResult(responseHeaders); in HandleReceivedResponseHeaders()
540 …se(bool success, ClientSideStatus receivedStatus, byte[] receivedMessage, Metadata responseHeaders) in HandleUnaryResponse() argument
574 responseHeadersTcs.SetResult(responseHeaders); in HandleUnaryResponse()
637 …nt(bool success, ClientSideStatus receivedStatus, byte[] receivedMessage, Metadata responseHeaders) in IUnaryResponseClientCallback.OnUnaryResponseClient() argument
639 HandleUnaryResponse(success, receivedStatus, receivedMessage, responseHeaders); in IUnaryResponseClientCallback.OnUnaryResponseClient()
651 … IReceivedResponseHeadersCallback.OnReceivedResponseHeaders(bool success, Metadata responseHeaders) in IReceivedResponseHeadersCallback.OnReceivedResponseHeaders() argument
653 HandleReceivedResponseHeaders(success, responseHeaders); in IReceivedResponseHeadersCallback.OnReceivedResponseHeaders()
|
| D | ServerResponseStream.cs | 43 public Task WriteResponseHeadersAsync(Metadata responseHeaders) in WriteResponseHeadersAsync() argument
45 return call.SendInitialMetadataAsync(responseHeaders); in WriteResponseHeadersAsync()
|
| D | INativeCall.cs | 25 …t(bool success, ClientSideStatus receivedStatus, byte[] receivedMessage, Metadata responseHeaders); in OnUnaryResponseClient() argument
41 void OnReceivedResponseHeaders(bool success, Metadata responseHeaders); in OnReceivedResponseHeaders() argument
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/ |
| D | HeaderServerInterceptor.java | 47 public void sendHeaders(Metadata responseHeaders) { in interceptCall()
48 responseHeaders.put(CUSTOM_HEADER_KEY, "customRespondValue"); in interceptCall()
49 super.sendHeaders(responseHeaders); in interceptCall()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | Cache.java | 475 private final Headers responseHeaders; field in Entry
548 responseHeaders = responseHeadersBuilder.build(); in Entry()
574 this.responseHeaders = response.headers(); in Entry()
596 sink.writeDecimalLong(responseHeaders.size()); in writeTo()
598 for (int i = 0, size = responseHeaders.size(); i < size; i++) { in writeTo()
599 sink.writeUtf8(responseHeaders.name(i)); in writeTo()
601 sink.writeUtf8(responseHeaders.value(i)); in writeTo()
661 String contentType = responseHeaders.get("Content-Type"); in response()
662 String contentLength = responseHeaders.get("Content-Length"); in response()
673 .headers(responseHeaders) in response()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | Cache.java | 477 private final Headers responseHeaders; field in Entry
550 responseHeaders = responseHeadersBuilder.build(); in Entry()
576 this.responseHeaders = response.headers(); in Entry()
598 sink.writeDecimalLong(responseHeaders.size()); in writeTo()
600 for (int i = 0, size = responseHeaders.size(); i < size; i++) { in writeTo()
601 sink.writeUtf8(responseHeaders.name(i)); in writeTo()
603 sink.writeUtf8(responseHeaders.value(i)); in writeTo()
663 String contentType = responseHeaders.get("Content-Type"); in response()
664 String contentLength = responseHeaders.get("Content-Length"); in response()
675 .headers(responseHeaders) in response()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 517 public void sendHeaders(Metadata responseHeaders) {
518 responseHeaders.merge(requestHeaders, keySet);
519 super.sendHeaders(responseHeaders);
545 public void sendHeaders(Metadata responseHeaders) {
546 responseHeaders.merge(requestHeaders, keySet);
547 super.sendHeaders(responseHeaders);
572 public void sendHeaders(Metadata responseHeaders) {
573 super.sendHeaders(responseHeaders);
|
| /external/volley/src/test/java/com/android/volley/toolbox/ |
| D | BasicNetworkTest.java | 141 entry.responseHeaders = new HashMap<>(); in notModified_legacyCache()
142 entry.responseHeaders.put("CachedKeyA", "CachedValueA"); in notModified_legacyCache()
143 entry.responseHeaders.put("CachedKeyB", "CachedValueB"); in notModified_legacyCache()
144 entry.responseHeaders.put("SharedKey", "CachedValueShared"); in notModified_legacyCache()
145 entry.responseHeaders.put("SHAREDCASEINSENSITIVEKEY", "CachedValueShared1"); in notModified_legacyCache()
146 entry.responseHeaders.put("shAREDcaSEinSENSITIVEkeY", "CachedValueShared2"); in notModified_legacyCache()
|
| /external/okhttp/repackaged/okhttp-android-support/src/main/java/com/android/okhttp/internal/huc/ |
| D | JavaApiConverter.java | 78 Headers responseHeaders = createHeaders(urlConnection.getHeaderFields()); in createOkResponseForCachePut() local
80 Headers varyHeaders = varyHeaders(urlConnection, responseHeaders); in createOkResponseForCachePut()
156 private static Headers varyHeaders(URLConnection urlConnection, Headers responseHeaders) { in varyHeaders() argument
157 if (OkHeaders.hasVaryAll(responseHeaders)) { in varyHeaders()
161 Set<String> varyFields = OkHeaders.varyFields(responseHeaders); in varyHeaders()
205 Headers responseHeaders = createHeaders(javaResponse.getHeaders()); in createOkResponseForCacheGet() local
207 if (OkHeaders.hasVaryAll(responseHeaders)) { in createOkResponseForCacheGet()
211 varyHeaders = OkHeaders.varyHeaders(request.headers(), responseHeaders); in createOkResponseForCacheGet()
|
| /external/okhttp/okhttp-android-support/src/main/java/com/squareup/okhttp/internal/huc/ |
| D | JavaApiConverter.java | 76 Headers responseHeaders = createHeaders(urlConnection.getHeaderFields()); in createOkResponseForCachePut() local
78 Headers varyHeaders = varyHeaders(urlConnection, responseHeaders); in createOkResponseForCachePut()
154 private static Headers varyHeaders(URLConnection urlConnection, Headers responseHeaders) { in varyHeaders() argument
155 if (OkHeaders.hasVaryAll(responseHeaders)) { in varyHeaders()
159 Set<String> varyFields = OkHeaders.varyFields(responseHeaders); in varyHeaders()
203 Headers responseHeaders = createHeaders(javaResponse.getHeaders()); in createOkResponseForCacheGet() local
205 if (OkHeaders.hasVaryAll(responseHeaders)) { in createOkResponseForCacheGet()
209 varyHeaders = OkHeaders.varyHeaders(request.headers(), responseHeaders); in createOkResponseForCacheGet()
|
| /external/okhttp/okhttp-android-support/src/test/java/com/squareup/okhttp/internal/huc/ |
| D | JavaApiConverterTest.java | 375 Map<String, List<String>> responseHeaders = httpUrlConnection.getHeaderFields(); in createJavaUrlConnection_responseHeadersOk() local
376 assertEquals(Arrays.asList("HTTP/1.1 200 Fantastic"), responseHeaders.get(null)); in createJavaUrlConnection_responseHeadersOk()
377 assertEquals(newSet("c", "e"), newSet(responseHeaders.get("A"))); in createJavaUrlConnection_responseHeadersOk()
379 assertEquals(newSet("c", "e"), newSet(responseHeaders.get("a"))); in createJavaUrlConnection_responseHeadersOk()
382 assertHeadersContainsMapping(responseHeaders, null, "HTTP/1.1 200 Fantastic"); in createJavaUrlConnection_responseHeadersOk()
383 assertHeadersContainsMapping(responseHeaders, "A", "c", "e"); in createJavaUrlConnection_responseHeadersOk()
384 assertHeadersContainsMapping(responseHeaders, "B", "d"); in createJavaUrlConnection_responseHeadersOk()
388 responseHeaders.put("N", Arrays.asList("o")); in createJavaUrlConnection_responseHeadersOk()
393 responseHeaders.get("A").add("f"); in createJavaUrlConnection_responseHeadersOk()
|