Add a done task to ScreenRecorder::Stop()

remoting/protocol/buffered_socket_writer.cc

 // Copyright (c) 2010 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/message_loop.h"
 #include "base/stl_util-inl.h"
 #include "net/base/net_errors.h"
 
@@ skipping 52 matching lines @@
   buffer_size_ += data->size();
   message_loop_->PostTask(
       FROM_HERE, NewRunnableMethod(this, &BufferedSocketWriterBase::DoWrite));
   return true;
 }
 
 void BufferedSocketWriterBase::DoWrite() {
   DCHECK_EQ(message_loop_, MessageLoop::current());
   DCHECK(socket_);
 
-  // Don't try to write if there is another write pending.
-  if (write_pending_)
-    return;
+   // Don't try to write if there is another write pending.

[Sergey Ulanov, 2011/01/20 19:14:17]

Remove extra spaces

[Alpha Left Google, 2011/01/20 19:32:08]

weird... done.

+   if (write_pending_)
+     return;
 
-  // Don't write after Close().
-  {
-    AutoLock auto_lock(lock_);
-    if (closed_)
-      return;
-  }
+   // Don't write after Close().
+   {
+     AutoLock auto_lock(lock_);
+     if (closed_)
+       return;
+   }
 
-  while (true) {
-    net::IOBuffer* current_packet;
-    int current_packet_size;
-    {
-      AutoLock auto_lock(lock_);
-      GetNextPacket_Locked(&current_packet, &current_packet_size);
-    }
+   while (true) {
+     net::IOBuffer* current_packet;
+     int current_packet_size;
+     {
+       AutoLock auto_lock(lock_);
+       GetNextPacket_Locked(&current_packet, &current_packet_size);
+     }
 
-    // Return if the queue is empty.
-    if (!current_packet)
-      return;
+     // Return if the queue is empty.
+     if (!current_packet)
+       return;
 
     int result = socket_->Write(current_packet, current_packet_size,
                                 &written_callback_);
     if (result >= 0) {
       AutoLock auto_lock(lock_);
       AdvanceBufferPosition_Locked(result);
     } else {
       if (result == net::ERR_IO_PENDING) {
         write_pending_ = true;
       } else {
         HandleError(result);
-        if (write_failed_callback_.get())
-          write_failed_callback_->Run(result);
       }
       return;
     }
   }
 }
 
 void BufferedSocketWriterBase::OnWritten(int result) {
   DCHECK_EQ(message_loop_, MessageLoop::current());
   write_pending_ = false;
 
   if (result < 0) {
     HandleError(result);
-    if (write_failed_callback_.get())
-      write_failed_callback_->Run(result);
     return;
   }
 
   {
     AutoLock auto_lock(lock_);
     AdvanceBufferPosition_Locked(result);
   }
 
   // Schedule next write.
   message_loop_->PostTask(
@@ skipping 83 matching lines @@
   buffer_size_ -= queue_.front()->data()->size();
   PopQueue();
 }
 
 void BufferedDatagramWriter::OnError_Locked(int result) {
   // Nothing to do here.
 }
 
 }  // namespace protocol
 }  // namespace remoting