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
|
// Copyright 2019 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chromeos/components/mojo_bootstrap/pending_connection_manager.h"
#include <utility>
#include "base/check_op.h"
#include "base/no_destructor.h"
namespace mojo_bootstrap {
// static
PendingConnectionManager& PendingConnectionManager::Get() {
static base::NoDestructor<PendingConnectionManager> connection_manager;
return *connection_manager;
}
bool PendingConnectionManager::OpenIpcChannel(const std::string& token,
base::ScopedFD fd) {
auto it = open_ipc_channel_callbacks_.find(token);
if (it == open_ipc_channel_callbacks_.end()) {
return false;
}
OpenIpcChannelCallback callback = std::move(it->second);
open_ipc_channel_callbacks_.erase(it);
std::move(callback).Run(std::move(fd));
return true;
}
void PendingConnectionManager::ExpectOpenIpcChannel(
base::UnguessableToken token,
OpenIpcChannelCallback handler) {
DCHECK(token);
open_ipc_channel_callbacks_.emplace(token.ToString(), std::move(handler));
}
void PendingConnectionManager::CancelExpectedOpenIpcChannel(
base::UnguessableToken token) {
bool erased = open_ipc_channel_callbacks_.erase(token.ToString());
DCHECK_EQ(1u, erased);
}
PendingConnectionManager::PendingConnectionManager() = default;
PendingConnectionManager::~PendingConnectionManager() = default;
} // namespace mojo_bootstrap
|
