// Copyright 2014 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 BRIGHTRAY_BROWSER_NET_DEVTOOLS_NETWORK_TRANSACTION_H_ #define BRIGHTRAY_BROWSER_NET_DEVTOOLS_NETWORK_TRANSACTION_H_ #include #include "base/memory/weak_ptr.h" #include "brightray/browser/net/devtools_network_interceptor.h" #include "net/base/completion_callback.h" #include "net/base/load_states.h" #include "net/base/request_priority.h" #include "net/http/http_transaction.h" namespace brightray { class DevToolsNetworkController; class DevToolsNetworkUploadDataStream; class DevToolsNetworkTransaction : public net::HttpTransaction { public: static const char kDevToolsEmulateNetworkConditionsClientId[]; DevToolsNetworkTransaction( DevToolsNetworkController* controller, std::unique_ptr network_transaction); ~DevToolsNetworkTransaction() override; // HttpTransaction methods: int Start(const net::HttpRequestInfo* request, const net::CompletionCallback& callback, const net::NetLogWithSource& net_log) override; int RestartIgnoringLastError( const net::CompletionCallback& callback) override; int RestartWithCertificate( scoped_refptr client_cert, scoped_refptr client_private_key, const net::CompletionCallback& callback) override; int RestartWithAuth(const net::AuthCredentials& credentials, const net::CompletionCallback& callback) override; bool IsReadyToRestartForAuth() override; int Read(net::IOBuffer* buf, int buf_len, const net::CompletionCallback& callback) override; void StopCaching() override; bool GetFullRequestHeaders(net::HttpRequestHeaders* headers) const override; int64_t GetTotalReceivedBytes() const override; int64_t GetTotalSentBytes() const override; void DoneReading() override; const net::HttpResponseInfo* GetResponseInfo() const override; net::LoadState GetLoadState() const override; void SetQuicServerInfo(net::QuicServerInfo* quic_server_info) override; bool GetLoadTimingInfo(net::LoadTimingInfo* load_timing_info) const override; bool GetRemoteEndpoint(net::IPEndPoint* endpoint) const override; void PopulateNetErrorDetails(net::NetErrorDetails* details) const override; void SetPriority(net::RequestPriority priority) override; void SetWebSocketHandshakeStreamCreateHelper( net::WebSocketHandshakeStreamBase::CreateHelper* create_helper) override; void SetBeforeNetworkStartCallback( const BeforeNetworkStartCallback& callback) override; void SetBeforeHeadersSentCallback( const BeforeHeadersSentCallback& callback) override; int ResumeNetworkStart() override; void GetConnectionAttempts(net::ConnectionAttempts* out) const override; private: void Fail(); bool CheckFailed(); void IOCallback(const net::CompletionCallback& callback, bool start, int result); int Throttle(const net::CompletionCallback& callback, bool start, int result); void ThrottleCallback(const net::CompletionCallback& callback, int result, int64_t bytes); DevToolsNetworkInterceptor::ThrottleCallback throttle_callback_; int64_t throttled_byte_count_; DevToolsNetworkController* controller_; base::WeakPtr interceptor_; // Modified upload data stream. Should be destructed after |custom_request_|. std::unique_ptr custom_upload_data_stream_; // Modified request. Should be destructed after |transaction_|. std::unique_ptr custom_request_; // Original network transaction. std::unique_ptr transaction_; const net::HttpRequestInfo* request_; // True if Fail was already invoked. bool failed_; DISALLOW_COPY_AND_ASSIGN(DevToolsNetworkTransaction); }; } // namespace brightray #endif // BRIGHTRAY_BROWSER_NET_DEVTOOLS_NETWORK_TRANSACTION_H_