|
92 | 92 |
|
93 | 93 | for line in lines: |
94 | 94 | if 'Obj create time' in line: |
95 | | - t = float(line.split(':')[1]) |
| 95 | + t = float(line.split(':')[-1]) |
96 | 96 | obj_create_time_file_agg += t |
97 | 97 | total_time_file_agg += t |
98 | 98 | observed_time_file_agg += t |
99 | 99 | obj_create_time_node.append(t) |
100 | 100 | elif 'Transfer create time' in line: |
101 | | - t = float(line.split(':')[1]) |
| 101 | + t = float(line.split(':')[-1]) |
102 | 102 | xfer_create_time_file_agg += t |
103 | 103 | total_time_file_agg += t |
104 | 104 | observed_time_file_agg += t |
105 | 105 | xfer_create_time_node.append(t) |
106 | 106 | elif 'Transfer start time' in line: |
107 | | - t = float(line.split(':')[1]) |
| 107 | + t = float(line.split(':')[-1]) |
108 | 108 | xfer_start_time_file_agg += t |
109 | 109 | total_time_file_agg += t |
110 | 110 | observed_time_file_agg += t |
111 | 111 | xfer_start_time_node.append(t) |
112 | 112 | elif 'Transfer wait time' in line: |
113 | | - t = float(line.split(':')[1]) |
| 113 | + t = float(line.split(':')[-1]) |
114 | 114 | xfer_wait_time_file_agg += t |
115 | 115 | total_time_file_agg += t |
116 | 116 | observed_time_file_agg += t |
117 | 117 | xfer_wait_time_node.append(t) |
118 | 118 | elif 'Transfer close time' in line: |
119 | | - t = float(line.split(':')[1]) |
| 119 | + t = float(line.split(':')[-1]) |
120 | 120 | xfer_close_time_file_agg += t |
121 | 121 | total_time_file_agg += t |
122 | 122 | observed_time_file_agg += t |
123 | 123 | xfer_close_time_node.append(t) |
124 | 124 | elif 'Obj close time' in line: |
125 | | - t = float(line.split(':')[1]) |
| 125 | + t = float(line.split(':')[-1]) |
126 | 126 | obj_close_time_file_agg += t |
127 | 127 | total_time_file_agg += t |
128 | 128 | observed_time_file_agg += t |
129 | 129 | obj_close_time_node.append(t) |
130 | 130 | elif 'Sleep end' in line: |
131 | | - t = float(line.split(':')[1]) |
| 131 | + t = float(line.split(':')[-1]) |
132 | 132 | sleep_time_file_agg += t |
133 | 133 | observed_time_file_agg += t |
134 | 134 | sleep_time_node.append(t) |
135 | 135 |
|
136 | 136 | if 'PDC Metadata servers, running with' in line and (pdc_metadata_servers is None or pdc_metadata_clients is None): |
137 | 137 | parts = line.split() |
138 | 138 |
|
139 | | - pdc_metadata_servers = parts[2] |
140 | | - pdc_metadata_clients = parts[8] |
| 139 | + pdc_metadata_servers = parts[3] |
| 140 | + pdc_metadata_clients = parts[9] |
141 | 141 |
|
142 | 142 | obj_create_time_file.append(obj_create_time_file_agg) |
143 | 143 | obj_close_time_file.append(obj_close_time_file_agg) |
|
270 | 270 | 'xfer_wait_time_step': xfer_wait_time_node[step], |
271 | 271 | 'xfer_close_time_step': xfer_close_time_node[step], |
272 | 272 | 'obj_close_time_step': obj_close_time_node[step], |
273 | | - 'sleep_time_step': sleep_time_node[step] if len(sleep_time_node) < step else 0 |
| 273 | + 'sleep_time_step': sleep_time_node[step] if step < len(sleep_time_node) else 0 |
274 | 274 | } |
275 | 275 |
|
276 | 276 | lines.append(line) |
|
0 commit comments