| // Copyright 2018 The Fuchsia Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #ifndef SRC_DEVELOPER_DEBUG_IPC_MESSAGE_READER_H_ |
| #define SRC_DEVELOPER_DEBUG_IPC_MESSAGE_READER_H_ |
| |
| #include <stdint.h> |
| |
| #include <cstdint> |
| #include <string> |
| #include <vector> |
| |
| #include "src/developer/debug/ipc/protocol.h" |
| #include "src/developer/debug/shared/serialization.h" |
| |
| namespace debug_ipc { |
| |
| class MessageReader : public Serializer { |
| public: |
| MessageReader(std::vector<char> message, uint32_t version) |
| : message_(std::move(message)), version_(version) {} |
| |
| bool has_error() const { return has_error_; } |
| |
| // Returns the number of bytes available still to read. |
| size_t remaining() const { return message_.size() - offset_; } |
| size_t message_size() const { return message_.size(); } |
| |
| // Implement |Serializer|. |
| uint32_t GetVersion() const override { return version_; } |
| // Although it's called "SerializeBytes", it's actually "DeserializeBytes". |
| void SerializeBytes(void* data, uint32_t len) override; |
| |
| private: |
| const std::vector<char> message_; |
| |
| uint32_t version_ = 0; |
| |
| size_t offset_ = 0; // Current read offset. |
| |
| bool has_error_ = false; |
| }; |
| |
| // Helper functions to deserialize bytes into messages. Returns true if succeeds. |
| #define FN(msg_type) \ |
| bool Deserialize(std::vector<char> data, msg_type##Request* request, uint32_t* transaction_id, \ |
| uint32_t version); \ |
| bool Deserialize(std::vector<char> data, msg_type##Reply* reply, uint32_t* transaction_id, \ |
| uint32_t version); |
| |
| FOR_EACH_REQUEST_TYPE(FN) |
| #undef FN |
| |
| #define FN(msg_type) bool Deserialize(std::vector<char> data, msg_type* notify, uint32_t version); |
| |
| FOR_EACH_NOTIFICATION_TYPE(FN) |
| #undef FN |
| |
| } // namespace debug_ipc |
| |
| #endif // SRC_DEVELOPER_DEBUG_IPC_MESSAGE_READER_H_ |