Skip to content

Commit 5b707dc

Browse files
committed
dbg: decoder buffer printouts
1 parent 545007f commit 5b707dc

File tree

3 files changed

+12
-0
lines changed

3 files changed

+12
-0
lines changed

src/client.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ class RPCClient {
5858
bool get_response(RType& result) {
5959
RpcError tmp_error;
6060
decoder->decode();
61+
decoder->print_buf("Client->");
6162

6263
if (decoder->get_response(_waiting_msg_id, result, tmp_error)) {
6364
lastError.code = tmp_error.code;

src/decoder.h

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,16 @@ class RpcDecoder {
1818
public:
1919
RpcDecoder(ITransport& transport) : _transport(transport) {}
2020

21+
void print_buf(String msg) {
22+
Serial.print(msg);
23+
Serial.print("-- DECODER BUF -- : ");
24+
for (size_t i=0; i<_bytes_stored; i++){
25+
Serial.print(_raw_buffer[i], HEX);
26+
Serial.print(" ");
27+
}
28+
Serial.println(" ");
29+
}
30+
2131
template<typename... Args>
2232
bool send_call(const int call_type, const MsgPack::str_t method, uint32_t& msg_id, Args&&... args) {
2333

src/server.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ class RPCServer {
4040

4141
bool get_rpc() {
4242
decoder->decode();
43+
decoder->print_buf("Server->");
4344
if (_rpc_size > 0) return true; // Already have a request
4445
// TODO USE A QUEUE
4546
_rpc_size = decoder->get_request(_rpc_buffer, RPC_BUFFER_SIZE);

0 commit comments

Comments
 (0)