Commit 1d618a0e authored by Andreas Schmidt's avatar Andreas Schmidt

Pause appSendPace on pacing and Pipe_push.

parent 2691cf40
Pipeline #2827 passed with stages
in 1 minute and 40 seconds
......@@ -282,9 +282,13 @@ int sendpacket(PrrtSocket *s, const uint8_t *data, const size_t data_len, bool s
XlapTimeStampCycle(s, ts_data_packet, packet->sequenceNumber, PrrtSubmitPackage);
if (sync) {
PrrtDataTransmitter_transmit(s, packet);
PrrtPace_track_pause(s->appSendPace);
PrrtSocket_pace(s, false);
PrrtPace_track_resume(s->appSendPace);
} else {
PrrtPace_track_pause(s->appSendPace);
Pipe_push(s->sendDataQueue, &packet->asListNode);
PrrtPace_track_resume(s->appSendPace);
}
PrrtReceiver_on_application_write(s->receiver, Pipe_get_size(s->sendDataQueue), s->sequenceNumberSource);
......
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