Commit c4695481 authored by Andreas Schmidt's avatar Andreas Schmidt
Browse files

Pacing.

parent 90bb4cdb

prrt/proto/processes/dataTransmitter.c

+9 −5
Original line number Diff line number Diff line
@@ -102,15 +102,19 @@ static bool send_packet(PrrtSocket *sock_ptr, PrrtPacket *packet) { 
                usleep_nano(diff / 2);

            }

        } while (diff > 0);

    } else {

        usleep_nano(1);

    }



    prrtTimestamp_t now = PrrtClock_get_current_time_us();

    if (sock_ptr->pacingEnabled) {

        uint32_t pacing_rate = BBR_getPacingRate(sock_ptr->receiver->bbr);

    if (sock_ptr->pacingEnabled && pacing_rate != 0) {

        if(pacing_rate != 0) {

            debug(DEBUG_DATATRANSMITTER, "Payload: %u, PacingRate: %u, Pacing Time: %u", packet->payloadLength, pacing_rate, packet->payloadLength /

                                                                                                                             pacing_rate);

            sock_ptr->nextSendTime = now + ((prrtTimedelta_t) round((((double) 1000 * 1000 * packet->payloadLength) / pacing_rate)));

        }

    }



    struct timespec timestamp;

    uint64_t cyclestamp;