OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "ipc/attachment_broker.h" | 5 #include "ipc/attachment_broker.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 namespace { | 9 namespace { |
10 IPC::AttachmentBroker* g_attachment_broker = nullptr; | 10 IPC::AttachmentBroker* g_attachment_broker = nullptr; |
11 } | 11 } |
12 | 12 |
13 namespace IPC { | 13 namespace IPC { |
14 | 14 |
15 // static | 15 // static |
16 void AttachmentBroker::SetGlobal(AttachmentBroker* broker) { | 16 void AttachmentBroker::SetGlobal(AttachmentBroker* broker) { |
17 CHECK(!g_attachment_broker || !broker) | 17 CHECK(!g_attachment_broker || !broker) |
18 << "Global attachment broker address: " << broker | 18 << "Global attachment broker address: " << broker |
19 << ". New attachment broker address: " << broker; | 19 << ". New attachment broker address: " << broker; |
20 g_attachment_broker = broker; | 20 g_attachment_broker = broker; |
21 } | 21 } |
22 | 22 |
23 // static | 23 // static |
24 AttachmentBroker* AttachmentBroker::GetGlobal() { | 24 AttachmentBroker* AttachmentBroker::GetGlobal() { |
25 return g_attachment_broker; | 25 return g_attachment_broker; |
26 } | 26 } |
27 | 27 |
| 28 #if defined(OS_MACOSX) && !defined(OS_IOS) |
| 29 AttachmentBroker::AttachmentBroker() : port_provider_(nullptr) {} |
| 30 #else |
28 AttachmentBroker::AttachmentBroker() {} | 31 AttachmentBroker::AttachmentBroker() {} |
| 32 #endif // defined(OS_MACOSX) && !defined(OS_IOS) |
| 33 |
29 AttachmentBroker::~AttachmentBroker() {} | 34 AttachmentBroker::~AttachmentBroker() {} |
30 | 35 |
31 bool AttachmentBroker::GetAttachmentWithId( | 36 bool AttachmentBroker::GetAttachmentWithId( |
32 BrokerableAttachment::AttachmentId id, | 37 BrokerableAttachment::AttachmentId id, |
33 scoped_refptr<BrokerableAttachment>* out_attachment) { | 38 scoped_refptr<BrokerableAttachment>* out_attachment) { |
34 for (AttachmentVector::iterator it = attachments_.begin(); | 39 for (AttachmentVector::iterator it = attachments_.begin(); |
35 it != attachments_.end(); ++it) { | 40 it != attachments_.end(); ++it) { |
36 if ((*it)->GetIdentifier() == id) { | 41 if ((*it)->GetIdentifier() == id) { |
37 *out_attachment = *it; | 42 *out_attachment = *it; |
38 attachments_.erase(it); | 43 attachments_.erase(it); |
39 return true; | 44 return true; |
40 } | 45 } |
41 } | 46 } |
42 return false; | 47 return false; |
43 } | 48 } |
44 | 49 |
45 void AttachmentBroker::AddObserver(AttachmentBroker::Observer* observer) { | 50 void AttachmentBroker::AddObserver(AttachmentBroker::Observer* observer) { |
46 auto it = std::find(observers_.begin(), observers_.end(), observer); | 51 auto it = std::find(observers_.begin(), observers_.end(), observer); |
47 if (it == observers_.end()) | 52 if (it == observers_.end()) |
48 observers_.push_back(observer); | 53 observers_.push_back(observer); |
49 } | 54 } |
50 | 55 |
51 void AttachmentBroker::RemoveObserver(AttachmentBroker::Observer* observer) { | 56 void AttachmentBroker::RemoveObserver(AttachmentBroker::Observer* observer) { |
52 auto it = std::find(observers_.begin(), observers_.end(), observer); | 57 auto it = std::find(observers_.begin(), observers_.end(), observer); |
53 if (it != observers_.end()) | 58 if (it != observers_.end()) |
54 observers_.erase(it); | 59 observers_.erase(it); |
55 } | 60 } |
56 | 61 |
| 62 void AttachmentBroker::RegisterCommunicationChannel(Endpoint* endpoint) { |
| 63 NOTREACHED(); |
| 64 } |
| 65 |
| 66 void AttachmentBroker::DeregisterCommunicationChannel(Endpoint* endpoint) { |
| 67 NOTREACHED(); |
| 68 } |
| 69 |
57 void AttachmentBroker::HandleReceivedAttachment( | 70 void AttachmentBroker::HandleReceivedAttachment( |
58 const scoped_refptr<BrokerableAttachment>& attachment) { | 71 const scoped_refptr<BrokerableAttachment>& attachment) { |
59 attachments_.push_back(attachment); | 72 attachments_.push_back(attachment); |
60 NotifyObservers(attachment->GetIdentifier()); | 73 NotifyObservers(attachment->GetIdentifier()); |
61 } | 74 } |
62 | 75 |
63 void AttachmentBroker::NotifyObservers( | 76 void AttachmentBroker::NotifyObservers( |
64 const BrokerableAttachment::AttachmentId& id) { | 77 const BrokerableAttachment::AttachmentId& id) { |
65 // Make a copy of observers_ to avoid mutations during iteration. | 78 // Make a copy of observers_ to avoid mutations during iteration. |
66 std::vector<Observer*> observers = observers_; | 79 std::vector<Observer*> observers = observers_; |
67 for (Observer* observer : observers) { | 80 for (Observer* observer : observers) { |
68 observer->ReceivedBrokerableAttachmentWithId(id); | 81 observer->ReceivedBrokerableAttachmentWithId(id); |
69 } | 82 } |
70 } | 83 } |
71 | 84 |
72 } // namespace IPC | 85 } // namespace IPC |
OLD | NEW |