Home
last modified time | relevance | path

Searched refs:streamId (Results 1 – 25 of 57) sorted by relevance

123

/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DHttp2.java136 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 …]
DFramedConnection.java194 synchronized FramedStream removeStream(int streamId) { in removeStream() argument
195 FramedStream stream = streams.remove(streamId); in removeStream()
253 int streamId; in newStream() local
260 streamId = nextStreamId; in newStream()
262 stream = new FramedStream(streamId, this, outFinished, inFinished, requestHeaders); in newStream()
264 streams.put(streamId, stream); in newStream()
269 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, in newStream()
274 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders); in newStream()
285 void writeSynReply(int streamId, boolean outFinished, List<Header> alternating) in writeSynReply() argument
287 frameWriter.synReply(outFinished, streamId, alternating); in writeSynReply()
[all …]
DPushObserver.java49 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) {
DSpdy3.java185 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 …]
DFrameWriter.java46 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
DFrameReader.java31 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/webrtc/webrtc/modules/video_render/
Dvideo_render_impl.cc146 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 …]
Dvideo_render.h95 * 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 …]
Dvideo_render_impl.h65 * 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 …]
Dvideo_render_internal_impl.cc369 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 …]
Di_video_render.h39 * AddIncomingRenderStream(const uint32_t streamId,
47 DeleteIncomingRenderStream(const uint32_t streamId) = 0;
50 GetIncomingRenderStreamProperties(const uint32_t streamId,
91 virtual uint32_t RenderFrameRate(const uint32_t streamId) = 0;
93 virtual int32_t SetStreamCropping(const uint32_t streamId,
99 virtual int32_t ConfigureRenderer(const uint32_t streamId,
/external/webrtc/webrtc/modules/video_render/linux/
Dvideo_x11_render.cc63 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 …]
Dvideo_render_linux_impl.cc81 const uint32_t streamId, in AddIncomingRenderStream() argument
96 _ptrX11Render->CreateX11RenderChannel(streamId, zOrder, left, in AddIncomingRenderStream()
102 streamId); in AddIncomingRenderStream()
117 const uint32_t streamId) in DeleteIncomingRenderStream() argument
125 return _ptrX11Render->DeleteX11RenderChannel(streamId); in DeleteIncomingRenderStream()
131 const uint32_t streamId, in GetIncomingRenderStreamProperties() argument
144 return _ptrX11Render->GetIncomingStreamProperties(streamId, zOrder, in GetIncomingRenderStreamProperties()
221 const uint32_t streamId, in ConfigureRenderer() argument
Dvideo_render_linux_impl.h46 * AddIncomingRenderStream(const uint32_t streamId,
52 DeleteIncomingRenderStream(const uint32_t streamId);
55 GetIncomingRenderStreamProperties(const uint32_t streamId,
90 virtual uint32_t RenderFrameRate(const uint32_t streamId);
92 virtual int32_t SetStreamCropping(const uint32_t streamId,
98 virtual int32_t ConfigureRenderer(const uint32_t streamId,
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DMockSpdyPeer.java222 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 …]
DBaseTestHandler.java26 @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/webrtc/webrtc/modules/video_render/windows/
Dvideo_render_windows_impl.cc88 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 …]
Dvideo_render_direct3d9.h46 virtual int32_t RenderFrame(const uint32_t streamId,
59 void SetStreamSettings(uint16_t streamId,
65 int GetStreamSettings(uint16_t streamId,
119 * CreateChannel(const uint32_t streamId,
126 virtual int32_t DeleteChannel(const uint32_t streamId);
129 const uint16_t streamId,
152 const uint16_t streamId,
157 const uint16_t streamId,
Dvideo_render_windows_impl.h54 * AddIncomingRenderStream(const uint32_t streamId,
60 DeleteIncomingRenderStream(const uint32_t streamId);
63 GetIncomingRenderStreamProperties(const uint32_t streamId,
98 virtual uint32_t RenderFrameRate(const uint32_t streamId);
100 virtual int32_t SetStreamCropping(const uint32_t streamId,
104 virtual int32_t ConfigureRenderer(const uint32_t streamId,
/external/webrtc/webrtc/modules/video_render/external/
Dvideo_render_external_impl.h45 * AddIncomingRenderStream(const uint32_t streamId,
51 DeleteIncomingRenderStream(const uint32_t streamId);
54 GetIncomingRenderStreamProperties(const uint32_t streamId,
89 virtual uint32_t RenderFrameRate(const uint32_t streamId);
91 virtual int32_t SetStreamCropping(const uint32_t streamId,
95 virtual int32_t ConfigureRenderer(const uint32_t streamId,
117 virtual int32_t RenderFrame(const uint32_t streamId,
Dvideo_render_external_impl.cc42 VideoRenderExternalImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream() argument
54 const uint32_t streamId) in DeleteIncomingRenderStream() argument
61 const uint32_t streamId, in GetIncomingRenderStreamProperties() argument
127 const uint32_t streamId) in RenderFrameRate() argument
134 const uint32_t streamId, in SetStreamCropping() argument
145 const uint32_t streamId, in ConfigureRenderer() argument
191 int32_t VideoRenderExternalImpl::RenderFrame(const uint32_t streamId, in RenderFrame() argument
/external/webrtc/webrtc/modules/video_render/mac/
Dvideo_render_mac_carbon_impl.cc119 VideoRenderMacCarbonImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream() argument
137 AGLChannel = _ptrCocoaRender->CreateNSGLChannel(streamId, zOrder, left, top, right, bottom); in AddIncomingRenderStream()
145 VideoRenderMacCarbonImpl::DeleteIncomingRenderStream(const uint32_t streamId) in DeleteIncomingRenderStream() argument
150 _ptrCarbonRender->DeleteAGLChannel(streamId); in DeleteIncomingRenderStream()
156 VideoRenderMacCarbonImpl::GetIncomingRenderStreamProperties(const uint32_t streamId, in GetIncomingRenderStreamProperties() argument
164 return _ptrCarbonRender->GetChannelProperties(streamId, zOrder, left, top, right, bottom); in GetIncomingRenderStreamProperties()
221 VideoRenderMacCarbonImpl::RenderFrameRate(const uint32_t streamId) in RenderFrameRate() argument
228 VideoRenderMacCarbonImpl::SetStreamCropping(const uint32_t streamId, in SetStreamCropping() argument
237 int32_t VideoRenderMacCarbonImpl::ConfigureRenderer(const uint32_t streamId, in ConfigureRenderer() argument
Dvideo_render_mac_carbon_impl.h48 virtual VideoRenderCallback* AddIncomingRenderStream(const uint32_t streamId,
55 virtual int32_t DeleteIncomingRenderStream(const uint32_t streamId);
57 virtual int32_t GetIncomingRenderStreamProperties(const uint32_t streamId,
92 virtual uint32_t RenderFrameRate(const uint32_t streamId);
94 virtual int32_t SetStreamCropping(const uint32_t streamId,
100 virtual int32_t ConfigureRenderer(const uint32_t streamId,
Dvideo_render_mac_cocoa_impl.h48 virtual VideoRenderCallback* AddIncomingRenderStream(const uint32_t streamId,
55 virtual int32_t DeleteIncomingRenderStream(const uint32_t streamId);
57 virtual int32_t GetIncomingRenderStreamProperties(const uint32_t streamId,
92 virtual uint32_t RenderFrameRate(const uint32_t streamId);
94 virtual int32_t SetStreamCropping(const uint32_t streamId,
100 virtual int32_t ConfigureRenderer(const uint32_t streamId,
/external/webrtc/webrtc/modules/video_render/android/
Dvideo_render_android_impl.h55 const uint32_t streamId,
61 const uint32_t streamId);
64 const uint32_t streamId,
91 virtual uint32_t RenderFrameRate(const uint32_t streamId);
93 virtual int32_t SetStreamCropping(const uint32_t streamId,
99 virtual int32_t ConfigureRenderer(const uint32_t streamId,
121 int32_t streamId,

123