sam_4_bbox.py

import argparse
import sys
import monai
import numpy as np
from torch import optim
from segment_anything import sam_model_registry
from segment_anything.utils.transforms import ResizeLongestSide
from utils.prostate import Prostate
import torch
import torch.nn as nn
from torch.utils.data import DataLoader
from tqdm import tqdm
import os
import matplotlib.pyplot as plt
from torch.utils.tensorboard import SummaryWriter
from torchvision import transforms
from torchvision.utils import save_image
import pdb

from utils.utils import dice_score
from models.models import CorruptionEncoder, ImageDecoder
import random

def setup_seed(seed):
    torch.manual_seed(seed)
    torch.cuda.manual_seed_all(seed)
    np.random.seed(seed)
    random.seed(seed)
    torch.backends.cudnn.deterministic = True

def test(args, validLoader, sam_model):
    sam_trans = ResizeLongestSide(args.input_size)
    alldice = []
    dataid = 0
    for i in range(5):
        if dataid == args.domain:
            dataid+=1
        test_dice = []
        tqdmtest = tqdm(validLoader[i])
        sam_model.eval()
        for iteration, (image, mask, bbox, id) in enumerate(tqdmtest):
            box = sam_trans.apply_boxes(bbox, (512, 512))
            box_tensor = torch.as_tensor(box, dtype=torch.float).cuda()
            bz, channels, height, width = image.shape
            row_num = 1024 // height
            col_num = 1024 // width
            patch_num = row_num * col_num
            mbz = bz // patch_num

            merged_images = torch.zeros(mbz, channels, 1024, 1024)
            merged_masks = torch.zeros(mbz, 1, 1024, 1024)

            for idx in range(mbz):
                for i in range(row_num):
                    for j in range(col_num):
                        bz_idx = idx * patch_num + i * col_num + j
                        merged_images[idx, :, i*height:(i+1)*height, j*width:(j+1)*width] = image[bz_idx, :, :, :]
                        merged_masks[idx, :, i*height:(i+1)*height, j*width:(j+1)*width] = mask[bz_idx, :, :, :]
                        box_tensor[bz_idx][0] += height * i
                        box_tensor[bz_idx][1] += width * j
                        box_tensor[bz_idx][2] += height * i
                        box_tensor[bz_idx][3] += width * j

            merged_images = merged_images.cuda()
            merged_masks = merged_masks.cuda()
            
            with torch.no_grad():
                image_embeddings = sam_model.image_encoder(merged_images)  # (B,256,64,64)

            predicted_masks = torch.zeros_like(merged_masks)
            for idx in range(mbz):
                cur_embedding = image_embeddings[idx]
                cur_boxes = box_tensor[idx*patch_num:(idx+1)*patch_num]
                with torch.no_grad():
                    sparse_embeddings, dense_embeddings = sam_model.prompt_encoder(
                        points=None,
                        boxes=cur_boxes,
                        masks=None,
                    )
                low_res_predictions, _ = sam_model.mask_decoder(
                    image_embeddings=cur_embedding.unsqueeze(0),  # (B, 256, 64, 64)
                    image_pe=sam_model.prompt_encoder.get_dense_pe(),  # (1, 256, 64, 64)
                    sparse_prompt_embeddings=sparse_embeddings,  # (B, 2, 256)
                    dense_prompt_embeddings=dense_embeddings,  # (B, 256, 64, 64)
                    multimask_output=False,
                )
                mask_predictions= sam_model.postprocess_masks(
                    low_res_predictions,
                    input_size=[1024,1024],
                    original_size=[1024,1024],
                )
                for i in range(row_num):
                    for j in range(col_num):
                        predicted_masks[idx, :, i*height:(i+1)*height, j*width:(j+1)*width] = mask_predictions[i * col_num + j, :, i*height:(i+1)*height, j*width:(j+1)*width]

            predicted_masks = torch.sigmoid(predicted_masks) > args.thresh
            dice = dice_score(predicted_masks, merged_masks)
            test_dice.append(dice.detach().item())

            # Update the progress bar
            tqdmtest.set_description(f"Testing on domain{dataid}")
            tqdmtest.set_postfix(eval_dice=np.mean(test_dice))
            tqdmtest.update()
        dataid+=1
        alldice.append(np.mean(test_dice))
    print('Average Dice:', np.mean(alldice))
    print(np.mean(alldice), alldice)
    return np.mean(alldice), alldice

def main():
    parser = argparse.ArgumentParser(description='SAM4Med')
    parser.add_argument('--input_size', type=int, default=512, help='the image size')
    parser.add_argument('--vit_name', type=str, default='vit_b', help='vit model of sam')
    parser.add_argument('--sam_ckpt', type=str, default='SAM/sam_vit_b_01ec64.pth',
                        help='Pretrained checkpoint of SAM')
    parser.add_argument('--batch_size', type=int, default=16, help='batch_size per gpu')
    parser.add_argument('--gpu', type=str, default='0', help='gpu device')
    parser.add_argument('--lr', type=float, default=0.0001, help='learning rate')
    parser.add_argument('--epoch', type=int, default=200, help='training epoch')
    parser.add_argument('--data_path', type=str, default='data/prostate', help='path to dataset')
    parser.add_argument('--domain', type=int, default=5, help='domain id')
    parser.add_argument('--thresh', type=float, default=0.5)

    args = parser.parse_args()

    os.environ["CUDA_VISIBLE_DEVICES"] = args.gpu  # device = torch.device('cuda:' + args.gpu)

    trainset = Prostate(base_dir=args.data_path, split='train', domain_idx=args.domain)
    trainLoader = DataLoader(trainset, batch_size=args.batch_size, shuffle=True, num_workers=4, pin_memory=True,drop_last=True)

    testsets = []
    testLoaders = []
    for i in range(6):
        if i!= args.domain:
            testsets.append(Prostate(base_dir=args.data_path, split='train', domain_idx=i))
            testLoaders.append(DataLoader(testsets[-1], batch_size=4, shuffle=False, num_workers=4, pin_memory=True,drop_last = True))

    sam_model = sam_model_registry[args.vit_name](checkpoint=args.sam_ckpt).cuda()

    seg_loss = monai.losses.DiceCELoss(sigmoid=True, squared_pred=True, reduction="mean")
    sam_trans = ResizeLongestSide(args.input_size)

    optimizer = optim.Adam(sam_model.parameters(), lr=args.lr, weight_decay=0.001)

    #scheduler = optim.lr_scheduler.ReduceLROnPlateau(optimizer, mode="min", patience=3, factor=0.01, verbose=True)
    writer = SummaryWriter()
    sam_model.train()
    # test(args, testLoaders, sam_model)
    maxdice, maxalldice = 0 , None
    max_epoch = 0
    for epoch in range(args.epoch):
        epoch_loss = []
        epoch_dice = []
        tqdmbar = tqdm(trainLoader)
        for iteration, (image, mask, bbox, id) in enumerate(tqdmbar):
            box = sam_trans.apply_boxes(bbox, (512, 512))
            box_tensor = torch.as_tensor(box, dtype=torch.float).cuda()
            bz, channels, height, width = image.shape
            row_num = 1024 // height
            col_num = 1024 // width
            patch_num = row_num * col_num
            mbz = bz // patch_num

            merged_images = torch.zeros(mbz, channels, 1024, 1024)
            merged_masks = torch.zeros(mbz, 1, 1024, 1024)

            for idx in range(mbz):
                for i in range(row_num):
                    for j in range(col_num):
                        bz_idx = idx * patch_num + i * col_num + j
                        merged_images[idx, :, i*height:(i+1)*height, j*width:(j+1)*width] = image[bz_idx, :, :, :]
                        merged_masks[idx, :, i*height:(i+1)*height, j*width:(j+1)*width] = mask[bz_idx, :, :, :]
                        box_tensor[bz_idx][0] += height * i
                        box_tensor[bz_idx][1] += width * j
                        box_tensor[bz_idx][2] += height * i
                        box_tensor[bz_idx][3] += width * j

            merged_images = merged_images.cuda()
            merged_masks = merged_masks.cuda()

            with torch.no_grad():
                image_embeddings = sam_model.image_encoder(merged_images)  # (B,256,64,64)

            predicted_masks = torch.zeros_like(merged_masks)
            for idx in range(mbz):
                cur_embedding = image_embeddings[idx]
                cur_boxes = box_tensor[idx*patch_num:(idx+1)*patch_num]
                with torch.no_grad():
                    sparse_embeddings, dense_embeddings = sam_model.prompt_encoder(
                        points=None,
                        boxes=cur_boxes,
                        masks=None,
                    )
                low_res_predictions, _ = sam_model.mask_decoder(
                    image_embeddings=cur_embedding.unsqueeze(0),  # (B, 256, 64, 64)
                    image_pe=sam_model.prompt_encoder.get_dense_pe(),  # (1, 256, 64, 64)
                    sparse_prompt_embeddings=sparse_embeddings,  # (B, 2, 256)
                    dense_prompt_embeddings=dense_embeddings,  # (B, 256, 64, 64)
                    multimask_output=False,
                )
                mask_predictions= sam_model.postprocess_masks(
                    low_res_predictions,
                    input_size=[1024,1024],
                    original_size=[1024,1024],
                )
                for i in range(row_num):
                    for j in range(col_num):
                        predicted_masks[idx, :, i*height:(i+1)*height, j*width:(j+1)*width] = mask_predictions[i * col_num + j, :, i*height:(i+1)*height, j*width:(j+1)*width]

            loss_seg = seg_loss(predicted_masks, merged_masks)
            predicted_masks = torch.sigmoid(predicted_masks) > args.thresh
            dice = dice_score(predicted_masks, merged_masks)
            
            loss = loss_seg

            epoch_loss.append(loss.detach().item())
            epoch_dice.append(dice.detach().item())


            # start optimizing the model
            optimizer.zero_grad()
            loss.backward()
            optimizer.step()

            tqdmbar.set_description(f"Epoch:{epoch + 1}/{args.epoch}")
            tqdmbar.set_postfix(loss=np.mean(epoch_loss), dice=np.mean(epoch_dice), seg=loss_seg.detach().item())
            tqdmbar.update()

        if (epoch + 1) % 10 == 0:
            val_dice, alldice = test(args, testLoaders, sam_model)
            if val_dice > maxdice:
                maxdice = val_dice
                maxalldice = alldice
                max_epoch = epoch + 1
            writer.add_scalars("loss",{"train": round(np.mean(epoch_loss), 4),},epoch,)
            writer.add_scalars("dice",{"train": round(np.mean(epoch_dice), 4),"val": round(val_dice, 4),},epoch,)

    print('Final result. Best Dice:', maxdice, maxalldice)
    with open(f'4_bbox_results.txt','a') as f:
        f.write(f'full bbox trained on domain {args.domain}\n')
        f.write(f'max dice {str(maxdice)}, epoch {max_epoch}\n')
        f.write(str(maxalldice) + '\n\n')

if __name__ == '__main__':
    main()