Mirrors/overte-lubosz
3
0
Fork 0
mirror of https://github.com/lubosz/overte.git synced 2025-04-08 20:22:34 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

change stats to display difference between gap and expected gap

Browse source
This commit is contained in:
ZappoMan 2014-08-01 14:07:14 -07:00
parent 8db66e4322
commit 36f635ed8d
1 changed files with 22 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
tests/jitter/src/main.cpp
View file

@ -66,27 +66,29 @@ void runSend(const char* addressOption, int port, int gap, int size) {
servaddr.sin_port=htons(port);
const int SAMPLES_FOR_30_SECONDS = 30 * 1000 / gap;
MovingMinMaxAvg<quint64> timeGaps(1, SAMPLES_FOR_30_SECONDS); // stats
MovingMinMaxAvg<int> timeGaps(1, SAMPLES_FOR_30_SECONDS); // stats
quint64 last = usecTimestampNow();
while (true) {
quint64 now = usecTimestampNow();
quint64 actualGap = now - last;
int actualGap = now - last;
if (actualGap >= gap) {
sendto(sockfd, outputBuffer, size, 0, (struct sockaddr *)&servaddr, sizeof(servaddr));
timeGaps.update(actualGap);
std::cout << "packet sent gap:" << actualGap << " "
<< "min:" << timeGaps.getMin() << " "
<< "max:" << timeGaps.getMax() << " "
<< "avg:" << timeGaps.getAverage() << " "
<< "min last 30:" << timeGaps.getWindowMin() << " "
<< "max last 30:" << timeGaps.getWindowMax() << " "
<< "avg last 30:" << timeGaps.getWindowAverage() << " "
int gapDifferece = actualGap - gap;
timeGaps.update(gapDifferece);
std::cout << "packet sent gap: " << actualGap << " "
<< "gapDifference: " << gapDifferece << " "
<< "min: " << timeGaps.getMin() << " "
<< "max: " << timeGaps.getMax() << " "
<< "avg: " << timeGaps.getAverage() << " "
<< "min last 30: " << timeGaps.getWindowMin() << " "
<< "max last 30: " << timeGaps.getWindowMax() << " "
<< "avg last 30: " << timeGaps.getWindowAverage() << " "
<< "\n";
last = now;
}
@ -111,7 +113,7 @@ void runReceive(const char* addressOption, int port, int gap, int size) {
myaddr.sin_port=htons(port);
const int SAMPLES_FOR_30_SECONDS = 30 * 1000 / gap;
MovingMinMaxAvg<quint64> timeGaps(1, SAMPLES_FOR_30_SECONDS); // stats
MovingMinMaxAvg<int> timeGaps(1, SAMPLES_FOR_30_SECONDS); // stats
if (bind(sockfd, (struct sockaddr *)&myaddr, sizeof(myaddr)) < 0) {
std::cout << "bind failed\n";
@ -129,14 +131,16 @@ void runReceive(const char* addressOption, int port, int gap, int size) {
} else {
quint64 now = usecTimestampNow();
int actualGap = now - last;
timeGaps.update(actualGap);
int gapDifferece = actualGap - gap;
timeGaps.update(gapDifferece);
std::cout << "packet received gap:" << actualGap << " "
<< "min:" << timeGaps.getMin() << " "
<< "max:" << timeGaps.getMax() << " "
<< "avg:" << timeGaps.getAverage() << " "
<< "min last 30:" << timeGaps.getWindowMin() << " "
<< "max last 30:" << timeGaps.getWindowMax() << " "
<< "avg last 30:" << timeGaps.getWindowAverage() << " "
<< "gapDifference: " << gapDifferece << " "
<< "min: " << timeGaps.getMin() << " "
<< "max: " << timeGaps.getMax() << " "
<< "avg: " << timeGaps.getAverage() << " "
<< "min last 30: " << timeGaps.getWindowMin() << " "
<< "max last 30: " << timeGaps.getWindowMax() << " "
<< "avg last 30: " << timeGaps.getWindowAverage() << " "
<< "\n";
last = now;
}