Chromium Code Reviews| Index: net/socket/tcp_server_socket_libevent.cc |
| diff --git a/net/socket/tcp_server_socket_libevent.cc b/net/socket/tcp_server_socket_libevent.cc |
| index ef8d1b1bcbef21f851decf142c01181d9c5e1c30..d95e8c1286868d83d953c946df2c1c69524adfe6 100644 |
| --- a/net/socket/tcp_server_socket_libevent.cc |
| +++ b/net/socket/tcp_server_socket_libevent.cc |
| @@ -35,6 +35,7 @@ TCPServerSocketLibevent::TCPServerSocketLibevent( |
| const net::NetLog::Source& source) |
| : socket_(kInvalidSocket), |
| accept_socket_(NULL), |
| + reuse_address_(false), |
| net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_SOCKET)) { |
| net_log_.BeginEvent(NetLog::TYPE_SOCKET_ALIVE, |
| source.ToEventParametersCallback()); |
| @@ -46,6 +47,13 @@ TCPServerSocketLibevent::~TCPServerSocketLibevent() { |
| net_log_.EndEvent(NetLog::TYPE_SOCKET_ALIVE); |
| } |
| +void TCPServerSocketLibevent::AllowAddressReuse() { |
| + DCHECK(CalledOnValidThread()); |
| + DCHECK_EQ(socket_, kInvalidSocket); |
| + |
| + reuse_address_ = true; |
| +} |
| + |
| int TCPServerSocketLibevent::Listen(const IPEndPoint& address, int backlog) { |
| DCHECK(CalledOnValidThread()); |
| DCHECK_GT(backlog, 0); |
| @@ -63,11 +71,16 @@ int TCPServerSocketLibevent::Listen(const IPEndPoint& address, int backlog) { |
| return result; |
| } |
| + int result = SetSocketOptions(); |
| + if (result != OK) { |
|
wtc
2012/09/14 19:20:17
Remove the curly braces {}.
Also in tcp_server_so
justinlin
2012/09/15 19:03:25
Done.
|
| + return result; |
| + } |
| + |
| SockaddrStorage storage; |
| if (!address.ToSockAddr(storage.addr, &storage.addr_len)) |
| return ERR_INVALID_ARGUMENT; |
| - int result = bind(socket_, storage.addr, storage.addr_len); |
| + result = bind(socket_, storage.addr, storage.addr_len); |
| if (result < 0) { |
| PLOG(ERROR) << "bind() returned an error"; |
| result = MapSystemError(errno); |
| @@ -125,6 +138,17 @@ int TCPServerSocketLibevent::Accept( |
| return result; |
| } |
| +int TCPServerSocketLibevent::SetSocketOptions() { |
| + int true_value = 1; |
| + if (reuse_address_) { |
| + int rv = setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, &true_value, |
| + sizeof(true_value)); |
| + if (rv < 0) |
| + return MapSystemError(errno); |
| + } |
| + return OK; |
| +} |
| + |
| int TCPServerSocketLibevent::AcceptInternal( |
| scoped_ptr<StreamSocket>* socket) { |
| SockaddrStorage storage; |