Commit 606bbbc0 authored by Andreas Schmidt's avatar Andreas Schmidt
Browse files

Fix float error. Smaller payloads.

parent 3f93b30f

prrt/proto/processes/dataTransmitter.c

+1 −1
Original line number Diff line number Diff line
@@ -104,7 +104,7 @@ static bool send_packet(PrrtSocket *sock_ptr, PrrtPacket *packet) { 
    }



    prrtTimestamp_t now = PrrtClock_get_current_time_us();

    if (!sock_ptr->pacingEnabled || BBR_getPacingRate(sock_ptr->receiver->bbr) != 0) {

    if (sock_ptr->pacingEnabled && BBR_getPacingRate(sock_ptr->receiver->bbr) != 0) {

        debug(DEBUG_DATATRANSMITTER, "Payload: %u, PacingRate: %u, Pacing Time: %u", packet->payloadLength, BBR_getPacingRate(sock_ptr->receiver->bbr), packet->payloadLength / BBR_getPacingRate(sock_ptr->receiver->bbr));

        sock_ptr->nextSendTime = now + (packet->payloadLength / BBR_getPacingRate(sock_ptr->receiver->bbr));

    }

prrt/time-receiver.c

+1 −1
Original line number Diff line number Diff line
@@ -128,7 +128,7 @@ int main(int argc, char **argv) { 


		memcpy(&old, buffer, sizeof(struct timespec));



		fprintf(stderr, "%u: %lli\n", i, timedelta(&old, &now));

		fprintf(stderr, "%u: %lli\n", i, timedelta(&now, &old));



        i++;

    }

prrt/time-sender.c

+1 −1
Original line number Diff line number Diff line
@@ -125,7 +125,7 @@ int main(int argc, char **argv) { 
    XlapTimestampTableInstall(s, ts_redundancy_packet, tstable_redundancy);



    uint32_t j = 0;

    char buf[MAX_PAYLOAD_LENGTH - PRRT_PACKET_GENERAL_HEADER_SIZE - PRRT_PACKET_DATA_HEADER_SIZE - 20];

    char buf[1500];

	memset(buf, 0x0, sizeof(buf));

	assert(sizeof(buf) >= sizeof(struct timespec));

    while (j < rounds) {