Commit 2bd69c3f authored by Stefan Reif's avatar Stefan Reif

Add more timestamps

parent 79d8b160
Pipeline #907 passed with stages
in 2 minutes and 51 seconds
......@@ -86,6 +86,7 @@ void *send_data_loop(void *ptr)
}
PrrtPacket *packet = List_shift(sock_ptr->outQueue);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, packet->sequenceNumber, PrrtTransmitStart);
if(block == NULL) {
block = PrrtBlock_create(sock_ptr->codingParameters, packet->sequenceNumber);
}
......@@ -97,6 +98,7 @@ void *send_data_loop(void *ptr)
PrrtPacket *packetToSend = PrrtPacket_copy(packet);
send_packet(sock_ptr, packetToSend);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, packet->sequenceNumber, PrrtTransmitEnd);
PrrtBlock_insert_data_packet(block, packet);
......
......@@ -130,6 +130,7 @@ int PrrtSocket_send(PrrtSocket *sock_ptr, const uint8_t *data, const size_t data
PrrtPacket *packet = PrrtPacket_create_data_packet(5, data, (prrtPacketLength_t) data_len, sequenceNumber, PrrtApplicationConstraints_get_target_delay(sock_ptr->applicationConstraints));
PrrtTimestampPlaceholderUse(sock_ptr, ts_data_packet, packet->sequenceNumber, &tsph);
PrrtTimeStampCycle(sock_ptr, ts_data_packet, packet->sequenceNumber, PrrtSubmitPackage);
check(pthread_mutex_lock(&sock_ptr->outQueueFilledMutex) == 0, "Lock failed.");
List_push(sock_ptr->outQueue, packet);
check(pthread_cond_signal(&sock_ptr->outQueueFilledCv) == 0, "Signal failed.");
......
......@@ -25,8 +25,11 @@ typedef union PrrtTimestamp {
#define TIMESTAMP_ID_LIST \
PrrtSendStart, \
PrrtSendEnd, \
PrrtSubmitPackage, \
PrrtEncodeStart, \
PrrtEncodeEnd, \
PrrtTransmitStart, \
PrrtTransmitEnd, \
LinkTransmitStart, \
LinkTransmitEnd, \
LinkReceive, \
......
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