Make IPC::Channel::Listener:OnMessageReceived have a return value indicating ...

ipc/ipc_fuzzing_tests.cc

 // Copyright (c) 2006-2008 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.
 
 #include <stdio.h>
 #include <string>
 #include <sstream>
 
 #include "base/message_loop.h"
 #include "base/platform_thread.h"
@@ skipping 140 matching lines @@
   FUZZER_ROUTING_ID = 5
 };
 
 // The fuzzer server class. It runs in a child process and expects
 // only two IPC calls; after that it exits the message loop which
 // terminates the child process.
 class FuzzerServerListener : public SimpleListener {
  public:
   FuzzerServerListener() : message_count_(2), pending_messages_(0) {
   }
-  virtual void OnMessageReceived(const IPC::Message& msg) {
+  virtual bool OnMessageReceived(const IPC::Message& msg) {
     if (msg.routing_id() == MSG_ROUTING_CONTROL) {
       ++pending_messages_;
       IPC_BEGIN_MESSAGE_MAP(FuzzerServerListener, msg)
         IPC_MESSAGE_HANDLER(MsgClassIS, OnMsgClassISMessage)
         IPC_MESSAGE_HANDLER(MsgClassSI, OnMsgClassSIMessage)
       IPC_END_MESSAGE_MAP()
       if (pending_messages_) {
         // Probably a problem de-serializing the message.
         ReplyMsgNotHandled(msg.type());
       }
     }
+    return true;
   }
 
  private:
   void OnMsgClassISMessage(int value, const std::wstring& text) {
     UseData(MsgClassIS::ID, value, text);
     RoundtripAckReply(FUZZER_ROUTING_ID, MsgClassIS::ID, value);
     Cleanup();
   }
 
   void OnMsgClassSIMessage(const std::wstring& text, int value) {
@@ skipping 31 matching lines @@
 
   int message_count_;
   int pending_messages_;
 };
 
 class FuzzerClientListener : public SimpleListener {
  public:
   FuzzerClientListener() : last_msg_(NULL) {
   }
 
-  virtual void OnMessageReceived(const IPC::Message& msg) {
+  virtual bool OnMessageReceived(const IPC::Message& msg) {
     last_msg_ = new IPC::Message(msg);
     MessageLoop::current()->Quit();
+    return true;
   }
 
   bool ExpectMessage(int value, uint32 type_id) {
     if (!MsgHandlerInternal(type_id))
       return false;
     int msg_value1 = 0;
     int msg_value2 = 0;
     void* iter = NULL;
     if (!last_msg_->ReadInt(&iter, &msg_value1))
       return false;
@@ skipping 185 matching lines @@
   msg = new IPC::Message(MSG_ROUTING_CONTROL, MsgClassIS::ID,
                          IPC::Message::PRIORITY_NORMAL);
   msg->WriteInt(0x64);
   msg->WriteInt(0x32);
   EXPECT_FALSE(server.OnMessageReceived(*msg));
   delete msg;
 
   EXPECT_EQ(0, server.unhandled_msgs());
 #endif
 }