1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
// Copyright 2017 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "third_party/blink/public/common/messaging/message_port_channel.h"
#include "base/memory/ref_counted.h"
#include "base/synchronization/lock.h"
#include "mojo/public/cpp/system/message_pipe.h"
#include "third_party/blink/public/common/messaging/message_port_descriptor.h"
namespace blink {
class MessagePortChannel::State : public base::RefCountedThreadSafe<State> {
public:
State();
explicit State(MessagePortDescriptor handle);
MessagePortDescriptor TakeHandle();
const MessagePortDescriptor& handle() const { return handle_; }
private:
friend class base::RefCountedThreadSafe<State>;
~State();
// Guards access to the fields below.
base::Lock lock_;
MessagePortDescriptor handle_;
};
MessagePortChannel::~MessagePortChannel() = default;
MessagePortChannel::MessagePortChannel() : state_(new State()) {}
MessagePortChannel::MessagePortChannel(const MessagePortChannel& other) =
default;
MessagePortChannel& MessagePortChannel::operator=(
const MessagePortChannel& other) {
state_ = other.state_;
return *this;
}
MessagePortChannel::MessagePortChannel(MessagePortDescriptor handle)
: state_(new State(std::move(handle))) {}
const MessagePortDescriptor& MessagePortChannel::GetHandle() const {
return state_->handle();
}
MessagePortDescriptor MessagePortChannel::ReleaseHandle() const {
return state_->TakeHandle();
}
// static
std::vector<MessagePortDescriptor> MessagePortChannel::ReleaseHandles(
const std::vector<MessagePortChannel>& ports) {
std::vector<MessagePortDescriptor> handles(ports.size());
for (size_t i = 0; i < ports.size(); ++i)
handles[i] = ports[i].ReleaseHandle();
return handles;
}
// static
std::vector<MessagePortChannel> MessagePortChannel::CreateFromHandles(
std::vector<MessagePortDescriptor> handles) {
std::vector<MessagePortChannel> ports(handles.size());
for (size_t i = 0; i < handles.size(); ++i)
ports[i] = MessagePortChannel(std::move(handles[i]));
return ports;
}
MessagePortChannel::State::State() = default;
MessagePortChannel::State::State(MessagePortDescriptor handle)
: handle_(std::move(handle)) {}
MessagePortDescriptor MessagePortChannel::State::TakeHandle() {
base::AutoLock lock(lock_);
return std::move(handle_);
}
MessagePortChannel::State::~State() = default;
} // namespace blink
|
