| /external/chromium/net/spdy/ |
| D | spdy_stream.cc | 38 SpdyStream::SpdyStream(SpdySession* session, in SpdyStream() function in net::SpdyStream
63 SpdyStream::~SpdyStream() { in ~SpdyStream()
67 void SpdyStream::SetDelegate(Delegate* delegate) { in SetDelegate()
75 &SpdyStream::PushedStreamReplayData)); in SetDelegate()
81 void SpdyStream::PushedStreamReplayData() { in PushedStreamReplayData()
114 void SpdyStream::DetachDelegate() { in DetachDelegate()
122 const linked_ptr<spdy::SpdyHeaderBlock>& SpdyStream::spdy_headers() const { in spdy_headers()
126 void SpdyStream::set_spdy_headers( in set_spdy_headers()
131 void SpdyStream::IncreaseSendWindowSize(int delta_window_size) { in IncreaseSendWindowSize()
167 void SpdyStream::DecreaseSendWindowSize(int delta_window_size) { in DecreaseSendWindowSize()
[all …]
|
| D | spdy_session.h | 44 class SpdyStream; variable
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, in PendingCreateStream()
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 …]
|
| D | spdy_io_buffer.h | 14 class SpdyStream; variable
28 SpdyIOBuffer(IOBuffer* buffer, int size, int priority, SpdyStream* stream);
37 const scoped_refptr<SpdyStream>& stream() const { return stream_; } in stream()
50 scoped_refptr<SpdyStream> stream_;
|
| D | spdy_stream.h | 39 class SpdyStream
40 : public base::RefCounted<SpdyStream>,
93 SpdyStream(SpdySession* session,
249 friend class base::RefCounted<SpdyStream>;
250 virtual ~SpdyStream();
293 SpdyStream::Delegate* delegate_;
324 DISALLOW_COPY_AND_ASSIGN(SpdyStream);
|
| D | spdy_session.cc | 354 scoped_refptr<SpdyStream>* stream, in GetPushStream()
382 scoped_refptr<SpdyStream>* spdy_stream, in CreateStream()
411 scoped_refptr<SpdyStream>* stream = pending_create.spdy_stream; in ProcessPendingCreateStreams()
428 const scoped_refptr<SpdyStream>* spdy_stream) { in CancelPendingCreateStreams()
455 scoped_refptr<SpdyStream>* spdy_stream, in CreateStreamImpl()
471 *spdy_stream = new SpdyStream(this, in CreateStreamImpl()
475 const scoped_refptr<SpdyStream>& stream = *spdy_stream; in CreateStreamImpl()
501 const scoped_refptr<SpdyStream>& stream = active_streams_[stream_id]; in WriteSynStream()
538 scoped_refptr<SpdyStream> stream = active_streams_[stream_id]; in WriteStreamData()
607 scoped_refptr<SpdyStream> stream = active_streams_[stream_id]; in ResetStream()
[all …]
|
| D | spdy_http_stream.h | 32 class SpdyHttpStream : public SpdyStream::Delegate, public HttpStream {
38 void InitializeWithExistingStream(SpdyStream* spdy_stream);
40 SpdyStream* stream() { return stream_.get(); } in stream()
97 scoped_refptr<SpdyStream> stream_;
|
| D | spdy_proxy_client_socket.h | 37 class SpdyStream; variable
40 public SpdyStream::Delegate {
46 SpdyProxyClientSocket(SpdyStream* spdy_stream,
135 scoped_refptr<SpdyStream> spdy_stream_;
|
| D | spdy_stream_unittest.cc | 32 class TestSpdyStreamDelegate : public SpdyStream::Delegate {
34 TestSpdyStreamDelegate(SpdyStream* stream, in TestSpdyStreamDelegate()
94 SpdyStream* stream_;
213 scoped_refptr<SpdyStream> stream; in TEST_F()
259 scoped_refptr<SpdyStream> stream = new SpdyStream(spdy_session, in TEST_F()
|
| D | spdy_session_unittest.cc | 29 class TestSpdyStreamDelegate : public net::SpdyStream::Delegate {
226 scoped_refptr<SpdyStream> spdy_stream1; in TEST_F()
266 SpdyStream* first_stream) in StreamReleaserCallback()
282 scoped_refptr<SpdyStream>* stream() { return &stream_; } in stream()
286 scoped_refptr<SpdyStream> first_stream_;
287 scoped_refptr<SpdyStream> stream_;
360 scoped_refptr<SpdyStream> spdy_stream1; in TEST_F()
450 scoped_refptr<SpdyStream> spdy_stream1; in TEST_F()
459 scoped_refptr<SpdyStream> spdy_stream2; in TEST_F()
|
| D | spdy_io_buffer.cc | 14 IOBuffer* buffer, int size, int priority, SpdyStream* stream) in SpdyIOBuffer()
|
| D | spdy_proxy_client_socket.cc | 25 SpdyStream* spdy_stream, in SpdyProxyClientSocket()
394 SpdyStream* stream = spdy_stream_; in DoReadReplyComplete()
|
| D | spdy_http_stream.cc | 40 void SpdyHttpStream::InitializeWithExistingStream(SpdyStream* spdy_stream) { in InitializeWithExistingStream()
|
| D | spdy_proxy_client_socket_unittest.cc | 113 scoped_refptr<SpdyStream> spdy_stream_;
|
| /external/okhttp/src/main/java/libcore/net/spdy/ |
| D | SpdyConnection.java | 70 private final Map<Integer, SpdyStream> streams = Collections.synchronizedMap(
71 new HashMap<Integer, SpdyStream>());
93 private SpdyStream getStream(int id) { in getStream()
94 SpdyStream stream = streams.get(id); in getStream()
113 public synchronized SpdyStream newStream(List<String> requestHeaders, boolean out, boolean in) in newStream()
121 SpdyStream result = new SpdyStream(streamId, this, requestHeaders, flags); in newStream()
240 final SpdyStream stream = new SpdyStream(spdyReader.streamId, SpdyConnection.this, in readFrame()
242 SpdyStream previous = streams.put(spdyReader.streamId, stream); in readFrame()
244 previous.close(SpdyStream.RST_PROTOCOL_ERROR); in readFrame()
|
| D | IncomingStreamHandler.java | 26 @Override public void receive(SpdyStream stream) throws IOException {
27 stream.close(SpdyStream.RST_REFUSED_STREAM);
37 void receive(SpdyStream stream) throws IOException; in receive()
|
| D | SpdyStream.java | 32 public final class SpdyStream { class
80 SpdyStream(int id, SpdyConnection connection, List<String> requestHeaders, int flags) { in SpdyStream() method in SpdyStream
228 synchronized (SpdyStream.this) { in available()
245 synchronized (SpdyStream.this) { in read()
251 SpdyStream.this.wait(); in read()
324 SpdyStream.this.notifyAll(); in receive()
400 synchronized (SpdyStream.this) { in checkNotClosed()
|
| D | SpdyServer.java | 50 @Override public void receive(final SpdyStream stream) throws IOException { in receive()
75 private void send404(SpdyStream stream, String path) throws IOException { in send404()
87 private void serveFile(SpdyStream stream, File file) throws IOException { in serveFile()
|
| /external/okhttp/src/main/java/libcore/net/http/ |
| D | SpdyTransport.java | 26 import libcore.net.spdy.SpdyStream;
31 private SpdyStream stream;
|
| /external/okhttp/src/test/java/libcore/net/spdy/ |
| D | SpdyConnectionTest.java | 46 SpdyStream stream = connection.newStream(Arrays.asList("b", "banana"), true, true); in testClientCreatesStreamAndServerReplies()
79 @Override public void receive(SpdyStream stream) throws IOException { in testServerCreatesStreamAndClientReplies()
|
| /external/chromium/net/http/ |
| D | http_proxy_client_socket_pool.h | 31 class SpdyStream; variable
168 scoped_refptr<SpdyStream> spdy_stream_;
|