| /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 | 93 private final Map<Integer, SpdyStream> streams = new HashMap<Integer, SpdyStream>();
121 * Returns the number of {@link SpdyStream#isOpen() open streams} on this
128 private synchronized SpdyStream getStream(int id) {
132 synchronized SpdyStream removeStream(int streamId) {
133 SpdyStream stream = streams.remove(streamId);
162 public SpdyStream newStream(List<String> requestHeaders, boolean out, boolean in)
168 SpdyStream stream;
178 stream = new SpdyStream(streamId, this, flags, priority, slot, requestHeaders, settings);
315 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_org/net/spdy/ |
| spdy_write_queue.h | 21 class SpdyStream;
42 const base::WeakPtr<SpdyStream>& stream);
50 base::WeakPtr<SpdyStream>* stream);
54 void RemovePendingWritesForStream(const base::WeakPtr<SpdyStream>& stream);
70 base::WeakPtr<SpdyStream> stream;
77 const base::WeakPtr<SpdyStream>& stream);
|
| spdy_stream_test_util.h | 23 class ClosingDelegate : public SpdyStream::Delegate {
25 explicit ClosingDelegate(const base::WeakPtr<SpdyStream>& stream);
28 // SpdyStream::Delegate implementation.
40 base::WeakPtr<SpdyStream> stream_;
45 class StreamDelegateBase : public SpdyStream::Delegate {
47 explicit StreamDelegateBase(const base::WeakPtr<SpdyStream>& stream);
76 const base::WeakPtr<SpdyStream>& stream() { return stream_; }
79 base::WeakPtr<SpdyStream> stream_;
91 StreamDelegateDoNothing(const base::WeakPtr<SpdyStream>& stream);
99 StreamDelegateSendImmediate(const base::WeakPtr<SpdyStream>& stream
[all...] |
| spdy_write_queue_unittest.cc | 62 // Makes a SpdyStream with the given priority and a NULL SpdySession
65 SpdyStream* MakeTestStream(RequestPriority priority) {
66 return new SpdyStream(
80 scoped_ptr<SpdyStream> stream_medium(MakeTestStream(MEDIUM));
81 scoped_ptr<SpdyStream> stream_highest(MakeTestStream(HIGHEST));
85 LOW, SYN_STREAM, producer_low.Pass(), base::WeakPtr<SpdyStream>());
94 base::WeakPtr<SpdyStream> stream;
122 scoped_ptr<SpdyStream> stream1(MakeTestStream(DEFAULT_PRIORITY));
123 scoped_ptr<SpdyStream> stream2(MakeTestStream(DEFAULT_PRIORITY));
124 scoped_ptr<SpdyStream> stream3(MakeTestStream(DEFAULT_PRIORITY))
[all...] |
| spdy_stream.cc | 57 class SpdyStream::SynStreamBufferProducer : public SpdyBufferProducer {
59 SynStreamBufferProducer(const base::WeakPtr<SpdyStream>& stream)
77 const base::WeakPtr<SpdyStream> stream_;
80 SpdyStream::SpdyStream(SpdyStreamType type,
121 SpdyStream::~SpdyStream() {
126 void SpdyStream::SetDelegate(Delegate* delegate) {
135 base::Bind(&SpdyStream::PushedStreamReplayData, GetWeakPtr()));
139 void SpdyStream::PushedStreamReplayData()
[all...] |
| spdy_stream_test_util.cc | 19 const base::WeakPtr<SpdyStream>& stream) : stream_(stream) {
43 const base::WeakPtr<SpdyStream>& stream)
104 const base::WeakPtr<SpdyStream>& stream)
111 const base::WeakPtr<SpdyStream>& stream,
131 const base::WeakPtr<SpdyStream>& stream,
|
| spdy_proxy_client_socket.h | 37 class SpdyStream;
40 public SpdyStream::Delegate {
46 SpdyProxyClientSocket(const base::WeakPtr<SpdyStream>& spdy_stream,
94 // SpdyStream::Delegate implementation.
132 base::WeakPtr<SpdyStream> spdy_stream_;
|
| spdy_session.h | 66 class SpdyStream;
152 base::WeakPtr<SpdyStream> ReleaseStream();
159 void OnRequestCompleteSuccess(const base::WeakPtr<SpdyStream>& stream);
177 base::WeakPtr<SpdyStream> stream_;
240 base::WeakPtr<SpdyStream>* spdy_stream,
281 void EnqueueStreamWrite(const base::WeakPtr<SpdyStream>& stream,
308 void CloseCreatedStream(const base::WeakPtr<SpdyStream>& stream, int status);
488 explicit ActiveStreamInfo(SpdyStream* stream);
491 SpdyStream* stream;
506 typedef std::set<SpdyStream*> CreatedStreamSet
[all...] |
| spdy_websocket_stream.h | 27 : public SpdyStream::Delegate {
54 // Called when SpdyStream is closed.
77 // SpdyStream::Delegate
93 base::WeakPtr<SpdyStream> stream_;
|
| spdy_stream.h | 52 // Passed to some SpdyStream functions to indicate whether there's
59 // Returned by SpdyStream::OnResponseHeadersUpdated() to indicate
66 // The SpdyStream is used by the SpdySession to represent each stream known
73 class NET_EXPORT_PRIVATE SpdyStream {
142 // Called when SpdyStream is closed. No other delegate functions
158 // SpdyStream constructor
159 SpdyStream(SpdyStreamType type,
167 ~SpdyStream();
337 base::WeakPtr<SpdyStream> GetWeakPtr();
468 base::WeakPtrFactory<SpdyStream> weak_ptr_factory_
[all...] |
| spdy_http_stream.h | 30 class NET_EXPORT_PRIVATE SpdyHttpStream : public SpdyStream::Delegate,
37 SpdyStream* stream() { return stream_.get(); }
79 // SpdyStream::Delegate implementation.
117 base::WeakPtr<SpdyStream> stream_;
138 // We don't use SpdyStream's |response_header_status_| as we
|
| spdy_write_queue.cc | 21 const base::WeakPtr<SpdyStream>& stream)
46 const base::WeakPtr<SpdyStream>& stream) {
57 base::WeakPtr<SpdyStream>* stream) {
74 const base::WeakPtr<SpdyStream>& stream) {
|
| /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,
|
| /external/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
| SpdyTransport.java | 20 import com.squareup.okhttp.internal.spdy.SpdyStream;
31 private SpdyStream stream;
87 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 {
|
