From 33a9e08dc9b65abc3f3e18d14253f95c79e0f749 Mon Sep 17 00:00:00 2001
From: 游雁 <zhifu.gzf@alibaba-inc.com>
Date: 星期三, 08 五月 2024 19:20:43 +0800
Subject: [PATCH] dynamic batch

---
 funasr/models/campplus/components.py |  244 +++++++++++++++++++++++-------------------------
 1 files changed, 118 insertions(+), 126 deletions(-)

diff --git a/funasr/models/campplus/components.py b/funasr/models/campplus/components.py
index 8db9aef..263b943 100644
--- a/funasr/models/campplus/components.py
+++ b/funasr/models/campplus/components.py
@@ -14,30 +14,25 @@
 
     def __init__(self, in_planes, planes, stride=1):
         super(BasicResBlock, self).__init__()
-        self.conv1 = torch.nn.Conv2d(in_planes,
-                               planes,
-                               kernel_size=3,
-                               stride=(stride, 1),
-                               padding=1,
-                               bias=False)
+        self.conv1 = torch.nn.Conv2d(
+            in_planes, planes, kernel_size=3, stride=(stride, 1), padding=1, bias=False
+        )
         self.bn1 = torch.nn.BatchNorm2d(planes)
-        self.conv2 = torch.nn.Conv2d(planes,
-                               planes,
-                               kernel_size=3,
-                               stride=1,
-                               padding=1,
-                               bias=False)
+        self.conv2 = torch.nn.Conv2d(planes, planes, kernel_size=3, stride=1, padding=1, bias=False)
         self.bn2 = torch.nn.BatchNorm2d(planes)
 
         self.shortcut = torch.nn.Sequential()
         if stride != 1 or in_planes != self.expansion * planes:
             self.shortcut = torch.nn.Sequential(
-                torch.nn.Conv2d(in_planes,
-                          self.expansion * planes,
-                          kernel_size=1,
-                          stride=(stride, 1),
-                          bias=False),
-                torch.nn.BatchNorm2d(self.expansion * planes))
+                torch.nn.Conv2d(
+                    in_planes,
+                    self.expansion * planes,
+                    kernel_size=1,
+                    stride=(stride, 1),
+                    bias=False,
+                ),
+                torch.nn.BatchNorm2d(self.expansion * planes),
+            )
 
     def forward(self, x):
         out = F.relu(self.bn1(self.conv1(x)))
@@ -48,11 +43,7 @@
 
 
 class FCM(torch.nn.Module):
-    def __init__(self,
-                 block=BasicResBlock,
-                 num_blocks=[2, 2],
-                 m_channels=32,
-                 feat_dim=80):
+    def __init__(self, block=BasicResBlock, num_blocks=[2, 2], m_channels=32, feat_dim=80):
         super(FCM, self).__init__()
         self.in_planes = m_channels
         self.conv1 = torch.nn.Conv2d(1, m_channels, kernel_size=3, stride=1, padding=1, bias=False)
@@ -61,7 +52,9 @@
         self.layer1 = self._make_layer(block, m_channels, num_blocks[0], stride=2)
         self.layer2 = self._make_layer(block, m_channels, num_blocks[0], stride=2)
 
-        self.conv2 = torch.nn.Conv2d(m_channels, m_channels, kernel_size=3, stride=(2, 1), padding=1, bias=False)
+        self.conv2 = torch.nn.Conv2d(
+            m_channels, m_channels, kernel_size=3, stride=(2, 1), padding=1, bias=False
+        )
         self.bn2 = torch.nn.BatchNorm2d(m_channels)
         self.out_channels = m_channels * (feat_dim // 8)
 
@@ -87,18 +80,17 @@
 
 def get_nonlinear(config_str, channels):
     nonlinear = torch.nn.Sequential()
-    for name in config_str.split('-'):
-        if name == 'relu':
-            nonlinear.add_module('relu', torch.nn.ReLU(inplace=True))
-        elif name == 'prelu':
-            nonlinear.add_module('prelu', torch.nn.PReLU(channels))
-        elif name == 'batchnorm':
-            nonlinear.add_module('batchnorm', torch.nn.BatchNorm1d(channels))
-        elif name == 'batchnorm_':
-            nonlinear.add_module('batchnorm',
-                                 torch.nn.BatchNorm1d(channels, affine=False))
+    for name in config_str.split("-"):
+        if name == "relu":
+            nonlinear.add_module("relu", torch.nn.ReLU(inplace=True))
+        elif name == "prelu":
+            nonlinear.add_module("prelu", torch.nn.PReLU(channels))
+        elif name == "batchnorm":
+            nonlinear.add_module("batchnorm", torch.nn.BatchNorm1d(channels))
+        elif name == "batchnorm_":
+            nonlinear.add_module("batchnorm", torch.nn.BatchNorm1d(channels, affine=False))
         else:
-            raise ValueError('Unexpected module ({}).'.format(name))
+            raise ValueError("Unexpected module ({}).".format(name))
     return nonlinear
 
 
@@ -117,27 +109,32 @@
 
 
 class TDNNLayer(torch.nn.Module):
-    def __init__(self,
-                 in_channels,
-                 out_channels,
-                 kernel_size,
-                 stride=1,
-                 padding=0,
-                 dilation=1,
-                 bias=False,
-                 config_str='batchnorm-relu'):
+    def __init__(
+        self,
+        in_channels,
+        out_channels,
+        kernel_size,
+        stride=1,
+        padding=0,
+        dilation=1,
+        bias=False,
+        config_str="batchnorm-relu",
+    ):
         super(TDNNLayer, self).__init__()
         if padding < 0:
-            assert kernel_size % 2 == 1, 'Expect equal paddings, but got even kernel size ({})'.format(
-                kernel_size)
+            assert (
+                kernel_size % 2 == 1
+            ), "Expect equal paddings, but got even kernel size ({})".format(kernel_size)
             padding = (kernel_size - 1) // 2 * dilation
-        self.linear = torch.nn.Conv1d(in_channels,
-                                out_channels,
-                                kernel_size,
-                                stride=stride,
-                                padding=padding,
-                                dilation=dilation,
-                                bias=bias)
+        self.linear = torch.nn.Conv1d(
+            in_channels,
+            out_channels,
+            kernel_size,
+            stride=stride,
+            padding=padding,
+            dilation=dilation,
+            bias=bias,
+        )
         self.nonlinear = get_nonlinear(config_str, out_channels)
 
     def forward(self, x):
@@ -147,23 +144,19 @@
 
 
 class CAMLayer(torch.nn.Module):
-    def __init__(self,
-                 bn_channels,
-                 out_channels,
-                 kernel_size,
-                 stride,
-                 padding,
-                 dilation,
-                 bias,
-                 reduction=2):
+    def __init__(
+        self, bn_channels, out_channels, kernel_size, stride, padding, dilation, bias, reduction=2
+    ):
         super(CAMLayer, self).__init__()
-        self.linear_local = torch.nn.Conv1d(bn_channels,
-                                      out_channels,
-                                      kernel_size,
-                                      stride=stride,
-                                      padding=padding,
-                                      dilation=dilation,
-                                      bias=bias)
+        self.linear_local = torch.nn.Conv1d(
+            bn_channels,
+            out_channels,
+            kernel_size,
+            stride=stride,
+            padding=padding,
+            dilation=dilation,
+            bias=bias,
+        )
         self.linear1 = torch.nn.Conv1d(bn_channels, bn_channels // reduction, 1)
         self.relu = torch.nn.ReLU(inplace=True)
         self.linear2 = torch.nn.Conv1d(bn_channels // reduction, out_channels, 1)
@@ -176,45 +169,50 @@
         m = self.sigmoid(self.linear2(context))
         return y * m
 
-    def seg_pooling(self, x, seg_len=100, stype='avg'):
-        if stype == 'avg':
+    def seg_pooling(self, x, seg_len=100, stype="avg"):
+        if stype == "avg":
             seg = F.avg_pool1d(x, kernel_size=seg_len, stride=seg_len, ceil_mode=True)
-        elif stype == 'max':
+        elif stype == "max":
             seg = F.max_pool1d(x, kernel_size=seg_len, stride=seg_len, ceil_mode=True)
         else:
-            raise ValueError('Wrong segment pooling type.')
+            raise ValueError("Wrong segment pooling type.")
         shape = seg.shape
         seg = seg.unsqueeze(-1).expand(*shape, seg_len).reshape(*shape[:-1], -1)
-        seg = seg[..., :x.shape[-1]]
+        seg = seg[..., : x.shape[-1]]
         return seg
 
 
 class CAMDenseTDNNLayer(torch.nn.Module):
-    def __init__(self,
-                 in_channels,
-                 out_channels,
-                 bn_channels,
-                 kernel_size,
-                 stride=1,
-                 dilation=1,
-                 bias=False,
-                 config_str='batchnorm-relu',
-                 memory_efficient=False):
+    def __init__(
+        self,
+        in_channels,
+        out_channels,
+        bn_channels,
+        kernel_size,
+        stride=1,
+        dilation=1,
+        bias=False,
+        config_str="batchnorm-relu",
+        memory_efficient=False,
+    ):
         super(CAMDenseTDNNLayer, self).__init__()
-        assert kernel_size % 2 == 1, 'Expect equal paddings, but got even kernel size ({})'.format(
-            kernel_size)
+        assert kernel_size % 2 == 1, "Expect equal paddings, but got even kernel size ({})".format(
+            kernel_size
+        )
         padding = (kernel_size - 1) // 2 * dilation
         self.memory_efficient = memory_efficient
         self.nonlinear1 = get_nonlinear(config_str, in_channels)
         self.linear1 = torch.nn.Conv1d(in_channels, bn_channels, 1, bias=False)
         self.nonlinear2 = get_nonlinear(config_str, bn_channels)
-        self.cam_layer = CAMLayer(bn_channels,
-                                  out_channels,
-                                  kernel_size,
-                                  stride=stride,
-                                  padding=padding,
-                                  dilation=dilation,
-                                  bias=bias)
+        self.cam_layer = CAMLayer(
+            bn_channels,
+            out_channels,
+            kernel_size,
+            stride=stride,
+            padding=padding,
+            dilation=dilation,
+            bias=bias,
+        )
 
     def bn_function(self, x):
         return self.linear1(self.nonlinear1(x))
@@ -229,29 +227,33 @@
 
 
 class CAMDenseTDNNBlock(torch.nn.ModuleList):
-    def __init__(self,
-                 num_layers,
-                 in_channels,
-                 out_channels,
-                 bn_channels,
-                 kernel_size,
-                 stride=1,
-                 dilation=1,
-                 bias=False,
-                 config_str='batchnorm-relu',
-                 memory_efficient=False):
+    def __init__(
+        self,
+        num_layers,
+        in_channels,
+        out_channels,
+        bn_channels,
+        kernel_size,
+        stride=1,
+        dilation=1,
+        bias=False,
+        config_str="batchnorm-relu",
+        memory_efficient=False,
+    ):
         super(CAMDenseTDNNBlock, self).__init__()
         for i in range(num_layers):
-            layer = CAMDenseTDNNLayer(in_channels=in_channels + i * out_channels,
-                                      out_channels=out_channels,
-                                      bn_channels=bn_channels,
-                                      kernel_size=kernel_size,
-                                      stride=stride,
-                                      dilation=dilation,
-                                      bias=bias,
-                                      config_str=config_str,
-                                      memory_efficient=memory_efficient)
-            self.add_module('tdnnd%d' % (i + 1), layer)
+            layer = CAMDenseTDNNLayer(
+                in_channels=in_channels + i * out_channels,
+                out_channels=out_channels,
+                bn_channels=bn_channels,
+                kernel_size=kernel_size,
+                stride=stride,
+                dilation=dilation,
+                bias=bias,
+                config_str=config_str,
+                memory_efficient=memory_efficient,
+            )
+            self.add_module("tdnnd%d" % (i + 1), layer)
 
     def forward(self, x):
         for layer in self:
@@ -260,11 +262,7 @@
 
 
 class TransitLayer(torch.nn.Module):
-    def __init__(self,
-                 in_channels,
-                 out_channels,
-                 bias=True,
-                 config_str='batchnorm-relu'):
+    def __init__(self, in_channels, out_channels, bias=True, config_str="batchnorm-relu"):
         super(TransitLayer, self).__init__()
         self.nonlinear = get_nonlinear(config_str, in_channels)
         self.linear = torch.nn.Conv1d(in_channels, out_channels, 1, bias=bias)
@@ -276,11 +274,7 @@
 
 
 class DenseLayer(torch.nn.Module):
-    def __init__(self,
-                 in_channels,
-                 out_channels,
-                 bias=False,
-                 config_str='batchnorm-relu'):
+    def __init__(self, in_channels, out_channels, bias=False, config_str="batchnorm-relu"):
         super(DenseLayer, self).__init__()
         self.linear = torch.nn.Conv1d(in_channels, out_channels, 1, bias=bias)
         self.nonlinear = get_nonlinear(config_str, out_channels)
@@ -292,5 +286,3 @@
             x = self.linear(x)
         x = self.nonlinear(x)
         return x
-
-

--
Gitblit v1.9.1