import json import os import time from collections import defaultdict, deque, OrderedDict import datetime import numpy as np import torch import torch.distributed as dist from utils.cider.pyciderevalcap.ciderD.ciderD import CiderD class ScstRewardCriterion(torch.nn.Module): CIDER_REWARD_WEIGHT = 1 def __init__(self, cider_cached_tokens='corpus', baseline_type='greedy'): self.CiderD_scorer = CiderD(df=cider_cached_tokens) assert baseline_type in ['greedy', 'sample'] self.baseline_type = baseline_type self._cur_score = None super().__init__() def forward(self, gt_res, greedy_res, sample_res, sample_logprobs): batch_size = len(gt_res) sample_res_size = len(sample_res) seq_per_img = sample_res_size // batch_size gen_res = [] gen_res.extend(sample_res) gt_idx = [i // seq_per_img for i in range(sample_res_size)] if self.baseline_type == 'greedy': assert len(greedy_res) == batch_size gen_res.extend(greedy_res) gt_idx.extend([i for i in range(batch_size)]) scores = self._calculate_eval_scores(gen_res, gt_idx, gt_res) if self.baseline_type == 'greedy': baseline = scores[-batch_size:][:, np.newaxis] else: sc_ = scores.reshape(batch_size, seq_per_img) baseline = (sc_.sum(1, keepdims=True) - sc_) / (sc_.shape[1] - 1) # sample - baseline reward = scores[:sample_res_size].reshape(batch_size, seq_per_img) self._cur_score = reward.mean() reward = reward - baseline reward = reward.reshape(sample_res_size) reward = torch.as_tensor(reward, device=sample_logprobs.device, dtype=torch.float) loss = - sample_logprobs * reward loss = loss.mean() return loss def get_score(self): return self._cur_score def _calculate_eval_scores(self, gen_res, gt_idx, gt_res): ''' gen_res: generated captions, list of str gt_idx: list of int, of the same length as gen_res gt_res: ground truth captions, list of list of str. gen_res[i] corresponds to gt_res[gt_idx[i]] Each image can have multiple ground truth captions ''' gen_res_size = len(gen_res) res = OrderedDict() for i in range(gen_res_size): res[i] = [self._wrap_sentence(gen_res[i])] gts = OrderedDict() gt_res_ = [ [self._wrap_sentence(gt_res[i][j]) for j in range(len(gt_res[i]))] for i in range(len(gt_res)) ] for i in range(gen_res_size): gts[i] = gt_res_[gt_idx[i]] res_ = [{'image_id': i, 'caption': res[i]} for i in range(len(res))] _, batch_cider_scores = self.CiderD_scorer.compute_score(gts, res_) scores = self.CIDER_REWARD_WEIGHT * batch_cider_scores return scores @classmethod def _wrap_sentence(self, s): # ensure the sentence ends with token # in order to keep consisitent with cider_cached_tokens r = s.strip() if r.endswith('.'): r = r[:-1] r += ' ' return r class SmoothedValue(object): """Track a series of values and provide access to smoothed values over a window or the global series average. """ def __init__(self, window_size=20, fmt=None): if fmt is None: fmt = "{median:.4f} ({global_avg:.4f})" self.deque = deque(maxlen=window_size) self.total = 0.0 self.count = 0 self.fmt = fmt def update(self, value, n=1): self.deque.append(value) self.count += n self.total += value * n def synchronize_between_processes(self): """ Warning: does not synchronize the deque! """ if not is_dist_avail_and_initialized(): return t = torch.tensor([self.count, self.total], dtype=torch.float64, device='cuda') dist.barrier() dist.all_reduce(t) t = t.tolist() self.count = int(t[0]) self.total = t[1] @property def median(self): d = torch.tensor(list(self.deque)) return d.median().item() @property def avg(self): d = torch.tensor(list(self.deque), dtype=torch.float32) return d.mean().item() @property def global_avg(self): return self.total / self.count @property def max(self): return max(self.deque) @property def value(self): return self.deque[-1] def __str__(self): # d = torch.tensor(list(self.deque)) # if d.numel() == 0: # return self.fmt.format( # median=-1, # avg=-1, # global_avg=-1, # max=-1, # value=-1) return self.fmt.format( median=self.median, avg=self.avg, global_avg=self.global_avg, max=self.max, value=self.value) class MetricLogger(object): def __init__(self, delimiter="\t"): self.meters = defaultdict(SmoothedValue) self.delimiter = delimiter # def update(self, **kwargs): # for k, v in kwargs.items(): # if isinstance(v, torch.Tensor): # v = v.item() # assert isinstance(v, (float, int)) # self.meters[k].update(v) def update(self, **kwargs): for k, v in kwargs.items(): if v is None: continue if isinstance(v, torch.Tensor): v = v.item() assert isinstance(v, (float, int)) self.meters[k].update(v) def __getattr__(self, attr): if attr in self.meters: return self.meters[attr] if attr in self.__dict__: return self.__dict__[attr] raise AttributeError("'{}' object has no attribute '{}'".format( type(self).__name__, attr)) #### ### def __str__(self): loss_str = [] # print(self.meters.items()) for name, meter in self.meters.items(): # if torch.tensor(list(meter.deque)).numel != 0: if name != "loss_spatial" or (name == "loss_spatial" and torch.tensor(list(meter.deque)).numel() != 0): # print('Here is the', meter) loss_str.append( "{}: {}".format(name, str(meter)) ) return self.delimiter.join(loss_str) def global_avg(self): loss_str = [] for name, meter in self.meters.items(): loss_str.append( "{}: {:.4f}".format(name, meter.global_avg) ) return self.delimiter.join(loss_str) def synchronize_between_processes(self): for meter in self.meters.values(): meter.synchronize_between_processes() def add_meter(self, name, meter): self.meters[name] = meter def log_every(self, iterable, print_freq, header=None, dataset_len=None, epoch_info=None): if not header: header = '' if not dataset_len: dataset_len = len(iterable) start_time = time.time() end = time.time() iter_time = SmoothedValue(fmt='{avg:.4f}') data_time = SmoothedValue(fmt='{avg:.4f}') space_fmt = ':' + str(len(str(dataset_len))) + 'd' _msg = [ '[{0' + space_fmt + '}/{1}]', 'eta: {eta}', '{meters}', 'time: {time}', 'data: {data}' ] if torch.cuda.is_available(): _msg.append('max mem: {memory:.0f}') _msg = self.delimiter.join(_msg) MB = 1024.0 * 1024.0 iterable = iter(iterable) train_steps = dataset_len if epoch_info: start_epoch, end_epoch = epoch_info train_steps = (end_epoch - start_epoch) * dataset_len for i in range(train_steps): obj = next(iterable) data_time.update(time.time() - end) yield obj iter_time.update(time.time() - end) if epoch_info: header = int(i / dataset_len) + start_epoch header = 'Train step: [{}]'.format(header) log_msg = header + " " + _msg if (i % dataset_len) % print_freq == 0 or i == dataset_len - 1: eta_seconds = iter_time.global_avg * (dataset_len - i % dataset_len) eta_string = str(datetime.timedelta(seconds=int(eta_seconds))) if torch.cuda.is_available(): print(log_msg.format( i % dataset_len, dataset_len, eta=eta_string, meters=str(self), time=str(iter_time), data=str(data_time), memory=torch.cuda.max_memory_allocated() / MB)) else: print(log_msg.format( i % dataset_len, dataset_len, eta=eta_string, meters=str(self), time=str(iter_time), data=str(data_time))) end = time.time() total_time = time.time() - start_time total_time_str = str(datetime.timedelta(seconds=int(total_time))) print('{} Total time: {} ({:.4f} s / it)'.format( header, total_time_str, total_time / dataset_len)) class AttrDict(dict): def __init__(self, *args, **kwargs): super(AttrDict, self).__init__(*args, **kwargs) self.__dict__ = self def compute_acc(logits, label, reduction='mean'): ret = (torch.argmax(logits, dim=1) == label).float() if reduction == 'none': return ret.detach() elif reduction == 'mean': return ret.mean().item() def compute_n_params(model, return_str=True): tot = 0 for p in model.parameters(): w = 1 for x in p.shape: w *= x tot += w if return_str: if tot >= 1e6: return '{:.1f}M'.format(tot / 1e6) else: return '{:.1f}K'.format(tot / 1e3) else: return tot def setup_for_distributed(is_master): """ This function disables printing when not in master process """ import builtins as __builtin__ builtin_print = __builtin__.print def print(*args, **kwargs): force = kwargs.pop('force', False) if is_master or force: builtin_print(*args, **kwargs) __builtin__.print = print def is_dist_avail_and_initialized(): if not dist.is_available(): return False if not dist.is_initialized(): return False return True def get_world_size(): if not is_dist_avail_and_initialized(): return 1 return dist.get_world_size() def get_rank(): if not is_dist_avail_and_initialized(): return 0 return dist.get_rank() def is_main_process(): return get_rank() == 0 def save_on_master(*args, **kwargs): if is_main_process(): torch.save(*args, **kwargs) def init_distributed_mode(args): if 'RANK' in os.environ and 'WORLD_SIZE' in os.environ: args.rank = int(os.environ["RANK"]) args.world_size = int(os.environ['WORLD_SIZE']) args.gpu = int(os.environ['LOCAL_RANK']) elif 'SLURM_PROCID' in os.environ: args.rank = int(os.environ['SLURM_PROCID']) args.gpu = args.rank % torch.cuda.device_count() else: print('Not using distributed mode') args.distributed = False return args.distributed = True torch.cuda.set_device(args.gpu) args.dist_backend = 'nccl' print('| distributed init (rank {}): {}'.format( args.rank, args.dist_url), flush=True) torch.distributed.init_process_group(backend=args.dist_backend, init_method=args.dist_url, world_size=args.world_size, rank=args.rank, timeout=datetime.timedelta(seconds=54000)) torch.distributed.barrier() setup_for_distributed(args.rank == 0) def read_json(rpath): with open(rpath, 'r') as f: return json.load(f)