| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AbstractServerStreamTest.java | 246 stream.writeHeaders(null); in writeHeaders_failsOnNullHeaders()
250 public void writeHeaders() { in writeHeaders() method in AbstractServerStreamTest
252 stream.writeHeaders(headers); in writeHeaders()
253 verify(sink).writeHeaders(same(headers)); in writeHeaders()
258 stream.writeHeaders(new Metadata()); in writeMessage_dontWriteDuplicateHeaders()
262 verify(sink).writeHeaders(any(Metadata.class)); in writeMessage_dontWriteDuplicateHeaders()
267 stream.writeHeaders(new Metadata()); in writeMessage_ignoreIfFramerClosed()
279 stream.writeHeaders(new Metadata()); in writeMessage()
289 stream.writeHeaders(new Metadata()); in writeMessage_closesStream()
|
| D | AbstractClientStreamTest.java | 390 verify(sink, never()).writeHeaders(any(Metadata.class), any(byte[].class)); in getRequest()
394 verify(sink).writeHeaders(any(Metadata.class), payloadCaptor.capture()); in getRequest()
437 verify(sink).writeHeaders(headersCaptor.capture(), any(byte[].class)); in deadlineTimeoutPopulatedToHeaders()
514 public void writeHeaders(Metadata headers, byte[] payload) {} in writeHeaders() method in AbstractClientStreamTest.BaseSink
|
| D | ServerCallImplTest.java | 149 verify(stream).writeHeaders(headers); in sendHeader_firstCall()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractServerStream.java | 44 void writeHeaders(Metadata headers); in writeHeaders() method
110 public final void writeHeaders(Metadata headers) { in writeHeaders() method in AbstractServerStream
114 abstractServerStreamSink().writeHeaders(headers); in writeHeaders()
|
| D | AbstractClientStream.java | 64 void writeHeaders(Metadata metadata, @Nullable byte[] payload); in writeHeaders() method
159 abstractClientStreamSink().writeHeaders(headers, null); in start()
508 abstractClientStreamSink().writeHeaders(headers, payload); in close()
|
| D | ServerStream.java | 39 void writeHeaders(Metadata headers); in writeHeaders() method
|
| D | ServerCallImpl.java | 123 stream.writeHeaders(headers); in sendHeaders()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | HpackTest.java | 54 hpackWriter.writeHeaders(headerBlock); in largeHeaderValue()
198 hpackWriter.writeHeaders(headerBlock); in literalHeaderFieldWithoutIndexingIndexedName()
218 hpackWriter.writeHeaders(headerBlock); in literalHeaderFieldWithoutIndexingNewName()
676 hpackWriter.writeHeaders(Arrays.asList(new Header("FoO", "BaR"))); in lowercaseHeaderNameBeforeEmit()
|
| /external/grpc-grpc-java/okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/ |
| D | HpackTest.java | 66 hpackWriter.writeHeaders(headerBlock); in largeHeaderValue()
226 hpackWriter.writeHeaders(headerBlock); in literalHeaderFieldWithoutIndexingIndexedName()
246 hpackWriter.writeHeaders(headerBlock); in literalHeaderFieldWithoutIndexingNewName()
704 hpackWriter.writeHeaders(Arrays.asList(new Header("FoO", "BaR"))); in lowercaseHeaderNameBeforeEmit()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerStreamTest.java | 107 stream.writeHeaders(new Metadata()); in writeMessageShouldSendResponse()
133 stream().writeHeaders(headers); in writeHeadersShouldSendHeaders()
302 stream.writeHeaders(new Metadata()); in sendHeadersIfServer()
|
| D | NettyServerHandlerTest.java | 427 verifyWrite().writeHeaders(eq(ctx()), eq(STREAM_ID), eq(responseHeaders), eq(0), in headersWithInvalidContentTypeShouldFail()
446 verifyWrite().writeHeaders(eq(ctx()), eq(STREAM_ID), eq(responseHeaders), eq(0), in headersWithInvalidMethodShouldFail()
464 verifyWrite().writeHeaders(eq(ctx()), eq(STREAM_ID), eq(responseHeaders), eq(0), in headersWithMissingPathShouldFail()
483 verifyWrite().writeHeaders(eq(ctx()), eq(STREAM_ID), eq(responseHeaders), eq(0), in headersWithInvalidPathShouldFail()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerHandler.java | 638 encoder().writeHeaders(ctx, streamId, cmd.headers(), 0, cmd.endOfStream(), promise); in sendResponseHeaders()
679 encoder().writeHeaders(ctx, streamId, headers, 0, false, ctx.newPromise()); in respondWithHttpError()
937 public ChannelFuture writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, in writeHeaders() method in NettyServerHandler.WriteMonitoringFrameWriter
940 return super.writeHeaders(ctx, streamId, headers, padding, endStream, promise); in writeHeaders()
944 public ChannelFuture writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, in writeHeaders() method in NettyServerHandler.WriteMonitoringFrameWriter
948 return super.writeHeaders(ctx, streamId, headers, streamDependency, weight, exclusive, in writeHeaders()
|
| D | NettyServerStream.java | 107 public void writeHeaders(Metadata headers) { in writeHeaders() method in NettyServerStream.Sink
|
| D | NettyClientStream.java | 116 public void writeHeaders(Metadata headers, byte[] requestPayload) { in writeHeaders() method in NettyClientStream.Sink
|
| /external/okhttp/okhttp-hpacktests/src/test/java/com/squareup/okhttp/internal/spdy/ |
| D | HpackRoundTripTest.java | 56 hpackWriter.writeHeaders(caze.getHeaders()); in testRoundTrip()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 262 serverStreamCreation.stream.writeHeaders(new Metadata()); in frameAfterRstStreamShouldNotBreakClientChannel()
279 serverStreamCreation.stream.writeHeaders(new Metadata()); in frameAfterRstStreamShouldNotBreakClientChannel()
397 serverStream.writeHeaders(new Metadata()); in openStreamPreventsTermination()
753 serverStream.writeHeaders(serverHeaders); in basicStream()
864 serverStream.writeHeaders(new Metadata()); in zeroMessageStream()
897 serverStream.writeHeaders(new Metadata()); in earlyServerClose_withServerHeaders()
1127 serverStream.writeHeaders(new Metadata()); in clientCancelFromWithinMessageRead()
1221 serverStream.writeHeaders(new Metadata()); in flowControlPushBack()
1387 server.stream.writeHeaders(new Metadata()); in interactionsAfterServerStreamCloseAreNoops()
1688 serverStream.writeHeaders(new Metadata()); in transportTracer_server_send_msg()
|
| /external/icu/icu4c/source/i18n/unicode/ |
| D | vtzone.h | 382 void writeHeaders(VTZWriter& w, UErrorCode& status) const;
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | Http2.java | 430 hpackWriter.writeHeaders(requestHeaders); in pushPromise()
445 hpackWriter.writeHeaders(headerBlock); in headers()
|
| D | Hpack.java | 379 void writeHeaders(List<Header> headerBlock) throws IOException { in writeHeaders() method in Hpack.Writer
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | Http2.java | 428 hpackWriter.writeHeaders(requestHeaders); in pushPromise()
443 hpackWriter.writeHeaders(headerBlock); in headers()
|
| D | Hpack.java | 378 void writeHeaders(List<Header> headerBlock) throws IOException { in writeHeaders() method in Hpack.Writer
|
| /external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/ |
| D | Http2.java | 434 hpackWriter.writeHeaders(requestHeaders); in pushPromise()
449 hpackWriter.writeHeaders(headerBlock); in headers()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientStream.java | 137 public void writeHeaders(Metadata metadata, byte[] payload) { in writeHeaders() method in OkHttpClientStream.Sink
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientStream.java | 132 public void writeHeaders(Metadata metadata, byte[] payload) { in writeHeaders() method in CronetClientStream.Sink
|
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| D | transport.go | 837 werr := cc.writeHeaders(cs.ID, endStream, int(cc.maxFrameSize), hdrs)
993 func (cc *ClientConn) writeHeaders(streamID uint32, endStream bool, maxFrameSize int, hdrs []byte) … func
1125 err = cc.writeHeaders(cs.ID, true, maxFrameSize, trls)
|