Better debugging messages for received messages

diff --git a/iop.c b/iop.c
index a9a44fb6b3c70d7e13e3c23285c34a4fadf207cf..05d39196d9b3ab02d5cdf411112bb80c293ce56b 100644 (file)
--- a/iop.c
+++ b/iop.c
@@ -172,6 +172,7 @@ process_request(forb_port_t *port, CDR_Codec *codec, uint32_t message_size)
        CDR_Codec reply_codec;
        forb_exec_req_t *exec_req;
        uint32_t req_size, data_size, header_size;
+       char str[32];
 
        data_size = CDR_data_size(codec);
        ret = forb_iop_request_header_deserialize(codec, &request_header);
@@ -190,7 +191,8 @@ process_request(forb_port_t *port, CDR_Codec *codec, uint32_t message_size)
        header_size = data_size - CDR_data_size(codec);
        req_size = message_size - header_size;
 
-       ul_logdeb("rcvd request: id=%u, iface=%s, method=%hd\n",
+       ul_logdeb("rcvd request: src=%s, id=%u, iface=%s, method=%hd\n",
+                 forb_server_id_to_string(str, &request_header.source, sizeof(str)),
                  request_header.request_id,
                  request_header.iface,
                  request_header.method_index);
@@ -274,6 +276,7 @@ process_reply(forb_port_t *port, CDR_Codec *codec)
        forb_request_t *req;
 
        forb_iop_reply_header_deserialize(codec, &rh);
+       ul_logdeb("rcvd reply: id=%u\n", rh.request_id);
        req = forb_request_find(forb, &rh.request_id);
        if (!req) {
                ul_logerr("Received reply to unknown request_id %u\n", rh.request_id);
@@ -371,7 +374,9 @@ process_message(forb_port_t *port, const forb_iop_message_header *mh,
                        break;
        }
        if (CDR_data_size(codec) != data_size - mh->message_size) {
-               ul_logerr("Message of type %d handled incorrectly\n", mh->message_type);
+               ul_logerr("Message of type %d handled incorrectly (size=%d, processed=%d)\n",
+                         mh->message_type, mh->message_size,
+                         data_size - CDR_data_size(codec));
        }
 }