Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(982)

Unified Diff: ipc/attachment_broker.cc

Issue 2473993003: Delete IPC::ChannelPosix, IPC::ChannelWin and IPC::AttachmentBroker. (Closed)
Patch Set: Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « ipc/attachment_broker.h ('k') | ipc/attachment_broker_mac_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: ipc/attachment_broker.cc
diff --git a/ipc/attachment_broker.cc b/ipc/attachment_broker.cc
deleted file mode 100644
index e27414465047685bced9f9ba38893a591cf39266..0000000000000000000000000000000000000000
--- a/ipc/attachment_broker.cc
+++ /dev/null
@@ -1,161 +0,0 @@
-// Copyright 2015 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/attachment_broker.h"
-
-#include <algorithm>
-
-#include "base/bind.h"
-#include "base/location.h"
-#include "base/sequenced_task_runner.h"
-
-namespace {
-IPC::AttachmentBroker* g_attachment_broker = nullptr;
-}
-
-namespace IPC {
-
-// static
-void AttachmentBroker::SetGlobal(AttachmentBroker* broker) {
- g_attachment_broker = broker;
-}
-
-// static
-AttachmentBroker* AttachmentBroker::GetGlobal() {
- return g_attachment_broker;
-}
-
-AttachmentBroker::AttachmentBroker() : last_unique_id_(0) {}
-AttachmentBroker::~AttachmentBroker() {}
-
-bool AttachmentBroker::GetAttachmentWithId(
- BrokerableAttachment::AttachmentId id,
- scoped_refptr<BrokerableAttachment>* out_attachment) {
- base::AutoLock auto_lock(*get_lock());
- for (AttachmentVector::iterator it = attachments_.begin();
- it != attachments_.end(); ++it) {
- if ((*it)->GetIdentifier() == id) {
- *out_attachment = *it;
- attachments_.erase(it);
- return true;
- }
- }
- return false;
-}
-
-void AttachmentBroker::AddObserver(
- AttachmentBroker::Observer* observer,
- const scoped_refptr<base::SequencedTaskRunner>& runner) {
- base::AutoLock auto_lock(*get_lock());
- auto it = std::find_if(observers_.begin(), observers_.end(),
- [observer](const ObserverInfo& info) {
- return info.observer == observer;
- });
- if (it == observers_.end()) {
- ObserverInfo info;
- info.observer = observer;
- info.runner = runner;
- info.unique_id = ++last_unique_id_;
- observers_.push_back(info);
-
- // Give the observer a chance to handle attachments that arrived while the
- // observer was handling the message that caused it to register, but our
- // mutex was not yet locked.
- for (const auto& attachment : attachments_) {
- info.runner->PostTask(
- FROM_HERE,
- base::Bind(&AttachmentBroker::NotifyObserver, base::Unretained(this),
- info.unique_id, attachment->GetIdentifier()));
- }
- }
-}
-
-void AttachmentBroker::RemoveObserver(AttachmentBroker::Observer* observer) {
- base::AutoLock auto_lock(*get_lock());
- auto it = std::find_if(observers_.begin(), observers_.end(),
- [observer](const ObserverInfo& info) {
- return info.observer == observer;
- });
- if (it != observers_.end())
- observers_.erase(it);
-}
-
-void AttachmentBroker::RegisterCommunicationChannel(
- Endpoint* endpoint,
- scoped_refptr<base::SingleThreadTaskRunner> runner) {
- NOTREACHED();
-}
-
-void AttachmentBroker::DeregisterCommunicationChannel(Endpoint* endpoint) {
- NOTREACHED();
-}
-
-void AttachmentBroker::RegisterBrokerCommunicationChannel(Endpoint* endpoint) {
- NOTREACHED();
-}
-
-void AttachmentBroker::DeregisterBrokerCommunicationChannel(
- Endpoint* endpoint) {
- NOTREACHED();
-}
-
-void AttachmentBroker::ReceivedPeerPid(base::ProcessId peer_pid) {
- NOTREACHED();
-}
-
-bool AttachmentBroker::IsPrivilegedBroker() {
- NOTREACHED();
- return false;
-}
-
-void AttachmentBroker::HandleReceivedAttachment(
- const scoped_refptr<BrokerableAttachment>& attachment) {
- {
- base::AutoLock auto_lock(*get_lock());
- attachments_.push_back(attachment);
- }
- NotifyObservers(attachment->GetIdentifier());
-}
-
-void AttachmentBroker::NotifyObservers(
- const BrokerableAttachment::AttachmentId& id) {
- base::AutoLock auto_lock(*get_lock());
-
- // Dispatch notifications onto the appropriate task runners. This has two
- // effects:
- // 1. Ensures that the notification is posted from the right task runner.
- // 2. Avoids any complications from re-entrant functions, since one of the
- // observers may be halfway through processing some messages.
- for (const auto& info : observers_) {
- info.runner->PostTask(
- FROM_HERE, base::Bind(&AttachmentBroker::NotifyObserver,
- base::Unretained(this), info.unique_id, id));
- }
-}
-
-void AttachmentBroker::NotifyObserver(
- int unique_id,
- const BrokerableAttachment::AttachmentId& id) {
- Observer* observer = nullptr;
- {
- // Check that the same observer is still registered.
- base::AutoLock auto_lock(*get_lock());
- auto it = std::find_if(observers_.begin(), observers_.end(),
- [unique_id](const ObserverInfo& info) {
- return info.unique_id == unique_id;
- });
- if (it == observers_.end())
- return;
- observer = it->observer;
- }
-
- observer->ReceivedBrokerableAttachmentWithId(id);
-}
-
-AttachmentBroker::ObserverInfo::ObserverInfo() {}
-AttachmentBroker::ObserverInfo::ObserverInfo(const ObserverInfo& other) =
- default;
-AttachmentBroker::ObserverInfo::~ObserverInfo() {}
-
-} // namespace IPC
« no previous file with comments | « ipc/attachment_broker.h ('k') | ipc/attachment_broker_mac_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698