Changed MessageReader so that it doesn't read from the socket if there are

remoting/protocol/fake_session.h

 // 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.
 
 #ifndef REMOTING_PROTOCOL_FAKE_SESSION_H_
 #define REMOTING_PROTOCOL_FAKE_SESSION_H_
 
 #include <string>
 #include <vector>
 
@@ skipping 11 matching lines @@
 // Read() reads data from another buffer that can be set with AppendInputData().
 // Pending reads are supported, so if there is a pending read AppendInputData()
 // calls the read callback.
 class FakeSocket : public net::Socket {
  public:
   FakeSocket();
   virtual ~FakeSocket();
 
   const std::string& written_data() { return written_data_; }
 
-  void AppendInputData(char* data, int data_size);
+  void AppendInputData(const char* data, int data_size);
   int input_pos() { return input_pos_; }

[awong, 2011/01/20 20:06:38]

const functions here and below?

[Sergey Ulanov, 2011/01/20 21:55:57]

Done.

+  bool read_pending() { return read_pending_; }
 
   // net::Socket interface.
   virtual int Read(net::IOBuffer* buf, int buf_len,
                    net::CompletionCallback* callback);
   virtual int Write(net::IOBuffer* buf, int buf_len,
                     net::CompletionCallback* callback);
 
   virtual bool SetReceiveBufferSize(int32 size);
   virtual bool SetSendBufferSize(int32 size);
 
@@ skipping 13 matching lines @@
 // one packet that will be returned by Read().
 class FakeUdpSocket : public net::Socket {
  public:
   FakeUdpSocket();
   virtual ~FakeUdpSocket();
 
   const std::vector<std::string>& written_packets() {
     return written_packets_;
   }
 
-  void AppendInputPacket(char* data, int data_size);
+  void AppendInputPacket(const char* data, int data_size);
   int input_pos() { return input_pos_; }
 
   // net::Socket interface.
   virtual int Read(net::IOBuffer* buf, int buf_len,
                    net::CompletionCallback* callback);
   virtual int Write(net::IOBuffer* buf, int buf_len,
                     net::CompletionCallback* callback);
 
   virtual bool SetReceiveBufferSize(int32 size);
   virtual bool SetSendBufferSize(int32 size);
@@ skipping 62 matching lines @@
   std::string receiver_token_;
 
   std::string jid_;
   bool closed_;
 };
 
 }  // namespace protocol
 }  // namespace remoting
 
 #endif  // REMOTING_PROTOCOL_FAKE_SESSION_H_