
    UhJ                        d dl mZ d dlmZmZmZmZ d dlZd dlm	Z	 ddl
mZmZ ddlmZ ddlmZ ddlmZmZ dd	lmZ dd
lmZ ddlmZmZmZmZ ddlmZ ddlm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z' ddl(m)Z)m*Z* ddl+m,Z,  ejZ                  e.      Z/e G d de             Z0 ed      e G d de                    Z1 G d de&      Z2 G d de'      Z3 G d de$      Z4 G d de!      Z5 G d  d!e"      Z6e G d" d#e%             Z7 G d$ d%e	jp                        Z9 ed&       G d' d(e#e             Z: G d) d*e	jp                        Z;e G d+ d,e%             Z< ed-       G d. d/e1e,             Z=g d0Z>y)1    )	dataclass)ListOptionalTupleUnionN   )CacheDynamicCache)GenerationMixin)FlashAttentionKwargs)BaseModelOutputWithPastCausalLMOutputWithPast)PreTrainedModel)Unpack)ModelOutputauto_docstringcan_return_tuplelogging   )	AutoModel)KwargsForCausalLMLlamaAttentionLlamaDecoderLayerLlamaForCausalLMLlamaMLP
LlamaModelLlamaRMSNormLlamaRotaryEmbedding   )	CsmConfigCsmDepthDecoderConfig)CsmGenerationMixinc                      e Zd ZU dZdZeej                     ed<   dZ	ej                  ed<   dZ
eeeej                           ed<   dZeeej                  df      ed<   dZeeej                  df      ed<   dZeej                     ed	<   dZej                  ed
<   dZeeeej                           ed<   dZeeej                  df      ed<   dZeeej                  df      ed<   dZeej                     ed<   y)CsmOutputWithPastaf  
    Base class for the model autoregressive outputs.

    Args:
        loss (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `labels` is provided):
            Language modeling loss (for next-token prediction).
        logits (`torch.FloatTensor` of shape `(batch_size, sequence_length, config.vocab_size)`):
            Prediction scores of the language modeling head (scores for each vocabulary token before SoftMax).
        past_key_values (`tuple(tuple(torch.FloatTensor))`, *optional*, returned when `use_cache=True` is passed or when `config.use_cache=True`):
            Tuple of `tuple(torch.FloatTensor)` of length `config.n_layers`, with each tuple having 2 tensors of shape
            `(batch_size, num_heads, sequence_length, embed_size_per_head)`)

            Contains pre-computed hidden-states (key and values in the self-attention blocks) that can be used (see
            `past_key_values` input) to speed up sequential decoding.
        hidden_states (`tuple(torch.FloatTensor)`, *optional*, returned when `output_hidden_states=True` is passed or when `config.output_hidden_states=True`):
            Tuple of `torch.FloatTensor` (one for the output of the embeddings, if the model has an embedding layer, +
            one for the output of each layer) of shape `(batch_size, sequence_length, hidden_size)`.

            Hidden-states of the model at the output of each layer plus the optional initial embedding outputs.
        attentions (`tuple(torch.FloatTensor)`, *optional*, returned when `output_attentions=True` is passed or when `config.output_attentions=True`):
            Tuple of `torch.FloatTensor` (one for each layer) of shape `(batch_size, num_heads, sequence_length,
            sequence_length)`.

            Attentions weights after the attention softmax, used to compute the weighted average in the self-attention
            heads.
        depth_decoder_loss (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `labels` is provided):
            Language modeling loss (for next-token prediction) of the depth decoder model.
        depth_decoder_logits (`torch.FloatTensor` of shape `(batch_size, sequence_length, config.vocab_size)`):
            Prediction scores of the depth decoder (scores for each vocabulary token before SoftMax).
        depth_decoder_past_key_values (`tuple(tuple(torch.FloatTensor))`, *optional*, returned when `use_cache=True` is passed or when `config.use_cache=True`):
            Tuple of `tuple(torch.FloatTensor)` of length `config.n_layers`, with each tuple having 2 tensors of shape
            `(batch_size, num_heads, sequence_length, embed_size_per_head)`)
        depth_decoder_hidden_states (`tuple(torch.FloatTensor)`, *optional*, returned when `output_hidden_states=True` is passed or when `config.output_hidden_states=True`):
            Tuple of `torch.FloatTensor` (one for the output of the embeddings, if the model has an embedding layer, +
            one for the output of each layer) of shape `(batch_size, sequence_length, hidden_size)`.

            Hidden-states of the model at the output of each layer plus the optional initial embedding outputs.
        depth_decoder_attentions (`tuple(torch.FloatTensor)`, *optional*, returned when `output_attentions=True` is passed or when `config.output_attentions=True`):
            Tuple of `torch.FloatTensor` (one for each layer) of shape `(batch_size, num_heads, sequence_length,
            sequence_length)`.
        backbone_loss (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `labels` is provided):
            Language modeling loss (for next-token prediction) of the backbone model.
    Nlosslogitspast_key_values.hidden_states
attentionsdepth_decoder_lossdepth_decoder_logitsdepth_decoder_past_key_valuesdepth_decoder_hidden_statesdepth_decoder_attentionsbackbone_loss)__name__
__module____qualname____doc__r%   r   torchFloatTensor__annotations__r&   r'   r   r(   r)   r*   r+   r,   r-   r.   r/        u/var/www/catia.catastroantioquia-mas.com/valormas/lib/python3.12/site-packages/transformers/models/csm/modular_csm.pyr$   r$   /   s(   *X )-D(5$$
%, $FE$AEOXeE%*;*;$<=>E=AM8E%"3"3S"89:A:>Ju00#567>6:!2!23:.2%++2OS!8E%8I8I2J,K#LSKO%0A0A30F*G!HOHLhuU->->-C'DEL15M8E--.5r8   r$   z[
    The bare Csm Model outputting raw hidden-states without any specific head on top.
    )custom_introc                   B    e Zd ZeZdZdZdgZdgZdZ	dZ
dZdZdZdZd Zy)CsmPreTrainedModelmodelTCsmDecoderLayerr'   c                 6   | j                   j                  }t        |t        j                        rY|j
                  j                  j                  d|       |j                  %|j                  j                  j                          y y t        |t        j                        rf|j
                  j                  j                  d|       |j                  2|j
                  j                  |j                     j                          y y t        |t              rJ|j                  }t        |dz
        D ],  }|j
                  j                  |   j                  d|       . y t        |t              r&|j
                  j                  j!                  d       y y )Ng        )meanstdr   g      ?)configinitializer_range
isinstancennLinearweightdatanormal_biaszero_	Embeddingpadding_idxCsmCodebooksHeadnum_codebooksrange
CsmRMSNormfill_)selfmodulerA   rO   is        r9   _init_weightsz CsmPreTrainedModel._init_weights   s8   kk++fbii(MM&&CS&9{{&  &&( '-MM&&CS&9!!-""6#5#56<<> . 01"00M=1,- A""1%--3C-@A
+MM$$S) ,r8   N)r0   r1   r2   r    config_classbase_model_prefixsupports_gradient_checkpointing_no_split_modules_skip_keys_device_placement_supports_flash_attn_2_supports_sdpa_supports_cache_class_supports_quantized_cache_supports_static_cache_supports_attention_backendrV   r7   r8   r9   r<   r<   j   sQ     L&*#*+#4"5!N ! $!"&*r8   r<   c                       e Zd Zy)rQ   Nr0   r1   r2   r7   r8   r9   rQ   rQ          r8   rQ   c                       e Zd Zy)CsmRotaryEmbeddingNrc   r7   r8   r9   rf   rf      rd   r8   rf   c                       e Zd Zy)CsmMLPNrc   r7   r8   r9   rh   rh      rd   r8   rh   c                       e Zd Zy)CsmAttentionNrc   r7   r8   r9   rj   rj      rd   r8   rj   c                       e Zd Zy)r>   Nrc   r7   r8   r9   r>   r>      rd   r8   r>   c                   B    e Zd ZeZ fdZee	 	 	 	 	 	 	 	 	 	 ddej                  de
ej                     de
ej                     de
ej                     de
e   de
ej                     de
e   d	e
e   d
e
e   de
ej                     dee   deeef   fd              Z xZS )CsmDepthDecoderModelc                     t         |   |       t        j                  |j                  |j
                  z  |j                        | _        t        j                  |j                  |j                  d      | _
        y NF)rJ   )super__init__rE   rL   rO   
vocab_sizebackbone_hidden_sizeembed_tokensrF   hidden_sizeinputs_embeds_projectorrS   rB   	__class__s     r9   rq   zCsmDepthDecoderModel.__init__   s]     LL&*>*>ARAR*RU[UpUpq')yy1L1LfN`N`gl'm$r8   	input_idsbackbone_last_hidden_stateattention_maskposition_idsr'   inputs_embeds	use_cacheoutput_attentionsoutput_hidden_statescache_positionflash_attn_kwargsreturnc                 B   |5t         j                  j                         st        j	                  d       d}||n| j
                  j                  }|	|	n| j
                  j                  }	||n| j
                  j                  }|du |duz  rt        d      | j                  r%| j                  r|rt        j	                  d       d}|r|
t               }|
i||j                         nd}||j                  d   n|j                  d   }||j                  n|j                  }t        j                   |||z   |      }
|t        j"                  |
dz
  d	      }|| j$                  z  }| j'                  ||z         }|
d   dk(  }|
||dddf<   n5t         j                  j                         s|rt        j)                  d
       | j+                  |      }| j-                  |||
||      }|}|
j/                  d      }| j1                  ||      }|	rdnd}|rdnd}| j2                  d| j
                  j4                   D ],  }|	r||fz  } ||f||||||
|d|}|d   }|s$||d   fz  }. | j7                  |      }|	r||fz  }t9        ||r|nd||      S )aJ  
        backbone_last_hidden_state (`torch.FloatTensor` of shape `(batch_size, backbone_hidden_size)`, *optional*):
            The last hidden state of the backbone model. Such input is required when the first codebook token (the one generated by the backbone model)
            is provided in the `input_ids` argument.
        NzCustom `position_ids` were provided but will be ignored. CSM depth decoder automatically determines position_ids from `cache_position` and as it requires them to be identical across the batch, the provided position_ids will be ignored.z;You must specify exactly one of input_ids or inputs_embeds.zX`use_cache=True` is incompatible with gradient checkpointing. Setting `use_cache=False`.Fr   r   device)minzvWhen the first codebook token is provided, `backbone_last_hidden_state` should also be provided for correct inference.r7   )r{   r|   past_key_valuer   r~   r   position_embeddings)last_hidden_stater'   r(   r)   )r4   compileris_compilingloggerwarning_oncerB   r   r   r~   
ValueErrorgradient_checkpointingtrainingr
   get_seq_lengthshaper   arangeclamprr   rt   warningrv   _update_causal_mask	unsqueeze
rotary_emblayersnum_hidden_layersnormr   )rS   ry   rz   r{   r|   r'   r}   r~   r   r   r   r   past_seen_tokensinputs_seq_lengthr   codebook_idxsoffsetinput_ids_are_first_codebookcausal_maskr(   r   all_hidden_statesall_self_attnsdecoder_layerlayer_outputss                            r9   forwardzCsmDepthDecoderModel.forward   s   * #ENN,G,G,IM  L1B1N-TXT_T_TqTq$8$D $++JjJj 	 "+!6IDKK<Q<Q	-t";<Z[[&&4==Yj I0*nO!CRC^==?de:G:S 3 3A 6YbYhYhijYk-:-F]))IL\L\F"\\*:<LO`<`iopN !KK(:BM"T__4F --i&.@AM+9!+<+A()5&@ad#~~2249UNN Q 44]C..M>?L]
 & &//2"oom\J #7BD0d![[)H4;;+H+HI 	6M#!m%55!)
*)."3#-$7
 $
M *!,M =#3"55'	6* 		-0  -!11&+/8Od+%	
 	
r8   )
NNNNNNNNNN)r0   r1   r2   r!   rW   rq   r   r   r4   
LongTensorr   r5   Tensorr	   boolr   r   r   r   r   r   __classcell__rx   s   @r9   rm   rm      s*   (Ln
  '+BF1537+/59$(,0/359p
##p
 %-U->->$?p
 !.	p

 u//0p
 "%p
   1 12p
 D>p
 $D>p
 'tnp
 !!1!12p
 $$89p
 
u--	.p
  p
r8   rm   c                   &     e Zd Z fdZddZ xZS )rN   c                     t         |           || _        t        j                  t        j                  | j                  dz
  ||            | _        y )Nr   )rp   rq   rO   rE   	Parameterr4   emptyrG   )rS   ru   rO   rr   rx   s       r9   rq   zCsmCodebooksHead.__init__%  s?    *ll5;;t/A/AA/E{T^#_`r8   c           
         |2|j                   d   }| j                  t        j                  |         }n|dz
  }| j                  |   }t	        |j                   d         D cg c]9  }t
        j                  j                  |d d |d d f   ||   j                        ; }}t        j                  |d      }|S c c}w )Nr   r   dim)
r   rG   r4   r   rP   rE   
functionallinearTstack)rS   r(   r   
seq_lengthcodebook_weightr   codebook_idxs          r9   r   zCsmCodebooksHead.forward*  s    !&,,Q/J"kk%,,z*BCO*Q.M"kk-8O !&o&;&;A&> ?
 MM  q,/A!BOT`DaDcDcd
 
 Mq9
s   #>B<Nr0   r1   r2   rq   r   r   r   s   @r9   rN   rN   $  s    a
r8   rN   a$  
    The CsmDepthDecoder Model transformer, with a [`CsmCodebooksHead`] on top,
    which can be seen a position-specific language modeling head, allowing to use a different linear layer for each codebook
    (e.g. position 0 is the first codebook and uses the first codebook head, etc.)
    c            !       P    e Zd ZdZdZdZ fdZd Zd Z	 	 	 	 dde	j                  dee   dee	j                     dee	j                     d	ee	j                     f
 fd
Zee	 	 	 	 	 	 	 	 	 	 	 	 dde	j                  dee	j                     dee	j"                     dee	j                     deeeee	j                     f      dee	j                     dee	j                     dee   dee   dee   d	ee	j                     deee	j"                  f   dee   deeef   fd              Z xZS )CsmDepthDecoderForCausalLMNc                     t         |   |       | `t        |j                  |j
                  |j                        | _        t        |      | _	        y r   )
rp   rq   lm_headrN   ru   rO   rr   codebooks_headrm   r=   rw   s     r9   rq   z#CsmDepthDecoderForCausalLM.__init__G  sE     L.v/A/A6CWCWY_YjYjk)&1
r8   c                     t        d      NzNot needed for CsmAttributeErrorrS   s    r9   get_output_embeddingsz0CsmDepthDecoderForCausalLM.get_output_embeddingsM      122r8   c                     t        d      r   r   rS   new_embeddingss     r9   set_output_embeddingsz0CsmDepthDecoderForCausalLM.set_output_embeddingsP  r   r8   ry   r'   r{   r}   r   c                     t        	|   |||||fi |}|d   d   dk(  }|s|j                  d       |j                  d       |S )Nr   r   rz   r|   )rp   prepare_inputs_for_generationpop)
rS   ry   r'   r{   r}   r   kwargsmodel_inputsis_first_generation_steprx   s
            r9   r   z8CsmDepthDecoderForCausalLM.prepare_inputs_for_generationS  sg     w<~
Y_
 $00@#A!#D#I '9: 	(r8   rz   r|   labelsr~   r   r   logits_to_keepr   r   c                 `   |	|	n| j                   j                  }	|
|
n| j                   j                  }
 | j                  d||||||||	|
|d
|}|d   }t	        |t
              r |dk(  rt        dd      }nt        | d      }n|}| j                  |dd|ddf   |||   nd      }|j                         }d}|B|dddf   j                         } | j                  d|d| j                   j                  |d|}t        |||j                  |j                  |j                        S )	a  
        backbone_last_hidden_state (`torch.FloatTensor` of shape `(batch_size, backbone_hidden_size)`, *optional*):
            The last hidden state of the backbone model. Such input is required when the first codebook token (the one generated by the backbone model)
            is provided in the `input_ids` argument.
        labels (`torch.LongTensor` of shape `(batch_size, sequence_length)`, *optional*):
            Labels for computing the masked language modeling loss. Indices should either be in `[0, ...,
            config.vocab_size]` or -100 (see `input_ids` docstring). Tokens with indices set to `-100` are ignored
            (masked), the loss is only computed for the tokens with labels in `[0, ..., config.vocab_size]`.
        N)
ry   rz   r{   r|   r'   r}   r~   r   r   r   r   r   .)r&   r   rr   shift_labels)r%   r&   r'   r(   r)   r7   )rB   r   r   r=   rD   intslicer   
contiguousloss_functionrr   r   r'   r(   r)   )rS   ry   rz   r{   r|   r'   r}   r   r~   r   r   r   r   r   outputsr(   slice_indicesr&   r%   r   s                       r9   r   z"CsmDepthDecoderForCausalLM.forwardi  sy   6 2C1N-TXT_T_TqTq$8$D $++JjJj 	
 $** 
'A)%+'/!5)
 
  
nc*" %a %~ot <*M$$!]A-.Q_Qk}0Mqu
 ""$!#qr'?557L%4%% dt{{7M7M\hlrD &#33!//))
 	
r8   NNNN)NNNNNNNNNNNr   )r0   r1   r2   _tied_weights_keys_tp_plan_pp_planrq   r   r   r4   r   r   r	   r5   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   s   @r9   r   r   ;  s    HH233 ,0595959## "% !!1!12	
   1 12 !!1!12,  '+BF1537KO59-1$(,0/35934J
##J
 %-U->->$?J
 !.	J

 u//0J
 "%tE4E4E/F(F"GHJ
   1 12J
 ))*J
 D>J
 $D>J
 'tnJ
 !!1!12J
 c5<</0J
 *+J
 
u,,	-J
  J
r8   r   c                   $     e Zd Z fdZd Z xZS )CsmBackboneModelEmbeddingsc                    t         |           t        j                  |j                  |j
                  z  |j                        | _        | j                  dt        j                  |j                        |j
                  z  d       y )Naudio_tokens_offsetsF)
persistent)rp   rq   rE   rL   rO   rr   ru   embed_audio_tokensregister_bufferr4   r   rw   s     r9   rq   z#CsmBackboneModelEmbeddings.__init__  sn    "$,,0D0DvGXGX0X[a[m[m"n"ELL1E1E$FIZIZ$Zgl 	 	
r8   c                 f    | j                  || j                  z         }|j                  d      }|S )Nr   r   )r   r   sum)rS   ry   input_embedss      r9   r   z"CsmBackboneModelEmbeddings.forward  s6    ..y4;T;T/TU#''A'.r8   r   r   s   @r9   r   r     s    
r8   r   c                   <     e Zd Z fdZee fd              Z xZS )CsmBackboneModelc                 D    t         |   |       t        |      | _        y r   )rp   rq   r   rt   rw   s     r9   rq   zCsmBackboneModel.__init__  s     6v>r8   c                 "    t        |   di |S )a&  
        input_ids (`torch.LongTensor` of shape `(batch_size, sequence_length, num_codebooks) or (batch_size, sequence_length)`):
            1. (batch_size, sequence_length): corresponds to the input sequence prepared with the processor from the text prompt. Such input
            requires `input_values` to be provided so that audio can be encoded in codebook tokens and then merged with the text tokens.

            2. (batch_size, sequence_length, num_codebooks): codebook tokens generated during the autoregressive decoding. Such input is not meant to be used by end users.

            Indices can be obtained using [`AutoTokenizer`]. See [`PreTrainedTokenizer.encode`] and
            [`PreTrainedTokenizer.__call__`] for details.

            [What are input IDs?](../glossary#input-ids)
        r7   )rp   r   )rS   super_kwargsrx   s     r9   r   zCsmBackboneModel.forward  s     w...r8   )r0   r1   r2   rq   r   r   r   r   r   s   @r9   r   r     s$    ? /  /r8   r   z
    The Csm model consists of two llama-like auto-regressive transformer models: a backbone model that predicts the first codebook token and a depth decoder that predicts the other codebook tokens.
    c            #           e Zd ZddgZ fdZd Zd Zd Zd Zd Z	e
 fd	       Z fd
Z	 	 	 	 d"deej                     deej                     deej                     deej                     deej                     f
dZ	 	 	 	 d"dej"                  dee   deej"                     deej&                     deej"                     f
 fdZee	 	 	 	 	 	 	 	 	 	 	 	 	 d#dej"                  deej                     deej                     deej                     deej"                     deeeeej&                     f      deej&                     deej"                     dee   dee   dee   deej"                     deeej                  f   dee   deeef   fd              Ze dej                  dededejB                  dej                  d efd!       Z" xZ#S )$CsmForConditionalGenerationz5backbone_model.embed_tokens.embed_audio_tokens.weightz'depth_decoder.model.embed_tokens.weightc                    t         |   |       |j                  | _        t        j                  |j
                  |j                  d      | _        t        j                  |j                  |j
                        | _	        t        j                  |      | _        t        j                  |j                        | _        t!        j"                  |j$                        | _        | j)                          y ro   )rp   rq   rr   rE   rF   ru   r   rL   text_vocab_sizeembed_text_tokensr   _from_configbackbone_modelr   depth_decoder_configdepth_decoderr   from_configcodec_configcodec_model	post_initrw   s     r9   rq   z$CsmForConditionalGeneration.__init__  s      ++yy!3!3V5F5FUS!#f.D.DfFXFX!Y.;;FC7DDVE`E`a$001D1DE 	r8   c                 .    | j                   j                  S r   r   rt   r   s    r9   get_input_embeddingsz0CsmForConditionalGeneration.get_input_embeddings  s    ""///r8   c                 &    || j                   _        y r   r   )rS   values     r9   set_input_embeddingsz0CsmForConditionalGeneration.set_input_embeddings  s    +0(r8   c                     | j                   S r   r   r   s    r9   r   z1CsmForConditionalGeneration.get_output_embeddings  s    ||r8   c                     || _         y r   r  r   s     r9   r   z1CsmForConditionalGeneration.set_output_embeddings  s	    %r8   c                     | j                   j                  rO| j                  | j                  j                  j
                  | j                  j                  j                         y y r   )rB   tie_codebooks_embeddings_tie_or_clone_weightsr   rt   r   r   r=   r   s    r9   _tie_weightsz(CsmForConditionalGeneration._tie_weights  sL    ;;//&&##00CC""((55 0r8   c                    |j                  dd      rt        
|   |i |\  }}nt        
|   |i |}d}t        |      }t	        |j
                        j                         D ci c]  \  }}|j                  |      r||d  | }	}}t	        |j                  j
                        j                  ddi|	       |	D ]  }t        |j
                  ||z           d|v r|fS |S c c}}w )Noutput_loading_infoFdepth_decoder__from_model_config)getrp   from_pretrainedlenvarsgeneration_configitems
startswithr   updatedelattr)clsargsr   r=   loading_infoprefix
prefix_lenattrr  depth_decoder_attrsrx   s             r9   r  z+CsmForConditionalGeneration.from_pretrained  s   ::+U3"''"94"J6"JE<G+T<V<E "[
  $E$;$;<BBD
ev& u$
 
 	U  223::<PRW;o[n;op ( 	<DE++Vd];	< !F*,&&L
s   )!C)c                     d}| j                   j                  j                         }|j                  dd        |j	                         D ]  \  }}t        | j                  ||z   |       ! t        |   |i | y )Nr  transformers_version)r   r  to_diff_dictr   r  setattrrp   save_pretrained)rS   r  r   r  r  r  r  rx   s          r9   r"  z+CsmForConditionalGeneration.save_pretrained#  s|    !"00BBOOQ 6=.446 	BKD%D**FTM5A	B 	00r8   ry   input_valuesinput_values_cutoffsr   r   c                    | j                  |      }|3t        j                  j                  |d      }||dk\     j	                         }||dkD     }t        j                  |j                         |j                        j                  t        |      d      }||j                  d      k  }g }t        ||      D ]  \  }	}
|
|
dk\     }
t        |
j                  d   dz
        D ]r  }|
|   }|
|dz      }|	d||f   }| j                  j!                  |j                  d            }|j"                  j%                  dd      }|j'                  |d          t  t        d |D              }t        j(                  |D cg c]6  }t        j                  j                  |ddd||j                  d   z
  f      8 c}      }| j                  j+                  |      }| j,                  j.                  }||k(  }| j0                  j3                  |      }||   ||<   t        j4                  dd| j,                  j6                  f|j                  t
        j8                  	      | j,                  j:                  z  }| j0                  j3                  |      j=                  d      }|| j,                  j>                  k(  }|jA                  |jC                         d      ||<   |e|j                  d      jA                  dd| j,                  j6                        }||   ||<   |d
k(  jE                  d      }d||d   |d   ddf<   |}||dS c c}w )a  
        Merges the input_ids and input_values to produce a single inputs_embeds tensor:
        1 - Infers the codec model on the input_values to retreive codebook token.
        2 - Embeds codebook tokens and places them at the correct positions in the inputs_embeds tensor.
        3 - If labels are provided, expands them to match codebook dimensions and position the target codebook tokens in the inputs_embeds tensor.

        Args:
            input_ids (`torch.Tensor` of shape `(batch_size, sequence_length)`):
                The input ids to embed.
            input_values (`torch.Tensor` of shape `(batch_size, channels, audio_sequence_length)`):
                The audio input values to embed.
            input_values_cutoffs (`torch.Tensor` of shape `(batch_size, max_num_audio)`):
                The cutoffs of the audio input values relative to its batch index, padded with -1 when no audio.
        Nr   r   r   r   r   .c              3   :   K   | ]  }|j                   d      yw)r   N)r   ).0els     r9   	<genexpr>zQCsmForConditionalGeneration._merge_input_ids_with_input_values.<locals>.<genexpr>\  s     "K2288A;"Ks   )r   dtypeiTas_tuple)r}   r   )#r   rE   r   paddiffr4   r   maxr   expandr  r   ziprP   r   r   encodeaudio_codes	transposeappendr   get_audio_codes_maskrB   audio_token_idr   rt   onesrO   longcodebook_eos_token_idsqueezeaudio_eos_token_idrepeatr   nonzero)rS   ry   r#  r$  r   r}   audio_lengthsinput_values_maskaudio_tokens_listbatch_input_valuesbatch_input_values_cutoffsrU   	start_idxend_idxaudio_batchcodec_outputscodebook_idsmax_audio_framesr*  batched_audio_token_idsaudio_codes_maskr:  audio_token_maskaudio_embedsaudio_eos_frame_idsaudio_eos_embedsaudio_eos_token_masklabels_expanded depth_decoder_ignore_frames_idxss                                r9   "_merge_input_ids_with_input_valuesz>CsmForConditionalGeneration._merge_input_ids_with_input_values-  sl   * ..y9##%==#4#45I6#R 01E1JKPPRM)-!*;<M %-A-E-E-GP\PcPc d k kM"B! !2M4K4KA4N N
 !#BElThBi >>"$>-GHbfgHg-h*9??BQFG >A :1 =I8Q?G"4S)G:K5K"LK$($4$4$;$;K<Q<QRS<T$UM#0#<#<#F#Fq"#ML%,,\!_=>>  #"K9J"KK&+kk\mnVX""21a1ABHHQK1O'PQn'#  $//DDEVW![[77N(N:..;;<STL.:;K.LM*+ 

Aq$++";";<YEUEU]b]g]gh++334    $22??@ST\\]^_#,0N0N#N 2B2I2IJ^JbJbJdfg2hM./ !"("2"22"6"="=aDKKD]D]"^4KL\4] 014:dN3K3KUY3K3Z0pt @ CEefgEhjkjl lm(!.&AA; os   ;Mr'   r{   r}   r   c           	      0   t        	|   d	|||||d|}|}|j                  dk(  rn|j                  d      ]| j	                  ||j                  d      |j                  d      |j                  d            }|j                  |d   |d   d d       |S )
N)ry   r'   r{   r}   r   r   r}   r#  r$  r   )ry   r#  r$  r   )r}   r   ry   r7   )rp   r   ndimr  rV  r  )
rS   ry   r'   r{   r}   r   r   r   merged_inputsrx   s
            r9   r   z9CsmForConditionalGeneration.prepare_inputs_for_generation}  s     w< 
+)')
 
  Y^^q%8\=M=Mo=^=f CC##ZZ7%+ZZ0F%Gzz(+	 D M "/"@MZbLcrvw r8   r|   r~   r   r   r   r   c                 X   |
|
n| j                   j                  }
||n| j                   j                  }|/|j                  dk(  r | j	                  ||||      }|d   }|d   }d} | j
                  d||||||	|
||d	|}|d   }t        |t              rt        | d      n|}| j                  |dd|ddf         }d}d}d}d}||dddddf   } | j                  d||| j                   j                  d|}|ddddddf   d	k(  j                  d
       }||   dd| j                   j                  dz
  f   }t        j                  j!                  |dd      }|j#                  d      }||d   |d   dz
  ddf   }||   }| j%                  |||	|
|d|      }|j&                  }||z   }t)        |||||j*                  |j,                  |j.                  ||j0                  nd||j*                  nd||j,                  nd||j.                        S d      S )a  
        input_ids (`torch.LongTensor` of shape `(batch_size, sequence_length, num_codebooks) or (batch_size, sequence_length)`):
            1. (batch_size, sequence_length): corresponds to the input sequence prepared with the processor from the text prompt. Such input
            requires `input_values` to be provided so that audio can be encoded in codebook tokens and then merged with the text tokens.

            2. (batch_size, sequence_length, num_codebooks): codebook tokens generated during the autoregressive decoding. Such input is not meant to be used by end users.

            Indices can be obtained using [`AutoTokenizer`]. See [`PreTrainedTokenizer.encode`] and
            [`PreTrainedTokenizer.__call__`] for details.

            [What are input IDs?](../glossary#input-ids)
        input_values_cutoffs (`torch.Tensor` of shape `(batch_size, max_num_audio)`, *optional*):
            Specify the end positions of audio segments within each batch entry, relative to the concatenated audio input.
            If a batch entry has fewer segments than the maximum, it is padded with -1. For example, in a batch of 2 sequences
            where the first contains 2 audio segments of length l1, and the second contains 1 audio segment of length l2,
            the input_values_cutoffs would be: [[l1, 2 * l1], [l2, -1]].
        labels (`torch.LongTensor` of shape `(batch_size, sequence_length)`, *optional*):
            Labels for computing the masked language modeling loss. Indices should be in `[config.audio_token_id, -100, -101]`.
            Requires targeted `input_values` to be provided as audio tokens will be infered from it using the `codec_model`.
            - `config.audio_token_id` indicates an audio frames (considering sequence length elements as frames)
            - `-100` will be ignored in the loss computation
            - `-101` indicates the audio frame will be used only for the backbone model (using the first codebook token as labels)

            Such labels can be prepared using `output_labels=True` when calling [`CsmProcessor`].
        logits_to_keep (`int` or `torch.Tensor`, *optional*):
            Kept for compatibility. Does not support another value than:
            1. `0`, which is equivalent to keeping all logits, used in the training regime
            2. `1`, which is equivalent to keeping only the last logit, used in the generation regime

        Example:

        ```python
        >>> import torch
        >>> from transformers import CsmForConditionalGeneration, AutoProcessor
        >>> from datasets import load_dataset, Audio

        >>> model_id = "eustlb/csm-1b"
        >>> torch_device = "cuda" if torch.cuda.is_available() else "cpu"

        >>> processor = AutoProcessor.from_pretrained(model_id)

        >>> ds = load_dataset("hf-internal-testing/dailytalk-dummy", split="train")
        >>> # ensure the audio is 24kHz
        >>> ds = ds.cast_column("audio", Audio(sampling_rate=24000))

        >>> conversation = []
        >>> # prepare a conversation with text and corresponding audio
        >>> for text, audio, speaker_id in zip(ds[:4]["text"], ds[:4]["audio"], ds[:4]["speaker_id"]):
        ...     conversation.append(
        ...         {
        ...             "role": f"{speaker_id}",
        ...             "content": [{"type": "text", "text": text}, {"type": "audio", "path": audio["array"]}],
        ...         }
        ...     )

        >>> inputs = processor.apply_chat_template(
        ...     conversation,
        ...     tokenize=True,
        ...     return_dict=True,
        ...     output_labels=True,
        ... ).to(torch_device)

        >>> model = CsmForConditionalGeneration.from_pretrained(model_id, device_map=torch_device)
        >>> output = model(**inputs)
        >>> output.loss.backward()
        ```Nr   r}   r   )	ry   r{   r|   r'   r}   r~   r   r   r   r   )r&   r   rr   r   r/  r'  r   .r&  )r  Tr-  )ry   rz   r~   r   r   return_dictr   )r%   r/   r*   r&   r'   r(   r)   r+   r,   r-   r.   r7   )rB   r   r   rX  rV  r   rD   r   r   r   r   rr   allrO   rE   r   r0  rA  r   r%   r$   r'   r(   r)   r&   )rS   ry   r#  r{   r$  r|   r'   r}   r   r~   r   r   r   r   r   rY  backbone_outputsbackbone_hidden_statesr   backbone_logitsr%   r/   r*   depth_decoder_outputsbackbone_labels
train_maskdepth_decoder_input_ids
train_idxsbackbone_last_hidden_statesdepth_decoder_labelss                                 r9   r   z#CsmForConditionalGeneration.forward  s   l 2C1N-TXT_T_TqTq$8$D $++JjJj 	  Y^^q%8 CC<)=vM */:M"8,FI.4.. 
)%+'/!5)
 
 "2!!48B>SV8W~ot4]k,,'=aPQ>Q'RS! $$Q1WoO.D.. &4;;KaKaekM "!Q(+t388R8@@J&,Z&8>]@Y@Y\]@]>]9]&^#&(mm&7&78OQW_`&7&a##++T+:J*@APZ[\P]`aPacdAd*e'#)*#5 $($6$61+F#"3%9 + %7 %! "7!;!; #55D '1",<<*88'22AVAb!6!=!=hl$0 +@*O*O$0 )>(K(KI^Ij%:%E%E
 	
 qu
 	
r8   sequence_lengthtarget_lengthr,  
batch_sizec                    | | j                         dk(  r| }|S t        j                  |      j                  }t        j                  ||f|||j
                        }|dk7  rt        j                  |d      }|t        j                  ||j
                        |j                  dd      kD  z  }|ddddddf   j                  |ddd      }| |j                         }| j                  d   }	|ddddddd|	f   | ddddddf   j                  |j
                        z   }
|
dk(  }
|ddddddd|	f   j                  |
|      |ddddddd|	f<   |S )	aM  
        Creates a causal 4D mask of shape `(batch_size, 1, query_length, key_value_length)` from a 2D mask of shape
        `(batch_size, key_value_length)`, or if the input `attention_mask` is already 4D, do nothing.

        Args:
            attention_mask (`torch.Tensor`):
                A 2D attention mask of shape `(batch_size, key_value_length)` or a 4D attention mask of shape
                `(batch_size, 1, query_length, key_value_length)`.
            sequence_length (`int`):
                The sequence length being processed.
            target_length (`int`):
                The target length: when generating with static cache, the mask should be as long as the static cache,
                to account for the 0 padding, the part of the cache that is not filled yet.
            dtype (`torch.dtype`):
                The dtype to use for the 4D attention mask.
            cache_position (`torch.Tensor`):
                Indices depicting the position of the input sequence tokens in the sequence.
            batch_size (`torch.Tensor`):
                Batch size.
        N   )
fill_valuer,  r   r   )diagonalr   r'  r   )r   r4   finfor   fullr   triur   reshaper3  cloner   tomasked_fill)r{   rg  rh  r,  r   ri  r   r   	min_dtypemask_lengthpadding_masks              r9   5_prepare_4d_causal_attention_mask_with_cache_positionzQCsmForConditionalGeneration._prepare_4d_causal_attention_mask_with_cache_positionF  s   < %.*<*<*>!*C(K* ' E*..I** -0Ye\j\q\qK !##jjqA5<<n>S>STWeWmWmnprsWtttK%dD!Q&67>>z1bRTUK))//1,2226*1aL[L+@ANSTVZ\`bcScDdDgDg&&E    ,q05@Aq,;,AV5W5c5c )6Aq!\k\12 r8   r   )NNNNNNNNNNNNr   )$r0   r1   r2   r   rq   r   r  r   r   r	  classmethodr  r"  r   r4   r   rV  r   r	   r5   r   r   r   r   r   r   r   r   r   r   r$   r   staticmethodr,  rx  r   r   s   @r9   r   r     s    	@1

01&  41 -1/37;)-NBELL)NB u||,NB 'u||4	NB
 &NB 
%,,	NBf ,0595959## "% !!1!12	
   1 12 !!1!12>  '+/3157;37KO59-1$(,0/35934f
##f
 u||,f
 !.	f

 'u||4f
 u//0f
 "%tE4E4E/F(F"GHf
   1 12f
 ))*f
 D>f
 $D>f
 'tnf
 !!1!12f
 c5<</0f
 *+f
  
u''	(!f
  f
P 444 4 {{	4
 4 4 4r8   r   )r<   r   rm   r   r   )?dataclassesr   typingr   r   r   r   r4   torch.nnrE   cache_utilsr	   r
   
generationr   modeling_flash_attention_utilsr   modeling_outputsr   r   modeling_utilsr   processing_utilsr   utilsr   r   r   r   autor   llama.modeling_llamar   r   r   r   r   r   r   r   configuration_csmr    r!   generation_csmr"   
get_loggerr0   r   r$   r<   rQ   rf   rh   rj   r>   rm   ModulerN   r   r   r   r   __all__r7   r8   r9   <module>r     s    " / /   . ) B O - & K K 	 	 	 @ . 
		H	% 76 76 76t 
 * * *D	 		- 		X 		> 		' 	 z
: z
 z
zryy . s
!1? s
s
l  /z / /. 
X"46H X
Xvr8   