Commit 79d8b160 authored by Stefan Reif's avatar Stefan Reif

Add more timestamps

parent c1862815
Pipeline #903 passed with stages
in 2 minutes and 26 seconds
......@@ -227,12 +227,18 @@ void *receive_data_loop(void *ptr)
PrrtTimestampPlaceholderUse(sock_ptr, ts_data_packet, seqno, &tsph1);
PrrtTimestampPlaceholderUse(sock_ptr, ts_data_packet, seqno, &tsph2);
PrrtTimestampPlaceholderUse(sock_ptr, ts_data_packet, seqno, &tsph3);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, seqno, HandlePacketStart);
handle_data_packet(sock_ptr, packet, remote);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, seqno, HandlePacketEnd);
} else if(packetType == PACKET_TYPE_REDUNDANCY) {
PrrtTimestampPlaceholderUse(sock_ptr, ts_redundancy_packet, seqno, &tsph1);
PrrtTimestampPlaceholderUse(sock_ptr, ts_redundancy_packet, seqno, &tsph2);
PrrtTimestampPlaceholderUse(sock_ptr, ts_redundancy_packet, seqno, &tsph3);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, seqno, HandlePacketStart);
handle_redundancy_packet(sock_ptr, packet);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, seqno, HandlePacketEnd);
} else {
PrrtPacket_print(packet);
PrrtPacket_destroy(packet);
......
......@@ -158,7 +158,9 @@ int32_t PrrtSocket_recv(PrrtSocket *sock_ptr, void *buf_ptr) {
PrrtPacket *packet = List_shift(sock_ptr->inQueue);
prrtPacketLength_t len = (prrtPacketLength_t) (packet->payloadLength - PRRT_PACKET_DATA_HEADER_SIZE);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, packet->sequenceNumber, CopyOutputStart);
PrrtPacket_copy_payload_to_buffer(buf_ptr, packet, PRRT_PACKET_DATA_HEADER_SIZE);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, packet->sequenceNumber, CopyOutputEnd);
debug(DEBUG_SOCKET, "len: %d", (int) len);
......
......@@ -32,6 +32,10 @@ typedef union PrrtTimestamp {
LinkReceive, \
DecodeStart, \
DecodeEnd, \
HandlePacketStart, \
HandlePacketEnd, \
CopyOutputStart, \
CopyOutputEnd, \
SendFeedbackStart, \
SendFeedbackEnd, \
PrrtDeliver \
......
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