Home
last modified time | relevance | path

Searched refs:outFinished (Results 1 – 10 of 10) sorted by relevance

/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/
DSpdyStream.java76 SpdyStream(int id, SpdyConnection connection, boolean outFinished, boolean inFinished, in SpdyStream() argument
88 this.sink.finished = outFinished; in SpdyStream()
165 boolean outFinished = false; in reply()
176 outFinished = true; in reply()
179 connection.writeSynReply(id, outFinished, responseHeaders); in reply()
181 if (outFinished) { in reply()
499 private void emitDataFrame(boolean outFinished) throws IOException { in emitDataFrame() argument
518 connection.writeData(id, outFinished && toWrite == sendBuffer.size(), sendBuffer, toWrite); in emitDataFrame()
DFrameWriter.java51 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
69 void data(boolean outFinished, int streamId, Buffer source, int byteCount) throws IOException; in data() argument
DSpdy3.java201 boolean outFinished = (flags & FLAG_UNIDIRECTIONAL) != 0; in readSynStream()
202 handler.headers(outFinished, inFinished, streamId, associatedStreamId, headerBlock, in readSynStream()
323 @Override public synchronized void synStream(boolean outFinished, boolean inFinished, in synStream() argument
330 int flags = (outFinished ? FLAG_FIN : 0) | (inFinished ? FLAG_UNIDIRECTIONAL : 0); in synStream()
342 @Override public synchronized void synReply(boolean outFinished, int streamId, in synReply() argument
347 int flags = (outFinished ? FLAG_FIN : 0); in synReply()
389 @Override public synchronized void data(boolean outFinished, int streamId, Buffer source, in data() argument
391 int flags = (outFinished ? FLAG_FIN : 0); in data()
DSpdyConnection.java248 boolean outFinished = !out; in newStream()
260 stream = new SpdyStream(streamId, this, outFinished, inFinished, requestHeaders); in newStream()
267 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, in newStream()
283 void writeSynReply(int streamId, boolean outFinished, List<Header> alternating) in writeSynReply() argument
285 frameWriter.synReply(outFinished, streamId, alternating); in writeSynReply()
300 public void writeData(int streamId, boolean outFinished, Buffer buffer, long byteCount) in writeData() argument
303 frameWriter.data(outFinished, streamId, buffer, 0); in writeData()
329 frameWriter.data(outFinished && byteCount == 0, streamId, buffer, toWrite); in writeData()
611 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers() argument
638 final SpdyStream newStream = new SpdyStream(streamId, SpdyConnection.this, outFinished, in headers()
DHttp2.java405 @Override public synchronized void synStream(boolean outFinished, boolean inFinished, in synStream() argument
410 headers(outFinished, streamId, headerBlock); in synStream()
413 @Override public synchronized void synReply(boolean outFinished, int streamId, in synReply() argument
416 headers(outFinished, streamId, headerBlock); in synReply()
442 void headers(boolean outFinished, int streamId, List<Header> headerBlock) throws IOException { in headers() argument
451 if (outFinished) flags |= FLAG_END_STREAM; in headers()
484 @Override public synchronized void data(boolean outFinished, int streamId, Buffer source, in data() argument
488 if (outFinished) flags |= FLAG_END_STREAM; in data()
DFrameReader.java45 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/
DHttp2Test.java71 public void headers(boolean outFinished, boolean inFinished, int streamId, in onlyOneLiteralHeadersFrame()
73 assertFalse(outFinished); in onlyOneLiteralHeadersFrame()
103 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headersWithPriority()
106 assertFalse(outFinished); in headersWithPriority()
140 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headersFrameThenContinuation()
142 assertFalse(outFinished); in headersFrameThenContinuation()
655 private Buffer sendHeaderFrames(boolean outFinished, List<Header> headers) throws IOException { in sendHeaderFrames() argument
657 new Http2.Writer(out, true).headers(outFinished, expectedStreamId, headers); in sendHeaderFrames()
695 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in assertHeaderBlock()
697 assertFalse(outFinished); in assertHeaderBlock()
DMockSpdyPeer.java212 public boolean outFinished; field in MockSpdyPeer.InFrame
244 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers() argument
248 this.outFinished = outFinished; in headers()
DBaseTestHandler.java32 public void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
DSpdy3ConnectionTest.java89 assertFalse(synStream.outFinished); in clientCreatesStreamAndServerReplies()
404 assertTrue(synStream.outFinished);
450 assertFalse(synStream.outFinished);
492 assertFalse(synStream.outFinished);
532 assertFalse(synStream.outFinished);
539 assertFalse(fin.outFinished);
567 assertFalse(synStream.outFinished);