| /external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/ |
| D | Http2.java | 143 int streamId = (source.readInt() & 0x7fffffff); // Ignore reserved bit. in nextFrame() local
190 private void readHeaders(Handler handler, int length, byte flags, int streamId) in readHeaders()
210 private List<Header> readHeaderBlock(int length, short padding, byte flags, int streamId) in readHeaderBlock()
223 private void readData(Handler handler, int length, byte flags, int streamId) in readData()
241 Handler handler, int length, @SuppressWarnings("UnusedVariable") byte flags, int streamId) in readPriority()
248 private void readPriority(Handler handler, int streamId) throws IOException { in readPriority()
257 Handler handler, int length, @SuppressWarnings("UnusedVariable") byte flags, int streamId) in readRstStream()
269 private void readSettings(Handler handler, int length, byte flags, int streamId) in readSettings()
320 private void readPushPromise(Handler handler, int length, byte flags, int streamId) in readPushPromise()
333 private void readPing(Handler handler, int length, byte flags, int streamId) in readPing()
[all …]
|
| D | FrameWriter.java | 50 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
55 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream()
57 void synReply(boolean outFinished, int streamId, List<Header> headerBlock) in synReply()
59 void headers(int streamId, List<Header> headerBlock) throws IOException; in headers()
60 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream()
73 void data(boolean outFinished, int streamId, Buffer source, int byteCount) throws IOException; in data()
106 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate()
|
| D | FrameReader.java | 35 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
49 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers()
51 void rstStream(int streamId, io.grpc.okhttp.internal.framed.ErrorCode errorCode); in rstStream()
88 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate()
100 void priority(int streamId, int streamDependency, int weight, boolean exclusive); in priority()
116 …void pushPromise(int streamId, int promisedStreamId, List<io.grpc.okhttp.internal.framed.Header> r… in pushPromise()
138 void alternateService(int streamId, String origin, ByteString protocol, String host, int port, in alternateService()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | Http2.java | 136 int streamId = (source.readInt() & 0x7fffffff); // Ignore reserved bit. in nextFrame() local
183 private void readHeaders(Handler handler, int length, byte flags, int streamId) in readHeaders()
203 private List<Header> readHeaderBlock(int length, short padding, byte flags, int streamId) in readHeaderBlock()
216 private void readData(Handler handler, int length, byte flags, int streamId) in readData()
232 private void readPriority(Handler handler, int length, byte flags, int streamId) in readPriority()
239 private void readPriority(Handler handler, int streamId) throws IOException { in readPriority()
247 private void readRstStream(Handler handler, int length, byte flags, int streamId) in readRstStream()
259 private void readSettings(Handler handler, int length, byte flags, int streamId) in readSettings()
309 private void readPushPromise(Handler handler, int length, byte flags, int streamId) in readPushPromise()
322 private void readPing(Handler handler, int length, byte flags, int streamId) in readPing()
[all …]
|
| D | FrameWriter.java | 46 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
51 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream()
53 void synReply(boolean outFinished, int streamId, List<Header> headerBlock) in synReply()
55 void headers(int streamId, List<Header> headerBlock) throws IOException; in headers()
56 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream()
69 void data(boolean outFinished, int streamId, Buffer source, int byteCount) throws IOException; in data()
102 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate()
|
| D | FrameReader.java | 31 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
45 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers()
47 void rstStream(int streamId, ErrorCode errorCode); in rstStream()
84 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate()
96 void priority(int streamId, int streamDependency, int weight, boolean exclusive); in priority()
112 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
134 void alternateService(int streamId, String origin, ByteString protocol, String host, int port, in alternateService()
|
| D | PushObserver.java | 49 boolean onRequest(int streamId, List<Header> requestHeaders); in onRequest()
59 boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last); in onHeaders()
70 boolean onData(int streamId, BufferedSource source, int byteCount, boolean last) in onData()
74 void onReset(int streamId, ErrorCode errorCode); in onReset()
|
| D | FramedConnection.java | 194 synchronized FramedStream removeStream(int streamId) { in removeStream()
257 int streamId; in newStream() local
289 void writeSynReply(int streamId, boolean outFinished, List<Header> alternating) in writeSynReply()
306 public void writeData(int streamId, boolean outFinished, Buffer buffer, long byteCount) in writeData()
348 void writeSynResetLater(final int streamId, final ErrorCode errorCode) { in writeSynResetLater()
359 void writeSynReset(int streamId, ErrorCode statusCode) throws IOException { in writeSynReset()
363 void writeWindowUpdateLater(final int streamId, final long unacknowledgedBytesRead) { in writeWindowUpdateLater()
622 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
640 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers()
701 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream()
[all …]
|
| D | Spdy3.java | 185 int streamId = w1 & 0x7fffffff; in nextFrame() local
195 int streamId = w1 & 0x7fffffff; in readSynStream() local
208 int streamId = w1 & 0x7fffffff; in readSynReply() local
216 int streamId = source.readInt() & 0x7fffffff; in readRstStream() local
227 int streamId = w1 & 0x7fffffff; in readHeaders() local
236 int streamId = w1 & 0x7fffffff; in readWindowUpdate() local
309 public void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
324 int streamId, int associatedStreamId, List<Header> headerBlock) in synStream()
342 @Override public synchronized void synReply(boolean outFinished, int streamId, in synReply()
357 @Override public synchronized void headers(int streamId, List<Header> headerBlock) in headers()
[all …]
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | Http2.java | 138 int streamId = (source.readInt() & 0x7fffffff); // Ignore reserved bit. in nextFrame() local
185 private void readHeaders(Handler handler, int length, byte flags, int streamId) in readHeaders()
205 private List<Header> readHeaderBlock(int length, short padding, byte flags, int streamId) in readHeaderBlock()
218 private void readData(Handler handler, int length, byte flags, int streamId) in readData()
234 private void readPriority(Handler handler, int length, byte flags, int streamId) in readPriority()
241 private void readPriority(Handler handler, int streamId) throws IOException { in readPriority()
249 private void readRstStream(Handler handler, int length, byte flags, int streamId) in readRstStream()
261 private void readSettings(Handler handler, int length, byte flags, int streamId) in readSettings()
311 private void readPushPromise(Handler handler, int length, byte flags, int streamId) in readPushPromise()
324 private void readPing(Handler handler, int length, byte flags, int streamId) in readPing()
[all …]
|
| D | FrameWriter.java | 48 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
53 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream()
55 void synReply(boolean outFinished, int streamId, List<Header> headerBlock) in synReply()
57 void headers(int streamId, List<Header> headerBlock) throws IOException; in headers()
58 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream()
71 void data(boolean outFinished, int streamId, Buffer source, int byteCount) throws IOException; in data()
104 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate()
|
| D | FrameReader.java | 33 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
47 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers()
49 void rstStream(int streamId, ErrorCode errorCode); in rstStream()
86 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate()
98 void priority(int streamId, int streamDependency, int weight, boolean exclusive); in priority()
114 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
136 void alternateService(int streamId, String origin, ByteString protocol, String host, int port, in alternateService()
|
| D | PushObserver.java | 51 boolean onRequest(int streamId, List<Header> requestHeaders); in onRequest()
61 boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last); in onHeaders()
72 boolean onData(int streamId, BufferedSource source, int byteCount, boolean last) in onData()
76 void onReset(int streamId, ErrorCode errorCode); in onReset()
|
| D | FramedConnection.java | 196 synchronized FramedStream removeStream(int streamId) { in removeStream()
259 int streamId; in newStream() local
291 void writeSynReply(int streamId, boolean outFinished, List<Header> alternating) in writeSynReply()
308 public void writeData(int streamId, boolean outFinished, Buffer buffer, long byteCount) in writeData()
350 void writeSynResetLater(final int streamId, final ErrorCode errorCode) { in writeSynResetLater()
361 void writeSynReset(int streamId, ErrorCode statusCode) throws IOException { in writeSynReset()
365 void writeWindowUpdateLater(final int streamId, final long unacknowledgedBytesRead) { in writeWindowUpdateLater()
627 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
645 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers()
706 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream()
[all …]
|
| D | Spdy3.java | 187 int streamId = w1 & 0x7fffffff; in nextFrame() local
197 int streamId = w1 & 0x7fffffff; in readSynStream() local
210 int streamId = w1 & 0x7fffffff; in readSynReply() local
218 int streamId = source.readInt() & 0x7fffffff; in readRstStream() local
229 int streamId = w1 & 0x7fffffff; in readHeaders() local
238 int streamId = w1 & 0x7fffffff; in readWindowUpdate() local
311 public void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
326 int streamId, int associatedStreamId, List<Header> headerBlock) in synStream()
344 @Override public synchronized void synReply(boolean outFinished, int streamId, in synReply()
359 @Override public synchronized void headers(int streamId, List<Header> headerBlock) in headers()
[all …]
|
| /external/cronet/components/cronet/android/test/src/org/chromium/net/ |
| D | Http2TestHandler.java | 117 int streamId, in onHeadersRead()
133 int streamId, in onDataRead()
143 void sendResponseString(ChannelHandlerContext ctx, int streamId, String responseString) { in sendResponseString()
163 int streamId, in onHeadersRead()
181 int streamId, in onDataRead()
196 int streamId, in onHeadersRead()
215 int streamId, in onHeadersRead()
229 int streamId, in onHeadersRead()
252 int streamId, in onHeadersRead()
267 int streamId, in onHeadersRead()
[all …]
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | ForwardingFrameWriter.java | 53 public void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
64 public void synStream(boolean outFinished, boolean inFinished, int streamId, in synStream()
70 public void synReply(boolean outFinished, int streamId, List<Header> headerBlock) in synReply()
76 public void headers(int streamId, List<Header> headerBlock) throws IOException { in headers()
81 public void rstStream(int streamId, ErrorCode errorCode) throws IOException { in rstStream()
91 public void data(boolean outFinished, int streamId, Buffer source, int byteCount) in data()
113 public void windowUpdate(int streamId, long windowSizeIncrement) throws IOException { in windowUpdate()
|
| D | ExceptionHandlingFrameWriter.java | 78 public void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) { in pushPromise()
101 int streamId, in synStream()
112 public void synReply(boolean outFinished, int streamId, in synReply()
122 public void headers(int streamId, List<Header> headerBlock) { in headers()
132 public void rstStream(int streamId, ErrorCode errorCode) { in rstStream()
147 public void data(boolean outFinished, int streamId, Buffer source, int byteCount) { in data()
198 public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate()
|
| D | OkHttpFrameLogger.java | 73 void logData(Direction direction, int streamId, Buffer data, int length, boolean endStream) { in logData()
89 void logHeaders(Direction direction, int streamId, List<Header> headers, boolean endStream) { in logHeaders()
104 Direction direction, int streamId, int streamDependency, int weight, boolean exclusive) { in logPriority()
120 void logRstStream(Direction direction, int streamId, ErrorCode errorCode) { in logRstStream()
152 Direction direction, int streamId, int promisedStreamId, List<Header> headers) { in logPushPromise()
182 void logWindowsUpdate(Direction direction, int streamId, long windowSizeIncrement) { in logWindowsUpdate()
|
| D | OkHttpServerTransport.java | 438 void streamClosed(int streamId, boolean flush) { in streamClosed()
613 int streamId, in headers()
815 public void data(boolean inFinished, int streamId, BufferedSource in, int length) in data()
873 public void rstStream(int streamId, ErrorCode errorCode) { in rstStream()
968 public void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
980 public void windowUpdate(int streamId, long delta) { in windowUpdate()
998 public void priority(int streamId, int streamDependency, int weight, boolean exclusive) { in priority()
1006 public void alternateService(int streamId, String origin, ByteString protocol, String host, in alternateService()
1022 private void streamError(int streamId, ErrorCode errorCode, String reason) { in streamError()
1041 int streamId, boolean inFinished, int httpCode, Status.Code statusCode, String msg) { in respondWithHttpError()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | BaseTestHandler.java | 26 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
32 public void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers()
37 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream()
57 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate()
61 @Override public void priority(int streamId, int streamDependency, int weight, in priority()
67 public void pushPromise(int streamId, int associatedStreamId, List<Header> headerBlock) { in pushPromise()
71 @Override public void alternateService(int streamId, String origin, ByteString protocol, in alternateService()
|
| D | MockSpdyPeer.java | 231 public int streamId; field in MockSpdyPeer.InFrame
261 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers()
273 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
282 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream()
305 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate()
312 @Override public void priority(int streamId, int streamDependency, int weight, in priority()
318 public void pushPromise(int streamId, int associatedStreamId, List<Header> headerBlock) { in pushPromise()
325 @Override public void alternateService(int streamId, String origin, ByteString protocol, in alternateService()
|
| /external/cronet/third_party/quic_trace/src/examples/ |
| D | example-first-200ms.json | 13 "streamId": "3", string
31 "streamId": "3", string
49 "streamId": "3", string
67 "streamId": "3", string
85 "streamId": "3", string
103 "streamId": "3", string
121 "streamId": "3", string
139 "streamId": "3", string
157 "streamId": "3", string
175 "streamId": "3", string
[all …]
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 374 private void onHeadersRead(int streamId, Http2Headers headers, boolean endStream) { in onHeadersRead()
390 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) { in onDataRead()
403 private void onRstStreamRead(int streamId, long errorCode) { in onRstStreamRead()
551 int streamId; in createStream() local
605 final int streamId, in createStreamTraced()
614 encoder().writeHeaders(ctx(), streamId, headers, 0, isGet, tempPromise) in createStreamTraced() local
900 private Http2Stream requireHttp2Stream(int streamId) { in requireHttp2Stream()
921 public int onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, in onDataRead()
929 int streamId, in onHeadersRead()
940 public void onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) in onRstStreamRead()
[all …]
|
| D | NettyServerHandler.java | 392 private void onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers) in onHeadersRead()
510 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) in onDataRead()
526 private void onRstStreamRead(int streamId, long errorCode) throws Http2Exception { in onRstStreamRead()
680 private void closeStreamWhenDone(ChannelPromise promise, int streamId) throws Http2Exception { in closeStreamWhenDone()
716 int streamId = cmd.stream().id(); in sendResponseHeaders() local
778 ChannelHandlerContext ctx, int streamId, int code, Status.Code statusCode, String msg) { in respondWithHttpError()
795 private Http2Stream requireHttp2Stream(int streamId) { in requireHttp2Stream()
811 private Http2Exception newStreamException(int streamId, Throwable cause) { in newStreamException()
830 public int onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, in onDataRead()
841 int streamId, in onHeadersRead()
[all …]
|