Fix MessageReader to handle errors properly.

remoting/protocol/message_reader_unittest.cc

Index: remoting/protocol/message_reader_unittest.cc
diff --git a/remoting/protocol/message_reader_unittest.cc b/remoting/protocol/message_reader_unittest.cc
index c228f93c29ce8d8087e860e3941a37babbcd13ab..d82c07257bee91e7b5ad7e1ee21fd569e02033f4 100644
--- a/remoting/protocol/message_reader_unittest.cc
+++ b/remoting/protocol/message_reader_unittest.cc
@@ -11,6 +11,7 @@
 #include "base/stl_util.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/threading/thread.h"
+#include "net/base/net_errors.h"
 #include "net/socket/socket.h"
 #include "remoting/protocol/fake_session.h"
 #include "remoting/protocol/message_reader.h"
@@ -288,5 +289,18 @@ TEST_F(MessageReaderTest, UseSocketOnCorrectThread) {
   done_task.Run();
 }
 
+// Read() returns error.
+TEST_F(MessageReaderTest, ReadError) {
+  socket_.set_next_read_error(net::ERR_FAILED);
+
+  // Add a message. It should never be read after the error above.
+  AddMessage(kTestMessage1);
+
+  EXPECT_CALL(callback_, OnMessage(_))
+      .Times(0);
+
+  InitReader();
+}
+
 }  // namespace protocol
 }  // namespace remoting