From 6852d7d96f3643277e8dab49e3bfa0e482aafffe Mon Sep 17 00:00:00 2001 From: "sergeyu@chromium.org" Date: Sat, 22 Jan 2011 02:34:56 +0000 Subject: Changed MessageReader so that it doesn't read from the socket if there are other messages being processed. Added unittests for MessageReader. BUG=None TEST=Unittests Review URL: http://codereview.chromium.org/6271004 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@72262 0039d316-1c4b-4281-b951-d872f2087c98 --- remoting/protocol/fake_session.h | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) (limited to 'remoting/protocol/fake_session.h') diff --git a/remoting/protocol/fake_session.h b/remoting/protocol/fake_session.h index 62818e4..3ffe20b 100644 --- a/remoting/protocol/fake_session.h +++ b/remoting/protocol/fake_session.h @@ -27,10 +27,11 @@ class FakeSocket : public net::Socket { 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, @@ -60,12 +61,12 @@ class FakeUdpSocket : public net::Socket { FakeUdpSocket(); virtual ~FakeUdpSocket(); - const std::vector& written_packets() { + const std::vector& 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, @@ -100,7 +101,7 @@ class FakeSession : public Session { message_loop_ = message_loop; } - bool is_closed() { return closed_; } + bool is_closed() const { return closed_; } virtual void SetStateChangeCallback(StateChangeCallback* callback); -- cgit v1.1