blob: c750ba54ff4447823aa311f0baf8de14fc191e80 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
IDX_TIME = 0
IDX_STATE = 5
def adjustTimestamps(perFile)
startTime = 0
offset = 0
lastDeactivation = -1
lastSample = nil
perFile.each_key do |file|
perFile[file].each do |line|
time = line[0].to_i
startTime = time if startTime == 0
time = time - startTime - offset
line[IDX_TIME] = time.to_s
if line[IDX_STATE] == 'RUNNING'
lastSample = line
elsif line[IDX_STATE] == 'ACTIVATED'
offset = time - lastDeactivation unless lastDeactivation == -1
perFile[file].delete(line)
elsif line[IDX_STATE] == 'DEACTIVATED'
lastDeactivation = time
perFile[file].delete(line)
elsif line[IDX_STATE] == 'FINISHED'
# print last sample: time speed=0 downloaded left=0 peersTotal
# puts "#{line[0].to_i},0,#{lastSample[2].to_i + lastSample[3].to_i},0,#{lastSample[4].to_i}"
perFile[file].delete(line)
end
end
end
end
perFile = Hash.new
inputFile = File.new(ARGV[0])
inputFile.each do |line|
splitted = line.strip.split(",")
if splitted.length == 7
key = splitted[0]
perFile[key] = Array.new if perFile[key] == nil
perFile[key].push(splitted[1..6])
end
end
inputFile.close
adjustTimestamps(perFile)
perFile.each_key do |file|
outfile = File.new("torrent-#{file}.log", "w")
perFile[file].each do |line|
outfile.puts line[0..4].join(",")
end
outfile.close
end
|
