ipc/attachment_broker.cc

   1 // Copyright 2015 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/attachment_broker.h"
   6
   7 #include <algorithm>
   8
   9 namespace {
  10 IPC::AttachmentBroker* g_attachment_broker = nullptr;
  11 }
  12
  13 namespace IPC {
  14
  15 // static
  16 void AttachmentBroker::SetGlobal(AttachmentBroker* broker) {
  17   // TODO(erikchen): There should be a CHECK here to make sure that
  18   // |g_attachment_broker| is nullptr. Right now, this causes problems with
  19   // --single_process and similar testing conditions. I'm temporarily removing
  20   // this CHECK. http://crbug.com/534539.
  21   g_attachment_broker = broker;
  22 }
  23
  24 // static
  25 AttachmentBroker* AttachmentBroker::GetGlobal() {
  26   return g_attachment_broker;
  27 }
  28
  29 AttachmentBroker::AttachmentBroker() {}
  30 AttachmentBroker::~AttachmentBroker() {}
  31
  32 bool AttachmentBroker::GetAttachmentWithId(
  33     BrokerableAttachment::AttachmentId id,
  34     scoped_refptr<BrokerableAttachment>* out_attachment) {
  35   for (AttachmentVector::iterator it = attachments_.begin();
  36        it != attachments_.end(); ++it) {
  37     if ((*it)->GetIdentifier() == id) {
  38       *out_attachment = *it;
  39       attachments_.erase(it);
  40       return true;
  41     }
  42   }
  43   return false;
  44 }
  45
  46 void AttachmentBroker::AddObserver(AttachmentBroker::Observer* observer) {
  47   auto it = std::find(observers_.begin(), observers_.end(), observer);
  48   if (it == observers_.end())
  49     observers_.push_back(observer);
  50 }
  51
  52 void AttachmentBroker::RemoveObserver(AttachmentBroker::Observer* observer) {
  53   auto it = std::find(observers_.begin(), observers_.end(), observer);
  54   if (it != observers_.end())
  55     observers_.erase(it);
  56 }
  57
  58 void AttachmentBroker::HandleReceivedAttachment(
  59     const scoped_refptr<BrokerableAttachment>& attachment) {
  60   attachments_.push_back(attachment);
  61   NotifyObservers(attachment->GetIdentifier());
  62 }
  63
  64 void AttachmentBroker::NotifyObservers(
  65     const BrokerableAttachment::AttachmentId& id) {
  66   // Make a copy of observers_ to avoid mutations during iteration.
  67   std::vector<Observer*> observers = observers_;
  68   for (Observer* observer : observers) {
  69     observer->ReceivedBrokerableAttachmentWithId(id);
  70   }
  71 }
  72
  73 }  // namespace IPC