| Index: net/spdy/bidirectional_stream_spdy_impl.h
|
| diff --git a/net/spdy/bidirectional_stream_spdy_impl.h b/net/spdy/bidirectional_stream_spdy_impl.h
|
| deleted file mode 100644
|
| index 9e97b9142eea4fb3a69c3e6fd06e5f3feccfa028..0000000000000000000000000000000000000000
|
| --- a/net/spdy/bidirectional_stream_spdy_impl.h
|
| +++ /dev/null
|
| @@ -1,136 +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_IMPL_H_
|
| -#define NET_SPDY_BIDIRECTIONAL_STREAM_SPDY_IMPL_H_
|
| -
|
| -#include <stdint.h>
|
| -
|
| -#include <memory>
|
| -#include <vector>
|
| -
|
| -#include "base/macros.h"
|
| -#include "base/memory/ref_counted.h"
|
| -#include "base/memory/weak_ptr.h"
|
| -#include "net/base/load_timing_info.h"
|
| -#include "net/base/net_export.h"
|
| -#include "net/http/bidirectional_stream_impl.h"
|
| -#include "net/http/bidirectional_stream_request_info.h"
|
| -#include "net/http/http_request_info.h"
|
| -#include "net/log/net_log_source.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 IOBuffer;
|
| -class NetLogWithSource;
|
| -class SpdyHeaderBlock;
|
| -
|
| -class NET_EXPORT_PRIVATE BidirectionalStreamSpdyImpl
|
| - : public BidirectionalStreamImpl,
|
| - public SpdyStream::Delegate {
|
| - public:
|
| - BidirectionalStreamSpdyImpl(const base::WeakPtr<SpdySession>& spdy_session,
|
| - NetLogSource source_dependency);
|
| -
|
| - ~BidirectionalStreamSpdyImpl() override;
|
| -
|
| - // BidirectionalStreamImpl implementation:
|
| - void Start(const BidirectionalStreamRequestInfo* request_info,
|
| - const NetLogWithSource& net_log,
|
| - bool send_request_headers_automatically,
|
| - BidirectionalStreamImpl::Delegate* delegate,
|
| - std::unique_ptr<base::Timer> timer) override;
|
| - void SendRequestHeaders() override;
|
| - int ReadData(IOBuffer* buf, int buf_len) override;
|
| - void SendData(const scoped_refptr<IOBuffer>& data,
|
| - int length,
|
| - bool end_stream) override;
|
| - void SendvData(const std::vector<scoped_refptr<IOBuffer>>& buffers,
|
| - const std::vector<int>& lengths,
|
| - bool end_stream) override;
|
| - NextProto GetProtocol() const override;
|
| - int64_t GetTotalReceivedBytes() const override;
|
| - int64_t GetTotalSentBytes() const override;
|
| - bool GetLoadTimingInfo(LoadTimingInfo* load_timing_info) const override;
|
| -
|
| - // SpdyStream::Delegate implementation:
|
| - void OnHeadersSent() override;
|
| - void OnHeadersReceived(const SpdyHeaderBlock& response_headers) override;
|
| - void OnDataReceived(std::unique_ptr<SpdyBuffer> buffer) override;
|
| - void OnDataSent() override;
|
| - void OnTrailers(const SpdyHeaderBlock& trailers) override;
|
| - void OnClose(int status) override;
|
| - NetLogSource source_dependency() const override;
|
| -
|
| - private:
|
| - int SendRequestHeadersHelper();
|
| - void OnStreamInitialized(int rv);
|
| - // Notifies delegate of an error.
|
| - void NotifyError(int rv);
|
| - void ResetStream();
|
| - void ScheduleBufferedRead();
|
| - void DoBufferedRead();
|
| - bool ShouldWaitForMoreBufferedData() const;
|
| - // Handles the case where stream is closed when SendData()/SendvData() is
|
| - // called. Return true if stream is closed.
|
| - bool MaybeHandleStreamClosedInSendData();
|
| -
|
| - const base::WeakPtr<SpdySession> spdy_session_;
|
| - const BidirectionalStreamRequestInfo* request_info_;
|
| - BidirectionalStreamImpl::Delegate* delegate_;
|
| - std::unique_ptr<base::Timer> timer_;
|
| - SpdyStreamRequest stream_request_;
|
| - base::WeakPtr<SpdyStream> stream_;
|
| - const NetLogSource source_dependency_;
|
| -
|
| - 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 client has written the end of stream flag in request headers or
|
| - // in SendData()/SendvData().
|
| - bool written_end_of_stream_;
|
| - // Whether a SendData() or SendvData() is pending.
|
| - bool write_pending_;
|
| -
|
| - // 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_;
|
| - // True if |stream_| has LoadTimingInfo when it is closed.
|
| - bool closed_has_load_timing_info_;
|
| - // LoadTimingInfo populated when |stream_| is closed.
|
| - LoadTimingInfo closed_load_timing_info_;
|
| -
|
| - // This is the combined buffer of buffers passed in through SendvData.
|
| - // Keep a reference here so it is alive until OnDataSent is invoked.
|
| - scoped_refptr<IOBuffer> pending_combined_buffer_;
|
| -
|
| - base::WeakPtrFactory<BidirectionalStreamSpdyImpl> weak_factory_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(BidirectionalStreamSpdyImpl);
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_SPDY_BIDIRECTIONAL_STREAM_SPDY_IMPL_H_
|
|
|