Index: net/socket/tcp_socket_libevent.h |
diff --git a/net/socket/tcp_socket_libevent.h b/net/socket/tcp_socket_libevent.h |
deleted file mode 100644 |
index 0958b6d25d0f3e522524452bcb8e87281e3368fb..0000000000000000000000000000000000000000 |
--- a/net/socket/tcp_socket_libevent.h |
+++ /dev/null |
@@ -1,214 +0,0 @@ |
-// Copyright 2013 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_SOCKET_TCP_SOCKET_LIBEVENT_H_ |
-#define NET_SOCKET_TCP_SOCKET_LIBEVENT_H_ |
- |
-#include "base/basictypes.h" |
-#include "base/callback.h" |
-#include "base/compiler_specific.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "net/base/address_family.h" |
-#include "net/base/completion_callback.h" |
-#include "net/base/net_export.h" |
-#include "net/base/net_log.h" |
- |
-namespace net { |
- |
-class AddressList; |
-class IOBuffer; |
-class IPEndPoint; |
-class SocketLibevent; |
- |
-class NET_EXPORT TCPSocketLibevent { |
- public: |
- TCPSocketLibevent(NetLog* net_log, const NetLog::Source& source); |
- virtual ~TCPSocketLibevent(); |
- |
- int Open(AddressFamily family); |
- // Takes ownership of |socket_fd|. |
- int AdoptConnectedSocket(int socket_fd, const IPEndPoint& peer_address); |
- |
- int Bind(const IPEndPoint& address); |
- |
- int Listen(int backlog); |
- int Accept(scoped_ptr<TCPSocketLibevent>* socket, |
- IPEndPoint* address, |
- const CompletionCallback& callback); |
- |
- int Connect(const IPEndPoint& address, const CompletionCallback& callback); |
- bool IsConnected() const; |
- bool IsConnectedAndIdle() const; |
- |
- // Multiple outstanding requests are not supported. |
- // Full duplex mode (reading and writing at the same time) is supported. |
- int Read(IOBuffer* buf, int buf_len, const CompletionCallback& callback); |
- int Write(IOBuffer* buf, int buf_len, const CompletionCallback& callback); |
- |
- int GetLocalAddress(IPEndPoint* address) const; |
- int GetPeerAddress(IPEndPoint* address) const; |
- |
- // Sets various socket options. |
- // The commonly used options for server listening sockets: |
- // - SetAddressReuse(true). |
- int SetDefaultOptionsForServer(); |
- // The commonly used options for client sockets and accepted sockets: |
- // - SetNoDelay(true); |
- // - SetKeepAlive(true, 45). |
- void SetDefaultOptionsForClient(); |
- int SetAddressReuse(bool allow); |
- int SetReceiveBufferSize(int32 size); |
- int SetSendBufferSize(int32 size); |
- bool SetKeepAlive(bool enable, int delay); |
- bool SetNoDelay(bool no_delay); |
- |
- void Close(); |
- |
- // Setter/Getter methods for TCP FastOpen socket option. |
- bool UsingTCPFastOpen() const; |
- void EnableTCPFastOpenIfSupported(); |
- |
- bool IsValid() const; |
- |
- // Marks the start/end of a series of connect attempts for logging purpose. |
- // |
- // TCPClientSocket may attempt to connect to multiple addresses until it |
- // succeeds in establishing a connection. The corresponding log will have |
- // multiple NetLog::TYPE_TCP_CONNECT_ATTEMPT entries nested within a |
- // NetLog::TYPE_TCP_CONNECT. These methods set the start/end of |
- // NetLog::TYPE_TCP_CONNECT. |
- // |
- // TODO(yzshen): Change logging format and let TCPClientSocket log the |
- // start/end of a series of connect attempts itself. |
- void StartLoggingMultipleConnectAttempts(const AddressList& addresses); |
- void EndLoggingMultipleConnectAttempts(int net_error); |
- |
- const BoundNetLog& net_log() const { return net_log_; } |
- |
- private: |
- // States that using a socket with TCP FastOpen can lead to. |
- enum TCPFastOpenStatus { |
- TCP_FASTOPEN_STATUS_UNKNOWN, |
- |
- // The initial FastOpen connect attempted returned synchronously, |
- // indicating that we had and sent a cookie along with the initial data. |
- TCP_FASTOPEN_FAST_CONNECT_RETURN, |
- |
- // The initial FastOpen connect attempted returned asynchronously, |
- // indicating that we did not have a cookie for the server. |
- TCP_FASTOPEN_SLOW_CONNECT_RETURN, |
- |
- // Some other error occurred on connection, so we couldn't tell if |
- // FastOpen would have worked. |
- TCP_FASTOPEN_ERROR, |
- |
- // An attempt to do a FastOpen succeeded immediately |
- // (TCP_FASTOPEN_FAST_CONNECT_RETURN) and we later confirmed that the server |
- // had acked the data we sent. |
- TCP_FASTOPEN_SYN_DATA_ACK, |
- |
- // An attempt to do a FastOpen succeeded immediately |
- // (TCP_FASTOPEN_FAST_CONNECT_RETURN) and we later confirmed that the server |
- // had nacked the data we sent. |
- TCP_FASTOPEN_SYN_DATA_NACK, |
- |
- // An attempt to do a FastOpen succeeded immediately |
- // (TCP_FASTOPEN_FAST_CONNECT_RETURN) and our probe to determine if the |
- // socket was using FastOpen failed. |
- TCP_FASTOPEN_SYN_DATA_GETSOCKOPT_FAILED, |
- |
- // An attempt to do a FastOpen failed (TCP_FASTOPEN_SLOW_CONNECT_RETURN) |
- // and we later confirmed that the server had acked initial data. This |
- // should never happen (we didn't send data, so it shouldn't have |
- // been acked). |
- TCP_FASTOPEN_NO_SYN_DATA_ACK, |
- |
- // An attempt to do a FastOpen failed (TCP_FASTOPEN_SLOW_CONNECT_RETURN) |
- // and we later discovered that the server had nacked initial data. This |
- // is the expected case results for TCP_FASTOPEN_SLOW_CONNECT_RETURN. |
- TCP_FASTOPEN_NO_SYN_DATA_NACK, |
- |
- // An attempt to do a FastOpen failed (TCP_FASTOPEN_SLOW_CONNECT_RETURN) |
- // and our later probe for ack/nack state failed. |
- TCP_FASTOPEN_NO_SYN_DATA_GETSOCKOPT_FAILED, |
- |
- // The initial FastOpen connect+write succeeded immediately |
- // (TCP_FASTOPEN_FAST_CONNECT_RETURN) and a subsequent attempt to read from |
- // the connection failed. |
- TCP_FASTOPEN_FAST_CONNECT_READ_FAILED, |
- |
- // The initial FastOpen connect+write failed |
- // (TCP_FASTOPEN_SLOW_CONNECT_RETURN) |
- // and a subsequent attempt to read from the connection failed. |
- TCP_FASTOPEN_SLOW_CONNECT_READ_FAILED, |
- |
- // We didn't try FastOpen because it had failed in the past |
- // (g_tcp_fastopen_has_failed was true.) |
- // NOTE: This status is currently registered before a connect/write call |
- // is attempted, and may capture some cases where the status is registered |
- // but no connect is subsequently attempted. |
- // TODO(jri): The expectation is that such cases are not the common case |
- // with TCP FastOpen for SSL sockets however. Change code to be more |
- // accurate when TCP FastOpen is used for more than just SSL sockets. |
- TCP_FASTOPEN_PREVIOUSLY_FAILED, |
- |
- TCP_FASTOPEN_MAX_VALUE |
- }; |
- |
- void AcceptCompleted(scoped_ptr<TCPSocketLibevent>* tcp_socket, |
- IPEndPoint* address, |
- const CompletionCallback& callback, |
- int rv); |
- int HandleAcceptCompleted(scoped_ptr<TCPSocketLibevent>* tcp_socket, |
- IPEndPoint* address, |
- int rv); |
- int BuildTcpSocketLibevent(scoped_ptr<TCPSocketLibevent>* tcp_socket, |
- IPEndPoint* address); |
- |
- void ConnectCompleted(const CompletionCallback& callback, int rv) const; |
- int HandleConnectCompleted(int rv) const; |
- void LogConnectBegin(const AddressList& addresses) const; |
- void LogConnectEnd(int net_error) const; |
- |
- void ReadCompleted(const scoped_refptr<IOBuffer>& buf, |
- const CompletionCallback& callback, |
- int rv); |
- int HandleReadCompleted(IOBuffer* buf, int rv); |
- |
- void WriteCompleted(const scoped_refptr<IOBuffer>& buf, |
- const CompletionCallback& callback, |
- int rv); |
- int HandleWriteCompleted(IOBuffer* buf, int rv); |
- int TcpFastOpenWrite(IOBuffer* buf, |
- int buf_len, |
- const CompletionCallback& callback); |
- |
- // Called after the first read completes on a TCP FastOpen socket. |
- void UpdateTCPFastOpenStatusAfterRead(); |
- |
- scoped_ptr<SocketLibevent> socket_; |
- scoped_ptr<SocketLibevent> accept_socket_; |
- |
- // Enables experimental TCP FastOpen option. |
- bool use_tcp_fastopen_; |
- |
- // True when TCP FastOpen is in use and we have attempted the |
- // connect with write. |
- bool tcp_fastopen_write_attempted_; |
- |
- // True when TCP FastOpen is in use and we have done the connect. |
- bool tcp_fastopen_connected_; |
- |
- TCPFastOpenStatus tcp_fastopen_status_; |
- |
- bool logging_multiple_connect_attempts_; |
- |
- BoundNetLog net_log_; |
- |
- DISALLOW_COPY_AND_ASSIGN(TCPSocketLibevent); |
-}; |
- |
-} // namespace net |
- |
-#endif // NET_SOCKET_TCP_SOCKET_LIBEVENT_H_ |