| /external/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
| IncomingStreamHandler.java | 24 @Override public void receive(SpdyStream stream) throws IOException {
25 stream.close(SpdyStream.RST_REFUSED_STREAM);
31 * respond by either {@link SpdyStream#reply replying to the stream} or
32 * {@link SpdyStream#close closing it}. This response does not need to be
35 void receive(SpdyStream stream) throws IOException;
|
| SpdyConnection.java | 95 private final Map<Integer, SpdyStream> streams = new HashMap<Integer, SpdyStream>();
123 * Returns the number of {@link SpdyStream#isOpen() open streams} on this
130 private synchronized SpdyStream getStream(int id) {
134 synchronized SpdyStream removeStream(int streamId) {
135 SpdyStream stream = streams.remove(streamId);
164 public SpdyStream newStream(List<String> requestHeaders, boolean out, boolean in)
170 SpdyStream stream;
180 stream = new SpdyStream(streamId, this, flags, priority, slot, requestHeaders, settings);
319 close(GOAWAY_OK, SpdyStream.RST_CANCEL)
[all...] |
| SpdyStream.java | 33 public final class SpdyStream {
98 SpdyStream(int id, SpdyConnection connection, int flags, int priority, int slot,
194 assert (!Thread.holdsLock(SpdyStream.this));
287 assert (!Thread.holdsLock(SpdyStream.this));
300 closeLater(SpdyStream.RST_STREAM_IN_USE);
307 assert (!Thread.holdsLock(SpdyStream.this));
320 closeLater(SpdyStream.RST_PROTOCOL_ERROR);
325 assert (!Thread.holdsLock(SpdyStream.this));
330 assert (!Thread.holdsLock(SpdyStream.this));
423 synchronized (SpdyStream.this)
[all...] |
| /external/chromium/net/spdy/ |
| spdy_io_buffer.h | 14 class SpdyStream;
18 // to track the SpdyStream which they are associated with so that incremental
28 SpdyIOBuffer(IOBuffer* buffer, int size, int priority, SpdyStream* stream);
37 const scoped_refptr<SpdyStream>& stream() const { return stream_; }
50 scoped_refptr<SpdyStream> stream_;
|
| spdy_stream.cc | 38 SpdyStream::SpdyStream(SpdySession* session,
63 SpdyStream::~SpdyStream() {
67 void SpdyStream::SetDelegate(Delegate* delegate) {
75 &SpdyStream::PushedStreamReplayData));
81 void SpdyStream::PushedStreamReplayData() {
114 void SpdyStream::DetachDelegate() {
122 const linked_ptr<spdy::SpdyHeaderBlock>& SpdyStream::spdy_headers() const {
126 void SpdyStream::set_spdy_headers
[all...] |
| spdy_io_buffer.cc | 14 IOBuffer* buffer, int size, int priority, SpdyStream* stream)
|
| spdy_session.h | 44 class SpdyStream;
76 scoped_refptr<SpdyStream>* spdy_stream,
84 scoped_refptr<SpdyStream>* spdy_stream,
89 void CancelPendingCreateStreams(const scoped_refptr<SpdyStream>* spdy_stream);
226 scoped_refptr<SpdyStream>* spdy_stream,
234 scoped_refptr<SpdyStream>* spdy_stream;
240 typedef std::map<int, scoped_refptr<SpdyStream> > ActiveStreamMap;
242 typedef std::map<std::string, scoped_refptr<SpdyStream> > PushedStreamMap;
254 typedef std::map<const scoped_refptr<SpdyStream>*, CallbackResultPair>
272 scoped_refptr<SpdyStream>* spdy_stream
[all...] |
| spdy_stream.h | 32 // The SpdyStream is used by the SpdySession to represent each stream known
39 class SpdyStream
40 : public base::RefCounted<SpdyStream>,
78 // Called when SpdyStream is closed.
92 // SpdyStream constructor
93 SpdyStream(SpdySession* session,
249 friend class base::RefCounted<SpdyStream>;
250 virtual ~SpdyStream();
293 SpdyStream::Delegate* delegate_;
324 DISALLOW_COPY_AND_ASSIGN(SpdyStream);
[all...] |
| spdy_http_stream.h | 32 class SpdyHttpStream : public SpdyStream::Delegate, public HttpStream {
37 // Initializes this SpdyHttpStream by wraping an existing SpdyStream.
38 void InitializeWithExistingStream(SpdyStream* spdy_stream);
40 SpdyStream* stream() { return stream_.get(); }
72 // SpdyStream::Delegate methods:
97 scoped_refptr<SpdyStream> stream_;
|
| spdy_proxy_client_socket.h | 37 class SpdyStream;
40 public SpdyStream::Delegate {
46 SpdyProxyClientSocket(SpdyStream* spdy_stream,
94 // SpdyStream::Delegate methods:
135 scoped_refptr<SpdyStream> spdy_stream_;
|
| spdy_stream_unittest.cc | 32 class TestSpdyStreamDelegate : public SpdyStream::Delegate {
34 TestSpdyStreamDelegate(SpdyStream* stream,
94 SpdyStream* stream_;
213 scoped_refptr<SpdyStream> stream;
259 scoped_refptr<SpdyStream> stream = new SpdyStream(spdy_session,
|
| spdy_session.cc | 354 scoped_refptr<SpdyStream>* stream,
382 scoped_refptr<SpdyStream>* spdy_stream,
411 scoped_refptr<SpdyStream>* stream = pending_create.spdy_stream;
428 const scoped_refptr<SpdyStream>* spdy_stream) {
455 scoped_refptr<SpdyStream>* spdy_stream,
471 *spdy_stream = new SpdyStream(this,
475 const scoped_refptr<SpdyStream>& stream = *spdy_stream;
501 const scoped_refptr<SpdyStream>& stream = active_streams_[stream_id];
538 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
607 scoped_refptr<SpdyStream> stream = active_streams_[stream_id]
[all...] |
| spdy_session_unittest.cc | 29 class TestSpdyStreamDelegate : public net::SpdyStream::Delegate {
226 scoped_refptr<SpdyStream> spdy_stream1;
266 SpdyStream* first_stream)
282 scoped_refptr<SpdyStream>* stream() { return &stream_; }
286 scoped_refptr<SpdyStream> first_stream_;
287 scoped_refptr<SpdyStream> stream_;
360 scoped_refptr<SpdyStream> spdy_stream1;
450 scoped_refptr<SpdyStream> spdy_stream1;
459 scoped_refptr<SpdyStream> spdy_stream2;
|
| spdy_proxy_client_socket.cc | 25 SpdyStream* spdy_stream,
390 // Immediately hand off our SpdyStream to a newly created SpdyHttpStream
394 SpdyStream* stream = spdy_stream_;
403 // SpdyStream::Delegate methods:
|
| spdy_http_stream.cc | 40 void SpdyHttpStream::InitializeWithExistingStream(SpdyStream* spdy_stream) {
348 // SpdyStream won't call us with data if the header block didn't contain a
353 // Note that data may be received for a SpdyStream prior to the user calling
|
| spdy_proxy_client_socket_unittest.cc | 113 scoped_refptr<SpdyStream> spdy_stream_;
[all...] |
| /external/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| SpdyTransport.java | 20 import com.squareup.okhttp.internal.spdy.SpdyStream;
31 private SpdyStream stream;
85 stream.closeLater(SpdyStream.RST_CANCEL);
|
| /external/okhttp/src/test/java/com/squareup/okhttp/internal/spdy/ |
| SpdyConnectionTest.java | 45 import static com.squareup.okhttp.internal.spdy.SpdyStream.RST_FLOW_CONTROL_ERROR;
46 import static com.squareup.okhttp.internal.spdy.SpdyStream.RST_INVALID_STREAM;
47 import static com.squareup.okhttp.internal.spdy.SpdyStream.RST_PROTOCOL_ERROR;
48 import static com.squareup.okhttp.internal.spdy.SpdyStream.RST_REFUSED_STREAM;
49 import static com.squareup.okhttp.internal.spdy.SpdyStream.RST_STREAM_IN_USE;
50 import static com.squareup.okhttp.internal.spdy.SpdyStream.WINDOW_UPDATE_THRESHOLD;
57 @Override public void receive(SpdyStream stream) throws IOException {
77 SpdyStream stream = connection.newStream(Arrays.asList("b", "banana"), true, true);
100 SpdyStream stream = connection.newStream(Arrays.asList("a", "android"), false, false);
137 @Override public void receive(SpdyStream stream) throws IOException
[all...] |
| SpdyServer.java | 82 @Override public void receive(final SpdyStream stream) throws IOException {
109 private void send404(SpdyStream stream, String path) throws IOException {
119 private void serveDirectory(SpdyStream stream, String[] files) throws IOException {
132 private void serveFile(SpdyStream stream, File file) throws IOException {
|
| /external/okhttp/src/test/java/com/squareup/okhttp/internal/mockspdyserver/ |
| MockSpdyServer.java | 26 import com.squareup.okhttp.internal.spdy.SpdyStream;
190 @Override public void receive(final SpdyStream stream) throws IOException {
203 private RecordedRequest readRequest(SpdyStream stream) throws IOException {
237 private void writeResponse(SpdyStream stream, MockResponse response) throws IOException {
|
| /external/chromium/net/http/ |
| http_proxy_client_socket_pool.h | 31 class SpdyStream;
168 scoped_refptr<SpdyStream> spdy_stream_;
|
