|
|
|---|
| 8 |
|
8 |
|
| 9 |
def parse_time_ns(tm): |
9 |
def parse_time_ns(tm): |
| 10 |
if tm.endswith('ns'): |
10 |
if tm.endswith('ns'): |
| 11 |
return long(tm[:-2]) |
11 |
return long(tm[:-4]) |
| 12 |
raise ValueError(tm) |
12 |
raise ValueError(tm) |
| 13 |
|
13 |
|
| 14 |
|
14 |
|
|
|
|---|
| 39 |
self.flowId = int(flow_el.get('flowId')) |
39 |
self.flowId = int(flow_el.get('flowId')) |
| 40 |
rxPackets = long(flow_el.get('rxPackets')) |
40 |
rxPackets = long(flow_el.get('rxPackets')) |
| 41 |
txPackets = long(flow_el.get('txPackets')) |
41 |
txPackets = long(flow_el.get('txPackets')) |
| 42 |
tx_duration = float(long(flow_el.get('timeLastTxPacket')[:-2]) - long(flow_el.get('timeFirstTxPacket')[:-2]))*1e-9 |
42 |
tx_duration = float(long(flow_el.get('timeLastTxPacket')[:-4]) - long(flow_el.get('timeFirstTxPacket')[:-4]))*1e-9 |
| 43 |
rx_duration = float(long(flow_el.get('timeLastRxPacket')[:-2]) - long(flow_el.get('timeFirstRxPacket')[:-2]))*1e-9 |
43 |
rx_duration = float(long(flow_el.get('timeLastRxPacket')[:-4]) - long(flow_el.get('timeFirstRxPacket')[:-4]))*1e-9 |
| 44 |
self.rx_duration = rx_duration |
44 |
self.rx_duration = rx_duration |
| 45 |
self.probe_stats_unsorted = [] |
45 |
self.probe_stats_unsorted = [] |
| 46 |
if rxPackets: |
46 |
if rxPackets: |
|
|
|---|
| 48 |
else: |
48 |
else: |
| 49 |
self.hopCount = -1000 |
49 |
self.hopCount = -1000 |
| 50 |
if rxPackets: |
50 |
if rxPackets: |
| 51 |
self.delayMean = float(flow_el.get('delaySum')[:-2]) / rxPackets * 1e-9 |
51 |
self.delayMean = float(flow_el.get('delaySum')[:-4]) / rxPackets * 1e-9 |
| 52 |
self.packetSizeMean = float(flow_el.get('rxBytes')) / rxPackets |
52 |
self.packetSizeMean = float(flow_el.get('rxBytes')) / rxPackets |
| 53 |
else: |
53 |
else: |
| 54 |
self.delayMean = None |
54 |
self.delayMean = None |