Index: net/spdy/bidirectional_stream_spdy_job.h |
diff --git a/net/spdy/bidirectional_stream_spdy_job.h b/net/spdy/bidirectional_stream_spdy_job.h |
deleted file mode 100644 |
index 7dda52f47598eea01b8ce48da3b9ee6aedcf797c..0000000000000000000000000000000000000000 |
--- a/net/spdy/bidirectional_stream_spdy_job.h |
+++ /dev/null |
@@ -1,102 +0,0 @@ |
-// Copyright 2015 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#ifndef NET_SPDY_BIDIRECTIONAL_STREAM_SPDY_JOB_H_ |
-#define NET_SPDY_BIDIRECTIONAL_STREAM_SPDY_JOB_H_ |
- |
-#include <stdint.h> |
- |
-#include "base/macros.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/memory/weak_ptr.h" |
-#include "net/http/bidirectional_stream_job.h" |
-#include "net/http/bidirectional_stream_request_info.h" |
-#include "net/http/http_request_info.h" |
-#include "net/spdy/spdy_read_queue.h" |
-#include "net/spdy/spdy_session.h" |
-#include "net/spdy/spdy_stream.h" |
- |
-namespace base { |
-class Timer; |
-} // namespace base |
- |
-namespace net { |
- |
-class BoundNetLog; |
-class IOBuffer; |
-class SpdyHeaderBlock; |
- |
-class NET_EXPORT_PRIVATE BidirectionalStreamSpdyJob |
- : public BidirectionalStreamJob, |
- public SpdyStream::Delegate { |
- public: |
- explicit BidirectionalStreamSpdyJob( |
- const base::WeakPtr<SpdySession>& spdy_session); |
- |
- ~BidirectionalStreamSpdyJob() override; |
- |
- // BidirectionalStreamJob implementation: |
- void Start(const BidirectionalStreamRequestInfo* request_info, |
- const BoundNetLog& net_log, |
- BidirectionalStreamJob::Delegate* delegate, |
- scoped_ptr<base::Timer> timer) override; |
- int ReadData(IOBuffer* buf, int buf_len) override; |
- void SendData(IOBuffer* data, int length, bool end_stream) override; |
- void Cancel() override; |
- NextProto GetProtocol() const override; |
- int64_t GetTotalReceivedBytes() const override; |
- int64_t GetTotalSentBytes() const override; |
- |
- // SpdyStream::Delegate implementation: |
- void OnRequestHeadersSent() override; |
- SpdyResponseHeadersStatus OnResponseHeadersUpdated( |
- const SpdyHeaderBlock& response_headers) override; |
- void OnDataReceived(scoped_ptr<SpdyBuffer> buffer) override; |
- void OnDataSent() override; |
- void OnTrailers(const SpdyHeaderBlock& trailers) override; |
- void OnClose(int status) override; |
- |
- private: |
- void SendRequestHeaders(); |
- void OnStreamInitialized(int rv); |
- void ScheduleBufferedRead(); |
- void DoBufferedRead(); |
- bool ShouldWaitForMoreBufferedData() const; |
- |
- const base::WeakPtr<SpdySession> spdy_session_; |
- const BidirectionalStreamRequestInfo* request_info_; |
- BidirectionalStreamJob::Delegate* delegate_; |
- scoped_ptr<base::Timer> timer_; |
- SpdyStreamRequest stream_request_; |
- base::WeakPtr<SpdyStream> stream_; |
- |
- NextProto negotiated_protocol_; |
- |
- // Buffers the data as it arrives asynchronously from the stream. |
- SpdyReadQueue read_data_queue_; |
- // Whether received more data has arrived since started waiting. |
- bool more_read_data_pending_; |
- // User provided read buffer for ReadData() response. |
- scoped_refptr<IOBuffer> read_buffer_; |
- int read_buffer_len_; |
- |
- // Whether OnClose has been invoked. |
- bool stream_closed_; |
- // Status reported in OnClose. |
- int closed_stream_status_; |
- // After |stream_| has been closed, this keeps track of the total number of |
- // bytes received over the network for |stream_| while it was open. |
- int64_t closed_stream_received_bytes_; |
- // After |stream_| has been closed, this keeps track of the total number of |
- // bytes sent over the network for |stream_| while it was open. |
- int64_t closed_stream_sent_bytes_; |
- |
- base::WeakPtrFactory<BidirectionalStreamSpdyJob> weak_factory_; |
- |
- DISALLOW_COPY_AND_ASSIGN(BidirectionalStreamSpdyJob); |
-}; |
- |
-} // namespace net |
- |
-#endif // NET_SPDY_BIDIRECTIONAL_STREAM_SPDY_JOB_H_ |