OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:MessageBuffer
(Results
1 - 15
of
15
) sorted by null
/external/libmojo/mojo/public/cpp/bindings/lib/
message_buffer.h
20
class
MessageBuffer
: public Buffer {
23
MessageBuffer
(size_t capacity, bool zero_initialized);
26
MessageBuffer
(ScopedMessageHandle message, uint32_t num_bytes);
28
~
MessageBuffer
();
37
DISALLOW_COPY_AND_ASSIGN(
MessageBuffer
);
message_buffer.cc
14
MessageBuffer
::
MessageBuffer
(size_t capacity, bool zero_initialized) {
32
MessageBuffer
::
MessageBuffer
(ScopedMessageHandle message, uint32_t num_bytes) {
43
MessageBuffer
::~
MessageBuffer
() {}
45
void
MessageBuffer
::NotifyBadMessage(const std::string& error) {
message.cc
68
buffer_.reset(new internal::
MessageBuffer
(capacity, zero_initialized));
75
buffer_.reset(new internal::
MessageBuffer
(std::move(message), num_bytes));
/system/connectivity/wifilogd/
message_buffer.cpp
29
MessageBuffer
::
MessageBuffer
(size_t size)
34
bool
MessageBuffer
::Append(const uint8_t* message, uint16_t message_len) {
46
bool
MessageBuffer
::CanFitEver(uint16_t length) const {
51
bool
MessageBuffer
::CanFitNow(uint16_t length) const {
57
void
MessageBuffer
::Clear() {
62
std::tuple<const uint8_t*, size_t>
MessageBuffer
::ConsumeNextMessage() {
78
void
MessageBuffer
::Rewind() { read_pos_ = 0; }
82
void
MessageBuffer
::AppendHeader(uint16_t message_len) {
88
void
MessageBuffer
::AppendRawBytes(const void* data_start, size_t data_len)
[
all
...]
message_buffer.h
33
class
MessageBuffer
{
35
// A wrapper which guarantees that a
MessageBuffer
will be rewound,
40
explicit ScopedRewinder(NONNULL
MessageBuffer
* buffer) : buffer_(buffer) {}
44
MessageBuffer
* const buffer_;
48
explicit
MessageBuffer
(size_t size);
69
// message, returns {nullptr, 0}.
MessageBuffer
retains ownership of the
73
// Returns the size of
MessageBuffer
's per-message header.
106
//
MessageBuffer
is a value type, so it would be semantically reasonable to
110
DISALLOW_COPY_AND_ASSIGN(
MessageBuffer
);
command_processor.h
76
// The
MessageBuffer
is inlined, since there's not much value to mocking
85
MessageBuffer
current_log_buffer_;
command_processor.cpp
212
MessageBuffer
::ScopedRewinder rewinder(¤t_log_buffer_);
/frameworks/native/libs/vr/libpdx/private/pdx/rpc/
message_buffer.h
16
using
MessageBuffer
= ThreadLocalBuffer<T, Allocator, Capacity, Slot>;
payload.h
15
// of a thread-local
MessageBuffer
.
19
using BufferType = typename
MessageBuffer
<Slot>::BufferType;
20
using ValueType = typename
MessageBuffer
<Slot>::ValueType;
24
: buffer_(
MessageBuffer
<Slot>::GetEmptyBuffer()),
29
// into the underlying
MessageBuffer
.
33
// underlying
MessageBuffer
.
36
// Returns a const iterator marking the end of the underlying
MessageBuffer
.
39
// Resizes the underlying
MessageBuffer
and sets the cursor to the beginning.
49
// Adds |size| bytes to the size of the underlying
MessageBuffer
and positions
58
// Clears the underlying
MessageBuffer
and sets the cursor to the beginning
[
all
...]
/frameworks/native/libs/vr/libpdx/
thread_local_buffer_tests.cpp
20
return reinterpret_cast<std::uintptr_t>(&
MessageBuffer
<Slot>::buffer_);
27
return reinterpret_cast<std::uintptr_t>(
MessageBuffer
<Slot>::buffer_);
98
MessageBuffer
<SendSlotX>::GetBuffer();
108
auto& buffer1 =
MessageBuffer
<SendSlotA>::GetBuffer();
109
auto& buffer2 =
MessageBuffer
<SendSlotA>::GetBuffer();
110
auto& buffer3 =
MessageBuffer
<SendSlotB>::GetBuffer();
111
auto& buffer4 =
MessageBuffer
<SendSlotB>::GetBuffer();
/external/deqp/framework/delibs/decpp/
deBlockBuffer.cpp
57
typedef BlockBuffer<Message>
MessageBuffer
;
62
Consumer (
MessageBuffer
& buffer, int numProducers)
117
MessageBuffer
& m_buffer;
125
Producer (
MessageBuffer
& buffer, deUint16 threadId, int numMessages)
154
MessageBuffer
& m_buffer;
170
MessageBuffer
buffer (blockSize, numBlocks);
/external/v8/src/inspector/
v8-inspector-session-impl.cc
136
class
MessageBuffer
: public StringBuffer {
138
static std::unique_ptr<
MessageBuffer
> create(
140
return std::unique_ptr<
MessageBuffer
>(
141
new
MessageBuffer
(std::move(message)));
153
explicit
MessageBuffer
(std::unique_ptr<protocol::Serializable> message)
164
m_channel->sendResponse(callId,
MessageBuffer
::create(std::move(message)));
169
m_channel->sendNotification(
MessageBuffer
::create(std::move(message)));
/system/connectivity/wifilogd/tests/
message_buffer_unittest.cpp
30
constexpr size_t kHeaderSizeBytes =
MessageBuffer
::GetHeaderSize();
61
MessageBuffer
buffer_;
332
EXPECT_DEATH(
MessageBuffer
{kHeaderSizeBytes}, "Check failed");
/external/libmojo/mojo/public/cpp/bindings/
message.h
161
std::unique_ptr<internal::
MessageBuffer
> buffer_;
/frameworks/native/libs/vr/libpdx_default_transport/
pdx_benchmarks.cpp
50
using android::pdx::rpc::
MessageBuffer
;
480
MessageBuffer
<ReplyBuffer>::Reserve(kMaxMessageSize - 1);
[
all
...]
Completed in 157 milliseconds