/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
H A D | PushObserver.java | 45 * @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 D | SpdyConnection.java | 192 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 D | FrameReader.java | 31 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 D | FrameWriter.java | 37 * {@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 D | Http2.java | 136 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 D | Spdy3.java | 185 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 D | BaseTestHandler.java | 26 @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 D | MockSpdyPeer.java | 214 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 D | Http2ConnectionTest.java | 70 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 D | Http2Test.java | 71 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 D | Spdy3ConnectionTest.java | 90 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 D | svga_overlay.h | 68 uint32 streamId; member in struct:SVGAEscapeVideoSetRegs::__anon12337 81 uint32 streamId; member in struct:SVGAEscapeVideoFlush
|
/external/skia/experimental/PdfViewer/ |
H A D | SkPdfConfig.h | 65 #define STORE_TRACK_PARAMETERS(obj) (obj)->fStreamId = streamId;\
|
/external/libvncserver/x11vnc/misc/turbovnc/ |
H A D | tight.c | 140 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 D | tight.c | 197 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 D | sctpHeader.h | 298 u_int16_t streamId; member in struct:sctpDataPart
|
H A D | print-sctp.c | 226 printf("[SID: %u] ", EXTRACT_16BITS(&dataHdrPtr->streamId));
|
/external/libvncserver/webclients/novnc/include/ |
H A D | rfb.js | 1304 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 D | SkPdfNativeObject.h | 128 int streamId() const { return fStreamId; } function in class:SkPdfNativeObject
|