| /external/chromium_org/net/spdy/ |
| D | spdy_buffer.cc | 39 class SpdyBuffer::SharedFrameIOBuffer : public IOBuffer {
59 SpdyBuffer::SpdyBuffer(scoped_ptr<SpdyFrame> frame) in SpdyBuffer() function in net::SpdyBuffer
67 SpdyBuffer::SpdyBuffer(const char* data, size_t size) : in SpdyBuffer() function in net::SpdyBuffer
75 SpdyBuffer::~SpdyBuffer() { in ~SpdyBuffer()
80 const char* SpdyBuffer::GetRemainingData() const { in GetRemainingData()
84 size_t SpdyBuffer::GetRemainingSize() const { in GetRemainingSize()
88 void SpdyBuffer::AddConsumeCallback(const ConsumeCallback& consume_callback) { in AddConsumeCallback()
92 void SpdyBuffer::Consume(size_t consume_size) { in Consume()
96 IOBuffer* SpdyBuffer::GetIOBufferForRemainingData() { in GetIOBufferForRemainingData()
100 void SpdyBuffer::ConsumeHelper(size_t consume_size, in ConsumeHelper()
|
| D | spdy_buffer_unittest.cc | 29 std::string BufferToString(const SpdyBuffer& buffer) { in BufferToString()
36 SpdyBuffer buffer( in TEST_F()
49 SpdyBuffer buffer(data.data(), data.size()); in TEST_F()
59 SpdyBuffer::ConsumeSource expected_consume_source, in IncrementBy()
61 SpdyBuffer::ConsumeSource consume_source) { in IncrementBy()
70 SpdyBuffer buffer(kData, kDataSize); in TEST_F()
75 base::Bind(&IncrementBy, &x1, SpdyBuffer::CONSUME)); in TEST_F()
77 base::Bind(&IncrementBy, &x2, SpdyBuffer::CONSUME)); in TEST_F()
98 SpdyBuffer buffer(kData, kDataSize); in TEST_F()
100 base::Bind(&IncrementBy, &x, SpdyBuffer::DISCARD)); in TEST_F()
[all …]
|
| D | spdy_buffer_producer.h | 15 class SpdyBuffer; variable
25 virtual scoped_ptr<SpdyBuffer> ProduceBuffer() = 0;
36 explicit SimpleBufferProducer(scoped_ptr<SpdyBuffer> buffer);
40 virtual scoped_ptr<SpdyBuffer> ProduceBuffer() OVERRIDE;
43 scoped_ptr<SpdyBuffer> buffer_;
|
| D | spdy_buffer.h | 30 class NET_EXPORT_PRIVATE SpdyBuffer {
50 explicit SpdyBuffer(scoped_ptr<SpdyFrame> frame);
54 SpdyBuffer(const char* data, size_t size);
58 ~SpdyBuffer();
99 DISALLOW_COPY_AND_ASSIGN(SpdyBuffer);
|
| D | spdy_read_queue.h | 17 class SpdyBuffer; variable
33 void Enqueue(scoped_ptr<SpdyBuffer> buffer);
43 std::deque<SpdyBuffer*> queue_;
|
| D | spdy_stream.h | 138 virtual void OnDataReceived(scoped_ptr<SpdyBuffer> buffer) = 0;
226 SpdyBuffer::ConsumeSource consume_source);
254 SpdyBuffer::ConsumeSource consume_source);
316 void OnDataReceived(scoped_ptr<SpdyBuffer> buffer);
529 ScopedVector<SpdyBuffer> pending_recv_data_;
|
| D | spdy_write_queue_unittest.cc | 40 scoped_ptr<SpdyBuffer>( in StringToProducer()
41 new SpdyBuffer( in StringToProducer()
57 buffer_.reset(new SpdyBuffer(kOriginal, arraysize(kOriginal))); in RequeingBufferProducer()
62 virtual scoped_ptr<SpdyBuffer> ProduceBuffer() OVERRIDE { in ProduceBuffer()
68 SpdyBuffer::ConsumeSource source) { in ConsumeCallback()
70 new SimpleBufferProducer(scoped_ptr<SpdyBuffer>( in ConsumeCallback()
71 new SpdyBuffer(kRequeued, arraysize(kRequeued))))); in ConsumeCallback()
78 scoped_ptr<SpdyBuffer> buffer_;
84 scoped_ptr<SpdyBuffer> buffer = producer->ProduceBuffer(); in ProducerToString()
|
| D | spdy_buffer_producer.cc | 17 SimpleBufferProducer::SimpleBufferProducer(scoped_ptr<SpdyBuffer> buffer) in SimpleBufferProducer()
22 scoped_ptr<SpdyBuffer> SimpleBufferProducer::ProduceBuffer() { in ProduceBuffer()
|
| D | spdy_read_queue.cc | 28 void SpdyReadQueue::Enqueue(scoped_ptr<SpdyBuffer> buffer) { in Enqueue()
38 SpdyBuffer* buffer = queue_.front(); in Dequeue()
|
| D | spdy_stream.cc | 66 virtual scoped_ptr<SpdyBuffer> ProduceBuffer() OVERRIDE { in ProduceBuffer()
69 return scoped_ptr<SpdyBuffer>(); in ProduceBuffer()
72 return scoped_ptr<SpdyBuffer>( in ProduceBuffer()
73 new SpdyBuffer(stream_->ProduceSynStreamFrame())); in ProduceBuffer()
174 scoped_ptr<SpdyBuffer> buffer(pending_recv_data_.front()); in PushedStreamReplay()
236 SpdyBuffer::ConsumeSource consume_source) { in OnWriteBufferConsumed()
238 if (consume_source == SpdyBuffer::DISCARD) { in OnWriteBufferConsumed()
307 SpdyBuffer::ConsumeSource consume_source) { in OnReadBufferConsumed()
466 void SpdyStream::OnDataReceived(scoped_ptr<SpdyBuffer> buffer) { in OnDataReceived()
807 scoped_ptr<SpdyBuffer> data_buffer( in QueueNextDataFrame()
|
| D | spdy_websocket_stream.h | 52 virtual void OnReceivedSpdyData(scoped_ptr<SpdyBuffer> buffer) = 0;
81 virtual void OnDataReceived(scoped_ptr<SpdyBuffer> buffer) OVERRIDE;
|
| D | spdy_read_queue_unittest.cc | 34 scoped_ptr<SpdyBuffer>(new SpdyBuffer(data.data() + i, buffer_size))); in EnqueueString()
|
| D | spdy_stream_test_util.h | 32 virtual void OnDataReceived(scoped_ptr<SpdyBuffer> buffer) OVERRIDE;
53 virtual void OnDataReceived(scoped_ptr<SpdyBuffer> buffer) OVERRIDE;
|
| D | spdy_stream_test_util.cc | 32 void ClosingDelegate::OnDataReceived(scoped_ptr<SpdyBuffer> buffer) {} in OnDataReceived()
65 void StreamDelegateBase::OnDataReceived(scoped_ptr<SpdyBuffer> buffer) { in OnDataReceived()
|
| D | spdy_write_queue.h | 19 class SpdyBuffer; variable
|
| D | spdy_session.h | 328 scoped_ptr<SpdyBuffer> CreateDataBuffer(SpdyStreamId stream_id,
874 SpdyBuffer::ConsumeSource consume_source);
900 SpdyBuffer::ConsumeSource consume_source);
1033 scoped_ptr<SpdyBuffer> in_flight_write_;
|
| D | spdy_session.cc | 1089 scoped_ptr<SpdyBuffer> SpdySession::CreateDataBuffer(SpdyStreamId stream_id, in CreateDataBuffer()
1094 return scoped_ptr<SpdyBuffer>(); in CreateDataBuffer()
1104 return scoped_ptr<SpdyBuffer>(); in CreateDataBuffer()
1156 return scoped_ptr<SpdyBuffer>(); in CreateDataBuffer()
1171 return scoped_ptr<SpdyBuffer>(); in CreateDataBuffer()
1202 scoped_ptr<SpdyBuffer> data_buffer(new SpdyBuffer(frame.Pass())); in CreateDataBuffer()
1871 scoped_ptr<SpdyBuffer>(new SpdyBuffer(frame.Pass())))), in EnqueueSessionWrite()
2047 scoped_ptr<SpdyBuffer> buffer; in OnStreamFrameData()
2051 buffer.reset(new SpdyBuffer(data, len)); in OnStreamFrameData()
2412 it->second.stream->OnDataReceived(scoped_ptr<SpdyBuffer>()); in OnRstStream()
[all …]
|
| D | spdy_websocket_stream.cc | 97 void SpdyWebSocketStream::OnDataReceived(scoped_ptr<SpdyBuffer> buffer) { in OnDataReceived()
|
| D | spdy_http_stream.h | 82 virtual void OnDataReceived(scoped_ptr<SpdyBuffer> buffer) OVERRIDE;
|
| D | spdy_proxy_client_socket.h | 98 virtual void OnDataReceived(scoped_ptr<SpdyBuffer> buffer) OVERRIDE;
|
| D | spdy_proxy_client_socket.cc | 468 void SpdyProxyClientSocket::OnDataReceived(scoped_ptr<SpdyBuffer> buffer) { in OnDataReceived()
529 OnDataReceived(scoped_ptr<SpdyBuffer>()); in OnClose()
|
| D | spdy_http_stream.cc | 341 void SpdyHttpStream::OnDataReceived(scoped_ptr<SpdyBuffer> buffer) { in OnDataReceived()
|
| D | spdy_session_pool_unittest.cc | 74 virtual void OnDataReceived(scoped_ptr<SpdyBuffer> buffer) OVERRIDE {} in OnDataReceived()
|
| /external/chromium_org/net/websockets/ |
| D | websocket_job.h | 82 virtual void OnReceivedSpdyData(scoped_ptr<SpdyBuffer> buffer) OVERRIDE;
|
| D | websocket_job.cc | 329 void WebSocketJob::OnReceivedSpdyData(scoped_ptr<SpdyBuffer> buffer) { in OnReceivedSpdyData()
|