Home
last modified time | relevance | path

Searched refs:inFinished (Results 1 – 21 of 21) sorted by relevance

/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DFramedConnection.java255 boolean inFinished = !in; in newStream()
266 stream = new FramedStream(streamId, this, outFinished, inFinished, requestHeaders); in newStream()
273 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, in newStream()
622 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
625 pushDataLater(streamId, source, length, inFinished); in data()
635 if (inFinished) { in data()
640 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers() argument
643 pushHeadersLater(streamId, headerBlock, inFinished); in headers()
669 inFinished, headerBlock); in headers()
698 if (inFinished) stream.receiveFin(); in headers()
[all …]
DSpdy3.java186 boolean inFinished = (flags & FLAG_FIN) != 0; in nextFrame()
187 handler.data(inFinished, streamId, source, length); in nextFrame()
200 boolean inFinished = (flags & FLAG_FIN) != 0; in readSynStream()
202 handler.headers(outFinished, inFinished, streamId, associatedStreamId, headerBlock, in readSynStream()
210 boolean inFinished = (flags & FLAG_FIN) != 0; in readSynReply()
211 handler.headers(false, inFinished, streamId, -1, headerBlock, HeadersMode.SPDY_REPLY); in readSynReply()
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()
DFrameReader.java31 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
45 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
DFrameWriter.java51 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream() argument
DHttp2.java219 boolean inFinished = (flags & FLAG_END_STREAM) != 0; in readData()
228 handler.data(inFinished, streamId, source, length); in readData()
405 @Override public synchronized void synStream(boolean outFinished, boolean inFinished, in synStream() argument
408 if (inFinished) throw new UnsupportedOperationException(); in synStream()
DFramedStream.java76 FramedStream(int id, FramedConnection connection, boolean outFinished, boolean inFinished, in FramedStream() argument
87 this.source.finished = inFinished; in FramedStream()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DFramedConnection.java257 boolean inFinished = !in; in newStream()
268 stream = new FramedStream(streamId, this, outFinished, inFinished, requestHeaders); in newStream()
275 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, in newStream()
627 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
630 pushDataLater(streamId, source, length, inFinished); in data()
640 if (inFinished) { in data()
645 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers() argument
648 pushHeadersLater(streamId, headerBlock, inFinished); in headers()
674 inFinished, headerBlock); in headers()
703 if (inFinished) stream.receiveFin(); in headers()
[all …]
DSpdy3.java188 boolean inFinished = (flags & FLAG_FIN) != 0; in nextFrame()
189 handler.data(inFinished, streamId, source, length); in nextFrame()
202 boolean inFinished = (flags & FLAG_FIN) != 0; in readSynStream()
204 handler.headers(outFinished, inFinished, streamId, associatedStreamId, headerBlock, in readSynStream()
212 boolean inFinished = (flags & FLAG_FIN) != 0; in readSynReply()
213 handler.headers(false, inFinished, streamId, -1, headerBlock, HeadersMode.SPDY_REPLY); in readSynReply()
325 @Override public synchronized void synStream(boolean outFinished, boolean inFinished, in synStream() argument
332 int flags = (outFinished ? FLAG_FIN : 0) | (inFinished ? FLAG_UNIDIRECTIONAL : 0); in synStream()
DFrameReader.java33 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
47 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
DFrameWriter.java53 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream() argument
DHttp2.java221 boolean inFinished = (flags & FLAG_END_STREAM) != 0; in readData()
230 handler.data(inFinished, streamId, source, length); in readData()
407 @Override public synchronized void synStream(boolean outFinished, boolean inFinished, in synStream() argument
410 if (inFinished) throw new UnsupportedOperationException(); in synStream()
DFramedStream.java78 FramedStream(int id, FramedConnection connection, boolean outFinished, boolean inFinished, in FramedStream() argument
89 this.source.finished = inFinished; in FramedStream()
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/
DMockSpdyPeer.java230 public boolean inFinished; field in MockSpdyPeer.InFrame
261 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers() argument
266 this.inFinished = inFinished; in headers()
273 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
277 this.inFinished = inFinished; in data()
DHttp2Test.java71 public void headers(boolean outFinished, boolean inFinished, int streamId, in onlyOneLiteralHeadersFrame()
74 assertTrue(inFinished); in onlyOneLiteralHeadersFrame()
103 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headersWithPriority()
107 assertFalse(inFinished); in headersWithPriority()
140 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headersFrameThenContinuation()
143 assertFalse(inFinished); in headersFrameThenContinuation()
388 @Override public void data(boolean inFinished, int streamId, BufferedSource source, in maxLengthDataFrame()
390 assertFalse(inFinished); in maxLengthDataFrame()
695 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in assertHeaderBlock()
698 assertFalse(inFinished); in assertHeaderBlock()
[all …]
DBaseTestHandler.java26 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
32 public void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
DSpdy3ConnectionTest.java86 assertFalse(synStream.inFinished); in clientCreatesStreamAndServerReplies()
173 assertFalse(reply.inFinished); in serverCreatesStreamAndClientReplies()
201 assertTrue(reply.inFinished); in replyWithNoData()
443 assertFalse(synStream.inFinished);
447 assertFalse(data.inFinished);
451 assertTrue(fin.inFinished);
491 assertFalse(synStream.inFinished);
535 assertTrue(synStream.inFinished);
577 assertFalse(synStream.inFinished);
584 assertTrue(fin.inFinished);
[all …]
/external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/
DFrameReader.java35 void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
49 void headers(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in headers() argument
DFrameWriter.java55 void synStream(boolean outFinished, boolean inFinished, int streamId, int associatedStreamId, in synStream() argument
DHttp2.java224 boolean inFinished = (flags & FLAG_END_STREAM) != 0; in readData()
233 handler.data(inFinished, streamId, source, length); in readData()
411 @Override public synchronized void synStream(boolean outFinished, boolean inFinished, in synStream() argument
414 if (inFinished) throw new UnsupportedOperationException(); in synStream()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DAsyncFrameWriter.java119 public void synStream(final boolean outFinished, final boolean inFinished, final int streamId, in synStream() argument
124 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, headerBlock); in synStream()
DOkHttpClientTransport.java1002 public void data(boolean inFinished, int streamId, BufferedSource in, int length) in data() argument
1020 stream.transportState().transportDataReceived(buf, inFinished); in data()
1037 boolean inFinished, in headers() argument
1052 stream.transportState().transportHeadersReceived(headerBlock, inFinished); in headers()