/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_;
|