quentin/tor_multipath_voip
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Add a parsing tool

Browse source
This commit is contained in:
Quentin 2021-01-29 12:40:45 +01:00
parent c16221e2e7
commit 8cebe37466
1 changed files with 93 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

93
results/b2/parse.c Normal file
View file

@ -0,0 +1,93 @@
#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include <uuid/uuid.h>
#include <assert.h>
int cmpuint64t(const void* u1, const void* u2) {
const uint64_t *i1 = u1;
const uint64_t *i2 = u2;
return *i1 < *i2 ? -1 : 1;
}
int main(int argc, char *argv[]) {
FILE *r, *w;
uint64_t taglen;
char tag[255];
uuid_t uuid;
char uuidstr[37];
uint64_t meascount;
uint64_t meas[25*60*90]; /* can contain up to ninety minutes of meas */
uint64_t target = 25*60*5; /* five minutes of measures*/
if ((w = fopen("5min.csv", "w")) == NULL) goto iofail;
for (int i = 1; i < argc; i++) {
printf("selected %s\n", argv[i]);
if ((r = fopen(argv[i], "r")) == NULL) goto iofail;
if (fread(&taglen, sizeof(taglen), 1, r) != 1) goto iofail;
assert(taglen < 255);
tag[taglen] = 0;
if (fread(&tag, sizeof(char), taglen, r) != taglen) goto iofail;
printf("tag: %s\n", tag);
if (fread(uuid, sizeof(uuid_t), 1, r) != 1) goto iofail;
uuid_unparse(uuid, uuidstr);
printf("uuid: %s\n", uuidstr);
if (fread(&meascount, sizeof(meascount), 1, r) != 1) goto iofail;
assert(meascount == 135000);
if (fread(meas, sizeof(meas[0]), meascount, r) != meascount) goto iofail;
printf("read %d values\n", meascount);
uint64_t* real_log = meas;
uint64_t real_log_size = meascount;
// cut beginning
while (real_log[0] == 0 && real_log_size > 0) {
real_log = &(real_log[1]);
real_log_size--;
}
printf("cutted %lu values at beginning\n", meascount - real_log_size);
assert(real_log_size > target);
uint64_t missmeas = 0;
for (int j = 0; j < target; j++) {
if (real_log[j] == 0) missmeas++;
}
uint64_t targetmeas = target - missmeas;
// AVERAGE
double avg = 0;
for (int j = 0; j < target; j++) {
if (real_log[j] == 0) continue;
avg += ((double) real_log[j]) / ((double) targetmeas);
}
// DISTRIBUTION
qsort (real_log, target, sizeof(uint64_t), cmpuint64t);
uint64_t min = real_log[missmeas];
uint64_t max = real_log[target-1];
uint64_t med = real_log[(int)(0.50 * targetmeas) - 1 + missmeas];
uint64_t q25 = real_log[(int)(0.25 * targetmeas) - 1 + missmeas];
uint64_t q75 = real_log[(int)(0.75 * targetmeas) - 1 + missmeas];
uint64_t q99 = real_log[(int)(0.99 * targetmeas) - 1 + missmeas];
if (fprintf(w, "%s,%s,count,%lu\n", tag, uuidstr, targetmeas) < 0) goto iofail;
if (fprintf(w, "%s,%s,avg,%f\n", tag, uuidstr, avg) < 0) goto iofail;
if (fprintf(w, "%s,%s,min,%lu\n", tag, uuidstr, min) < 0) goto iofail;
if (fprintf(w, "%s,%s,max,%lu\n", tag, uuidstr, max) < 0) goto iofail;
if (fprintf(w, "%s,%s,med,%lu\n", tag, uuidstr, med) < 0) goto iofail;
if (fprintf(w, "%s,%s,q25,%lu\n", tag, uuidstr, q25) < 0) goto iofail;
if (fprintf(w, "%s,%s,q75,%lu\n", tag, uuidstr, q75) < 0) goto iofail;
if (fprintf(w, "%s,%s,q99,%lu\n", tag, uuidstr, q99) < 0) goto iofail;
if(fclose(r) != 0) goto iofail;
}
if(fclose(w) != 0) goto iofail;
printf("success\n");
return EXIT_SUCCESS;
iofail:
perror("an IO failure occurred");
return EXIT_FAILURE;
}