Implement ChannelMultiplexer.

remoting/protocol/buffered_socket_writer.cc

 // Copyright (c) 2012 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 "remoting/protocol/buffered_socket_writer.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/single_thread_task_runner.h"
 #include "base/stl_util.h"
@@ skipping 37 matching lines @@
   DCHECK(data.get());
 
   // Don't write after Close().
   if (closed_)
     return false;
 
   queue_.push_back(new PendingPacket(data, done_task));
   buffer_size_ += data->size();
 
   DoWrite();
-  return true;
+
+  // DoWrite() may trigger OnWriteError() to be called.
+  return !closed_;
 }
 
 void BufferedSocketWriterBase::DoWrite() {
   DCHECK(CalledOnValidThread());
   DCHECK(socket_);
 
   // Don't try to write if there is another write pending.
   if (write_pending_)
     return;
 
@@ skipping 156 matching lines @@
 
 void BufferedDatagramWriter::OnError(int result) {
   // Nothing to do here.
 }
 
 BufferedDatagramWriter::~BufferedDatagramWriter() {
 }
 
 }  // namespace protocol
 }  // namespace remoting