hw::trezor::ProtocolV1 Class Reference

#include <transport.hpp>

Inheritance diagram for hw::trezor::ProtocolV1:

Collaboration diagram for hw::trezor::ProtocolV1:

Public Member Functions
	ProtocolV1 ()=default
virtual	~ProtocolV1 ()=default
void	write (Transport &transport, const google::protobuf::Message &req) override
void	read (Transport &transport, std::shared_ptr< google::protobuf::Message > &msg, messages::MessageType *msg_type=nullptr) override
Public Member Functions inherited from hw::trezor::Protocol
	Protocol ()=default
virtual	~Protocol ()=default
virtual void	session_begin (Transport &transport)
virtual void	session_end (Transport &transport)

Detailed Description

Definition at line 124 of file transport.hpp.

Constructor & Destructor Documentation

ProtocolV1()

hw::trezor::ProtocolV1::ProtocolV1 ( )

default

~ProtocolV1()

virtual hw::trezor::ProtocolV1::~ProtocolV1 ( )

virtualdefault

Here is the call graph for this function:

Member Function Documentation

read()

void hw::trezor::ProtocolV1::read ( Transport & transport, std::shared_ptr< google::protobuf::Message > & msg, messages::MessageType * msg_type = nullptr )

overridevirtual

Implements hw::trezor::Protocol.

Definition at line 223 of file transport.cpp.

                                                                                                                        {
    char chunk[REPLEN];
 
    // Initial chunk read
    size_t nread = transport.read_chunk(chunk, REPLEN);
    if (nread != REPLEN){
      throw exc::CommunicationException("Read chunk has invalid size");
    }
 
    if (strncmp(chunk, "?##", 3) != 0){
      throw exc::CommunicationException("Malformed chunk");
    }
 
    uint16_t tag;
    uint32_t len;
    nread -= 3 + 6;
    deserialize_message_header(chunk + 3, tag, len);
 
    std::string data_acc(chunk + 3 + 6, nread);
    data_acc.reserve(len);
 
    while(nread < len){
      const size_t cur = transport.read_chunk(chunk, REPLEN);
      if (chunk[0] != '?'){
        throw exc::CommunicationException("Chunk malformed");
      }
 
      data_acc.append(chunk + 1, cur - 1);
      nread += cur - 1;
    }
 
    if (msg_type){
      *msg_type = static_cast<messages::MessageType>(tag);
    }
 
    if (nread < len){
      throw exc::CommunicationException("Response incomplete");
    }
 
    std::shared_ptr<google::protobuf::Message> msg_wrap(MessageMapper::get_message(tag));
    if (!msg_wrap->ParseFromArray(data_acc.c_str(), len)){
      throw exc::CommunicationException("Message could not be parsed");
    }
 
    msg = msg_wrap;
  }

Here is the call graph for this function:

write()

void hw::trezor::ProtocolV1::write ( Transport & transport, const google::protobuf::Message & req )

overridevirtual

Implements hw::trezor::Protocol.

Definition at line 192 of file transport.cpp.

                                                                                {
    const auto msg_size = message_size(req);
    const auto buff_size = serialize_message_buffer_size(msg_size) + 2;
 
    std::unique_ptr<uint8_t[]> req_buff(new uint8_t[buff_size]);
    uint8_t * req_buff_raw = req_buff.get();
    req_buff_raw[0] = '#';
    req_buff_raw[1] = '#';
 
    serialize_message(req, msg_size, req_buff_raw + 2, buff_size - 2);
 
    size_t offset = 0;
    uint8_t chunk_buff[REPLEN];
 
    // Chunk by chunk upload
    while(offset < buff_size){
      auto to_copy = std::min((size_t)(buff_size - offset), (size_t)(REPLEN - 1));
 
      chunk_buff[0] = '?';
      memcpy(chunk_buff + 1, req_buff_raw + offset, to_copy);
 
      // Pad with zeros
      if (to_copy < REPLEN - 1){
        memset(chunk_buff + 1 + to_copy, 0, REPLEN - 1 - to_copy);
      }
 
      transport.write_chunk(chunk_buff, REPLEN);
      offset += REPLEN - 1;
    }
  }

Here is the call graph for this function:

---

The documentation for this class was generated from the following files:

• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/src/device_trezor/trezor/transport.hpp
• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/src/device_trezor/trezor/transport.cpp