158537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)// Copyright 2013 The Chromium Authors. All rights reserved. 258537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)// found in the LICENSE file. 458537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 558537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#ifndef NET_SOCKET_TCP_SOCKET_LIBEVENT_H_ 658537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#define NET_SOCKET_TCP_SOCKET_LIBEVENT_H_ 758537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 858537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "base/basictypes.h" 9d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)#include "base/callback.h" 1058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "base/compiler_specific.h" 11d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)#include "base/memory/ref_counted.h" 1258537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "base/memory/scoped_ptr.h" 1358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "base/message_loop/message_loop.h" 1458537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "base/threading/non_thread_safe.h" 1558537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "net/base/address_family.h" 1658537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "net/base/completion_callback.h" 1758537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "net/base/net_export.h" 1858537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#include "net/base/net_log.h" 19d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)#include "net/socket/socket_descriptor.h" 2058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 2158537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)namespace net { 2258537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 23d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)class AddressList; 24d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)class IOBuffer; 2558537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)class IPEndPoint; 2658537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 27d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)class NET_EXPORT TCPSocketLibevent : public base::NonThreadSafe { 2858537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) public: 2958537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) TCPSocketLibevent(NetLog* net_log, const NetLog::Source& source); 3058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) virtual ~TCPSocketLibevent(); 3158537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 32d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int Open(AddressFamily family); 3358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) // Takes ownership of |socket|. 34d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int AdoptConnectedSocket(int socket, const IPEndPoint& peer_address); 35d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 3658537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) int Bind(const IPEndPoint& address); 37d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 3858537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) int Listen(int backlog); 3958537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) int Accept(scoped_ptr<TCPSocketLibevent>* socket, 4058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) IPEndPoint* address, 4158537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) const CompletionCallback& callback); 42d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 43d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int Connect(const IPEndPoint& address, const CompletionCallback& callback); 44d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool IsConnected() const; 45d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool IsConnectedAndIdle() const; 46d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 47d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Multiple outstanding requests are not supported. 48d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Full duplex mode (reading and writing at the same time) is supported. 49d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int Read(IOBuffer* buf, int buf_len, const CompletionCallback& callback); 50d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int Write(IOBuffer* buf, int buf_len, const CompletionCallback& callback); 51d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 52d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int GetLocalAddress(IPEndPoint* address) const; 53d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int GetPeerAddress(IPEndPoint* address) const; 54d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 55d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Sets various socket options. 56d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The commonly used options for server listening sockets: 57d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // - SetAddressReuse(true). 5858537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) int SetDefaultOptionsForServer(); 59d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The commonly used options for client sockets and accepted sockets: 60d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // - SetNoDelay(true); 61d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // - SetKeepAlive(true, 45). 62d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void SetDefaultOptionsForClient(); 6358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) int SetAddressReuse(bool allow); 64c5cede9ae108bb15f6b7a8aea21c7e1fefa2834cBen Murdoch int SetReceiveBufferSize(int32 size); 65c5cede9ae108bb15f6b7a8aea21c7e1fefa2834cBen Murdoch int SetSendBufferSize(int32 size); 66d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool SetKeepAlive(bool enable, int delay); 67d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool SetNoDelay(bool no_delay); 68d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 6958537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) void Close(); 7058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 71d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool UsingTCPFastOpen() const; 72d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool IsValid() const { return socket_ != kInvalidSocket; } 73d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 74d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Marks the start/end of a series of connect attempts for logging purpose. 75d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // 76d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // TCPClientSocket may attempt to connect to multiple addresses until it 77d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // succeeds in establishing a connection. The corresponding log will have 78d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // multiple NetLog::TYPE_TCP_CONNECT_ATTEMPT entries nested within a 79d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // NetLog::TYPE_TCP_CONNECT. These methods set the start/end of 80d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // NetLog::TYPE_TCP_CONNECT. 81d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // 82d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // TODO(yzshen): Change logging format and let TCPClientSocket log the 83d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // start/end of a series of connect attempts itself. 84d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void StartLoggingMultipleConnectAttempts(const AddressList& addresses); 85d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void EndLoggingMultipleConnectAttempts(int net_error); 8658537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 87d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) const BoundNetLog& net_log() const { return net_log_; } 8858537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 8958537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) private: 90d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // States that a fast open socket attempt can result in. 91d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) enum FastOpenStatus { 92d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_STATUS_UNKNOWN, 93d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 94d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The initial fast open connect attempted returned synchronously, 95d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // indicating that we had and sent a cookie along with the initial data. 96d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_FAST_CONNECT_RETURN, 97d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 98d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The initial fast open connect attempted returned asynchronously, 99d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // indicating that we did not have a cookie for the server. 100d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_SLOW_CONNECT_RETURN, 101d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 102d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Some other error occurred on connection, so we couldn't tell if 103d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // fast open would have worked. 104d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_ERROR, 105d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 106d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // An attempt to do a fast open succeeded immediately 107d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // (FAST_OPEN_FAST_CONNECT_RETURN) and we later confirmed that the server 108d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // had acked the data we sent. 109d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_SYN_DATA_ACK, 110d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 111d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // An attempt to do a fast open succeeded immediately 112d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // (FAST_OPEN_FAST_CONNECT_RETURN) and we later confirmed that the server 113d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // had nacked the data we sent. 114d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_SYN_DATA_NACK, 115d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 116d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // An attempt to do a fast open succeeded immediately 117d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // (FAST_OPEN_FAST_CONNECT_RETURN) and our probe to determine if the 118d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // socket was using fast open failed. 119d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_SYN_DATA_FAILED, 120d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 121d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // An attempt to do a fast open failed (FAST_OPEN_SLOW_CONNECT_RETURN) 122d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // and we later confirmed that the server had acked initial data. This 123d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // should never happen (we didn't send data, so it shouldn't have 124d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // been acked). 125d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_NO_SYN_DATA_ACK, 126d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 127d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // An attempt to do a fast open failed (FAST_OPEN_SLOW_CONNECT_RETURN) 128d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // and we later discovered that the server had nacked initial data. This 129d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // is the expected case results for FAST_OPEN_SLOW_CONNECT_RETURN. 130d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_NO_SYN_DATA_NACK, 131d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 132d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // An attempt to do a fast open failed (FAST_OPEN_SLOW_CONNECT_RETURN) 133d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // and our later probe for ack/nack state failed. 134d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_NO_SYN_DATA_FAILED, 135d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 136d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FAST_OPEN_MAX_VALUE 137d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) }; 138d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 139d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Watcher simply forwards notifications to Closure objects set via the 140d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // constructor. 141d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) class Watcher: public base::MessageLoopForIO::Watcher { 142d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) public: 143d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) Watcher(const base::Closure& read_ready_callback, 144d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) const base::Closure& write_ready_callback); 145d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) virtual ~Watcher(); 146d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 147d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // base::MessageLoopForIO::Watcher methods. 148d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) virtual void OnFileCanReadWithoutBlocking(int fd) OVERRIDE; 149d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) virtual void OnFileCanWriteWithoutBlocking(int fd) OVERRIDE; 150d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 151d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) private: 152d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) base::Closure read_ready_callback_; 153d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) base::Closure write_ready_callback_; 154d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 155d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(Watcher); 156d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) }; 157d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 15858537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) int AcceptInternal(scoped_ptr<TCPSocketLibevent>* socket, 15958537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) IPEndPoint* address); 16058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 161d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int DoConnect(); 162d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void DoConnectComplete(int result); 163d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 164d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void LogConnectBegin(const AddressList& addresses); 165d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void LogConnectEnd(int net_error); 166d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 167d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void DidCompleteRead(); 168d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void DidCompleteWrite(); 169d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void DidCompleteConnect(); 170d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void DidCompleteConnectOrWrite(); 171d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void DidCompleteAccept(); 172d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 173d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Internal function to write to a socket. Returns an OS error. 174d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int InternalWrite(IOBuffer* buf, int buf_len); 175d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 176d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Called when the socket is known to be in a connected state. 177d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) void RecordFastOpenStatus(); 178d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 17958537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) int socket_; 18058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 18158537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) base::MessageLoopForIO::FileDescriptorWatcher accept_socket_watcher_; 182d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) Watcher accept_watcher_; 18358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 18458537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) scoped_ptr<TCPSocketLibevent>* accept_socket_; 18558537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) IPEndPoint* accept_address_; 18658537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) CompletionCallback accept_callback_; 18758537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 188d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The socket's libevent wrappers for reads and writes. 189d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) base::MessageLoopForIO::FileDescriptorWatcher read_socket_watcher_; 190d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) base::MessageLoopForIO::FileDescriptorWatcher write_socket_watcher_; 191d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 192d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The corresponding watchers for reads and writes. 193d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) Watcher read_watcher_; 194d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) Watcher write_watcher_; 195d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 196d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The buffer used for reads. 197d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) scoped_refptr<IOBuffer> read_buf_; 198d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int read_buf_len_; 199d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 200d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The buffer used for writes. 201d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) scoped_refptr<IOBuffer> write_buf_; 202d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int write_buf_len_; 203d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 204d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // External callback; called when read is complete. 205d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) CompletionCallback read_callback_; 206d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 207d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // External callback; called when write or connect is complete. 208d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) CompletionCallback write_callback_; 209d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 210d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Enables experimental TCP FastOpen option. 211d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) const bool use_tcp_fastopen_; 212d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 213d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // True when TCP FastOpen is in use and we have done the connect. 214d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool tcp_fastopen_connected_; 215d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 216d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) FastOpenStatus fast_open_status_; 217d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 218d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // A connect operation is pending. In this case, |write_callback_| needs to be 219d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // called when connect is complete. 220d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool waiting_connect_; 221d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 222d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) scoped_ptr<IPEndPoint> peer_address_; 223d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // The OS error that a connect attempt last completed with. 224d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int connect_os_error_; 225d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 226d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool logging_multiple_connect_attempts_; 227d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 22858537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) BoundNetLog net_log_; 22958537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 23058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(TCPSocketLibevent); 23158537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)}; 23258537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 23358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)} // namespace net 23458537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) 23558537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles)#endif // NET_SOCKET_TCP_SOCKET_LIBEVENT_H_ 236