AGLRs_Train_1shot.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-


from __future__ import print_function
import argparse
import os
import random
import shutil
import numpy as np
import torch
import torch.nn as nn
import torch.nn.parallel
import torch.backends.cudnn as cudnn
import torch.optim as optim
import torch.utils.data
import torchvision.datasets as dset
import torchvision.transforms as transforms
import torchvision.utils as vutils
from torch.autograd import grad
import time
from torch import autograd
from PIL import ImageFile
import pdb
import sys

sys.dont_write_bytecode = True

# ============================ Data & Networks =====================================
import dataset.few_shot_dataloader as FewShotDataloader
from models import network_AGLRs_1shot
import utils

model_dict = dict(AGLRs1=network_AGLRs_1shot)
# ==================================================================================


ImageFile.LOAD_TRUNCATED_IMAGES = True
os.environ['CUDA_DEVICE_ORDER'] = 'PCI_BUS_ID'
os.environ['CUDA_VISIBLE_DEVICES'] = '0'

parser = argparse.ArgumentParser()
parser.add_argument('--dataset_dir', default='/home/data/miniImageNet', help='./miniImageNet')
parser.add_argument('--data_name', default='miniImageNet', help='miniImageNet | CUB | StanfordDog | StanfordCar')
parser.add_argument('--mode', default='train', help='train|val|test')
parser.add_argument('--outf', default='./results/miniImageNet_AGLRs_1shot/')
parser.add_argument('--resume', default='./results/miniImageNet_AGLRs_1shot/BatchSize_4_Conv64F_miniImageNet_5Way_1Shot/model_best_test.pth.tar', type=str, help='path to the lastest checkpoint (default: none)')
parser.add_argument('--basemodel', default='Conv64F', help='Conv64F')
parser.add_argument('--workers', type=int, default=8)
parser.add_argument('--imageSize', type=int, default=84)
parser.add_argument('--augment', action='store_true', default=True, help='Perform data augmentation or not')
parser.add_argument('--episodeSize', type=int, default=4, help='the mini-batch size of training')
parser.add_argument('--testepisodeSize', type=int, default=4, help='one episode is taken as a mini-batch')
parser.add_argument('--epochs', type=int, default=50, help='the total number of training epoch')
parser.add_argument('--start_epoch', default=0, type=int, help='manual epoch number (useful on restarts)')
parser.add_argument('--episode_train_num', type=int, default=10000, help='the total number of training episodes')
parser.add_argument('--episode_val_num', type=int, default=1000, help='the total number of evaluation episodes')
parser.add_argument('--episode_test_num', type=int, default=1000, help='the total number of testing episodes')
parser.add_argument('--way_num', type=int, default=5, help='the number of way/class')
parser.add_argument('--shot_num', type=int, default=1, help='the number of shot')
parser.add_argument('--query_num', type=int, default=15, help='the number of queries')
parser.add_argument('--neighbor_k', type=int, default=3, help='the number of k-nearest neighbors')
parser.add_argument('--lr', type=float, default=0.001, help='learning rate, default=0.005')
parser.add_argument('--adam', action='store_true', default=True, help='use adam optimizer')
parser.add_argument('--cosine', type=bool, default=False, help='using cosine annealing')
parser.add_argument('--beta1', type=float, default=0.5, help='beta1 for adam. default=0.5')
parser.add_argument('--cuda', action='store_true', default=True, help='enables cuda')
parser.add_argument('--ngpu', type=int, default=1, help='the number of gpus')
parser.add_argument('--nc', type=int, default=3, help='input image channels')
parser.add_argument('--clamp_lower', type=float, default=-0.01)
parser.add_argument('--clamp_upper', type=float, default=0.01)
parser.add_argument('--print_freq', '-p', default=50, type=int, metavar='N', help='print frequency (default: 100)')
opt = parser.parse_args()
opt.cuda = True
cudnn.benchmark = True


# ======================================= Define functions =============================================
def train(train_loader, model, criterion, optimizer, epoch_index, F_txt):
    batch_time = utils.AverageMeter()
    data_time = utils.AverageMeter()
    losses = utils.AverageMeter()
    top1 = utils.AverageMeter()

    end = time.time()
    for episode_index, (batch) in enumerate(train_loader(epoch_index)):

        query_images, query_targets, support_images, support_targets = [item.cuda() for item in batch]

        """
        query_images:    (4, 75, 3, 84, 84)       ==> (batch_size, query_nums * way_nums, channels, H, W)
        query_targets:   (4, 75)                  ==> (batch_size, query_nums * way_nums)
        support_images:  (4, 5, 3, 84, 84)        ==> (batch_size, shot_nums * way_nums, channels, H, W)
        support_targets: (4, 5)                   ==> (batch_size, shot_nums * way_nums)
        """

        batch_size = support_targets.shape[0]
        support_nums = support_targets.shape[-1]
        query_nums = query_targets.shape[-1]

        # Measure data loading time
        data_time.update(time.time() - end)

        # Convert query and support images
        input_var1 = query_images.contiguous().view(-1, query_images.size(2), query_images.size(3),
                                                    query_images.size(4))
        input_var2 = support_images.contiguous().view(-1, support_images.size(2), support_images.size(3),
                                                      support_images.size(4))

        # Calculate the output
        output = model(input_var1, input_var2)

        # Calculate the losses
        loss = torch.tensor(0.).cuda()
        loss.requires_grad = True
        for i in range(len(output)):
            temp_loss = criterion(output[i], query_targets[i])
            loss = loss + temp_loss

            # Measure accuracy and record loss
            prec1, _ = utils.accuracy(output[i], query_targets[i], topk=(1, 3))
            losses.update(temp_loss.item(), query_nums)
            top1.update(prec1[0], query_nums)

        # Compute gradients and do SGD step
        optimizer.zero_grad()
        loss.backward()
        optimizer.step()

        # Measure elapsed time
        batch_time.update(time.time() - end)
        end = time.time()

        # ============== print the intermediate results ==============#
        if episode_index % opt.print_freq == 0 and episode_index != 0:
            print('Eposide-({0}): [{1}/{2}]\t'
                  'Time {batch_time.val:.3f} ({batch_time.avg:.3f})\t'
                  'Data {data_time.val:.3f} ({data_time.avg:.3f})\t'
                  'Loss {loss.val:.3f} ({loss.avg:.3f})\t'
                  'Prec@1 {top1.val:.3f} ({top1.avg:.3f})'.format(
                epoch_index, episode_index, len(train_loader), batch_time=batch_time, data_time=data_time, loss=losses,
                top1=top1))

            print('Eposide-({0}): [{1}/{2}]\t'
                  'Time {batch_time.val:.3f} ({batch_time.avg:.3f})\t'
                  'Data {data_time.val:.3f} ({data_time.avg:.3f})\t'
                  'Loss {loss.val:.3f} ({loss.avg:.3f})\t'
                  'Prec@1 {top1.val:.3f} ({top1.avg:.3f})'.format(
                epoch_index, episode_index, len(train_loader), batch_time=batch_time, data_time=data_time, loss=losses,
                top1=top1), file=F_txt)

    return top1.avg, losses.avg


def validate(val_loader, model, criterion, epoch_index, best_prec1, F_txt):
    batch_time = utils.AverageMeter()
    losses = utils.AverageMeter()
    top1 = utils.AverageMeter()

    # switch to evaluate mode
    model.eval()
    accuracies = []

    end = time.time()
    for episode_index, (batch) in enumerate(val_loader(epoch_index)):

        query_images, query_targets, support_images, support_targets = [item.cuda() for item in batch]

        """
        query_images:    (4, 75, 3, 84, 84)       ==> (batch_size, query_nums * way_nums, channels, H, W)
        query_targets:   (4, 75)                  ==> (batch_size, query_nums * way_nums)
        support_images:  (4, 5, 3, 84, 84)        ==> (batch_size, shot_nums * way_nums, channels, H, W)
        support_targets: (4, 5)                   ==> (batch_size, shot_nums * way_nums)
        """

        batch_size = support_targets.shape[0]
        support_nums = support_targets.shape[-1]
        query_nums = query_targets.shape[-1]

        # Convert query and support images
        input_var1 = query_images.contiguous().view(-1, query_images.size(2), query_images.size(3),
                                                    query_images.size(4))
        input_var2 = support_images.contiguous().view(-1, support_images.size(2), support_images.size(3),
                                                      support_images.size(4))

        # Calculate the output
        output = model(input_var1, input_var2)

        # Calculate the losses
        loss = torch.tensor(0.).cuda()
        loss.requires_grad = True
        for i in range(len(output)):
            temp_loss = criterion(output[i], query_targets[i])
            loss = loss + temp_loss

            # Measure accuracy and record loss
            prec1, _ = utils.accuracy(output[i], query_targets[i], topk=(1, 3))
            losses.update(temp_loss.item(), query_nums)
            top1.update(prec1[0], query_nums)
            accuracies.append(prec1)

        # measure elapsed time
        batch_time.update(time.time() - end)
        end = time.time()

        # ============== print the intermediate results ==============#
        if episode_index % opt.print_freq == 0 and episode_index != 0:
            print('Test-({0}): [{1}/{2}]\t'
                  'Time {batch_time.val:.3f} ({batch_time.avg:.3f})\t'
                  'Loss {loss.val:.3f} ({loss.avg:.3f})\t'
                  'Prec@1 {top1.val:.3f} ({top1.avg:.3f})'.format(
                epoch_index, episode_index, len(val_loader), batch_time=batch_time, loss=losses, top1=top1))

            print('Test-({0}): [{1}/{2}]\t'
                  'Time {batch_time.val:.3f} ({batch_time.avg:.3f})\t'
                  'Loss {loss.val:.3f} ({loss.avg:.3f})\t'
                  'Prec@1 {top1.val:.3f} ({top1.avg:.3f})'.format(
                epoch_index, episode_index, len(val_loader), batch_time=batch_time, loss=losses, top1=top1), file=F_txt)

    print(' * Prec@1 {top1.avg:.3f} Best_prec1 {best_prec1:.3f}'.format(top1=top1, best_prec1=best_prec1))
    print(' * Prec@1 {top1.avg:.3f} Best_prec1 {best_prec1:.3f}'.format(top1=top1, best_prec1=best_prec1), file=F_txt)

    return top1.avg, losses.avg, accuracies


if __name__ == '__main__':

    # Save path
    opt.outf, F_txt = utils.set_save_path(opt)

    # Check if the cuda is available
    if torch.cuda.is_available() and not opt.cuda:
        print("WARNING: You have a CUDA device, so you should probably run with --cuda")

    # ========================================== Model Config ===============================================

    global best_prec1_val, best_prec1_test, epoch_index
    best_prec1_val = 0
    best_prec1_test = 0
    epoch_index = 0

    
    FewShotNet = model_dict["AGLRs1"]
    model = FewShotNet.define_FewShotNet(which_model=opt.basemodel, num_classes=opt.way_num, neighbor_k=opt.neighbor_k,
                                         norm='batch',
                                         shot_num=opt.shot_num, batch_size=opt.episodeSize, init_type='normal',
                                         use_gpu=opt.cuda)

    # define loss function (criterion) and optimizer
    criterion = nn.CrossEntropyLoss().cuda()
    if opt.adam:
        optimizer = optim.Adam(model.parameters(), lr=opt.lr, betas=(opt.beta1, 0.9))
    else:
        optimizer = optim.SGD(model.parameters(), lr=opt.lr, momentum=0.9, dampening=0.9, weight_decay=0.001)

    # optionally resume from a checkpoint
    if opt.resume:
        if os.path.isfile(opt.resume):
            print("=> loading checkpoint '{}'".format(opt.resume))
            checkpoint = torch.load(opt.resume)
            epoch_index = checkpoint['epoch_index']
            best_prec1 = checkpoint['best_prec1_test']
            best_prec1 = 0
            best_prec1_test = checkpoint['best_prec1_test']
            model.load_state_dict(checkpoint['state_dict'])
            optimizer.load_state_dict(checkpoint['optimizer'])
            opt.start_epoch =  checkpoint['current_epoch']+1
            print("=> loaded checkpoint '{}' (epoch {})".format(opt.resume, checkpoint['epoch_index']))
            print("=> loaded checkpoint '{}' (epoch {})".format(opt.resume, checkpoint['epoch_index']), file=F_txt)
        else:
            print("=> no checkpoint found at '{}'".format(opt.resume))
            print("=> no checkpoint found at '{}'".format(opt.resume), file=F_txt)


    if opt.ngpu > 1:
        model = nn.DataParallel(model, range(opt.ngpu))

    # print the architecture of the network
    print(opt)
    print(opt, file=F_txt)
    print(model)
    print(model, file=F_txt)

    # ============================================ Training phase ========================================
    print('===================================== Training on the train set =====================================')
    print('===================================== Training on the train set =====================================',
          file=F_txt)
    print('Learning rate: %f' % opt.lr)
    print('Learning rate: %f' % opt.lr, file=F_txt)

    Train_losses = []
    Val_losses = []
    Test_losses = []
    # opt.start_epoch=37

    for epoch_item in range(opt.start_epoch, opt.epochs):
        print('==================== Epoch %d ====================' % epoch_item)
        print('==================== Epoch %d ====================' % epoch_item, file=F_txt)

        # ======================================= Loaders of Datasets =======================================
        opt.current_epoch = epoch_item
        train_loader, val_loader, test_loader = FewShotDataloader.get_dataloader(opt, ['train', 'val', 'test'])

        # ============================================ Training ===========================================
        # Fix the parameters of Batch Normalization after 10000 episodes (1 epoch)
        if epoch_item < 1:
            model.train()
        else:
            model.eval()

        # train for one epoch
        prec1_train, train_loss = train(train_loader, model, criterion, optimizer, epoch_item, F_txt)
        Train_losses.append(train_loss)

        F_txt.flush()
        os.fsync(F_txt.fileno())

        print('===================================== Validation on the val set =====================================')
        print('===================================== validation on the val set =====================================',
              file=F_txt)
        # evaluate on validation set
        prec1_val, val_loss, _ = validate(val_loader, model, criterion, epoch_item, best_prec1_val, F_txt)
        Val_losses.append(val_loss)

        F_txt.flush()
        os.fsync(F_txt.fileno())

        print('===================================== Validation on the test set =====================================')
        print('===================================== validation on the test set =====================================',
              file=F_txt)
        # evaluate on validation set
        prec1_test, test_loss, _ = validate(test_loader, model, criterion, epoch_item, best_prec1_test, F_txt)
        Test_losses.append(test_loss)

        F_txt.flush()
        os.fsync(F_txt.fileno())

        # Adjust the learning rates
        if opt.cosine:
            scheduler.step()
        else:
            utils.adjust_learning_rate(opt, optimizer, epoch_item, F_txt)

        # record the best prec@1 and save checkpoint
        is_best_val = prec1_val > best_prec1_val
        best_prec1_val = max(prec1_val, best_prec1_val)

        # save the checkpoint
        if is_best_val:
            utils.save_checkpoint(
                {
                    'epoch_index': epoch_item,
                    'arch': opt.basemodel,
                    'state_dict': model.state_dict(),
                    'best_prec1_val': best_prec1_val,
                    'optimizer': optimizer.state_dict(),
                }, os.path.join(opt.outf, 'model_best_val.pth.tar'))

            # record the best prec@1 and save checkpoint
        is_best_test = prec1_test > best_prec1_test
        best_prec1_test = max(prec1_test, best_prec1_test)

        # save the checkpoint
        if is_best_test:
            utils.save_checkpoint(
                {
                    'epoch_index': epoch_item,
                    'arch': opt.basemodel,
                    'state_dict': model.state_dict(),
                    'best_prec1_test': best_prec1_test,
                    'optimizer': optimizer.state_dict(),
                    'current_epoch': epoch_item
                }, os.path.join(opt.outf, 'model_best_test.pth.tar'))

        if epoch_item % 10 == 0:
            filename = os.path.join(opt.outf, 'epoch_%d.pth.tar' % epoch_item)
            utils.save_checkpoint(
                {
                    'epoch_index': epoch_item,
                    'arch': opt.basemodel,
                    'state_dict': model.state_dict(),
                    'best_prec1_test': best_prec1_test,
                    'optimizer': optimizer.state_dict(),
                }, filename)

    print('======================================== Training is END ========================================\n')
    print('======================================== Training is END ========================================\n',
          file=F_txt)
    F_txt.close()

    # ============================================ Test phase ============================================
    # Set the save path
    F_txt_test = utils.set_save_test_path(opt)
    print('========================================== Start Test ==========================================\n')
    print('========================================== Start Test ==========================================\n',
          file=F_txt_test)

    # Load the trained best model
    model_best_test = os.path.join(opt.outf, 'model_best_test.pth.tar')
    checkpoint = utils.get_resume_file(model_best_test, F_txt_test)
    epoch_index = checkpoint['epoch_index']
    best_prec1_test = checkpoint['best_prec1_test']
    model.load_state_dict(checkpoint['state_dict'])

    # print the parameters and architecture of the model
    print(opt)
    print(opt, file=F_txt_test)
    print(model)
    print(model, file=F_txt_test)

    # Repeat five times
    repeat_num = 5
    total_accuracy = 0.0
    total_h = np.zeros(repeat_num)
    for r in range(repeat_num):
        print('==================== The %d-th round ====================' % r)
        print('==================== The %d-th round ====================' % r, file=F_txt_test)

        # ======================================= Loaders of Datasets =======================================
        opt.current_epoch = repeat_num
        _, _, test_loader = FewShotDataloader.get_dataloader(opt, ['train', 'val', 'test'])

        # evaluate on validation/test set
        prec1, val_loss, accuracies = validate(test_loader, model, criterion, epoch_index, best_prec1, F_txt_test)
        test_accuracy, h = utils.mean_confidence_interval(accuracies)
        total_accuracy += test_accuracy
        total_h[r] = h

        print('Test accuracy: %f h: %f \n' % (test_accuracy, h))
        print('Test accuracy: %f h: %f \n' % (test_accuracy, h), file=F_txt_test)
    print('Mean_accuracy: %f h: %f' % (total_accuracy / repeat_num, total_h.mean()))
    print('Mean_accuracy: %f h: %f' % (total_accuracy / repeat_num, total_h.mean()), file=F_txt_test)
    print('===================================== Test is END =====================================\n')
    print('===================================== Test is END =====================================\n', file=F_txt_test)
    F_txt_test.close()