| Index: net/quic/bidirectional_stream_quic_impl.h
|
| diff --git a/net/quic/bidirectional_stream_quic_impl.h b/net/quic/bidirectional_stream_quic_impl.h
|
| deleted file mode 100644
|
| index 07b5f4273c238e25a074821fd6dc422bc92a9f89..0000000000000000000000000000000000000000
|
| --- a/net/quic/bidirectional_stream_quic_impl.h
|
| +++ /dev/null
|
| @@ -1,119 +0,0 @@
|
| -// Copyright 2016 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_QUIC_BIDIRECTIONAL_STREAM_QUIC_IMPL_H_
|
| -#define NET_QUIC_BIDIRECTIONAL_STREAM_QUIC_IMPL_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/net_features.h"
|
| -#include "net/quic/quic_chromium_client_session.h"
|
| -#include "net/quic/quic_chromium_client_stream.h"
|
| -
|
| -#if !BUILDFLAG(ENABLE_BIDIRECTIONAL_STREAM)
|
| -#error Only include this if ENABLE_BIDIRECTIONAL_STREAM is defined
|
| -#endif
|
| -
|
| -namespace base {
|
| -class Timer;
|
| -} // namespace base
|
| -
|
| -namespace net {
|
| -
|
| -struct BidirectionalStreamRequestInfo;
|
| -class BoundNetLog;
|
| -class IOBuffer;
|
| -class SpdyHeaderBlock;
|
| -
|
| -class NET_EXPORT_PRIVATE BidirectionalStreamQuicImpl
|
| - : public BidirectionalStreamJob,
|
| - public QuicChromiumClientStream::Delegate,
|
| - public QuicChromiumClientSession::Observer {
|
| - public:
|
| - explicit BidirectionalStreamQuicImpl(
|
| - const base::WeakPtr<QuicChromiumClientSession>& session);
|
| -
|
| - ~BidirectionalStreamQuicImpl() 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* buffer, int buffer_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;
|
| -
|
| - private:
|
| - // QuicChromiumClientStream::Delegate implementation:
|
| - void OnHeadersAvailable(const SpdyHeaderBlock& headers,
|
| - size_t frame_len) override;
|
| - void OnDataAvailable() override;
|
| - void OnClose(QuicErrorCode error) override;
|
| - void OnError(int error) override;
|
| - bool HasSendHeadersComplete() override;
|
| -
|
| - // QuicChromiumClientSession::Observer implementation:
|
| - void OnCryptoHandshakeConfirmed() override;
|
| - void OnSessionClosed(int error) override;
|
| -
|
| - void OnStreamReady(int rv);
|
| - void OnSendDataComplete(int rv);
|
| - void OnReadDataComplete(int rv);
|
| -
|
| - // Helper method to send request headers.
|
| - void SendRequestHeaders();
|
| - // Notifies the delegate of an error.
|
| - void NotifyError(int error);
|
| - // Resets the stream and ensures that |delegate_| won't be called back.
|
| - void ResetStream();
|
| -
|
| - base::WeakPtr<QuicChromiumClientSession> session_;
|
| - bool was_handshake_confirmed_; // True if the crypto handshake succeeded.
|
| - QuicChromiumClientSession::StreamRequest stream_request_;
|
| - QuicChromiumClientStream* stream_; // Non-owning.
|
| -
|
| - const BidirectionalStreamRequestInfo* request_info_;
|
| - BidirectionalStreamJob::Delegate* delegate_;
|
| - // Saves the response status if the stream is explicitly closed via OnError
|
| - // or OnClose with an error. Once all buffered data has been returned, this
|
| - // will be used as the final response.
|
| - int response_status_;
|
| -
|
| - // The protocol that is negotiated.
|
| - NextProto negotiated_protocol_;
|
| - // User provided read buffer for ReadData() response.
|
| - scoped_refptr<IOBuffer> read_buffer_;
|
| - int read_buffer_len_;
|
| -
|
| - // Number of bytes received by the headers stream on behalf of this stream.
|
| - int64_t headers_bytes_received_;
|
| - // Number of bytes sent by the headers stream on behalf of this stream.
|
| - int64_t headers_bytes_sent_;
|
| - // 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_;
|
| - // Indicates whether initial headers have been sent.
|
| - bool has_sent_headers_;
|
| - // Indicates whether initial headers have been received.
|
| - bool has_received_headers_;
|
| -
|
| - base::WeakPtrFactory<BidirectionalStreamQuicImpl> weak_factory_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(BidirectionalStreamQuicImpl);
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_QUIC_BIDIRECTIONAL_STREAM_QUIC_IMPL_H_
|
|
|