| /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
139 if (logger.isLoggable(FINE)) logger.fine(formatHeader(true, streamId, length, type, flags)); in nextFrame()
143 readData(handler, length, flags, streamId); in nextFrame()
147 readHeaders(handler, length, flags, streamId); in nextFrame()
151 readPriority(handler, length, flags, streamId); in nextFrame()
155 readRstStream(handler, length, flags, streamId); in nextFrame()
159 readSettings(handler, length, flags, streamId); in nextFrame()
163 readPushPromise(handler, length, flags, streamId); in nextFrame()
167 readPing(handler, length, flags, streamId); in nextFrame()
171 readGoAway(handler, length, flags, streamId); in nextFrame()
[all …]
|
| D | FramedConnection.java | 196 synchronized FramedStream removeStream(int streamId) { in removeStream() argument
197 FramedStream stream = streams.remove(streamId); in removeStream()
259 int streamId; in newStream() local
266 streamId = nextStreamId; in newStream()
268 stream = new FramedStream(streamId, this, outFinished, inFinished, requestHeaders); in newStream()
270 streams.put(streamId, stream); in newStream()
275 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, in newStream()
280 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders); in newStream()
291 void writeSynReply(int streamId, boolean outFinished, List<Header> alternating) in writeSynReply() argument
293 frameWriter.synReply(outFinished, streamId, alternating); in writeSynReply()
[all …]
|
| D | PushObserver.java | 51 boolean onRequest(int streamId, List<Header> requestHeaders); in onRequest() argument
61 boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last); in onHeaders() argument
72 boolean onData(int streamId, BufferedSource source, int byteCount, boolean last) in onData() argument
76 void onReset(int streamId, ErrorCode errorCode); in onReset() argument
80 @Override public boolean onRequest(int streamId, List<Header> requestHeaders) {
84 @Override public boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last) {
88 @Override public boolean onData(int streamId, BufferedSource source, int byteCount,
94 @Override public void onReset(int streamId, ErrorCode errorCode) {
|
| D | Spdy3.java | 187 int streamId = w1 & 0x7fffffff; in nextFrame() local
189 handler.data(inFinished, streamId, source, length); in nextFrame()
197 int streamId = w1 & 0x7fffffff; in readSynStream() local
204 handler.headers(outFinished, inFinished, streamId, associatedStreamId, headerBlock, in readSynStream()
210 int streamId = w1 & 0x7fffffff; in readSynReply() local
213 handler.headers(false, inFinished, streamId, -1, headerBlock, HeadersMode.SPDY_REPLY); in readSynReply()
218 int streamId = source.readInt() & 0x7fffffff; in readRstStream() local
224 handler.rstStream(streamId, errorCode); in readRstStream()
229 int streamId = w1 & 0x7fffffff; in readHeaders() local
231 handler.headers(false, false, streamId, -1, headerBlock, HeadersMode.SPDY_HEADERS); in readHeaders()
[all …]
|
| D | FrameReader.java | 33 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
47 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
49 void rstStream(int streamId, ErrorCode errorCode); in rstStream() argument
86 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate() argument
98 void priority(int streamId, int streamDependency, int weight, boolean exclusive); in priority() argument
114 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise() argument
136 void alternateService(int streamId, String origin, ByteString protocol, String host, int port, in alternateService() argument
|
| D | FrameWriter.java | 48 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise() argument
53 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream() argument
55 void synReply(boolean outFinished, int streamId, List<Header> headerBlock) in synReply() argument
57 void headers(int streamId, List<Header> headerBlock) throws IOException; in headers() argument
58 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream() argument
71 void data(boolean outFinished, int streamId, Buffer source, int byteCount) throws IOException; in data() argument
104 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate() argument
|
| /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
137 if (logger.isLoggable(FINE)) logger.fine(formatHeader(true, streamId, length, type, flags)); in nextFrame()
141 readData(handler, length, flags, streamId); in nextFrame()
145 readHeaders(handler, length, flags, streamId); in nextFrame()
149 readPriority(handler, length, flags, streamId); in nextFrame()
153 readRstStream(handler, length, flags, streamId); in nextFrame()
157 readSettings(handler, length, flags, streamId); in nextFrame()
161 readPushPromise(handler, length, flags, streamId); in nextFrame()
165 readPing(handler, length, flags, streamId); in nextFrame()
169 readGoAway(handler, length, flags, streamId); in nextFrame()
[all …]
|
| D | FramedConnection.java | 194 synchronized FramedStream removeStream(int streamId) { in removeStream() argument
195 FramedStream stream = streams.remove(streamId); in removeStream()
257 int streamId; in newStream() local
264 streamId = nextStreamId; in newStream()
266 stream = new FramedStream(streamId, this, outFinished, inFinished, requestHeaders); in newStream()
268 streams.put(streamId, stream); in newStream()
273 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, in newStream()
278 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders); in newStream()
289 void writeSynReply(int streamId, boolean outFinished, List<Header> alternating) in writeSynReply() argument
291 frameWriter.synReply(outFinished, streamId, alternating); in writeSynReply()
[all …]
|
| D | PushObserver.java | 49 boolean onRequest(int streamId, List<Header> requestHeaders); in onRequest() argument
59 boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last); in onHeaders() argument
70 boolean onData(int streamId, BufferedSource source, int byteCount, boolean last) in onData() argument
74 void onReset(int streamId, ErrorCode errorCode); in onReset() argument
78 @Override public boolean onRequest(int streamId, List<Header> requestHeaders) {
82 @Override public boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last) {
86 @Override public boolean onData(int streamId, BufferedSource source, int byteCount,
92 @Override public void onReset(int streamId, ErrorCode errorCode) {
|
| D | Spdy3.java | 185 int streamId = w1 & 0x7fffffff; in nextFrame() local
187 handler.data(inFinished, streamId, source, length); in nextFrame()
195 int streamId = w1 & 0x7fffffff; in readSynStream() local
202 handler.headers(outFinished, inFinished, streamId, associatedStreamId, headerBlock, in readSynStream()
208 int streamId = w1 & 0x7fffffff; in readSynReply() local
211 handler.headers(false, inFinished, streamId, -1, headerBlock, HeadersMode.SPDY_REPLY); in readSynReply()
216 int streamId = source.readInt() & 0x7fffffff; in readRstStream() local
222 handler.rstStream(streamId, errorCode); in readRstStream()
227 int streamId = w1 & 0x7fffffff; in readHeaders() local
229 handler.headers(false, false, streamId, -1, headerBlock, HeadersMode.SPDY_HEADERS); in readHeaders()
[all …]
|
| D | FrameWriter.java | 46 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise() argument
51 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream() argument
53 void synReply(boolean outFinished, int streamId, List<Header> headerBlock) in synReply() argument
55 void headers(int streamId, List<Header> headerBlock) throws IOException; in headers() argument
56 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream() argument
69 void data(boolean outFinished, int streamId, Buffer source, int byteCount) throws IOException; in data() argument
102 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate() argument
|
| D | FrameReader.java | 31 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
45 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
47 void rstStream(int streamId, ErrorCode errorCode); in rstStream() argument
84 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate() argument
96 void priority(int streamId, int streamDependency, int weight, boolean exclusive); in priority() argument
112 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise() argument
134 void alternateService(int streamId, String origin, ByteString protocol, String host, int port, in alternateService() argument
|
| /external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/ |
| D | Http2.java | 141 int streamId = (source.readInt() & 0x7fffffff); // Ignore reserved bit. in nextFrame() local
142 if (logger.isLoggable(FINE)) logger.fine(formatHeader(true, streamId, length, type, flags)); in nextFrame()
146 readData(handler, length, flags, streamId); in nextFrame()
150 readHeaders(handler, length, flags, streamId); in nextFrame()
154 readPriority(handler, length, flags, streamId); in nextFrame()
158 readRstStream(handler, length, flags, streamId); in nextFrame()
162 readSettings(handler, length, flags, streamId); in nextFrame()
166 readPushPromise(handler, length, flags, streamId); in nextFrame()
170 readPing(handler, length, flags, streamId); in nextFrame()
174 readGoAway(handler, length, flags, streamId); in nextFrame()
[all …]
|
| D | FrameWriter.java | 50 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise() argument
55 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream() argument
57 void synReply(boolean outFinished, int streamId, List<Header> headerBlock) in synReply() argument
59 void headers(int streamId, List<Header> headerBlock) throws IOException; in headers() argument
60 void rstStream(int streamId, ErrorCode errorCode) throws IOException; in rstStream() argument
73 void data(boolean outFinished, int streamId, Buffer source, int byteCount) throws IOException; in data() argument
106 void windowUpdate(int streamId, long windowSizeIncrement) throws IOException; in windowUpdate() argument
|
| D | FrameReader.java | 35 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
49 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
51 void rstStream(int streamId, io.grpc.okhttp.internal.framed.ErrorCode errorCode); in rstStream() argument
88 void windowUpdate(int streamId, long windowSizeIncrement); in windowUpdate() argument
100 void priority(int streamId, int streamDependency, int weight, boolean exclusive); in priority() argument
116 …void pushPromise(int streamId, int promisedStreamId, List<io.grpc.okhttp.internal.framed.Header> r… in pushPromise() argument
138 void alternateService(int streamId, String origin, ByteString protocol, String host, int port, in alternateService() argument
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | MockSpdyPeer.java | 231 public int streamId; field in MockSpdyPeer.InFrame
261 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers() argument
267 this.streamId = streamId; in headers()
273 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
278 this.streamId = streamId; in data()
282 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream() argument
285 this.streamId = streamId; in rstStream()
300 this.streamId = lastGoodStreamId; in goAway()
305 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate() argument
308 this.streamId = streamId; in windowUpdate()
[all …]
|
| D | BaseTestHandler.java | 26 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
32 public void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
37 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream() argument
57 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate() argument
61 @Override public void priority(int streamId, int streamDependency, int weight, in priority() argument
67 public void pushPromise(int streamId, int associatedStreamId, List<Header> headerBlock) { in pushPromise() argument
71 @Override public void alternateService(int streamId, String origin, ByteString protocol, in alternateService() argument
|
| D | Http2Test.java | 71 public void headers(boolean outFinished, boolean inFinished, int streamId, in onlyOneLiteralHeadersFrame()
75 assertEquals(expectedStreamId, streamId); in onlyOneLiteralHeadersFrame()
96 @Override public void priority(int streamId, int streamDependency, int weight, in headersWithPriority()
103 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headersWithPriority()
108 assertEquals(expectedStreamId, streamId); in headersWithPriority()
140 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headersFrameThenContinuation()
144 assertEquals(expectedStreamId, streamId); in headersFrameThenContinuation()
175 public void pushPromise(int streamId, int promisedStreamId, List<Header> headerBlock) { in pushPromise()
176 assertEquals(expectedStreamId, streamId); in pushPromise()
211 public void pushPromise(int streamId, int promisedStreamId, List<Header> headerBlock) { in pushPromiseThenContinuation()
[all …]
|
| D | Http2ConnectionTest.java | 68 assertEquals(0, ping.streamId); in serverPingsClientHttp2()
92 assertEquals(0, pingFrame.streamId); in clientPingsServerHttp2()
123 assertEquals(0, ackFrame.streamId);
127 assertEquals(0, ackFrame.streamId);
226 assertEquals(3, data1.streamId);
271 windowUpdateStreamIds.add(windowUpdate.streamId);
444 assertEquals(2, rstStream.streamId);
499 assertEquals(0, ackFrame.streamId);
521 @Override public boolean onRequest(int streamId, List<Header> requestHeaders) {
525 @Override public boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last) {
[all …]
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | AsyncFrameWriter.java | 91 public void pushPromise(final int streamId, final int promisedStreamId, in pushPromise() argument
96 frameWriter.pushPromise(streamId, promisedStreamId, requestHeaders); in pushPromise()
119 public void synStream(final boolean outFinished, final boolean inFinished, final int streamId, in synStream() argument
124 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, headerBlock); in synStream()
130 public void synReply(final boolean outFinished, final int streamId, in synReply() argument
135 frameWriter.synReply(outFinished, streamId, headerBlock); in synReply()
141 public void headers(final int streamId, final List<Header> headerBlock) { in headers() argument
145 frameWriter.headers(streamId, headerBlock); in headers()
151 public void rstStream(final int streamId, final ErrorCode errorCode) { in rstStream() argument
155 frameWriter.rstStream(streamId, errorCode); in rstStream()
[all …]
|
| D | OkHttpClientTransport.java | 797 int streamId, in finishStream() argument
804 OkHttpClientStream stream = streams.remove(streamId); in finishStream()
807 frameWriter.rstStream(streamId, ErrorCode.CANCEL); in finishStream()
903 boolean mayHaveCreatedStream(int streamId) { in mayHaveCreatedStream() argument
905 return streamId < nextStreamId && (streamId & 1) == 1; in mayHaveCreatedStream()
909 OkHttpClientStream getStream(int streamId) { in getStream() argument
911 return streams.get(streamId); in getStream()
1002 public void data(boolean inFinished, int streamId, BufferedSource in, int length) in data() argument
1004 OkHttpClientStream stream = getStream(streamId); in data()
1006 if (mayHaveCreatedStream(streamId)) { in data()
[all …]
|
| D | OutboundFlowController.java | 107 void data(boolean outFinished, int streamId, Buffer source, boolean flush) { in data() argument
110 OkHttpClientStream stream = transport.getStream(streamId); in data()
230 final int streamId; field in OutboundFlowController.OutboundFlowState
236 OutboundFlowState(int streamId) { in OutboundFlowState() argument
237 this.streamId = streamId; in OutboundFlowState()
272 throw new IllegalArgumentException("Window size overflow for stream: " + streamId); in incrementStreamWindow()
388 frameWriter.data(endStream, streamId, data, bytesToWrite); in write()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerHandler.java | 366 private void onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers) in onHeadersRead() argument
381 respondWithHttpError(ctx, streamId, 404, Status.Code.UNIMPLEMENTED, in onHeadersRead()
387 respondWithHttpError(ctx, streamId, 404, Status.Code.UNIMPLEMENTED, in onHeadersRead()
398 ctx, streamId, 415, Status.Code.INTERNAL, "Content-Type is missing from the request"); in onHeadersRead()
403 respondWithHttpError(ctx, streamId, 415, Status.Code.INTERNAL, in onHeadersRead()
409 respondWithHttpError(ctx, streamId, 405, Status.Code.INTERNAL, in onHeadersRead()
416 Http2Stream http2Stream = requireHttp2Stream(streamId); in onHeadersRead()
443 throw newStreamException(streamId, e); in onHeadersRead()
459 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) in onDataRead() argument
463 NettyServerStream.TransportState stream = serverStream(requireHttp2Stream(streamId)); in onDataRead()
[all …]
|
| D | NettyClientHandler.java | 341 private void onHeadersRead(int streamId, Http2Headers headers, boolean endStream) { in onHeadersRead() argument
342 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId)); in onHeadersRead()
352 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) { in onDataRead() argument
354 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId)); in onDataRead()
365 private void onRstStreamRead(int streamId, long errorCode) { in onRstStreamRead() argument
366 NettyClientStream.TransportState stream = clientStream(connection().stream(streamId)); in onRstStreamRead()
463 NettyClientStream.TransportState stream = clientStream(connection().stream(http2Ex.streamId())); in onStreamError()
467 logger.log(Level.FINE, "Stream error for unknown stream " + http2Ex.streamId(), cause); in onStreamError()
497 final int streamId; in createStream() local
499 streamId = incrementAndGetNextStreamId(); in createStream()
[all …]
|
| /external/webrtc/sdk/objc/api/peerconnection/ |
| D | RTCMediaStream.mm | 29 streamId:(NSString *)streamId {
31 NSParameterAssert(streamId.length);
32 std::string nativeId = [NSString stdStringForString:streamId];
46 - (NSString *)streamId { method in RTCMediaStream
84 self.streamId,
|