Fixed timestamp field name
[p2p-testing-infrastructure.git] / Utils / test-socket-signal / test / process / parse_timespan.R
1 #
2 # get mean download time, standard deviation and mean download speed
3 #
4
5 args <- commandArgs(trailingOnly = TRUE)
6
7 input_file_if <- args[2]
8 input_file_stop <- args[3]
9 input_file_suspend <- args[4]
10
11 data_if <- read.table(input_file_if, sep=" ")
12 data_stop <- read.table(input_file_stop, sep=" ")
13 data_suspend <- read.table(input_file_suspend, sep=" ")
14 # data_* $ V1 = timestamp
15 # data_* $ V2 = value
16
17 timestamp_values <- unique(data_if$V1)
18
19 mean_values_if = list()
20 sd_values_if = list()
21 rsd_values_if = list()
22
23 for (timestamp in timestamp_values) {
24         data_subset_if <- data_if[data_if$V1 %in% timestamp,]
25         values <- data_subset_if$V2
26         m <- mean(values)
27         s <- sd(values)
28         rsd <- s / m * 100
29         
30         mean_values_if = c(mean_values_if, m)
31         sd_values_if = c(sd_values_if, s)
32         rsd_values_if = c(rsd_values_if, rsd)
33 }
34
35
36 mean_values_stop = list()
37 sd_values_stop = list()
38 rsd_values_stop = list()
39
40 for (timestamp in timestamp_values) {
41         data_subset_stop <- data_stop[data_stop$V1 %in% timestamp,]
42         values <- data_subset_stop$V2
43         m <- mean(values)
44         s <- sd(values)
45         rsd <- s / m * 100
46         
47         mean_values_stop = c(mean_values_stop, m)
48         sd_values_stop = c(sd_values_stop, s)
49         rsd_values_stop = c(rsd_values_stop, rsd)
50 }
51
52
53 mean_values_suspend = list()
54 sd_values_suspend = list()
55 rsd_values_suspend = list()
56
57 for (timestamp in timestamp_values) {
58         data_subset_suspend <- data_suspend[data_suspend$V1 %in% timestamp,]
59         values <- data_subset_suspend$V2
60         m <- mean(values)
61         s <- sd(values)
62         rsd <- s / m * 100
63         
64         mean_values_suspend = c(mean_values_suspend, m)
65         sd_values_suspend = c(sd_values_suspend, s)
66         rsd_values_suspend = c(rsd_values_suspend, rsd)
67 }
68
69 all_data = data.frame(timestamp=timestamp_values, mean_if=unlist(mean_values_if), sd_if=unlist(sd_values_if), rsd_if=unlist(rsd_values_if), mean_stop=unlist(mean_values_stop), sd_stop=unlist(sd_values_stop), rsd_stop=unlist(rsd_values_stop), mean_suspend=unlist(mean_values_suspend), sd_suspend=unlist(sd_values_suspend), rsd_suspend=unlist(rsd_values_suspend))
70 print(all_data)