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.java221 public boolean inFinished; field in MockSpdyPeer.InFrame
252 @Override public void headers(boolean outFinished, boolean inFinished, int streamId, in headers() argument
257 this.inFinished = inFinished; in headers()
264 @Override public void data(boolean inFinished, int streamId, BufferedSource source, int length) in data() argument
268 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.java90 assertFalse(synStream.inFinished); in clientCreatesStreamAndServerReplies()
170 assertFalse(reply.inFinished); in serverCreatesStreamAndClientReplies()
196 assertTrue(reply.inFinished); in replyWithNoData()
420 assertFalse(synStream.inFinished);
424 assertFalse(data.inFinished);
428 assertTrue(fin.inFinished);
466 assertFalse(synStream.inFinished);
508 assertTrue(synStream.inFinished);
548 assertFalse(synStream.inFinished);
555 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.java111 public void synStream(final boolean outFinished, final boolean inFinished, final int streamId, in synStream() argument
116 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId, headerBlock); in synStream()
DOkHttpClientTransport.java1001 public void data(boolean inFinished, int streamId, BufferedSource in, int length) in data() argument
1019 stream.transportState().transportDataReceived(buf, inFinished); in data()
1036 boolean inFinished, in headers() argument
1051 stream.transportState().transportHeadersReceived(headerBlock, inFinished); in headers()