remoting: Update calls froms RunAllPending() to RunUntilIdle().

remoting/protocol/message_reader_unittest.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 <string>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/callback.h"
 #include "base/message_loop.h"
@@ skipping 99 matching lines @@
 TEST_F(MessageReaderTest, OneMessage_Delay) {
   base::Closure done_task;
 
   AddMessage(kTestMessage1);
 
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(1)
       .WillOnce(SaveArg<0>(&done_task));
 
   InitReader();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   Mock::VerifyAndClearExpectations(&callback_);
   Mock::VerifyAndClearExpectations(&socket_);
 
   EXPECT_TRUE(CompareResult(messages_[0], kTestMessage1));
 
   // Verify that the reader starts reading again only after we've
   // finished processing the previous message.
   EXPECT_FALSE(socket_.read_pending());
 
   done_task.Run();
 
   EXPECT_TRUE(socket_.read_pending());
 }
 
 // Receive one message and process it instantly.
 TEST_F(MessageReaderTest, OneMessage_Instant) {
   AddMessage(kTestMessage1);
 
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(1)
       .WillOnce(CallDoneTask());
 
   InitReader();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   EXPECT_TRUE(socket_.read_pending());
   EXPECT_EQ(1U, messages_.size());
 }
 
 // Receive two messages in one packet.
 TEST_F(MessageReaderTest, TwoMessages_Together) {
   base::Closure done_task1;
   base::Closure done_task2;
 
   AddMessage(kTestMessage1);
   AddMessage(kTestMessage2);
 
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(2)
       .WillOnce(SaveArg<0>(&done_task1))
       .WillOnce(SaveArg<0>(&done_task2));
 
   InitReader();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   Mock::VerifyAndClearExpectations(&callback_);
   Mock::VerifyAndClearExpectations(&socket_);
 
   EXPECT_TRUE(CompareResult(messages_[0], kTestMessage1));
   EXPECT_TRUE(CompareResult(messages_[1], kTestMessage2));
 
   // Verify that the reader starts reading again only after we've
   // finished processing the previous message.
   EXPECT_FALSE(socket_.read_pending());
 
   done_task1.Run();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   EXPECT_FALSE(socket_.read_pending());
 
   done_task2.Run();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   EXPECT_TRUE(socket_.read_pending());
 }
 
 // Receive two messages in one packet, and process the first one
 // instantly.
 TEST_F(MessageReaderTest, TwoMessages_Instant) {
   base::Closure done_task2;
 
   AddMessage(kTestMessage1);
   AddMessage(kTestMessage2);
 
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(2)
       .WillOnce(CallDoneTask())
       .WillOnce(SaveArg<0>(&done_task2));
 
   InitReader();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   Mock::VerifyAndClearExpectations(&callback_);
   Mock::VerifyAndClearExpectations(&socket_);
 
   EXPECT_TRUE(CompareResult(messages_[1], kTestMessage2));
 
   // Verify that the reader starts reading again only after we've
   // finished processing the second message.
   EXPECT_FALSE(socket_.read_pending());
 
   done_task2.Run();
 
   EXPECT_TRUE(socket_.read_pending());
 }
 
 // Receive two messages in one packet, and process both of them
 // instantly.
 TEST_F(MessageReaderTest, TwoMessages_Instant2) {
   AddMessage(kTestMessage1);
   AddMessage(kTestMessage2);
 
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(2)
       .WillOnce(CallDoneTask())
       .WillOnce(CallDoneTask());
 
   InitReader();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   EXPECT_TRUE(socket_.read_pending());
 }
 
 // Receive two messages in separate packets.
 TEST_F(MessageReaderTest, TwoMessages_Separately) {
   base::Closure done_task;
 
   AddMessage(kTestMessage1);
 
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(1)
       .WillOnce(SaveArg<0>(&done_task));
 
   InitReader();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   Mock::VerifyAndClearExpectations(&callback_);
   Mock::VerifyAndClearExpectations(&socket_);
 
   EXPECT_TRUE(CompareResult(messages_[0], kTestMessage1));
 
   // Verify that the reader starts reading again only after we've
   // finished processing the previous message.
   EXPECT_FALSE(socket_.read_pending());
 
   done_task.Run();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   EXPECT_TRUE(socket_.read_pending());
 
   // Write another message and verify that we receive it.
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(1)
       .WillOnce(SaveArg<0>(&done_task));
   AddMessage(kTestMessage2);
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   EXPECT_TRUE(CompareResult(messages_[1], kTestMessage2));
 
   // Verify that the reader starts reading again only after we've
   // finished processing the previous message.
   EXPECT_FALSE(socket_.read_pending());
 
   done_task.Run();
 
   EXPECT_TRUE(socket_.read_pending());
@@ skipping 15 matching lines @@
 // Verify that we the OnMessage callback is not reentered.
 TEST_F(MessageReaderTest, ReadFromCallback) {
   AddMessage(kTestMessage1);
 
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(2)
       .WillOnce(Invoke(this, &MessageReaderTest::AddSecondMessage))
       .WillOnce(Invoke(this, &MessageReaderTest::OnSecondMessage));
 
   InitReader();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 
   EXPECT_TRUE(socket_.read_pending());
 }
 
 // Verify that we stop getting callbacks after deleting MessageReader.
 TEST_F(MessageReaderTest, DeleteFromCallback) {
   base::Closure done_task1;
   base::Closure done_task2;
 
   AddMessage(kTestMessage1);
   AddMessage(kTestMessage2);
 
   // OnMessage() should never be called for the second message.
   EXPECT_CALL(callback_, OnMessage(_))
       .Times(1)
       .WillOnce(Invoke(this, &MessageReaderTest::DeleteReader));
 
   InitReader();
-  message_loop_.RunAllPending();
+  message_loop_.RunUntilIdle();
 }
 
 }  // namespace protocol
 }  // namespace remoting