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
88
89
90
91
92
93
94
95
96
97
98
|
// Copyright 2016 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_H_
#define MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_H_
#include <string_view>
#include <vector>
#include "base/check.h"
#include "mojo/public/c/system/message_pipe.h"
#include "mojo/public/cpp/system/handle.h"
#include "mojo/public/cpp/system/system_export.h"
namespace mojo {
const MojoMessageHandle kInvalidMessageHandleValue =
MOJO_MESSAGE_HANDLE_INVALID;
// Handle wrapper base class for a |MojoMessageHandle|.
class MessageHandle {
public:
MessageHandle() : value_(kInvalidMessageHandleValue) {}
explicit MessageHandle(MojoMessageHandle value) : value_(value) {}
~MessageHandle() {}
void swap(MessageHandle& other) {
MojoMessageHandle temp = value_;
value_ = other.value_;
other.value_ = temp;
}
bool is_valid() const { return value_ != kInvalidMessageHandleValue; }
const MojoMessageHandle& value() const { return value_; }
MojoMessageHandle* mutable_value() { return &value_; }
void set_value(MojoMessageHandle value) { value_ = value; }
void Close() {
DCHECK(is_valid());
[[maybe_unused]] MojoResult result = MojoDestroyMessage(value_);
DCHECK_EQ(MOJO_RESULT_OK, result);
}
private:
MojoMessageHandle value_;
};
using ScopedMessageHandle = ScopedHandleBase<MessageHandle>;
inline MojoResult CreateMessage(ScopedMessageHandle* handle,
MojoCreateMessageFlags flags) {
MojoCreateMessageOptions options = {};
options.struct_size = sizeof(options);
options.flags = flags;
MojoMessageHandle raw_handle;
MojoResult rv = MojoCreateMessage(&options, &raw_handle);
if (rv != MOJO_RESULT_OK)
return rv;
handle->reset(MessageHandle(raw_handle));
return MOJO_RESULT_OK;
}
inline MojoResult GetMessageData(MessageHandle message,
void** buffer,
uint32_t* num_bytes,
std::vector<ScopedHandle>* handles,
MojoGetMessageDataFlags flags) {
DCHECK(message.is_valid());
DCHECK(num_bytes);
DCHECK(buffer);
uint32_t num_handles = 0;
MojoGetMessageDataOptions options;
options.struct_size = sizeof(options);
options.flags = flags;
MojoResult rv = MojoGetMessageData(message.value(), &options, buffer,
num_bytes, nullptr, &num_handles);
if (rv != MOJO_RESULT_RESOURCE_EXHAUSTED) {
if (handles)
handles->clear();
return rv;
}
handles->resize(num_handles);
return MojoGetMessageData(message.value(), &options, buffer, num_bytes,
reinterpret_cast<MojoHandle*>(handles->data()),
&num_handles);
}
MOJO_CPP_SYSTEM_EXPORT MojoResult
NotifyBadMessage(MessageHandle message, const std::string_view& error);
} // namespace mojo
#endif // MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_H_
|
