(self, iterable, print_freq, header=None)
| 227 | self.meters[name] = meter |
| 228 | |
| 229 | def log_every(self, iterable, print_freq, header=None): |
| 230 | i = 0 |
| 231 | if not header: |
| 232 | header = '' |
| 233 | start_time = time.time() |
| 234 | end = time.time() |
| 235 | iter_time = SmoothedValue(fmt='{avg:.4f}') |
| 236 | data_time = SmoothedValue(fmt='{avg:.4f}') |
| 237 | space_fmt = ':' + str(len(str(len(iterable)))) + 'd' |
| 238 | if torch.cuda.is_available(): |
| 239 | log_msg = self.delimiter.join([ |
| 240 | header, |
| 241 | '[{0' + space_fmt + '}/{1}]', |
| 242 | 'eta: {eta}', |
| 243 | '{meters}', |
| 244 | 'time: {time}', |
| 245 | 'data: {data}', |
| 246 | 'max mem: {memory:.0f}' |
| 247 | ]) |
| 248 | else: |
| 249 | log_msg = self.delimiter.join([ |
| 250 | header, |
| 251 | '[{0' + space_fmt + '}/{1}]', |
| 252 | 'eta: {eta}', |
| 253 | '{meters}', |
| 254 | 'time: {time}', |
| 255 | 'data: {data}' |
| 256 | ]) |
| 257 | MB = 1024.0 * 1024.0 |
| 258 | for obj in iterable: |
| 259 | data_time.update(time.time() - end) |
| 260 | yield obj |
| 261 | iter_time.update(time.time() - end) |
| 262 | if i % print_freq == 0 or i == len(iterable) - 1: |
| 263 | eta_seconds = iter_time.global_avg * (len(iterable) - i) |
| 264 | eta_string = str(datetime.timedelta(seconds=int(eta_seconds))) |
| 265 | if torch.cuda.is_available(): |
| 266 | print(log_msg.format( |
| 267 | i, len(iterable), eta=eta_string, |
| 268 | meters=str(self), |
| 269 | time=str(iter_time), data=str(data_time), |
| 270 | memory=torch.cuda.max_memory_allocated() / MB)) |
| 271 | else: |
| 272 | print(log_msg.format( |
| 273 | i, len(iterable), eta=eta_string, |
| 274 | meters=str(self), |
| 275 | time=str(iter_time), data=str(data_time))) |
| 276 | i += 1 |
| 277 | end = time.time() |
| 278 | total_time = time.time() - start_time |
| 279 | total_time_str = str(datetime.timedelta(seconds=int(total_time))) |
| 280 | print('{} Total time: {} ({:.4f} s / it)'.format( |
| 281 | header, total_time_str, total_time / len(iterable))) |
| 282 | |
| 283 | |
| 284 | def get_sha(): |
no test coverage detected