Commit 2499d195 authored by Joanne Hugé's avatar Joanne Hugé

wip: debug recv recieving too small messages

parent 10656cd6
......@@ -399,6 +399,9 @@ static void *recv_thread(void *p) {
int ret = recvmmsg(recv_sockfd, msgh + j, RX_BURST_SIZE - j, 0, NULL);
if(ret <= -1)
error(EXIT_FAILURE, errno, "recvmmsg error");
for(int l = 0; l < ret; l++)
if((msgh + j + l)->msg_len != PACKET_SIZE)
log_info("RECV_THREAD", "Received message has len %d instead of %d", (msgh + j + l)->msg_len, PACKET_SIZE);
j += ret;
update_counter(&recv_counter, ret);
}
......@@ -560,6 +563,12 @@ static void *decode_thread(void *p) {
data = rbuf_read(&rx_rbuf);
printf("data = \n");
for(int l = 0; l < IQ_PAYLOAD; l++)
printf("%X", data[l]);
printf("\n");
log_exit("", "");
int j = ETHERNET_HEADER + ECPRI_COMMON_HEADER;
uint16_t antenna_id = ntohs(*((uint16_t *) (data + j + 0)));
uint8_t seq_id = ((uint8_t) (*((uint16_t * ) (data + j + 2)) >> 8));
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment