Home
last modified time | relevance | path

Searched defs:streamId (Results 1 – 25 of 48) sorted by relevance

12

/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DHttp2.java138 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 …]
DFrameWriter.java48 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()
DPushObserver.java51 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()
DFrameReader.java33 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()
DFramedConnection.java196 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 …]
DSpdy3.java187 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/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DHttp2.java136 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 …]
DFrameWriter.java46 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()
DPushObserver.java49 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()
DFrameReader.java31 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()
DFramedConnection.java194 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 …]
DSpdy3.java185 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/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/
DHttp2.java141 int streamId = (source.readInt() & 0x7fffffff); // Ignore reserved bit. in nextFrame() local
188 private void readHeaders(Handler handler, int length, byte flags, int streamId) in readHeaders()
208 private List<Header> readHeaderBlock(int length, short padding, byte flags, int streamId) in readHeaderBlock()
221 private void readData(Handler handler, int length, byte flags, int streamId) in readData()
237 private void readPriority(Handler handler, int length, byte flags, int streamId) in readPriority()
244 private void readPriority(Handler handler, int streamId) throws IOException { in readPriority()
252 private void readRstStream(Handler handler, int length, byte flags, int streamId) in readRstStream()
264 private void readSettings(Handler handler, int length, byte flags, int streamId) in readSettings()
315 private void readPushPromise(Handler handler, int length, byte flags, int streamId) in readPushPromise()
328 private void readPing(Handler handler, int length, byte flags, int streamId) in readPing()
[all …]
DFrameWriter.java50 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()
DFrameReader.java35 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-tests/src/test/java/com/squareup/okhttp/internal/framed/
DBaseTestHandler.java26 @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()
DMockSpdyPeer.java222 public int streamId; field in MockSpdyPeer.InFrame
252 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers()
264 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data()
273 @Override public void rstStream(int streamId, ErrorCode errorCode) { in rstStream()
296 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { in windowUpdate()
303 @Override public void priority(int streamId, int streamDependency, int weight, in priority()
309 public void pushPromise(int streamId, int associatedStreamId, List<Header> headerBlock) { in pushPromise()
316 @Override public void alternateService(int streamId, String origin, ByteString protocol, in alternateService()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DAsyncFrameWriter.java83 public void pushPromise(final int streamId, final int promisedStreamId, in pushPromise()
111 public void synStream(final boolean outFinished, final boolean inFinished, final int streamId, in synStream()
122 public void synReply(final boolean outFinished, final int streamId, in synReply()
133 public void headers(final int streamId, final List<Header> headerBlock) { in headers()
143 public void rstStream(final int streamId, final ErrorCode errorCode) { in rstStream()
153 public void data(final boolean outFinished, final int streamId, final Buffer source, in data()
197 public void windowUpdate(final int streamId, final long windowSizeIncrement) { in windowUpdate()
/external/webrtc/webrtc/modules/video_render/
Dvideo_render_impl.cc146 uint32_t ModuleVideoRenderImpl::GetIncomingFrameRate(const uint32_t streamId) { in GetIncomingFrameRate()
165 ModuleVideoRenderImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream()
212 const uint32_t streamId) in DeleteIncomingRenderStream()
241 const uint32_t streamId, in AddExternalRenderCallback()
264 const uint32_t streamId, in GetIncomingRenderStreamProperties()
299 const uint32_t streamId, in RegisterRawFrameCallback()
304 int32_t ModuleVideoRenderImpl::StartRender(const uint32_t streamId) in StartRender()
336 int32_t ModuleVideoRenderImpl::StopRender(const uint32_t streamId) in StopRender()
419 const uint32_t streamId) in RenderFrameRate()
433 const uint32_t streamId, in SetStreamCropping()
[all …]
Dvideo_render_internal_impl.cc369 uint32_t ModuleVideoRenderImpl::GetIncomingFrameRate(const uint32_t streamId) { in GetIncomingFrameRate()
388 ModuleVideoRenderImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream()
435 const uint32_t streamId) in DeleteIncomingRenderStream()
464 const uint32_t streamId, in AddExternalRenderCallback()
487 const uint32_t streamId, in GetIncomingRenderStreamProperties()
522 const uint32_t streamId, in RegisterRawFrameCallback()
527 int32_t ModuleVideoRenderImpl::StartRender(const uint32_t streamId) in StartRender()
559 int32_t ModuleVideoRenderImpl::StopRender(const uint32_t streamId) in StopRender()
642 const uint32_t streamId) in RenderFrameRate()
656 const uint32_t streamId, in SetStreamCropping()
[all …]
/external/webrtc/webrtc/modules/video_render/external/
Dvideo_render_external_impl.cc42 VideoRenderExternalImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream()
54 const uint32_t streamId) in DeleteIncomingRenderStream()
61 const uint32_t streamId, in GetIncomingRenderStreamProperties()
127 const uint32_t streamId) in RenderFrameRate()
134 const uint32_t streamId, in SetStreamCropping()
145 const uint32_t streamId, in ConfigureRenderer()
191 int32_t VideoRenderExternalImpl::RenderFrame(const uint32_t streamId, in RenderFrame()
/external/webrtc/webrtc/modules/video_render/mac/
Dvideo_render_mac_carbon_impl.cc119 VideoRenderMacCarbonImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream()
145 VideoRenderMacCarbonImpl::DeleteIncomingRenderStream(const uint32_t streamId) in DeleteIncomingRenderStream()
156 VideoRenderMacCarbonImpl::GetIncomingRenderStreamProperties(const uint32_t streamId, in GetIncomingRenderStreamProperties()
221 VideoRenderMacCarbonImpl::RenderFrameRate(const uint32_t streamId) in RenderFrameRate()
228 VideoRenderMacCarbonImpl::SetStreamCropping(const uint32_t streamId, in SetStreamCropping()
237 int32_t VideoRenderMacCarbonImpl::ConfigureRenderer(const uint32_t streamId, in ConfigureRenderer()
/external/webrtc/webrtc/modules/video_render/linux/
Dvideo_x11_render.cc63 int32_t streamId, in CreateX11RenderChannel()
102 int32_t VideoX11Render::DeleteX11RenderChannel(int32_t streamId) in DeleteX11RenderChannel()
127 int32_t streamId, in GetIncomingStreamProperties()
/external/webrtc/webrtc/modules/video_render/windows/
Dvideo_render_windows_impl.cc88 VideoRenderWindowsImpl::AddIncomingRenderStream(const uint32_t streamId, in AddIncomingRenderStream()
111 const uint32_t streamId) in DeleteIncomingRenderStream()
126 const uint32_t streamId, in GetIncomingRenderStreamProperties()
230 const uint32_t streamId) in RenderFrameRate()
237 const uint32_t streamId, in SetStreamCropping()
257 const uint32_t streamId, in ConfigureRenderer()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerHandler.java366 private void onHeadersRead(ChannelHandlerContext ctx, int streamId, Http2Headers headers) in onHeadersRead()
459 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) in onDataRead()
472 private void onRstStreamRead(int streamId, long errorCode) throws Http2Exception { in onRstStreamRead()
600 private void closeStreamWhenDone(ChannelPromise promise, int streamId) throws Http2Exception { in closeStreamWhenDone()
629 int streamId = cmd.stream().id(); in sendResponseHeaders() local
667 ChannelHandlerContext ctx, int streamId, int code, Status.Code statusCode, String msg) { in respondWithHttpError()
684 private Http2Stream requireHttp2Stream(int streamId) { in requireHttp2Stream()
700 private Http2Exception newStreamException(int streamId, Throwable cause) { in newStreamException()
719 public int onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, in onDataRead()
730 int streamId, in onHeadersRead()
[all …]

12