HomeSort by relevance Sort by last modified time
    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(&current_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