forked from pbridger/deepstream-video-pipeline
-
Notifications
You must be signed in to change notification settings - Fork 0
/
ds_ssd300_1.py
129 lines (104 loc) · 5.17 KB
/
ds_ssd300_1.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
import sys
import contextlib
import math, itertools
import torch, torchvision
# context manager to help keep track of ranges of time using NVTX
@contextlib.contextmanager
def nvtx_range(msg):
depth = torch.cuda.nvtx.range_push(msg)
try:
yield depth
finally:
torch.cuda.nvtx.range_pop()
def init_dboxes(model_dtype):
'adapted from https://github.com/NVIDIA/DeepLearningExamples/blob/master/PyTorch/Detection/SSD/src/utils.py'
fig_size = 300
feat_size = [38, 19, 10, 5, 3, 1]
steps = [8, 16, 32, 64, 100, 300]
scales = [21, 45, 99, 153, 207, 261, 315]
aspect_ratios = [[2], [2, 3], [2, 3], [2, 3], [2], [2]]
fk = fig_size / torch.tensor(steps).float()
dboxes = []
# size of feature and number of feature
for idx, sfeat in enumerate(feat_size):
sk1 = scales[idx] / fig_size
sk2 = scales[idx + 1] / fig_size
sk3 = math.sqrt(sk1 * sk2)
all_sizes = [(sk1, sk1), (sk3, sk3)]
for alpha in aspect_ratios[idx]:
w, h = sk1 * math.sqrt(alpha), sk1 / math.sqrt(alpha)
all_sizes.append((w, h))
all_sizes.append((h, w))
for w, h in all_sizes:
for i, j in itertools.product(range(sfeat), repeat=2):
cx, cy = (j + 0.5) / fk[idx], (i + 0.5) / fk[idx]
dboxes.append((cx, cy, w, h))
return torch.tensor(
dboxes,
dtype=model_dtype,
device='cuda'
).clamp(0, 1)
class SSD300(torch.nn.Module):
def __init__(self, detection_threshold, model_precision, batch_dim):
super().__init__()
self.detector = torch.hub.load('NVIDIA/DeepLearningExamples:torchhub', 'nvidia_ssd', model_math=model_precision).eval()
self.detection_threshold = torch.nn.Parameter(torch.tensor(0.4), requires_grad=False)
self.model_dtype = torch.float16 if model_precision == 'fp16' else torch.float32
self.batch_dim = batch_dim
self.class_dim = 81
self.scale_xy = 0.1
self.scale_wh = 0.2
self.dboxes_xywh = torch.nn.Parameter(init_dboxes(self.model_dtype).unsqueeze(dim=0), requires_grad=False)
self.box_dim = self.dboxes_xywh.size(1)
self.buffer_nchw = torch.nn.Parameter(torch.zeros((batch_dim, 3, 300, 300), dtype=self.model_dtype), requires_grad=False)
self.class_dim_tensor = torch.nn.Parameter(torch.tensor([self.class_dim]), requires_grad=False)
self.class_indexes = torch.nn.Parameter(torch.arange(self.class_dim).repeat(self.batch_dim * self.box_dim), requires_grad=False)
self.image_indexes = torch.nn.Parameter(
(torch.ones(self.box_dim * self.class_dim) * torch.arange(1, self.batch_dim + 1).unsqueeze(-1)).view(-1),
requires_grad=False
)
def preprocess(self, image_nchw):
'normalize'
with nvtx_range('preprocess'):
# Nvidia SSD300 code uses mean and std-dev of 128/256
return (2 * (image_nchw.to(self.model_dtype) / 255) - 1)
def xywh_to_xyxy(self, bboxes_batch, scores_batch):
bboxes_batch = bboxes_batch.permute(0, 2, 1)
scores_batch = scores_batch.permute(0, 2, 1)
bboxes_batch[:, :, :2] = self.scale_xy * bboxes_batch[:, :, :2]
bboxes_batch[:, :, 2:] = self.scale_wh * bboxes_batch[:, :, 2:]
bboxes_batch[:, :, :2] = bboxes_batch[:, :, :2] * self.dboxes_xywh[:, :, 2:] + self.dboxes_xywh[:, :, :2]
bboxes_batch[:, :, 2:] = bboxes_batch[:, :, 2:].exp() * self.dboxes_xywh[:, :, 2:]
# transform format to ltrb
l, t, r, b = bboxes_batch[:, :, 0] - 0.5 * bboxes_batch[:, :, 2],\
bboxes_batch[:, :, 1] - 0.5 * bboxes_batch[:, :, 3],\
bboxes_batch[:, :, 0] + 0.5 * bboxes_batch[:, :, 2],\
bboxes_batch[:, :, 1] + 0.5 * bboxes_batch[:, :, 3]
bboxes_batch[:, :, 0] = l
bboxes_batch[:, :, 1] = t
bboxes_batch[:, :, 2] = r
bboxes_batch[:, :, 3] = b
return bboxes_batch, torch.nn.functional.softmax(scores_batch, dim=-1)
def postprocess(self, locs, labels):
with nvtx_range('postprocess'):
locs, probs = self.xywh_to_xyxy(locs, labels)
# flatten batch and classes
# Exporting the operator repeat_interleave to ONNX opset version 11 is not supported.
flat_locs = locs.reshape(-1, 4).repeat_interleave(self.class_dim_tensor, dim=0)
flat_probs = probs.view(-1)
# only do NMS on detections over threshold, and ignore background (0)
threshold_mask = (flat_probs > self.detection_threshold) & (self.class_indexes > 0)
flat_locs = flat_locs[threshold_mask]
flat_probs = flat_probs[threshold_mask]
class_indexes = self.class_indexes[threshold_mask]
image_indexes = self.image_indexes[threshold_mask]
nms_mask = torchvision.ops.boxes.batched_nms(
flat_locs,
flat_probs,
class_indexes * image_indexes,
iou_threshold=0.7
)
bboxes = flat_locs[nms_mask]
probs = flat_probs[nms_mask]
class_indexes = class_indexes[nms_mask]
return bboxes, probs, class_indexes