1

src/pkt_normalizer.c

@@ -245,6 +245,8 @@ static void etcp_input_ready_cb(struct ll_queue* q, void* arg) {
     struct ll_entry* in_dgram = queue_data_get(pn->input);
     if (!in_dgram) { queue_resume_callback(pn->input); return; }
 
+    if (debug_should_output(DEBUG_LEVEL_DEBUG, DEBUG_CATEGORY_DUMP)) log_dump("->NORM", in_dgram->dgram, in_dgram->len);
+
     pn_buf_renew(pn);
     // DEBUG_INFO(DEBUG_CATEGORY_NORMALIZER, "pn_packer: new pkt hdrpos=%d",pn->data_ptr);
     if (!pn->data) goto exit;  // Allocation failed
@@ -340,6 +342,7 @@ static void pn_unpacker_cb(struct ll_queue* q, void* arg) {
 
             if (pn->recvpart->len == pn->recvpart->memlen) {
                 DEBUG_DEBUG(DEBUG_CATEGORY_NORMALIZER, "unpacked dgram (size=%d)", pn->recvpart->len);
+                if (debug_should_output(DEBUG_LEVEL_DEBUG, DEBUG_CATEGORY_DUMP)) log_dump("NORM->", pn->recvpart->dgram, pn->recvpart->len);
                 queue_data_put(pn->output, pn->recvpart, 0);
                 pn->recvpart = NULL;
             }