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>
 
 #include "base/scoped_ptr.h"
 #include "net/socket/socket.h"
 #include "remoting/protocol/session.h"
 
 namespace remoting {
 namespace protocol {
 
 extern const char kTestJid[];
 
 // FakeSocket implement net::Socket interface for FakeConnection. All data
 // written to FakeSocket is stored in a buffer returned by written_data().
 // 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_; }
+  const std::string& written_data() const { return written_data_; }
 
-  void AppendInputData(char* data, int data_size);
-  int input_pos() { return input_pos_; }
+  void AppendInputData(const char* data, int data_size);
+  int input_pos() const { return input_pos_; }
+  bool read_pending() const { 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);
 
  private:
   bool read_pending_;
   scoped_refptr<net::IOBuffer> read_buffer_;
   int read_buffer_size_;
   net::CompletionCallback* read_callback_;
 
   std::string written_data_;
   std::string input_data_;
   int input_pos_;
 };
 
 // FakeUdpSocket is similar to FakeSocket but behaves as UDP socket. All written
 // packets are stored separetely in written_packets(). AppendInputPacket() adds
 // one packet that will be returned by Read().
 class FakeUdpSocket : public net::Socket {
  public:
   FakeUdpSocket();
   virtual ~FakeUdpSocket();
 
-  const std::vector<std::string>& written_packets() {
+  const std::vector<std::string>& written_packets() const {
     return written_packets_;
   }
 
-  void AppendInputPacket(char* data, int data_size);
-  int input_pos() { return input_pos_; }
+  void AppendInputPacket(const char* data, int data_size);
+  int input_pos() const { 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 14 matching lines @@
  public:
   FakeSession();
   virtual ~FakeSession();
 
   StateChangeCallback* state_change_callback() { return callback_.get(); }
 
   void set_message_loop(MessageLoop* message_loop) {
     message_loop_ = message_loop;
   }
 
-  bool is_closed() { return closed_; }
+  bool is_closed() const { return closed_; }
 
   virtual void SetStateChangeCallback(StateChangeCallback* callback);
 
   virtual FakeSocket* control_channel();
   virtual FakeSocket* event_channel();
   virtual FakeSocket* video_channel();
 
   virtual FakeUdpSocket* video_rtp_channel();
   virtual FakeUdpSocket* video_rtcp_channel();
 
@@ skipping 26 matching lines @@
   std::string receiver_token_;
 
   std::string jid_;
   bool closed_;
 };
 
 }  // namespace protocol
 }  // namespace remoting
 
 #endif  // REMOTING_PROTOCOL_FAKE_SESSION_H_