Fix BufferedSocketWriter to buffer everything before it starts writing.

remoting/protocol/channel_multiplexer.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/channel_multiplexer.h"
 
 #include <stddef.h>
 #include <string.h>
 
 #include <utility>
@@ skipping 354 matching lines @@
 void ChannelMultiplexer::OnBaseChannelReady(
     scoped_ptr<P2PStreamSocket> socket) {
   base_channel_factory_ = nullptr;
   base_channel_ = std::move(socket);
 
   if (base_channel_.get()) {
     // Initialize reader and writer.
     reader_.StartReading(base_channel_.get(),
                          base::Bind(&ChannelMultiplexer::OnBaseChannelError,
                                     base::Unretained(this)));
-    writer_.Init(base::Bind(&P2PStreamSocket::Write,
-                            base::Unretained(base_channel_.get())),
-                 base::Bind(&ChannelMultiplexer::OnBaseChannelError,
-                            base::Unretained(this)));
+    writer_.Start(base::Bind(&P2PStreamSocket::Write,
+                             base::Unretained(base_channel_.get())),
+                  base::Bind(&ChannelMultiplexer::OnBaseChannelError,
+                             base::Unretained(this)));
   }
 
   DoCreatePendingChannels();
 }
 
 void ChannelMultiplexer::DoCreatePendingChannels() {
   if (pending_channels_.empty())
     return;
 
   // Every time this function is called it connects a single channel and posts a
@@ skipping 75 matching lines @@
   channel->OnIncomingPacket(std::move(packet), done_task);
 }
 
 void ChannelMultiplexer::DoWrite(scoped_ptr<MultiplexPacket> packet,
                                  const base::Closure& done_task) {
   writer_.Write(SerializeAndFrameMessage(*packet), done_task);
 }
 
 }  // namespace protocol
 }  // namespace remoting