| /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 | 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 | 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 | 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 | 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 | 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 | 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/webrtc/webrtc/modules/video_render/ |
| D | video_render_impl.cc | 146 uint32_t ModuleVideoRenderImpl::GetIncomingFrameRate(const uint32_t streamId) { in GetIncomingFrameRate() argument
149 IncomingVideoStreamMap::iterator it = _streamRenderMap.find(streamId); in GetIncomingFrameRate()
165 ModuleVideoRenderImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream() argument
181 if (_streamRenderMap.find(streamId) != _streamRenderMap.end()) { in AddIncomingRenderStream()
189 _ptrRenderer->AddIncomingRenderStream(streamId, zOrder, left, top, in AddIncomingRenderStream()
201 new IncomingVideoStream(streamId, false); in AddIncomingRenderStream()
206 _streamRenderMap[streamId] = ptrIncomingStream; in AddIncomingRenderStream()
212 const uint32_t streamId) in DeleteIncomingRenderStream() argument
223 IncomingVideoStreamMap::iterator item = _streamRenderMap.find(streamId); in DeleteIncomingRenderStream()
233 _ptrRenderer->DeleteIncomingRenderStream(streamId); in DeleteIncomingRenderStream()
[all …]
|
| D | video_render.h | 95 * AddIncomingRenderStream(const uint32_t streamId,
105 DeleteIncomingRenderStream(const uint32_t streamId) = 0;
116 AddExternalRenderCallback(const uint32_t streamId,
130 GetIncomingRenderStreamProperties(const uint32_t streamId,
138 GetIncomingFrameRate(const uint32_t streamId) = 0;
149 HasIncomingRenderStream(const uint32_t streamId) const = 0;
156 RegisterRawFrameCallback(const uint32_t streamId,
168 virtual int32_t StartRender(const uint32_t streamId) = 0;
173 virtual int32_t StopRender(const uint32_t streamId) = 0;
208 virtual uint32_t RenderFrameRate(const uint32_t streamId) = 0;
[all …]
|
| D | video_render_impl.h | 65 * AddIncomingRenderStream(const uint32_t streamId,
73 DeleteIncomingRenderStream(const uint32_t streamId);
79 AddExternalRenderCallback(const uint32_t streamId,
86 GetIncomingRenderStreamProperties(const uint32_t streamId,
93 virtual uint32_t GetIncomingFrameRate(const uint32_t streamId);
103 virtual bool HasIncomingRenderStream(const uint32_t streamId) const;
109 RegisterRawFrameCallback(const uint32_t streamId,
124 virtual int32_t StartRender(const uint32_t streamId);
129 virtual int32_t StopRender(const uint32_t streamId);
163 virtual uint32_t RenderFrameRate(const uint32_t streamId);
[all …]
|
| D | video_render_internal_impl.cc | 369 uint32_t ModuleVideoRenderImpl::GetIncomingFrameRate(const uint32_t streamId) { in GetIncomingFrameRate() argument
372 IncomingVideoStreamMap::iterator it = _streamRenderMap.find(streamId); in GetIncomingFrameRate()
388 ModuleVideoRenderImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream() argument
404 if (_streamRenderMap.find(streamId) != _streamRenderMap.end()) { in AddIncomingRenderStream()
412 _ptrRenderer->AddIncomingRenderStream(streamId, zOrder, left, top, in AddIncomingRenderStream()
424 new IncomingVideoStream(streamId, false); in AddIncomingRenderStream()
429 _streamRenderMap[streamId] = ptrIncomingStream; in AddIncomingRenderStream()
435 const uint32_t streamId) in DeleteIncomingRenderStream() argument
446 IncomingVideoStreamMap::iterator item = _streamRenderMap.find(streamId); in DeleteIncomingRenderStream()
456 _ptrRenderer->DeleteIncomingRenderStream(streamId); in DeleteIncomingRenderStream()
[all …]
|
| /external/webrtc/webrtc/modules/video_render/linux/ |
| D | video_x11_render.cc | 63 int32_t streamId, in CreateX11RenderChannel() argument
74 _streamIdToX11ChannelMap.find(streamId); in CreateX11RenderChannel()
78 renderChannel = new VideoX11Channel(streamId); in CreateX11RenderChannel()
86 streamId); in CreateX11RenderChannel()
90 _streamIdToX11ChannelMap[streamId] = renderChannel; in CreateX11RenderChannel()
95 "Render Channel already exists for streamId: %d", streamId); in CreateX11RenderChannel()
102 int32_t VideoX11Render::DeleteX11RenderChannel(int32_t streamId) in DeleteX11RenderChannel() argument
107 _streamIdToX11ChannelMap.find(streamId); in DeleteX11RenderChannel()
122 streamId); in DeleteX11RenderChannel()
127 int32_t streamId, in GetIncomingStreamProperties() argument
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | MockSpdyPeer.java | 222 public int streamId; field in MockSpdyPeer.InFrame
252 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers() argument
258 this.streamId = streamId; in headers()
264 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
269 this.streamId = streamId; in data()
273 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream() argument
276 this.streamId = streamId; in rstStream()
291 this.streamId = lastGoodStreamId; in goAway()
296 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate() argument
299 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
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | AsyncFrameWriter.java | 83 public void pushPromise(final int streamId, final int promisedStreamId, in pushPromise() argument
88 frameWriter.pushPromise(streamId, promisedStreamId, requestHeaders); in pushPromise()
111 public void synStream(final boolean outFinished, final boolean inFinished, final int streamId, in synStream() argument
116 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, headerBlock); in synStream()
122 public void synReply(final boolean outFinished, final int streamId, in synReply() argument
127 frameWriter.synReply(outFinished, streamId, headerBlock); in synReply()
133 public void headers(final int streamId, final List<Header> headerBlock) { in headers() argument
137 frameWriter.headers(streamId, headerBlock); in headers()
143 public void rstStream(final int streamId, final ErrorCode errorCode) { in rstStream() argument
147 frameWriter.rstStream(streamId, errorCode); in rstStream()
[all …]
|
| /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 …]
|
| /external/webrtc/webrtc/modules/video_render/windows/ |
| D | video_render_windows_impl.cc | 88 VideoRenderWindowsImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream() argument
103 renderCallback = _ptrRendererWin->CreateChannel(streamId, zOrder, left, in AddIncomingRenderStream()
111 const uint32_t streamId) in DeleteIncomingRenderStream() argument
120 error = _ptrRendererWin->DeleteChannel(streamId); in DeleteIncomingRenderStream()
126 const uint32_t streamId, in GetIncomingRenderStreamProperties() argument
146 error = _ptrRendererWin->GetStreamSettings(streamId, 0, zOrder, left, in GetIncomingRenderStreamProperties()
230 const uint32_t streamId) in RenderFrameRate() argument
237 const uint32_t streamId, in SetStreamCropping() argument
250 error = _ptrRendererWin->SetCropping(streamId, 0, left, top, right, in SetStreamCropping()
257 const uint32_t streamId, in ConfigureRenderer() argument
[all …]
|