Home
last modified time | relevance | path

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

12

/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()
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()
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()
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/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()
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()
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()
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-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.java231 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/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DAsyncFrameWriter.java91 public void pushPromise(final int streamId, final int promisedStreamId, in pushPromise()
119 public void synStream(final boolean outFinished, final boolean inFinished, final int streamId, in synStream()
130 public void synReply(final boolean outFinished, final int streamId, in synReply()
141 public void headers(final int streamId, final List<Header> headerBlock) { in headers()
151 public void rstStream(final int streamId, final ErrorCode errorCode) { in rstStream()
161 public void data(final boolean outFinished, final int streamId, final Buffer source, in data()
205 public void windowUpdate(final int streamId, final long windowSizeIncrement) { in windowUpdate()
DOkHttpClientTransport.java797 int streamId, in finishStream()
903 boolean mayHaveCreatedStream(int streamId) { in mayHaveCreatedStream()
909 OkHttpClientStream getStream(int streamId) { in getStream()
1002 public void data(boolean inFinished, int streamId, BufferedSource in, int length) in data()
1038 int streamId, in headers()
1062 public void rstStream(int streamId, ErrorCode errorCode) { in rstStream()
1157 public void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) in pushPromise()
1164 public void windowUpdate(int streamId, long delta) { in windowUpdate()
1198 public void priority(int streamId, int streamDependency, int weight, boolean exclusive) { in priority()
1204 public void alternateService(int streamId, String origin, ByteString protocol, String host, in alternateService()
DOutboundFlowController.java107 void data(boolean outFinished, int streamId, Buffer source, boolean flush) { in data()
230 final int streamId; field in OutboundFlowController.OutboundFlowState
236 OutboundFlowState(int streamId) { in OutboundFlowState()
/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 …]
DNettyClientHandler.java341 private void onHeadersRead(int streamId, Http2Headers headers, boolean endStream) { in onHeadersRead()
352 private void onDataRead(int streamId, ByteBuf data, int padding, boolean endOfStream) { in onDataRead()
365 private void onRstStreamRead(int streamId, long errorCode) { in onRstStreamRead()
497 final int streamId; in createStream() local
521 encoder().writeHeaders(ctx(), streamId, headers, 0, command.isGet(), tempPromise) in createStream() local
729 private Http2Stream requireHttp2Stream(int streamId) { in requireHttp2Stream()
750 public int onDataRead(ChannelHandlerContext ctx, int streamId, ByteBuf data, int padding, in onDataRead()
758 int streamId, in onHeadersRead()
769 public void onRstStreamRead(ChannelHandlerContext ctx, int streamId, long errorCode) in onRstStreamRead()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyHandlerTestBase.java246 protected ByteBuf grpcDataFrame(int streamId, boolean endStream, byte[] content) { in grpcDataFrame()
269 protected final ByteBuf dataFrame(int streamId, boolean endStream, ByteBuf content) { in dataFrame()
284 protected final ByteBuf headersFrame(int streamId, Http2Headers headers) { in headersFrame()
300 protected final ByteBuf rstStreamFrame(int streamId, int errorCode) { in rstStreamFrame()
312 protected final ByteBuf windowUpdate(int streamId, int delta) { in windowUpdate()
/external/webrtc/sdk/objc/api/peerconnection/
DRTCMediaStream.mm46 - (NSString *)streamId { method in RTCMediaStream
/external/mesa3d/src/gallium/drivers/svga/include/
Dsvga_overlay.h68 uint32 streamId; member
81 uint32 streamId; member

12