Add support for attaching filters to an IPC TestSink.

ipc/ipc_test_sink.cc

 // Copyright (c) 2011 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 "ipc/ipc_test_sink.h"
 
 #include "ipc/ipc_message.h"
 
 namespace IPC {
 
 TestSink::TestSink() {
 }
 
 TestSink::~TestSink() {
 }
 
 bool TestSink::Send(Message* message) {
   OnMessageReceived(*message);
   delete message;
   return true;
 }
 
 bool TestSink::OnMessageReceived(const Message& msg) {
   messages_.push_back(Message(msg));
+  FOR_EACH_OBSERVER(Observer, observer_list_, OnMessageReceived(msg));
   return true;
 }
 
 void TestSink::ClearMessages() {
   messages_.clear();
 }
 
 const Message* TestSink::GetMessageAt(size_t index) const {
   if (index >= messages_.size())
     return NULL;
@@ skipping 15 matching lines @@
     if (messages_[i].type() == id) {
       found_count++;
       found_index = i;
     }
   }
   if (found_count != 1)
     return NULL;  // Didn't find a unique one.
   return &messages_[found_index];
 }
 
+void TestSink::AddObserver(Observer* obs) {
+  observer_list_.AddObserver(obs);
+}
+
+void TestSink::RemoveObserver(Observer* obs) {
+  observer_list_.RemoveObserver(obs);

[noelutz, 2011/01/28 02:13:06]

Maybe check in the destructor that all observers have been removed?

[Brian Ryner, 2011/01/28 02:19:59]

I'm not sure how common this is for observer interfaces in Chrome -- Brett?

+}
+
 }  // namespace IPC