Roll mojo SDK to 734c6e1652ff2f3b696e441722838f453f4f9b42

mojo/services/network/tcp_connected_socket_impl.cc

 // 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.
 
 #include "mojo/services/network/tcp_connected_socket_impl.h"
 
 #include "base/message_loop/message_loop.h"
 #include "mojo/services/network/net_adapters.h"
 #include "net/base/net_errors.h"
 
 namespace mojo {
 
 TCPConnectedSocketImpl::TCPConnectedSocketImpl(
     scoped_ptr<net::TCPSocket> socket,
     ScopedDataPipeConsumerHandle send_stream,
     ScopedDataPipeProducerHandle receive_stream,
     InterfaceRequest<TCPConnectedSocket> request)
     : socket_(socket.Pass()),
       send_stream_(send_stream.Pass()),
       receive_stream_(receive_stream.Pass()),
       binding_(this, request.Pass()),
       send_more_posted_(false),
       weak_ptr_factory_(this) {
   // Queue up async communication.
-  binding_.set_error_handler(this);
+  binding_.set_connection_error_handler([this]() { OnConnectionError(); });
   ListenForReceivePeerClosed();
   ListenForSendPeerClosed();
   ReceiveMore();
   SendMore();
 }
 
 TCPConnectedSocketImpl::~TCPConnectedSocketImpl() {
 }
 
 void TCPConnectedSocketImpl::OnConnectionError() {
@@ skipping 220 matching lines @@
 }
 
 void TCPConnectedSocketImpl::DeleteIfNeeded() {
   bool has_send = pending_send_ || send_stream_.is_valid();
   bool has_receive = pending_receive_ || receive_stream_.is_valid();
   if (!binding_.is_bound() && !has_send && !has_receive)
     delete this;
 }
 
 }  // namespace mojo