ipc/ipc_test_sink.cc

   1 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "ipc/ipc_test_sink.h"
   6
   7 #include "ipc/ipc_listener.h"
   8 #include "ipc/ipc_message.h"
   9
  10 namespace IPC {
  11
  12 TestSink::TestSink() {
  13 }
  14
  15 TestSink::~TestSink() {
  16 }
  17
  18 bool TestSink::Send(Message* message) {
  19   OnMessageReceived(*message);
  20   delete message;
  21   return true;
  22 }
  23
  24 bool TestSink::Connect() {
  25   NOTIMPLEMENTED();
  26   return false;
  27 }
  28
  29 void TestSink::Close() {
  30   NOTIMPLEMENTED();
  31 }
  32
  33 base::ProcessId TestSink::GetPeerPID() const {
  34   NOTIMPLEMENTED();
  35   return base::ProcessId();
  36 }
  37
  38
  39 bool TestSink::OnMessageReceived(const Message& msg) {
  40   ObserverListBase<Listener>::Iterator it(filter_list_);
  41   Listener* observer;
  42   while ((observer = it.GetNext()) != NULL) {
  43     if (observer->OnMessageReceived(msg))
  44       return true;
  45   }
  46
  47   // No filter handled the message, so store it.
  48   messages_.push_back(Message(msg));
  49   return true;
  50 }
  51
  52 void TestSink::ClearMessages() {
  53   messages_.clear();
  54 }
  55
  56 const Message* TestSink::GetMessageAt(size_t index) const {
  57   if (index >= messages_.size())
  58     return NULL;
  59   return &messages_[index];
  60 }
  61
  62 const Message* TestSink::GetFirstMessageMatching(uint32 id) const {
  63   for (size_t i = 0; i < messages_.size(); i++) {
  64     if (messages_[i].type() == id)
  65       return &messages_[i];
  66   }
  67   return NULL;
  68 }
  69
  70 const Message* TestSink::GetUniqueMessageMatching(uint32 id) const {
  71   size_t found_index = 0;
  72   size_t found_count = 0;
  73   for (size_t i = 0; i < messages_.size(); i++) {
  74     if (messages_[i].type() == id) {
  75       found_count++;
  76       found_index = i;
  77     }
  78   }
  79   if (found_count != 1)
  80     return NULL;  // Didn't find a unique one.
  81   return &messages_[found_index];
  82 }
  83
  84 void TestSink::AddFilter(Listener* filter) {
  85   filter_list_.AddObserver(filter);
  86 }
  87
  88 void TestSink::RemoveFilter(Listener* filter) {
  89   filter_list_.RemoveObserver(filter);
  90 }
  91
  92 #if defined(OS_POSIX) && !defined(OS_NACL)
  93
  94 int TestSink::GetClientFileDescriptor() const {
  95   NOTREACHED();
  96   return -1;
  97 }
  98
  99 int TestSink::TakeClientFileDescriptor() {
 100   NOTREACHED();
 101   return -1;
 102 }
 103
 104 #endif  // defined(OS_POSIX) && !defined(OS_NACL)
 105
 106 }  // namespace IPC