Searched refs:streamId (Results 1 - 19 of 19) sorted by relevance

/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/
H A DPushObserver.java45 * @param streamId server-initiated stream ID: an even number.
49 boolean onRequest(int streamId, List<Header> requestHeaders); argument
55 * @param streamId server-initiated stream ID: an even number.
59 boolean onHeaders(int streamId, List<Header> responseHeaders, boolean last); argument
65 * @param streamId server-initiated stream ID: an even number.
70 boolean onData(int streamId, BufferedSource source, int byteCount, boolean last) argument
74 void onReset(int streamId, ErrorCode errorCode); 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, BufferedSourc
[all...]
H A DSpdyConnection.java192 synchronized SpdyStream removeStream(int streamId) { argument
193 SpdyStream stream = streams.remove(streamId);
251 int streamId;
258 streamId = nextStreamId;
260 stream = new SpdyStream(streamId, this, outFinished, inFinished, requestHeaders);
262 streams.put(streamId, stream);
267 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId,
272 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders);
283 void writeSynReply(int streamId, boolean outFinished, List<Header> alternating) argument
285 frameWriter.synReply(outFinished, streamId, alternatin
300 writeData(int streamId, boolean outFinished, Buffer buffer, long byteCount) argument
342 writeSynResetLater(final int streamId, final ErrorCode errorCode) argument
353 writeSynReset(int streamId, ErrorCode statusCode) argument
357 writeWindowUpdateLater(final int streamId, final long unacknowledgedBytesRead) argument
593 data(boolean inFinished, int streamId, BufferedSource source, int length) argument
611 headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, List<Header> headerBlock, HeadersMode headersMode) argument
670 rstStream(int streamId, ErrorCode errorCode) argument
759 windowUpdate(int streamId, long windowSizeIncrement) argument
775 priority(int streamId, int streamDependency, int weight, boolean exclusive) argument
781 pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) argument
785 alternateService(int streamId, String origin, ByteString protocol, String host, int port, long maxAge) argument
792 pushedStream(int streamId) argument
799 pushRequestLater(final int streamId, final List<Header> requestHeaders) argument
823 pushHeadersLater(final int streamId, final List<Header> requestHeaders, final boolean inFinished) argument
845 pushDataLater(final int streamId, final BufferedSource source, final int byteCount, final boolean inFinished) argument
867 pushResetLater(final int streamId, final ErrorCode errorCode) argument
[all...]
H A DFrameReader.java31 void data(boolean inFinished, int streamId, BufferedSource source, int length) argument
41 * @param streamId the stream owning these headers.
45 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, argument
47 void rstStream(int streamId, ErrorCode errorCode); argument
82 * sent on {@code streamId}, or the connection if {@code streamId} is zero.
84 void windowUpdate(int streamId, long windowSizeIncrement); argument
90 * @param streamId stream which has a priority change.
96 void priority(int streamId, int streamDependency, int weight, boolean exclusive); argument
104 * {@code streamId}
112 pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) argument
134 alternateService(int streamId, String origin, ByteString protocol, String host, int port, long maxAge) argument
[all...]
H A DFrameWriter.java37 * {@code streamId}. The {@code promisedStreamId} has a priority of one
38 * greater than {@code streamId}.
40 * @param streamId client-initiated stream ID. Must be an odd number.
46 void pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) argument
51 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, argument
53 void synReply(boolean outFinished, int streamId, List<Header> headerBlock) argument
55 void headers(int streamId, List<Header> headerBlock) throws IOException; argument
56 void rstStream(int streamId, ErrorCode errorCode) throws IOException; argument
69 void data(boolean outFinished, int streamId, Buffer source, int byteCount) throws IOException; argument
100 * sent on {@code streamId}, o
102 windowUpdate(int streamId, long windowSizeIncrement) argument
[all...]
H A DHttp2.java136 int streamId = (source.readInt() & 0x7fffffff); // Ignore reserved bit.
137 if (logger.isLoggable(FINE)) logger.fine(formatHeader(true, streamId, length, type, flags));
141 readData(handler, length, flags, streamId);
145 readHeaders(handler, length, flags, streamId);
149 readPriority(handler, length, flags, streamId);
153 readRstStream(handler, length, flags, streamId);
157 readSettings(handler, length, flags, streamId);
161 readPushPromise(handler, length, flags, streamId);
165 readPing(handler, length, flags, streamId);
169 readGoAway(handler, length, flags, streamId);
183 readHeaders(Handler handler, int length, byte flags, int streamId) argument
203 readHeaderBlock(int length, short padding, byte flags, int streamId) argument
216 readData(Handler handler, int length, byte flags, int streamId) argument
232 readPriority(Handler handler, int length, byte flags, int streamId) argument
239 readPriority(Handler handler, int streamId) argument
247 readRstStream(Handler handler, int length, byte flags, int streamId) argument
259 readSettings(Handler handler, int length, byte flags, int streamId) argument
309 readPushPromise(Handler handler, int length, byte flags, int streamId) argument
322 readPing(Handler handler, int length, byte flags, int streamId) argument
332 readGoAway(Handler handler, int length, byte flags, int streamId) argument
350 readWindowUpdate(Handler handler, int length, byte flags, int streamId) argument
405 synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, List<Header> headerBlock) argument
413 synReply(boolean outFinished, int streamId, List<Header> headerBlock) argument
419 headers(int streamId, List<Header> headerBlock) argument
425 pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) argument
442 headers(boolean outFinished, int streamId, List<Header> headerBlock) argument
458 writeContinuationFrames(int streamId, long byteCount) argument
467 rstStream(int streamId, ErrorCode errorCode) argument
484 data(boolean outFinished, int streamId, Buffer source, int byteCount) argument
492 dataFrame(int streamId, byte flags, Buffer buffer, int byteCount) argument
548 windowUpdate(int streamId, long windowSizeIncrement) argument
568 frameHeader(int streamId, int length, byte type, byte flags) argument
599 int streamId; field in class:Http2.ContinuationSource
672 formatHeader(boolean inbound, int streamId, int length, byte type, byte flags) argument
[all...]
H A DSpdy3.java185 int streamId = w1 & 0x7fffffff;
187 handler.data(inFinished, streamId, source, length);
195 int streamId = w1 & 0x7fffffff;
202 handler.headers(outFinished, inFinished, streamId, associatedStreamId, headerBlock,
208 int streamId = w1 & 0x7fffffff;
211 handler.headers(false, inFinished, streamId, -1, headerBlock, HeadersMode.SPDY_REPLY);
216 int streamId = source.readInt() & 0x7fffffff;
222 handler.rstStream(streamId, errorCode);
227 int streamId = w1 & 0x7fffffff;
229 handler.headers(false, false, streamId,
309 pushPromise(int streamId, int promisedStreamId, List<Header> requestHeaders) argument
323 synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, List<Header> headerBlock) argument
342 synReply(boolean outFinished, int streamId, List<Header> headerBlock) argument
357 headers(int streamId, List<Header> headerBlock) argument
371 rstStream(int streamId, ErrorCode errorCode) argument
389 data(boolean outFinished, int streamId, Buffer source, int byteCount) argument
395 sendDataFrame(int streamId, int flags, Buffer buffer, int byteCount) argument
470 windowUpdate(int streamId, long increment) argument
[all...]
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/
H A DBaseTestHandler.java26 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) argument
32 public void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, argument
37 @Override public void rstStream(int streamId, ErrorCode errorCode) { argument
57 @Override public void windowUpdate(int streamId, long windowSizeIncrement) { argument
61 @Override public void priority(int streamId, int streamDependency, int weight, argument
67 public void pushPromise(int streamId, int associatedStreamId, List<Header> headerBlock) { argument
71 @Override public void alternateService(int streamId, String origin, ByteString protocol, argument
H A DMockSpdyPeer.java214 public int streamId; field in class:MockSpdyPeer.InFrame
244 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, argument
250 this.streamId = streamId;
256 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) argument
261 this.streamId = streamId;
265 @Override public void rstStream(int streamId, ErrorCode errorCode) { argument
268 this.streamId = streamId;
288 windowUpdate(int streamId, long windowSizeIncrement) argument
295 priority(int streamId, int streamDependency, int weight, boolean exclusive) argument
301 pushPromise(int streamId, int associatedStreamId, List<Header> headerBlock) argument
308 alternateService(int streamId, String origin, ByteString protocol, String host, int port, long maxAge) argument
[all...]
H A DHttp2ConnectionTest.java70 assertEquals(0, ping.streamId);
92 assertEquals(0, pingFrame.streamId);
121 assertEquals(0, ackFrame.streamId);
125 assertEquals(0, ackFrame.streamId);
222 assertEquals(3, data1.streamId);
265 windowUpdateStreamIds.add(windowUpdate.streamId);
426 assertEquals(2, rstStream.streamId);
445 assertEquals(0, ackFrame.streamId);
465 @Override public boolean onRequest(int streamId, List<Header> requestHeaders) {
469 @Override public boolean onHeaders(int streamId, Lis
493 onRequest(int streamId, List<Header> requestHeaders) argument
500 onHeaders( int streamId, List<Header> responseHeaders, boolean last) argument
509 onData( int streamId, BufferedSource source, int byteCount, boolean last) argument
516 onReset(int streamId, ErrorCode errorCode) argument
[all...]
H A DHttp2Test.java71 public void headers(boolean outFinished, boolean inFinished, int streamId,
75 assertEquals(expectedStreamId, streamId);
96 @Override public void priority(int streamId, int streamDependency, int weight,
103 @Override public void headers(boolean outFinished, boolean inFinished, int streamId,
108 assertEquals(expectedStreamId, streamId);
140 @Override public void headers(boolean outFinished, boolean inFinished, int streamId,
144 assertEquals(expectedStreamId, streamId);
175 public void pushPromise(int streamId, int promisedStreamId, List<Header> headerBlock) {
176 assertEquals(expectedStreamId, streamId);
211 public void pushPromise(int streamId, in
661 sendPushPromiseFrames(int streamId, List<Header> headers) argument
[all...]
H A DSpdy3ConnectionTest.java90 assertEquals(1, synStream.streamId);
166 assertEquals(2, reply.streamId);
208 assertEquals(0, ping.streamId);
346 assertEquals(41, rstStream.streamId);
366 assertEquals(41, rstStream.streamId);
600 assertEquals(1, rstStream.streamId);
630 assertEquals(2, rstStream.streamId);
760 assertEquals(1, data1.streamId);
788 assertEquals(0, goaway.streamId);
855 assertEquals(1, rstStream.streamId);
[all...]
/external/mesa3d/src/gallium/drivers/svga/include/
H A Dsvga_overlay.h68 uint32 streamId; member in struct:SVGAEscapeVideoSetRegs::__anon12337
81 uint32 streamId; member in struct:SVGAEscapeVideoFlush
/external/skia/experimental/PdfViewer/
H A DSkPdfConfig.h65 #define STORE_TRACK_PARAMETERS(obj) (obj)->fStreamId = streamId;\
/external/libvncserver/x11vnc/misc/turbovnc/
H A Dtight.c140 static Bool CompressData(rfbClientPtr cl, int streamId, int dataLen,
705 int streamId = 1; local
721 updateBuf[ublen++] = (streamId | rfbTightExplicitFilter) << 4;
763 return CompressData(cl, streamId, dataLen,
773 int streamId = 2; local
786 updateBuf[ublen++] = (streamId | rfbTightExplicitFilter) << 4;
828 return CompressData(cl, streamId, w * h,
838 int streamId = 0; local
858 return CompressData(cl, streamId, w * h * len,
864 CompressData(cl, streamId, dataLe
[all...]
/external/libvncserver/libvncserver/
H A Dtight.c197 static rfbBool CompressData (rfbClientPtr cl, int streamId, int dataLen,
834 int streamId = 1; local
860 cl->updateBuf[cl->ublen++] = (streamId | rfbTightExplicitFilter) << 4;
902 return CompressData(cl, streamId, dataLen,
914 int streamId = 2; local
936 cl->updateBuf[cl->ublen++] = (streamId | rfbTightExplicitFilter) << 4;
981 return CompressData(cl, streamId, w * h,
993 int streamId = 0; local
1020 return CompressData(cl, streamId, w * h * len,
1027 int streamId,
1026 CompressData(rfbClientPtr cl, int streamId, int dataLen, int zlibLevel, int zlibStrategy) argument
[all...]
/external/tcpdump/
H A DsctpHeader.h298 u_int16_t streamId; member in struct:sctpDataPart
H A Dprint-sctp.c226 printf("[SID: %u] ", EXTRACT_16BITS(&dataHdrPtr->streamId));
/external/libvncserver/webclients/novnc/include/
H A Drfb.js1304 var filterId = -1, resetStreams = 0, streamId = -1;
1326 var uncompressed = FBU.zlibs[streamId].uncompress(data, 0);
1452 streamId = ctl & 0x3;
/external/skia/experimental/PdfViewer/pdfparser/native/
H A DSkPdfNativeObject.h128 int streamId() const { return fStreamId; } function in class:SkPdfNativeObject

Completed in 357 milliseconds