Index: ipc/ipc_tests.cc |
=================================================================== |
--- ipc/ipc_tests.cc (revision 70108) |
+++ ipc/ipc_tests.cc (working copy) |
@@ -182,7 +182,7 @@ |
class MyChannelListener : public IPC::Channel::Listener { |
public: |
- virtual void OnMessageReceived(const IPC::Message& message) { |
+ virtual bool OnMessageReceived(const IPC::Message& message) { |
IPC::MessageIterator iter(message); |
iter.NextInt(); |
@@ -196,6 +196,7 @@ |
} else { |
Send(sender_, "Foo"); |
} |
+ return true; |
} |
virtual void OnChannelError() { |
@@ -291,7 +292,7 @@ |
SendNextMessage(); |
} |
- virtual void OnMessageReceived(const IPC::Message& message) { |
+ virtual bool OnMessageReceived(const IPC::Message& message) { |
IPC::MessageIterator iter(message); |
iter.NextInt(); |
@@ -299,6 +300,7 @@ |
const std::string big_string = iter.NextString(); |
EXPECT_EQ(kLongMessageStringNumBytes - 1, big_string.length()); |
SendNextMessage(); |
+ return true; |
} |
virtual void OnChannelError() { |
@@ -402,7 +404,7 @@ |
std::cout << "Client Latency: " << latency_messages_ << std::endl; |
} |
- virtual void OnMessageReceived(const IPC::Message& message) { |
+ virtual bool OnMessageReceived(const IPC::Message& message) { |
count_messages_++; |
IPC::MessageIterator iter(message); |
int time = iter.NextInt(); |
@@ -421,6 +423,7 @@ |
msg->WriteInt(msgid); |
msg->WriteString(payload); |
channel_->Send(msg); |
+ return true; |
} |
private: |
IPC::Channel *channel_; |
@@ -446,7 +449,7 @@ |
std::cout << "Server Latency: " << latency_messages_ << std::endl; |
} |
- virtual void OnMessageReceived(const IPC::Message& message) { |
+ virtual bool OnMessageReceived(const IPC::Message& message) { |
count_messages_++; |
// decode the string so this gets counted in the total time |
IPC::MessageIterator iter(message); |
@@ -467,7 +470,7 @@ |
msg->WriteString("quit"); |
channel_->Send(msg); |
SetTimer(NULL, 1, 250, (TIMERPROC) PostQuitMessage); |
- return; |
+ return true; |
} |
IPC::Message* msg = new IPC::Message(0, |
@@ -477,6 +480,7 @@ |
msg->WriteInt(count_down_); |
msg->WriteString(payload_); |
channel_->Send(msg); |
+ return true; |
} |
private: |