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
|
// 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/cloneable_message.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "third_party/blink/public/mojom/blob/blob.mojom.h"
#include "third_party/blink/public/mojom/messaging/cloneable_message.mojom.h"
namespace blink {
CloneableMessage::CloneableMessage() = default;
CloneableMessage::CloneableMessage(CloneableMessage&&) = default;
CloneableMessage& CloneableMessage::operator=(CloneableMessage&&) = default;
CloneableMessage::~CloneableMessage() = default;
CloneableMessage CloneableMessage::ShallowClone() const {
CloneableMessage clone;
clone.encoded_message = encoded_message;
// Both |blobs| and |file_system_access_tokens| contain mojo pending remotes.
// ShallowClone() follows these steps to clone each pending remote:
//
// (1) Temporarily bind the source pending remote in this CloneableMessage's
// |blobs| or |file_system_access_tokens|. This requires a const_cast because
// it temporarily modifies this CloneableMessage's |blobs| or
// |file_system_access_tokens|.
//
// (2) Use the bound remote to call Clone(), which creates a new remote for
// the new clone.
//
// (3) Unbind the source remote to restore this CloneableMessage's |blobs| or
// |file_system_access_tokens| back to the original pending remote from (1).
for (const auto& blob : blobs) {
mojom::SerializedBlobPtr& source_serialized_blob =
const_cast<mojom::SerializedBlobPtr&>(blob);
mojo::Remote<mojom::Blob> source_blob(
std::move(source_serialized_blob->blob));
mojo::PendingRemote<mojom::Blob> cloned_blob;
source_blob->Clone(cloned_blob.InitWithNewPipeAndPassReceiver());
clone.blobs.push_back(mojom::SerializedBlob::New(
source_serialized_blob->uuid, source_serialized_blob->content_type,
source_serialized_blob->size, std::move(cloned_blob)));
source_serialized_blob->blob = source_blob.Unbind();
}
// Clone the |file_system_access_tokens| pending remotes using the steps
// described by the comment above.
std::vector<mojo::PendingRemote<mojom::FileSystemAccessTransferToken>>&
source_tokens = const_cast<std::vector<
mojo::PendingRemote<mojom::FileSystemAccessTransferToken>>&>(
file_system_access_tokens);
for (auto& token : source_tokens) {
mojo::Remote<mojom::FileSystemAccessTransferToken> source_token(
std::move(token));
mojo::PendingRemote<mojom::FileSystemAccessTransferToken> cloned_token;
source_token->Clone(cloned_token.InitWithNewPipeAndPassReceiver());
clone.file_system_access_tokens.push_back(std::move(cloned_token));
token = source_token.Unbind();
}
clone.sender_agent_cluster_id = sender_agent_cluster_id;
return clone;
}
void CloneableMessage::EnsureDataIsOwned() {
if (encoded_message.data() == owned_encoded_message.data())
return;
owned_encoded_message.assign(encoded_message.begin(), encoded_message.end());
encoded_message = owned_encoded_message;
}
} // namespace blink
|
