Update ICE protocol to handle closed channel

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/message_loop.h"
@@ skipping 131 matching lines @@
   AddMessage(kTestMessage2);
   base::RunLoop().RunUntilIdle();
 
   EXPECT_TRUE(CompareResult(messages_[1].get(), kTestMessage2));
 
   EXPECT_TRUE(socket_.read_pending());
 }
 
 // Read() returns error.
 TEST_F(MessageReaderTest, ReadError) {
-  socket_.AppendReadError(net::ERR_FAILED);
+  socket_.SetReadError(net::ERR_FAILED);
 
   EXPECT_CALL(callback_, OnMessage()).Times(0);
 
   InitReader();
 
   EXPECT_EQ(net::ERR_FAILED, read_error_);
   EXPECT_FALSE(reader_);
 }
 
+// Read() returns 0 (end of stream).
+TEST_F(MessageReaderTest, EndOfStream) {
+  socket_.SetReadError(0);
+
+  EXPECT_CALL(callback_, OnMessage()).Times(0);
+
+  InitReader();
+
+  EXPECT_EQ(0, read_error_);
+  EXPECT_FALSE(reader_);
+}
+
 // 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));
 
   InitReader();
   base::RunLoop().RunUntilIdle();
@@ skipping 10 matching lines @@
   EXPECT_CALL(callback_, OnMessage())
       .Times(1)
       .WillOnce(Invoke(this, &MessageReaderTest::DeleteReader));
 
   InitReader();
   base::RunLoop().RunUntilIdle();
 }
 
 }  // namespace protocol
 }  // namespace remoting