From eb08ec17f2f1590dcb08693f0024f76beb50157f Mon Sep 17 00:00:00 2001 From: klzgrad Date: Tue, 23 Jan 2018 01:52:09 -0500 Subject: [PATCH] Check for null callbacks --- net/tools/naive/naive_client_connection.cc | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/net/tools/naive/naive_client_connection.cc b/net/tools/naive/naive_client_connection.cc index eaee101c89..afed66d21b 100644 --- a/net/tools/naive/naive_client_connection.cc +++ b/net/tools/naive/naive_client_connection.cc @@ -72,9 +72,10 @@ int NaiveClientConnection::Connect(const CompletionCallback& callback) { void NaiveClientConnection::Disconnect() { full_duplex_ = false; - client_socket_->Disconnect(); + // Closes server side first because latency is higher. if (server_socket_handle_->socket()) server_socket_handle_->socket()->Disconnect(); + client_socket_->Disconnect(); next_state_ = STATE_NONE; connect_callback_.Reset(); @@ -221,8 +222,13 @@ void NaiveClientConnection::Push(StreamSocket* from, } void NaiveClientConnection::OnIOError(StreamSocket* socket, int error) { + // Avoids running run_callback_ again. + if (client_error_ < 0 || server_error_ < 0) + return; + if (socket == client_socket_.get()) { if (client_error_ == OK) { + DCHECK(run_callback_); base::ResetAndReturn(&run_callback_).Run(error); } client_error_ = error; @@ -230,6 +236,7 @@ void NaiveClientConnection::OnIOError(StreamSocket* socket, int error) { } if (socket == server_socket_handle_->socket()) { if (server_error_ == OK) { + DCHECK(run_callback_); base::ResetAndReturn(&run_callback_).Run(error); } server_error_ = error;