o
    i                     @   sr   d Z ddlZddlmZmZ ddlZddlm  mZ	 G dd dejj
Z
G dd de
ZG dd	 d	ejjZdS )
zeResidual block modules.

This code is modified from https://github.com/kan-bayashi/ParallelWaveGAN.

    N)OptionalTuplec                       s(   e Zd ZdZ fddZdd Z  ZS )Conv1dz-Conv1d module with customized initialization.c                    s   t  j|i | dS )zInitialize Conv1d module.Nsuper__init__)selfargskwargs	__class__ Z/home/ubuntu/.local/lib/python3.10/site-packages/espnet2/gan_tts/wavenet/residual_block.pyr      s   zConv1d.__init__c                 C   s8   t jjj| jdd | jdurt jj| jd dS dS )zReset parameters.relu)nonlinearityN        )torchnninitkaiming_normal_weightbias	constant_)r   r   r   r   reset_parameters   s   
zConv1d.reset_parameters)__name__
__module____qualname____doc__r   r   __classcell__r   r   r   r   r      s    r   c                       s.   e Zd ZdZdededef fddZ  ZS )	Conv1d1x1z*1x1 Conv1d with customized initialization.in_channelsout_channelsr   c                    s   t  j||ddd|d dS )zInitialize 1x1 Conv1d module.   r   )kernel_sizepaddingdilationr   Nr   )r   r    r!   r   r   r   r   r   "   s   
zConv1d1x1.__init__)r   r   r   r   intboolr   r   r   r   r   r   r      s    "r   c                       s   e Zd ZdZ											
ddedededededededededef fddZ			d dej	de
ej	 de
ej	 de
ej	 deej	ej	f f
ddZ  ZS )!ResidualBlockz!Residual block module in WaveNet.   @      P   r   r"   TFr#   residual_channelsgate_channelsskip_channelsaux_channelsglobal_channelsdropout_rater%   r   scale_residualc                    s   t    || _|| _|| _|
| _|d d dksJ d|d dks%J |d d | }t||||||	d| _|dkrEt||dd| _	nd| _	|dkrUt||dd| _
nd| _
|d }t||| |	d| _dS )	a[  Initialize ResidualBlock module.

        Args:
            kernel_size (int): Kernel size of dilation convolution layer.
            residual_channels (int): Number of channels for residual connection.
            skip_channels (int): Number of channels for skip connection.
            aux_channels (int): Number of local conditioning channels.
            dropout (float): Dropout probability.
            dilation (int): Dilation factor.
            bias (bool): Whether to add bias parameter in convolution layers.
            scale_residual (bool): Whether to scale the residual outputs.

        r"      r   z$Not support even number kernel size.)r$   r%   r   F)r   N)r   r   r3   r.   r0   r4   r   convr   conv1x1_auxconv1x1_gloconv1x1_out)r   r#   r.   r/   r0   r1   r2   r3   r%   r   r4   r$   gate_out_channelsr   r   r   r   ,   s4   


zResidualBlock.__init__Nxx_maskcgreturnc                 C   s.  |}t j|| j| jd}| |}d}|j||d |d\}}|durA| |}|j||d |d\}	}
||	 ||
 }}|dura| |}|j||d |d\}}|| || }}t	
|t	| }| |}|durx|| }|j| j| jgdd\}}|| }| jr|td }||fS )a  Calculate forward propagation.

        Args:
            x (Tensor): Input tensor (B, residual_channels, T).
            x_mask Optional[torch.Tensor]: Mask tensor (B, 1, T).
            c (Optional[Tensor]): Local conditioning tensor (B, aux_channels, T).
            g (Optional[Tensor]): Global conditioning tensor (B, global_channels, 1).

        Returns:
            Tensor: Output tensor for residual connection (B, residual_channels, T).
            Tensor: Output tensor for skip connection (B, skip_channels, T).

        )ptrainingr"   r5   )dimNg      ?)Fdropoutr3   rA   r6   splitsizer7   r8   r   tanhsigmoidr9   r.   r0   r4   mathsqrt)r   r;   r<   r=   r>   residualsplitdimxaxbcacbgagbsr   r   r   forwardp   s,   



zResidualBlock.forward)
r)   r*   r+   r*   r,   r-   r   r"   TF)NNN)r   r   r   r   r&   floatr'   r   r   Tensorr   r   rT   r   r   r   r   r   r(   )   s^    	
Gr(   )r   rI   typingr   r   r   torch.nn.functionalr   
functionalrC   r   r   Moduler(   r   r   r   r   <module>   s   
