o
    	۷ip                    @   s4  d Z ddlZddlZddlmZ ddlmZ ddlmZmZm	Z	 ddl
Z
ddl
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mZ ddlmZmZmZmZmZ ddlmZm Z m!Z!m"Z"m#Z# e$e%Z&dZ'dZ(dZ)e	e#e!e"f Z*eeddG dd deZ+eeddG dd deZ,eeddG dd deZ-G dd dej.Z/G dd dej.Z0G d d! d!ej.Z1G d"d# d#ej.Z2G d$d% d%ej.Z3G d&d' d'ej.Z4G d(d) d)ej.Z5G d*d+ d+ej.Z6G d,d- d-eZ7G d.d/ d/ej.Z8G d0d1 d1ej.Z9eG d2d3 d3eZ:eG d4d5 d5e:Z;eG d6d7 d7e:Z<eG d8d9 d9e:Z=eG d:d; d;e:Z>G d<d= d=ej.Z?G d>d? d?ej.Z@G d@dA dAej.ZAedBdG dCdD dDe:ZBG dEdF dFej.ZCG dGdH dHej.ZDG dIdJ dJej.ZEG dKdL dLej.ZFedMdG dNdO dOe:ZGg dPZHdS )QzPyTorch FLAVA model.    N)OrderedDict)	dataclass)AnyOptionalUnion)nn   )ACT2FN)GradientCheckpointingLayer)BaseModelOutputBaseModelOutputWithPooling)PreTrainedModel) find_pruneable_heads_and_indicesprune_linear_layer)ModelOutputauto_docstringfilter_out_non_signature_kwargslogging	torch_int   )FlavaConfigFlavaImageCodebookConfigFlavaImageConfigFlavaMultimodalConfigFlavaTextConfigzfacebook/flava-image-codebookg$(~k@a  
    Output from FlavaModel containing embeddings and outputs from individual encoders.

    Note that `image_embeddings` and `text_embeddigns` returned are similar to pooled output returned from a
    transformer. If you want embeddings for contrastive loss or retrieval use a FLAVA model's `image_projection` and
    `text_projection` layers on `image_embeddings` and `text_embeddings` respectively.
    )custom_introc                   @   s   e Zd ZU dZdZeej ed< dZ	ee
 ed< dZeej ed< dZee
 ed< dZeej ed< dZee
 ed< d	ee fd
dZdS )FlavaModelOutputa  
    image_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `pixel_values` are present):
        The image embeddings which are basically the pooled output of [`FlavaImageModel`].
    image_output (`BaseModelOutputWithPooling`, *optional*, returned when `pixel_values` are present):
        The output of the [`FlavaImageModel`].
    text_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `input_ids` are present):
        The text embeddings which are basically the pooled output of [`FlavaTextModel`].
    text_output (`BaseModelOutputWithPooling`, *optional*, returned when `input_ids` are present):
        The output of the [`FlavaTextModel`].
    multimodal_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `input_ids` and `pixel_values` are present and `skip_multimodal_encoder` is `None` or `False`):
        The multimodal embeddings which are basically the pooled output of [`FlavaTextModel`].
    multimodal_output (`BaseModelOutputWithPooling`, returned when `input_ids` and `pixel_values` are present and `skip_multimodal_encoder` is `None` or `False`):
        The output of the [`FlavaMultimodalModel`].
    Nimage_embeddingsimage_outputtext_embeddingstext_outputmultimodal_embeddingsmultimodal_outputreturnc                    s   t  fdd  D S )Nc                 3   s.    | ]}|d vr | nt  | V  qdS ))r    r   r"   Ngetattrto_tuple.0kself ^/home/ubuntu/vllm_env/lib/python3.10/site-packages/transformers/models/flava/modeling_flava.py	<genexpr>U   s
    
z,FlavaModelOutput.to_tuple.<locals>.<genexpr>tuplekeysr*   r,   r*   r-   r&   T   s   zFlavaModelOutput.to_tuple)__name__
__module____qualname____doc__r   r   torchFloatTensor__annotations__r   r   r   r    r!   r"   r0   r   r&   r,   r,   r,   r-   r   3   s   
 r   z@
    Class representing pretraining losses from FLAVA model
    c                   @   s   e Zd ZU dZdZeej ed< dZ	eej ed< dZ
eej ed< dZeej ed< dZeej ed< dZeej ed< d	efd
dZdS )FlavaLossesa  
    mim (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `mim_labels` and `pixel_values` are present, `input_ids_masked` is absent and `mim_weight` > 0.):
        Masked Image Modeling loss as used in BeIT calculated only for unimodal image data.
    mlm (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `mlm_labels` and `input_ids_masked` are present, `pixel_values` is absent and `mlm_weight` > 0.):
        Masked Language Modeling loss as used in BERT calculated only for unimodal text data.
    itm (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `itm_labels`, `input_ids_masked`, `pixel_values` are present and `itm_weight` > 0.):
        Image Text Matching (ITM) loss calculated for paired image-text data. Note that ITM loss is calculated on
        masked pairs in FLAVA.
    global_contrastive (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `input_ids` and `pixel_values` are present and `global_contrastive_weight` > 0.):
        Contrastive loss for image-text similarity similar to CLIP but calculated globally for paired image-text
        data. This is calculated on unmasked images and texts.
    mmm_image (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `mim_labels`, `pixel_values` and `input_ids_masked` are present and `mmm_image_weight` > 0.):
        Masked Multimodal Modeling loss's image component calculated on paired image-text data.
    mmm_text (`torch.FloatTensor` of shape `(1,)`, *optional*, returned when `mlm_labels`, `pixel_values` and `input_ids_masked` are present and `mmm_text_weight` > 0.):
        Masked Multimodal Modeling loss's text component calculated on paired image-text data.
    Nmimmlmitmglobal_contrastive	mmm_imagemmm_textr#   c                 C   s(   d}|   D ]}|d urd} |S q|S )NTF)values)r+   all_nonevr,   r,   r-   rA   z   s   zFlavaLosses.all_none)r2   r3   r4   r5   r:   r   r6   r7   r8   r;   r<   r=   r>   r?   boolrA   r,   r,   r,   r-   r9   [   s   
 r9   a  
    Output from FlavaForPreTraining containing embeddings, and outputs from individual encoders.

    Note that `image_embeddings` and `text_embeddings` returned are similar to pooled output returned from a
    transformer. If you want embeddings for contrastive loss or retrieval use a FLAVA model's `image_projection` and
    `text_projection` layers on `image_embeddings` and `text_embeddings` respectively.
    c                   @   s  e Zd ZU dZdZeej ed< dZ	e
ed< dZeej ed< dZee ed< dZeej ed< dZee ed< dZeej ed	< dZee ed
< dZeej ed< dZee ed< dZeej ed< dZee ed< dZeej ed< dZee ed< dZeej ed< dZeej ed< dZeej ed< dZeej ed< dZeej ed< dZeej ed< dZeej ed< dee  fddZ!dS )FlavaForPreTrainingOutputay  
    loss (`torch.FloatTensor`, *optional*, returned when `return_loss` is True):
        Total loss calculated for this model.
    loss_info (`FlavaLosses`):
        Detailed info for FLAVA Pretraining losses. Check `FlavaLosses` class description for the information on
        the keys.
    image_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `pixel_values` are present):
        The image embeddings which are basically the pooled output of [`FlavaImageModel`].
    image_output (`BaseModelOutputWithPooling`, *optional*, returned when `pixel_values` are present):
        The output of the [`FlavaImageModel`].
    text_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `input_ids` are present):
        The text embeddings which are basically the pooled output of [`FlavaTextModel`].
    text_output (`BaseModelOutputWithPooling`, *optional*, returned when `input_ids` are present):
        The output of the [`FlavaTextModel`].
    multimodal_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `input_ids` and `pixel_values` are present and `skip_unmasked_multimodal_encoder` is `None` or `False`):
        The multimodal embeddings which are basically the pooled output of [`FlavaTextModel`].
    multimodal_output (`BaseModelOutputWithPooling`, returned when `input_ids` and `pixel_values` are present and `skip_unmasked_multimodal_encoder` is `None` or `False`):
        The output of the [`FlavaMultimodalModel`].
    image_masked_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `pixel_values` are present):
        The image embeddings which are basically the pooled output of [`FlavaImageModel`]. Uses `bool_masked_pos`
        to create masked images.
    image_masked_output (`BaseModelOutputWithPooling`, *optional*, returned when `pixel_values` are present):
        The output of the [`FlavaImageModel`]. Uses `bool_masked_pos` to create masked images.
    text_masked_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `input_ids_masked` are present):
        The text embeddings which are basically the pooled output of [`FlavaTextModel`].
    text_masked_output (`BaseModelOutputWithPooling`, *optional*, returned when `input_ids_masked` are present):
        The output of the [`FlavaTextModel`].
    multimodal_masked_embeddings (`torch.FloatTensor` of shape `(batch_size, output_dim)`, *optional*, returned when `input_ids` and `pixel_values` are present):
        The multimodal embeddings which are basically the pooled output of [`FlavaTextModel`].
    multimodal_masked_output (`BaseModelOutputWithPooling`, *optional*, returned when `input_ids_masked` and `pixel_values` are present):
        The output of the [`FlavaMultimodalModel`].
    mim_logits (`torch.FloatTensor` of shape `(batch_size, num_image_patches, image_vocab_size)` or of shape `(total_masked_patches, image_vocab_size)` , *optional*, returned when `pixel_values` are present and `input_ids_masked` are not):
        The logits for MIM unimodal loss. Uses `book_masked_pos` to get masked patches. The flattened output is
            returned when `bool_masked_pos` has some of the patches masked.
    mlm_logits (`torch.FloatTensor` of shape `(batch_size, text_seq_length, text_vocab_size)` or of shape `(total_masked_seq_length, text_vocab_size)`, *optional*, returned when `input_ids_masked` are present and `pixel_values` are not):
        The logits for MLM unimodal loss. The flattened output is returned when `input_ids_masked` has some of
            the tokens masked.
    itm_logits (`torch.FloatTensor` of shape `(batch_size, 2)`, *optional*, returned when `input_ids_masked` and `pixel_values` are present):
        The logits for ITM loss. Note that ITM loss is calculated on masked pairs in FLAVA.
    contrastive_logits_per_image (`torch.FloatTensor` of shape `(image_batch_size, text_batch_size)`):
        The scaled dot product scores between `image_embeddings` and `text_embeddings` but passed through FLAVA's
        `image_projection` and `text_projection` layers respectively. This represents the image-text similarity
        scores. This is calculated on unmasked images and texts.
    contrastive_logits_per_text (`torch.FloatTensor` of shape `(text_batch_size, image_batch_size)`):
        The scaled dot product scores between `text_embeddings` and `image_embeddings` but passed through FLAVA's
        `text_projection` and `image_projection` layers respectively. This is calculated on unmasked images and
        texts.
    mmm_image_logits (`torch.FloatTensor` of shape `(batch_size, num_image_patches, image_vocab_size)` or of shape`(total_masked_patches, image_vocab_size)`, *optional*, returned when `pixel_values` and `input_ids_masked` are present):
        The logits for MMM image multimodal loss. Uses `book_masked_pos` to get masked patches. The flattened
            output is returned when `bool_masked_pos` has some of the patches masked.
    mmm_text_logits (`torch.FloatTensor` of shape `(batch_size, text_seq_length, text_vocab_size)` or of shape `(`(total_masked_seq_length, text_vocab_size)`), *optional*, returned when `pixel_values` and `input_ids_masked` are present):
        The logits for MMM text multimodal loss. The flattened output is returned when `input_ids_masked` has
            some of the tokens masked.
    Nloss	loss_infor   r   r   r    r!   r"   image_masked_embeddingsimage_masked_outputtext_masked_embeddingstext_masked_outputmultimodal_masked_embeddingsmultimodal_masked_output
mim_logits
mlm_logits
itm_logitscontrastive_logits_per_imagecontrastive_logits_per_textmmm_image_logitsmmm_text_logitsr#   c                    s$   g dt  fdd  D S )N)r    r   r"   rJ   rH   rL   c                 3   s.    | ]}|vr | nt  | V  qd S Nr$   r'   r+   transformer_outputsr,   r-   r.      s   , z5FlavaForPreTrainingOutput.to_tuple.<locals>.<genexpr>r/   r*   r,   rU   r-   r&      s   z"FlavaForPreTrainingOutput.to_tuple)"r2   r3   r4   r5   rE   r   r6   r7   r8   rF   r9   r   r   r   r   r    r!   r"   rG   rH   rI   rJ   rK   rL   rM   rN   rO   rP   rQ   rR   rS   r0   r   r&   r,   r,   r,   r-   rD      s0   
 7rD   c                	       sx   e Zd ZdZddededdf fddZd	ejd
e	de	dejfddZ
		ddejdeej dedejfddZ  ZS )FlavaImageEmbeddingszb
    Construct the CLS token, position and patch embeddings. Optionally, also the mask token.
    Fconfiguse_mask_tokenr#   Nc                    s   t    |p	|j}ttdd|j| _|r#ttdd|jnd | _t	|j
|j|j|jd| _| jj}ttd|d |j| _t|j| _|j| _|| _d S )Nr   )
image_size
patch_sizenum_channels	embed_dim)super__init__
mask_tokenr   	Parameterr6   zeroshidden_size	cls_tokenPatchEmbeddingsrZ   r[   r\   patch_embeddingsnum_patchesposition_embeddingsDropouthidden_dropout_probdropoutrX   )r+   rX   rY   rg   	__class__r,   r-   r_      s   

 
zFlavaImageEmbeddings.__init__
embeddingsheightwidthc                 C   s   |j d d }| jj d d }tj s||kr||kr| jS | jddddf }| jddddf }|j d }|| j }	|| j }
t|d }|d|||}|dddd}t	j
j||	|
fdd	d
}|dddddd|}tj||fddS )a   
        This method allows to interpolate the pre-trained position encodings, to be able to use the model on higher resolution
        images. This method is also adapted to support torch.jit tracing.

        Adapted from:
        - https://github.com/facebookresearch/dino/blob/de9ee3df6cf39fac952ab558447af1fa1365362a/vision_transformer.py#L174-L194, and
        - https://github.com/facebookresearch/dinov2/blob/e1277af2ba9496fbadf7aec6eba56e8d882d1e35/dinov2/models/vision_transformer.py#L179-L211
        r   Ng      ?r   r      bicubicF)sizemodealign_cornersdim)shaperh   r6   jit
is_tracingr[   r   reshapepermuter   
functionalinterpolateviewcat)r+   rn   ro   rp   rg   num_positionsclass_pos_embedpatch_pos_embedrx   
new_height	new_widthsqrt_num_positionsr,   r,   r-   interpolate_pos_encoding  s(   



z-FlavaImageEmbeddings.interpolate_pos_encodingpixel_valuesbool_masked_posr   c                 C   s   |j \}}}}| j||d}| \}}	}
|d urB| j||	d}| dkr0||dd}|d|}|d|  ||  }| j	|dd}t
j||fdd}|r_|| ||| }n|| j }| |}|S )N)r   rq   r   r         ?r   rw   )ry   rf   rt   r`   expandrx   r   	unsqueezetype_asrd   r6   r   r   rh   rk   )r+   r   r   r   
batch_sizer\   ro   rp   rn   seq_len_mask_tokensmask
cls_tokensr,   r,   r-   forward)  s    

zFlavaImageEmbeddings.forwardF)NF)r2   r3   r4   r5   r   rC   r_   r6   Tensorintr   r   
BoolTensorr   __classcell__r,   r,   rl   r-   rW      s    +rW   c                	       sh   e Zd ZdZ				ddedeeeeef f ded	ef fd
dZddej	de
dej	fddZ  ZS )re   z#
    Image to Patch Embedding.
          r      rZ   r[   r\   r]   c                    s   t    t|tjjs||f}t|tjjs||f}|d |d  |d |d   }|| _|| _|| _t	j
||||d| _d S )Nr   r   )kernel_sizestride)r^   r_   
isinstancecollectionsabcIterablerZ   r[   rg   r   Conv2d
projection)r+   rZ   r[   r\   r]   rg   rl   r,   r-   r_   R  s   
 zPatchEmbeddings.__init__Fr   r   r#   c              
   C   sx   |j \}}}}|s.|| jd ks|| jd kr.td| d| d| jd  d| jd  d	| |ddd}|S )Nr   r   zInput image size (*z) doesn't match model (z).rr   )ry   rZ   
ValueErrorr   flatten	transpose)r+   r   r   r   r\   ro   rp   xr,   r,   r-   r   e  s   zPatchEmbeddings.forward)r   r   r   r   r   )r2   r3   r4   r5   r   r   r0   r_   r6   r   rC   r   r   r,   r,   rl   r-   re   M  s     $re   c                       sP   e Zd ZdZ fddZ			d
deej deej deej fdd	Z  Z	S )FlavaTextEmbeddingszGConstruct the embeddings from word, position and token_type embeddings.c                    s   t    tj|j|j|jd| _t|j|j| _	t|j
|j| _tj|j|jd| _t|j| _t|dd| _| jdt|jddd | jd	tj| j tjd
dd d S )N)padding_idxepsposition_embedding_typeabsoluteposition_ids)r   rq   F)
persistenttoken_type_ids)dtype)r^   r_   r   	Embedding
vocab_sizerc   pad_token_idword_embeddingsmax_position_embeddingsrh   type_vocab_sizetoken_type_embeddings	LayerNormlayer_norm_epsri   rj   rk   r%   r   register_bufferr6   aranger   rb   r   rt   longr+   rX   rl   r,   r-   r_   t  s   

zFlavaTextEmbeddings.__init__N	input_idsr   r   c                 C   s   |  }|d }|d u r| jd d d |f }|d u rAt| dr6| jd d d |f }||d |}|}ntj|tj| jjd}| 	|}| 
|}	||	 }
| jdkr]| |}|
|7 }
| |
}
| |
}
|
S )Nr   r   r   )r   devicer   )rt   r   hasattrr   r   r6   rb   r   r   r   r   r   rh   r   rk   )r+   r   r   r   input_shape
seq_lengthbuffered_token_type_ids buffered_token_type_ids_expandedinputs_embedsr   rn   rh   r,   r,   r-   r     s&   






zFlavaTextEmbeddings.forwardNNN)
r2   r3   r4   r5   r_   r   r6   r   r   r   r,   r,   rl   r-   r   q  s    r   c                       st   e Zd Zdeddf fddZ			ddejdeej d	eej d
ede	e
ejejf e
ej f f
ddZ  ZS )FlavaSelfAttentionrX   r#   Nc                    s   t    |j|j dkrt|dstd|j d|j d|j| _t|j|j | _| j| j | _t	j
|j| j|jd| _t	j
|j| j|jd| _t	j
|j| j|jd| _t	|j| _d S )Nr   embedding_sizezThe hidden size z4 is not a multiple of the number of attention heads .bias)r^   r_   rc   num_attention_headsr   r   r   attention_head_sizeall_head_sizer   Linearqkv_biasquerykeyvalueri   attention_probs_dropout_probrk   r   rl   r,   r-   r_     s   

zFlavaSelfAttention.__init__Fhidden_statesattention_mask	head_maskoutput_attentionsc                 C   s,  |j \}}}| ||d| j| jdd}| ||d| j| jdd}	| ||d| j| jdd}
t	||	dd}|t
| j }|d urS|| }tjj|dd}| |}|d urh|| }t	||
}|dddd }| d d | jf }|j| }|r||f}|S |f}|S )Nrq   r   rr   rw   r   r   )ry   r   r   r   r   r   r   r   r6   matmulmathsqrtr   r~   softmaxrk   r}   
contiguousrt   r   )r+   r   r   r   r   r   r   r   query_layer	key_layervalue_layerattention_scoresattention_probscontext_layernew_context_layer_shapeoutputsr,   r,   r-   r     s:   

zFlavaSelfAttention.forwardNNF)r2   r3   r4   FlavaPossibleConfigsr_   r6   r   r   rC   r   r0   r   r   r,   r,   rl   r-   r     s     r   c                       sF   e Zd ZdZdeddf fddZdejdejdejfd	d
Z  Z	S )FlavaSelfOutputz
    The residual connection is defined in FlavaLayer (same as ViTLayer) instead of here (as is the case with other
    models), due to the layernorm applied before each block.
    rX   r#   Nc                    s.   t    t|j|j| _t|j| _d S rT   )	r^   r_   r   r   rc   denseri   rj   rk   r   rl   r,   r-   r_        
zFlavaSelfOutput.__init__r   input_tensorc                 C      |  |}| |}|S rT   r   rk   r+   r   r   r,   r,   r-   r        

zFlavaSelfOutput.forward)
r2   r3   r4   r5   r   r_   r6   r   r   r   r,   r,   rl   r-   r     s    $r   c                       s   e Zd Zdeddf fddZdee ddfddZ				dd
ej	de
ej	 de
ej	 dedeeej	ej	f eej	 f f
ddZ  ZS )FlavaAttentionrX   r#   Nc                    s*   t    t|| _t|| _t | _d S rT   )r^   r_   r   	attentionr   outputsetpruned_headsr   rl   r,   r-   r_     s   


zFlavaAttention.__init__headsc                 C   s   t |dkrd S t|| jj| jj| j\}}t| jj|| j_t| jj|| j_t| jj	|| j_	t| j
j|dd| j
_| jjt | | j_| jj| jj | j_| j|| _d S )Nr   r   rw   )lenr   r   r   r   r   r   r   r   r   r   r   r   union)r+   r   indexr,   r,   r-   prune_heads  s   zFlavaAttention.prune_headsFr   r   r   r   c                 C   s8   | j ||||d}| |d |}|f|dd   }|S N)r   r   r   r   r   )r   r   )r+   r   r   r   r   self_outputsattention_outputr   r,   r,   r-   r     s   zFlavaAttention.forwardr   )r2   r3   r4   r   r_   r   r   r   r6   r   r   rC   r   r0   r   r   r,   r,   rl   r-   r     s"    r   c                       s<   e Zd Zdeddf fddZdejdejfddZ  ZS )	FlavaIntermediaterX   r#   Nc                    sD   t    t|j|j| _t|jt	rt
|j | _d S |j| _d S rT   )r^   r_   r   r   rc   intermediate_sizer   r   
hidden_actstrr	   intermediate_act_fnr   rl   r,   r-   r_   0  s
   
zFlavaIntermediate.__init__r   c                 C   r   rT   )r   r  r+   r   r,   r,   r-   r   9  r   zFlavaIntermediate.forward	r2   r3   r4   r   r_   r6   r   r   r   r,   r,   rl   r-   r  /  s    	r  c                       sB   e Zd Zdeddf fddZdejdejdejfdd	Z  ZS )
FlavaOutputrX   r#   Nc                    s.   t    t|j|j| _t|j| _	d S rT   )
r^   r_   r   r   r  rc   r   ri   rj   rk   r   rl   r,   r-   r_   A  r   zFlavaOutput.__init__r   r   c                 C   s    |  |}| |}|| }|S rT   r   r   r,   r,   r-   r   G  s   

zFlavaOutput.forwardr  r,   r,   rl   r-   r	  @  s    $r	  c                       sx   e Zd ZdZdeddf fddZ			ddejd	eej d
eej de	de
eejejf eej f f
ddZ  ZS )
FlavaLayerz?This corresponds to the Block class in the timm implementation.rX   r#   Nc                    sb   t    |j| _d| _t|| _t|| _t|| _	t
j|j|jd| _t
j|j|jd| _d S )Nr   r   )r^   r_   chunk_size_feed_forwardseq_len_dimr   r   r  intermediater	  r   r   r   rc   r   layernorm_beforelayernorm_afterr   rl   r,   r-   r_   S  s   



zFlavaLayer.__init__Fr   r   r   r   c           	      C   sb   | j | ||||d}|d }|dd  }|| }| |}| |}| ||}|f| }|S r   )r   r  r  r  r   )	r+   r   r   r   r   self_attention_outputsr  r   layer_outputr,   r,   r-   r   _  s   


zFlavaLayer.forwardr   )r2   r3   r4   r5   r   r_   r6   r   r   rC   r   r0   r   r   r,   r,   rl   r-   r
  P  s"    r
  c                       sn   e Zd Zdeddf fddZ					ddejd	eej d
eej dededede	e
ef fddZ  ZS )FlavaEncoderrX   r#   Nc                    s:   t     | _t fddt jD | _d| _d S )Nc                    s   g | ]}t  qS r,   )r
  r(   r   rX   r,   r-   
<listcomp>  s    z)FlavaEncoder.__init__.<locals>.<listcomp>F)	r^   r_   rX   r   
ModuleListrangenum_hidden_layerslayergradient_checkpointingr   rl   r  r-   r_     s   
 
zFlavaEncoder.__init__FTr   r   r   r   output_hidden_statesreturn_dictc                 C   s   |rdnd }|r
dnd }t | jD ])\}	}
|r||f }|d ur$||	 nd }|
||||}|d }|r:||d f }q|rB||f }|sPtdd |||fD S t|||dS )Nr,   r   r   c                 s   s    | ]	}|d ur|V  qd S rT   r,   )r(   rB   r,   r,   r-   r.         z'FlavaEncoder.forward.<locals>.<genexpr>)last_hidden_stater   
attentions)	enumerater  r0   r   )r+   r   r   r   r   r  r  all_hidden_statesall_self_attentionsilayer_modulelayer_head_masklayer_outputsr,   r,   r-   r     s$   	

zFlavaEncoder.forward)NNFFT)r2   r3   r4   r   r_   r6   r   r   rC   r   r0   r   r   r   r,   r,   rl   r-   r  ~  s,    	
r  c                       s2   e Zd Zdef fddZdejfddZ  ZS )FlavaPoolerrX   c                    s*   t    t|j|j| _t | _d S rT   )r^   r_   r   r   rc   r   Tanh
activationr   rl   r,   r-   r_     s   
zFlavaPooler.__init__r   c                 C   s(   |d d df }|  |}| |}|S Nr   )r   r)  )r+   r   first_token_tensorpooled_outputr,   r,   r-   r     s   

zFlavaPooler.forwardr  r,   r,   rl   r-   r'    s    r'  c                   @   s@   e Zd ZU eed< dZdZdeej	ej
ejf ddfddZdS )	FlavaPreTrainedModelrX   flavaTmoduler#   Nc                 C   sX  t |tjtjfr#|jjjd| jjd |j	dur!|j	j
  dS dS t |tjrF|jjjd| jjd |jdurD|jj|j 
  dS dS t |tjr[|j	j
  |jjd dS t |trh|j	j
  dS t |tr|jj
  |jj
  |jdur|jj
  dS dS t |tr|jr|jj
  dS dS t |tr|jj| jj dS dS )zInitialize the weightsg        )meanstdNr   )r   r   r   r   weightdatanormal_rX   initializer_ranger   zero_r   r   r   fill_FlavaMaskedPredictionHeadrW   rd   rh   r`   FlavaMultimodalModeluse_cls_token
FlavaModellogit_scalelogit_scale_init_value)r+   r/  r,   r,   r-   _init_weights  s8   






z"FlavaPreTrainedModel._init_weights)r2   r3   r4   r   r8   base_model_prefixsupports_gradient_checkpointingr   r   r   r   r   r>  r,   r,   r,   r-   r-    s
   
 &r-  c                       s   e Zd ZU eed< dZdZddedef fddZde	j
fd	d
Zde	j
fddZdeeee f ddfddZe								ddeej deej dee deej deej dee dee dee deeef fddZ  ZS )FlavaImageModelrX   zflava.image_modelr   Tadd_pooling_layerc                    X   t  | || _t|| _t|| _tj|j	|j
d| _|r#t|nd| _|   dS v
        add_pooling_layer (bool, *optional*, defaults to `True`):
            Whether to add a pooling layer
        r   N)r^   r_   rX   rW   rn   r  encoderr   r   rc   r   	layernormr'  pooler	post_initr+   rX   rB  rl   r,   r-   r_     s   

zFlavaImageModel.__init__r#   c                 C      | j jS rT   rn   rf   r*   r,   r,   r-   get_input_embeddings     z$FlavaImageModel.get_input_embeddingsr   c                 C      || j _d S rT   rL  r+   r   r,   r,   r-   set_input_embeddings     z$FlavaImageModel.set_input_embeddingsheads_to_pruneNc                 C   *   |  D ]\}}| jj| j| qdS z
        Prunes heads of the model. heads_to_prune: dict of {layer_num: list of heads to prune in this layer} See base
        class PreTrainedModel
        NitemsrF  r  r   r   r+   rS  r  r   r,   r,   r-   _prune_heads     zFlavaImageModel._prune_headsr   r   r   r   r   r  r  c	                 C   s   |dur|n| j j}|dur|n| j j}|dur|n| j j}|du r&td| || j j}| j|||d}	| j|	|||||d}
|
d }| 	|}| j
durT| 
|nd}|sb||f|
dd  S t|||
j|
jdS )z
        bool_masked_pos (`torch.BoolTensor` of shape `(batch_size, image_num_patches)`):
            Boolean masked positions. Indicates which patches are masked (1) and which aren't (0).
        Nz You have to specify pixel_values)r   r   r   r   r   r  r  r   r   r  pooler_outputr   r  )rX   r   r  use_return_dictr   get_head_maskr  rn   rF  rG  rH  r   r   r  )r+   r   r   r   r   r   r   r  r  embedding_outputencoder_outputssequence_outputr,  r,   r,   r-   r      s:   
zFlavaImageModel.forwardTNNNNNNNN)r2   r3   r4   r   r8   r?  main_input_namerC   r_   r   ModulerM  rQ  dictr   listrY  r   r   r6   r   r   r   r0   r   r   r   r,   r,   rl   r-   rA    sH   
 	

rA  c                       s   e Zd ZU eed< dZddedef fddZdefdd	Z	d
e
jfddZdeeee f ddfddZe								ddeej deej deej deej deej dee dee dee deeef fddZ  ZS )FlavaTextModelrX   zflava.text_modelTrB  c                    rC  rD  )r^   r_   rX   r   rn   r  rF  r   r   rc   r   rG  r'  rH  rI  rJ  rl   r,   r-   r_   A  s   

zFlavaTextModel.__init__r#   c                 C   rK  rT   rn   r   r*   r,   r,   r-   rM  Q  rN  z#FlavaTextModel.get_input_embeddingsr   c                 C   rO  rT   rj  rP  r,   r,   r-   rQ  T  rR  z#FlavaTextModel.set_input_embeddingsrS  Nc                 C   rT  rU  rV  rX  r,   r,   r-   rY  W  rZ  zFlavaTextModel._prune_headsr   r   r   r   r   r   r  r  c	                 C   s  |dur|n| j j}|dur|n| j j}|dur|n| j j}|du r&td| }	|du r6tj|	|jd}| 	|| j j
}| ||	|j}
| j|||d}| j||
||||d}|d }| |}| jdurl| |nd}|sz||f|dd  S t|||j|jdS )	a  
        input_ids (`torch.LongTensor` of shape `(batch_size, text_seq_length)`):
            Indices of input sequence tokens in the vocabulary. Indices can be obtained using [`AutoTokenizer`]. See
            [`PreTrainedTokenizer.encode`] and [`PreTrainedTokenizer.__call__`] for details. [What are input
            IDs?](../glossary#input-ids)
        token_type_ids (`torch.LongTensor` of shape `(batch_size, text_seq_length)`, *optional*):
            Segment token indices to indicate first and second portions of the inputs. Indices are selected in `[0,
            1]`:
            - 0 corresponds to a *sentence A* token,
            - 1 corresponds to a *sentence B* token.
            [What are token type IDs?](../glossary#token-type-ids)
        NzYou have to specify input_idsr   )r   r   r   r[  r   r   r\  )rX   r   r  r^  r   rt   r6   onesr   r_  r  get_extended_attention_maskrn   rF  rG  rH  r   r   r  )r+   r   r   r   r   r   r   r  r  r   extended_attention_maskr`  ra  rb  r,  r,   r,   r-   r   _  sJ   
zFlavaTextModel.forwardrc  rd  )r2   r3   r4   r   r8   r?  rC   r_   re   rM  r   rf  rQ  rg  r   rh  rY  r   r   r6   r   r   r0   r   r   r   r,   r,   rl   r-   ri  ;  sF   
 	

ri  c                       s   e Zd ZU eed< dZdZddef fddZdee	e
e	 f dd	fd
dZe										ddejdeej deej dee dee dee deeef fddZ  ZS )r9  rX   zflava.multimodal_modelr   Tc                    sv   t  | || _| jj| _| jrttdd|j| _	t
|| _tj|j|jd| _|r2t|nd| _|   dS )rE  r   r   N)r^   r_   rX   r:  r   ra   r6   rb   rc   rd   r  rF  r   r   rG  r'  rH  rI  rJ  rl   r,   r-   r_     s   

zFlavaMultimodalModel.__init__rS  r#   Nc                 C   rT  rU  rV  rX  r,   r,   r-   rY    rZ  z!FlavaMultimodalModel._prune_headsr   r   r   r  r  c                 C   s&  |dur|n| j j}|dur|n| j j}|dur|n| j j}| \}}}	| jr=| j|dd}
tj	|
|fdd}|d7 }|du rKtj
||f|jd}| || j j}| |||f|j}| j||||||d}|d }| |}| jdur{| |nd}|s||f|dd  S t|||j|jdS )	z
        hidden_states (`torch.FloatTensor` of shape `(batch_size, image_num_patches + text_seq_len, hidden_size)`):
            The concatenated hidden states of unimodal encoders.
        Nrq   r   rw   rk  r[  r   r\  )rX   r   r  r^  rt   r:  rd   r   r6   r   rl  r   r_  r  rm  rF  rG  rH  r   r   r  )r+   r   r   r   r   r  r  r   r   r   r   rn  ra  rb  r,  r,   r,   r-   r     sD   
zFlavaMultimodalModel.forwardrc  )NNNNN)r2   r3   r4   r   r8   r?  re  r_   rg  r   rh  rY  r   r6   r   r   rC   r   r0   r   r   r   r,   r,   rl   r-   r9    s6   
 
r9  c                       sV  e Zd ZU eed< def fddZe e			ddej	de
ej	 de
ej	 de
ej	 d	ejf
d
dZe e				ddej	de
ej de
e de
ej	 de
ej	 d	ejfddZe											dde
ej de
ej de
ej	 de
ej	 de
ej	 de
ej de
ej	 de
e de
e dede
e d	eeef fddZ  ZS )r;  rX   c                    s0  t  | t|jtstdt|j dt|jts(tdt|j dt|j	t
s;tddt|j	 d |j}|j}|j	}|j| _|j| _|j| _|j| _t|| _t|| _t|| _t| j| j| _t| j| j| _tt| jj| _t| j| j| _ t| j| j| _!| "  d S )NzLconfig.text_config is expected to be of type FlavaTextConfig but is of type r   zNconfig.image_config is expected to be of type FlavaImageConfig but is of type zMconfig.multimodal_config is expected to be of type FlavaMultimodalConfig but zis of type )#r^   r_   r   text_configr   	TypeErrortypeimage_configr   multimodal_configr   projection_dimrc   text_hidden_sizeimage_hidden_sizemm_hidden_sizeri  
text_modelrA  image_modelr9  multimodal_modelr   r   image_projectiontext_projectionra   r6   tensorrX   r=  r<  image_to_mm_projectiontext_to_mm_projectionrI  )r+   rX   ro  rr  rs  rl   r,   r-   r_     sF   


zFlavaModel.__init__Nr   r   r   r   r#   c                 C   s&   | j ||||d}|j}| |}|S )a  
        input_ids (`torch.LongTensor` of shape `(batch_size, text_seq_length)`):
            Indices of input sequence tokens in the vocabulary. Indices can be obtained using [`AutoTokenizer`]. See
            [`PreTrainedTokenizer.encode`] and [`PreTrainedTokenizer.__call__`] for details. [What are input
            IDs?](../glossary#input-ids)
        token_type_ids (`torch.LongTensor` of shape `(batch_size, text_seq_length)`, *optional*):
            Segment token indices to indicate first and second portions of the inputs. Indices are selected in `[0,
            1]`:
            - 0 corresponds to a *sentence A* token,
            - 1 corresponds to a *sentence B* token.
            [What are token type IDs?](../glossary#token-type-ids)

        Returns:
            text_features (`torch.FloatTensor` of shape `(batch_size, output_dim`): The text embeddings obtained by
            applying the projection layer to the pooled output of [`FlavaTextModel`].

        Examples:

        ```python
        >>> import torch
        >>> from transformers import AutoProcessor, FlavaModel

        >>> model = FlavaModel.from_pretrained("{0}")
        >>> processor = AutoProcessor.from_pretrained("{0}")

        >>> inputs = processor(
        ...     text=["a photo of a cat", "a photo of a dog"], max_length=77, padding="max_length", return_tensors="pt"
        ... )
        >>> with torch.inference_mode():
        ...     text_features = model.get_text_features(**inputs)
        ```
        )r   r   r   r   )rx  r  r|  )r+   r   r   r   r   text_outputsr,  text_featuresr,   r,   r-   get_text_features;  s   )
zFlavaModel.get_text_featuresr   r   r   r   c           	      C   s(   | j |||||d}|j}| |}|S )a  
        bool_masked_pos (`torch.BoolTensor` of shape `(batch_size, image_num_patches)`):
            Boolean masked positions. Indicates which patches are masked (1) and which aren't (0).

        Returns:
            image_features (`torch.FloatTensor` of shape `(batch_size, output_dim`): The image embeddings obtained by
            applying the projection layer to the pooled output of [`FlavaImageModel`].

        Examples:

        ```python
        >>> import torch
        >>> from transformers import AutoProcessor, FlavaModel
        >>> from transformers.image_utils import load_image

        >>> model = FlavaModel.from_pretrained("{0}")
        >>> processor = AutoProcessor.from_pretrained("{0}")

        >>> url = "http://images.cocodataset.org/val2017/000000039769.jpg"
        >>> image = load_image(url)

        >>> inputs = processor(images=image, return_tensors="pt")

        >>> with torch.inference_mode():
        ...     image_features = model.get_image_features(**inputs)
        ```
        )r   r   r   r   r   )ry  r  r{  )	r+   r   r   r   r   r   image_outputsr,  image_featuresr,   r,   r-   get_image_featureso  s   %
zFlavaModel.get_image_featuresTimage_attention_maskskip_multimodal_encoderr   r  r  c              	   C   sz  |dur|n| j j}|
stdd}d}d}d}|dur7| j||||	|
|d}|d |d }}| |d }d}d}d}d}|dur_| j|||||	|
|d}|d |d }}| |d }d}d}|dur|dur|s|dur|j\}}}| jj	r|d7 }t
j|||jd	}t
j||gdd
}nd}t
j||gdd
}| j|||d}|d }|s||||||fS t||||||dS )a	  
        input_ids (`torch.LongTensor` of shape `(batch_size, image_num_patches + text_seq_len)`):
            Indices of input sequence tokens in the vocabulary. Indices can be obtained using [`AutoTokenizer`]. See
            [`PreTrainedTokenizer.encode`] and [`PreTrainedTokenizer.__call__`] for details. [What are input
            IDs?](../glossary#input-ids)
        token_type_ids (`torch.LongTensor` of shape `(batch_size, image_num_patches + text_seq_len)`, *optional*):
            Segment token indices to indicate first and second portions of the inputs. Indices are selected in `[0,
            1]`:
            - 0 corresponds to a *sentence A* token,
            - 1 corresponds to a *sentence B* token.
            [What are token type IDs?](../glossary#token-type-ids)
        bool_masked_pos (`torch.BoolTensor` of shape `(batch_size, image_num_patches)`):
            Boolean masked positions. Indicates which patches are masked (1) and which aren't (0).
        image_attention_mask (`torch.Tensor` of shape `(batch_size, image_num_patches)`, *optional*):
            Mask to avoid performing attention on padding pixel values for image inputs. Mask values selected in `[0, 1]`:
            - 1 for pixel values that are real (i.e., **not masked**),
            - 0 for pixel values that are padding (i.e., **masked**).
        skip_multimodal_encoder (*bool*, *optional*):
            Skip any calculations for multimodal encoder. Useful if multimodal encoding is not going to be used.

        Examples:

        ```python
        >>> from PIL import Image
        >>> import requests
        >>> from transformers import AutoProcessor, FlavaModel

        >>> model = FlavaModel.from_pretrained("facebook/flava-full")
        >>> processor = AutoProcessor.from_pretrained("facebook/flava-full")

        >>> url = "http://images.cocodataset.org/val2017/000000039769.jpg"
        >>> image = Image.open(requests.get(url, stream=True).raw)

        >>> inputs = processor(text=["a photo of a cat"], images=image, return_tensors="pt", padding=True)

        >>> outputs = model(**inputs)

        >>> image_embeddings = outputs.image_embeddings
        >>> text_embeddings = outputs.text_embeddings
        >>> multimodal_embeddings = outputs.multimodal_embeddings

        >>> outputs.image_embeddings.shape
        torch.Size([1, 197, 768])

        >>> text_embeddings.shape
        torch.Size([1, 7, 768])

        >>> multimodal_embeddings.shape
        torch.Size([1, 205, 768])
        ```
        NzRFLAVA model requires hidden states to work. Please set `output_hidden_states=True`)r   r   r   r   r  r  r   rr   rq   )r   r   r   r   r   r  r  r   rk  rw   )r   r  )r   r   r   r    r!   r"   )rX   r  r   ry  r~  rx  r  ry   rz  r:  r6   rl  r   r   r   )r+   r   r   r   r   r   r   r  r  r   r  r  r   image_statesimage_mm_projectionr   r   text_statestext_mm_projectionr    r!   r"   r   r   r   attention_mask_imageattention_multimodalmultimodal_inputr,   r,   r-   r     s   C
	zFlavaModel.forwardr   )NNNN)NNNNNNNNNTN)r2   r3   r4   r   r8   r_   r   r   r6   r   r   r7   r  r   rC   r  
LongTensorr   r0   r	  r   r   r,   r,   rl   r-   r;    s   
 +2/	

r;  c                       s<   e Zd Zdedef fddZdejdejfddZ  ZS )	FlavaImageCodebookResPathin_sizeout_sizec                    s   t    |d }t }t |d< tj||ddd|d< t |d< tj||ddd|d< t |d	< tj||ddd|d
< t |d< tj||ddd|d< t|| _d S )N   relu_1r   r   r   paddingconv_1relu_2conv_2relu_3conv_3relu_4r   conv_4)r^   r_   r   r   ReLUr   
Sequentialpath)r+   r  r  kwargshid_sizer  rl   r,   r-   r_   0  s   
z"FlavaImageCodebookResPath.__init__r   r#   c                 C   
   |  |S rT   )r  r+   r   r,   r,   r-   r   @     
z!FlavaImageCodebookResPath.forward	r2   r3   r4   r   r_   r6   r   r   r   r,   r,   rl   r-   r  /  s    r  c                       s@   e Zd Zdededef fddZdejdejfdd	Z  ZS )
FlavaImageCodebookBlockr  r  
num_layersc                    sP   t    d|d  | _||krtj||ddd| _nt | _t||| _d S )Nr   rr   r   r  )	r^   r_   	post_gainr   r   id_pathIdentityr  res_path)r+   r  r  r  r  rl   r,   r-   r_   E  s   

z FlavaImageCodebookBlock.__init__r   r#   c                 C   s   |  || j| |  S rT   )r  r  r  r  r,   r,   r-   r   Q  s   zFlavaImageCodebookBlock.forwardr  r,   r,   rl   r-   r  D  s    r  c                       sJ   e Zd Zddededededef
 fddZd	ejd
ejfddZ  Z	S )FlavaImageCodebookLayerGroupT
num_blocksr  r  r  use_poolc                    s   t    t }t|D ]!}|dkr t||||d|d  < qt||||d|d  < q|r8tjdd|d< t|| _d S )Nr   block_r   rr   )r   pool)	r^   r_   r   r  r  r   	MaxPool2dr  group)r+   r  r  r  r  r  blocksr#  rl   r,   r-   r_   V  s   
z%FlavaImageCodebookLayerGroup.__init__r   r#   c                 C   r  rT   )r  r  r,   r,   r-   r   d  r  z$FlavaImageCodebookLayerGroup.forwardrc  )
r2   r3   r4   r   rC   r_   r6   r   r   r   r,   r,   rl   r-   r  U  s    $r  a"  
    The FLAVA's image codebook model inspired from DALL-E's original encoder. Outputs raw hidden states and can be used
    to generate image tokens for an image based on DALL-E's vocab. Used to generate labels for MIM. Use
    `get_codebook_indices` to get image tokens for an image.
    c                       s~   e Zd ZU dZeed< dZdZdedef fddZ	de
jde
jfd	d
Zde
jde
jfddZde
jde
jfddZ  ZS )FlavaImageCodebook rX   r   Fr  c                    sd  t  | || _|j| _|j| _|j| _|j| _|j| _| j| j }t }t	
 |d< t	jd| j | jddd|d< t }t	j| jd| j ddd|d	< t| j|d| j d| j |d
< t| j|d| j d| j |d< t| j|d| j d| j |d< t| j|d| j d| j dd|d< t	||d< t	|| _|   | jjr|  D ]}d|_qd S d S )Nrelu   r   r   r  conv   r   inputgroup_1rr   group_2r  group_3F)r  group_4r   )r^   r_   rX   
num_groupsinput_channelsnum_blocks_per_grouprc   r   r   r   r  r   r  r  r  rI  freeze
parametersrequires_grad)r+   rX   r  r  output_blocksr  paramrl   r,   r-   r_   v  sB   
zFlavaImageCodebook.__init__r#   c                 C   s*   dt  dt  d | |}tj|ddS )Na)  
        Args:
            pixel_values (`torch.FloatTensor` of shape `(batch_size, num_channels, height, width)`):
                Pixel values. Codebook pixel values can be obtained using [`AutoImageProcessor`] by passing
                `return_codebook_pixels=True`. See [`FlavaImageProcessor.__call__`] for details.

        Examples:
        ```python
        >>> from PIL import Image
        >>> import requests
        >>> from transformers import AutoImageProcessor, FlavaImageCodebook

        >>> model = FlavaImageCodebook.from_pretrained("E")
        >>> image_processor = AutoImageProcessor.from_pretrained("a  ")

        >>> url = "http://images.cocodataset.org/val2017/000000039769.jpg"
        >>> image = Image.open(requests.get(url, stream=True).raw)

        >>> inputs = image_processor([image], return_codebook_pixels=True, return_tensors="pt")
        >>> inputs = dict(pixel_values=inputs.codebook_pixel_values)

        >>> outputs = model.get_codebook_indices(**inputs)
        ```
        r   )axis)_CHECKPOINT_FOR_CODEBOOK_DOCr  r6   argmaxr+   r   z_logitsr,   r,   r-   get_codebook_indices  s   
z'FlavaImageCodebook.get_codebook_indicesc                 C   s   |  |}tjdd|S )Nr   rw   )r  r   Softmaxr  r,   r,   r-   get_codebook_probs  s   
z%FlavaImageCodebook.get_codebook_probsc                 C   sh   dt  dt  d t|jdkrtd|j d|jd | jkr/td|jd  d	| j | |S )
Na*  
        Args:
            pixel_values (`torch.FloatTensor` of shape `(batch_size, num_channels, height, width)`):
                Pixel values. Codebook pixel values can be obtained using [`AutoImageProcessor`] by passing
                `return_codebook_pixels=True`. See [`FlavaImageProcessor.__call__`] for details.

        Examples:

        ```python
        >>> from PIL import Image
        >>> import requests
        >>> from transformers import AutoImageProcessor, FlavaImageCodebook

        >>> model = FlavaImageCodebook.from_pretrained("r  a  ")

        >>> url = "http://images.cocodataset.org/val2017/000000039769.jpg"
        >>> image = Image.open(requests.get(url, stream=True).raw)

        >>> inputs = image_processor([image], return_codebook_pixels=True, return_tensors="pt")
        >>> inputs = dict(pixel_values=inputs.codebook_pixel_values)

        >>> outputs = model(**inputs)
        >>> print(outputs.shape)
        (1, 196)
        ```
        r  zinput shape z
 is not 4dr   z
input has z channels but model built for )r  r   ry   r   r  r  )r+   r   r,   r,   r-   r     s   
zFlavaImageCodebook.forward)r2   r3   r4   r?  r   r8   re  r@  r   r_   r6   r   r  r  r7   r   r   r,   r,   rl   r-   r  i  s   
 ,r  c                       $   e Zd Z fddZdd Z  ZS )FlavaPredictionHeadTransformc                    sV   t    t|j|j| _t|jtrt	|j | _
n|j| _
tj|j|jd| _d S )Nr   )r^   r_   r   r   rc   r   r   r  r  r	   transform_act_fnr   r   r   rl   r,   r-   r_     s   
z%FlavaPredictionHeadTransform.__init__c                 C   s"   |  |}| |}| |}|S rT   )r   r  r   r  r,   r,   r-   r     s   


z$FlavaPredictionHeadTransform.forwardr2   r3   r4   r_   r   r   r,   r,   rl   r-   r    s    	r  c                       s.   e Zd Zd fdd	Zdd Zdd Z  ZS )	r8  Nc                    sb   t    || _t|| _tj|j|jdd| _	t
t|j| _|d ur*|| j	_| j| j	_d S )NFr   )r^   r_   rX   r  	transformr   r   rc   r   decoderra   r6   rb   r   r2  )r+   rX   r2  rl   r,   r-   r_     s   

z"FlavaMaskedPredictionHead.__init__c                 C   s   | j | j_ d S rT   )r   r  r*   r,   r,   r-   _tie_weights  s   z&FlavaMaskedPredictionHead._tie_weightsc                 C   r   rT   )r  r  r  r,   r,   r-   r        

z!FlavaMaskedPredictionHead.forwardrT   )r2   r3   r4   r_   r  r   r   r,   r,   rl   r-   r8    s    r8  c                       r  )FlavaITMHeadc                    s.   t    || _t|| _t|jd| _d S )Nrr   )	r^   r_   rX   r'  rH  r   r   rc   seq_relationshipr   rl   r,   r-   r_     s   

zFlavaITMHead.__init__c                 C   r   rT   )rH  r  r  r,   r,   r-   r     r  zFlavaITMHead.forwardr  r,   r,   rl   r-   r    s    r  c                       r  )FlavaGlobalContrastiveHeadc                    s   t    || _|j| _d S rT   )r^   r_   rX   global_backprop_contrastiver   rl   r,   r-   r_     s   
z#FlavaGlobalContrastiveHead.__init__c                    s2  t |}t j rt j s!t j d jd} g}g}nQ d}t j }	| j	r?t jj
j }t jj
j}n$fddt|	D } fddt|	D }t j|  t j| |t j  t j| jd }t |}t |}t  |dd| }
t |dd| }|
||fS )Nr   rk  c                       g | ]}t  qS r,   r6   
zeros_liker  )r   r,   r-   r  /      z6FlavaGlobalContrastiveHead.forward.<locals>.<listcomp>c                    r  r,   r  r  )r   r,   r-   r  0  r  r   )r6   expdistributedis_availableis_initializedr   rt   r   get_world_sizer  r   r~   
all_gatherr  get_rankr   r   r   )r+   r   r   r<  temperaturelabelsimage_embeddings_alltext_embeddings_alllocal_batch_size
world_sizelogits_per_imagelogits_per_textr,   )r   r   r-   r     s,   





z"FlavaGlobalContrastiveHead.forwardr  r,   r,   rl   r-   r    s    r  zk
    The FLAVA model for pretraining which outputs losses, embeddings, logits and transformer outputs.
    c                (       s&  e Zd Zg dZddedeej f fddZde	j
fdd	Ze															
		d dee	j dee	j dee	j dee	j dee	j
 dee	j
 dee	j
 dee	j dee	j
 dee dee	j
 dee	j
 dee	j
 dee dedee dee deee	j
 ef f$ddZ  ZS )!FlavaForPreTraining)zmmm_text_head.decoder.biaszmmm_image_head.decoder.biaszmlm_head.decoder.biaszmim_head.decoder.biasNrX   image_codebookc                    s   t  | t|| _|| _| jdu r|jrt|j| _t|j	| _
t|j| _t|| _t|j	| _t|j| _t|| _|j	j| _|jj| _|j| _|j| _|j| _|j| _|j| _|j| _|j| _|j| _|   dS )z
        image_codebook ([`nn.Module`]):
            If passed, the image codebook will be set to this. Otherwise, it will be initialized using the
            image_codebook_config defined in the config first as the first parameter.
        N)r^   r_   r;  r.  r  init_codebookr  image_codebook_configr8  rr  mim_headro  mlm_headr  itm_headmmm_image_headmmm_text_headr  global_contrastive_headr   image_vocab_sizetext_vocab_size
mlm_weight
mim_weightglobal_contrastive_weightce_ignore_index
itm_weightmmm_image_weightmmm_text_weight skip_unmasked_multimodal_encoderrI  )r+   rX   r  rl   r,   r-   r_   O  s,   




zFlavaForPreTraining.__init__r   c                 C   s"   |  dkr||dd}|S )Nrr   r   rq   )rx   r   rt   r  r,   r,   r-   _resize_to_2dr  s   z!FlavaForPreTraining._resize_to_2dTr   input_ids_maskedr   codebook_pixel_valuesr   r   r   r   r  r  
mlm_labels
mim_labels
itm_labelsr   r  r  return_lossr#   c           6      C   s  |dur|n| j j}|dur|n| j j}|
dur|
n| j}
|du r,|dur,td |}| j||||||	|
||dd
}| j|||||	|||dd	}d}|j}|j}|j}|j}|j	}d } } } } } }} d }! }" }#}$d }% }&}'|dus~|dur|du r|r| j
du rtd|du rtd| j
|}| jdkr	|dur	|du r	|}(|dur| |}| |}| j||d< |(dd|d	 dddf }(|| j})||) }*|(|)ddf }(| |(}!|rtj|!d
| j|*d
}|| j9 }n| |(}!| jdkrj|durj|du rj|}+|dure| |}|+dd|d	 dddf }+|| j})||) },|+|)ddf }+| |+}"|rdtj|"d
| j|,d
}|| j9 }n| |+}"| jdkr|dur| |}%|dur|d}-t|-  |-|-!dg}|rtj|%|} | | j9 } |dur|| }|dur|| }|dur|| }|| }|dur-| j"dkr-|}(|d	d	 }.|(dddd|. ddf }(|dur(| |}| |}| j||d< || j})||) }*|(|)ddf }(| #|(}$|r'tj|$d
| j|*d
}|| j"9 }n| #|(}$|dur| j$dkr|}+|+dd|d	 dddf }+|dur| |}|| j})||) },|+|)ddf }+| %|+}#|rtj|#d
| j|,d
}|| j$9 }n| %|+}#|dur	|dur	| j&dkr	| j'|dddddf }/tjj(|/d
d}/| j)|dddddf }0tjj(|0d
d}0| jj*j+,t-t. | /|0|/| jj*\}&}'}1|dur|&| }&|'| }'|1| }1|r	tj|&|1}2tj|'|1}3|2|3 d }|| j&9 }t0||| |||d}4|r&|41 s&t2dd |43 D }|s||j4dur5|j45 nd||j6durB|j65 nd|j	|j7durP|j75 nd||j4dur]|j45 nd||j6durj|j65 nd||j7durw|j75 nd|!|"|%|&|&|$|#f}5|r|41 s||4f|5 }5t8dd |5D S t9d&i d|d|4d|d|j4d|d|j6d|j	d|j7d|d|j4d|d|j6d|d|j7d|!d |"d!|%d"|&d#|'d$|$d%|#S )'a  
        input_ids (`torch.LongTensor` of shape `(batch_size, text_seq_len)`):
            Indices of input sequence tokens in the vocabulary. Indices can be obtained using [`AutoTokenizer`]. See
            [`PreTrainedTokenizer.encode`] and [`PreTrainedTokenizer.__call__`] for details. [What are input
            IDs?](../glossary#input-ids)
        input_ids_masked (`torch.LongTensor` of shape `(batch_size, text_seq_len)`):
            Indices of input sequence tokens in the vocabulary. These ones are the masked version of the original task
            to be used with MLM. Indices can be obtained using [`AutoTokenizer`] along with
            [`DataCollatorForMaskedLanguageModeling`]. See [`PreTrainedTokenizer.encode`] and
            [`PreTrainedTokenizer.__call__`] for details. [What are input IDs?](../glossary#input-ids)
        codebook_pixel_values (`torch.FloatTensor` of shape `(batch_size, num_image_patches, patch_size, patch_size, 3)`, *optional*):
            Pixel values for image patches that are used to compute the image codebook labels for masked image modeling.
        token_type_ids (`torch.LongTensor` of shape `(batch_size, text_seq_len)`, *optional*):
            Segment token indices to indicate first and second portions of the inputs. Indices are selected in `[0,
            1]`:
            - 0 corresponds to a *sentence A* token,
            - 1 corresponds to a *sentence B* token.
            [What are token type IDs?](../glossary#token-type-ids)
        bool_masked_pos (`torch.BoolTensor` of shape `(batch_size, image_num_patches)`):
            Boolean masked positions. Indicates which patches are masked (1) and which aren't (0).
        image_attention_mask (`torch.FloatTensor` of shape `(batch_size, image_num_patches)`, *optional*):
            Mask to avoid performing attention on padding token indices specifically for images. Mask values selected
            in `[0, 1]`:
            - 1 for tokens that are **not masked**,
            - 0 for tokens that are **masked**.
            [What are attention masks?](../glossary#attention-mask)
        skip_unmasked_multimodal_encoder (*bool*, *optional*):
            Skip any calculations for multimodal encoder for unmasked inputs. FLAVA pretraining doesn't need unmasked
            multimodal embeddings or outputs as of now.
        mlm_labels (`torch.LongTensor` of shape `(batch_size, text_seq_len)`, *optional*):
            Labels for computing the left-to-right language and multimodal masked modeling loss (next word prediction).
            Indices should be in `[-100, 0, ..., text_config.vocab_size - 1]` (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,
            ..., text_config.vocab_size - 1]`.
        mim_labels (`torch.LongTensor` of shape `(batch_size, image_num_patches)`, *optional*):
            Labels for computing the image and multimodal masked modeling loss. Indices should be in `[-100, 0, ...,
            image_config.vocab_size - 1]`. Tokens with indices set to `-100` are ignored (masked), the loss is only
            computed for the tokens with labels in `[0, ..., image_config.vocab_size - 1]`. If not passed, they are
            generated automatically using the image codebook assigned to the model. By default, it uses
            [`FlavaImageCodebook`]. See [`FlavaImageCodebook`] to understand how to generate mim_labels.
        itm_labels (`torch.LongTensor` of shape `(batch_size, 1)`, *optional*):
            Labels for computing the image-text matching loss. 0 means the pairs don't match and 1 means they match.
            The pairs with 0 will be skipped for calculation of MMM and global contrastive losses as well.
        return_loss (`bool`, *optional*, default to None):
            Whether to return calculated loss or not.

        Examples:
        ```python
        >>> from PIL import Image
        >>> import requests
        >>> from transformers import FlavaForPreTraining, AutoProcessor

        >>> url = "http://images.cocodataset.org/val2017/000000039769.jpg"
        >>> image = Image.open(requests.get(url, stream=True).raw)

        >>> model = FlavaForPreTraining.from_pretrained("facebook/flava-full")
        >>> processor = AutoProcessor.from_pretrained("facebook/flava-full")

        >>> text = ["a photo of a cat"]

        >>> inputs = processor(
        ...     images=[image],
        ...     text=text,
        ...     return_masks=True,
        ...     return_codebook_pixels=True,
        ...     padding=True,
        ...     max_length=77,
        ...     return_tensors="pt",
        ... )


        >>> output = model(**inputs)
        ```
        Nz`input_ids_masked` isn't passed which means MLM loss won't be calculated correctlySetting it to `input_ids` so that model can work. Please pass it if this is unintentional. This is usually OKAY if you are doing inference on unmasked text...T)
r   r   r   r   r   r  r  r   r  r  )	r   r   r   r   r  r   r   r  r  z`return_loss` is set to True but the image codebook is not initialized and no `mim_labels`  have been passed. Reinstantiate the model with `init_codebook` set to True or pass in your custom `mim_labels`z`codebook_pixel_value` are required to generate `mim_labels` if loss is expected. Call `AutoProcessor` with `return_codebook_pixels` set to Truer   r   rq   rr   rw   )r:   r;   r<   r=   r>   r?   c                 s   s     | ]}|d ur
|ndV  qd S r*  r,   )r(   rE   r,   r,   r-   r.     s    z.FlavaForPreTraining.forward.<locals>.<genexpr>c                 s   s    | ]	}|d u r|V  qd S rT   r,   )r(   r   r,   r,   r-   r.     r  rE   rF   r   r   r   r    r!   r"   rG   rH   rI   rJ   rK   rL   rM   rN   rO   rP   rQ   rR   rS   r,   ):rX   r^  r
  r  loggerwarningr.  r   r   r!   r  RuntimeErrorr   r  r  r  r  nert   r  r   r~   cross_entropyr   r  r  r  r  r   r  r6   whereanynewr  r  r  r  r  r|  	normalizer{  r<  r3  clamp_LOGIT_SCALE_CLAMP_MINLOGIT_SCALE_CLAMP_MAXr  r9   rA   sumr@   r   r&   r    r"   r0   rD   )6r+   r   r  r   r  r   r   r   r   r  r  r  r  r	  r   r  r  r
  flava_outputflava_masked_outputpos_maskr   r   rG   rI   rK   
total_lossmim_lossmlm_lossmmm_text_lossmmm_image_lossgc_lossitm_lossrM   rN   rS   rR   rO   r  r  sequence_for_imagemasked_tokensmim_labels_filteredsequence_for_textmlm_labels_filtered	pos_pairs	end_indextext_embeddingimage_embedding	gc_labelsgc_loss_imagegc_loss_textflava_lossesr   r,   r,   r-   r   w  s  _
 


"


 

"















"




 



	
	
zFlavaForPreTraining.forwardrT   )NNNNNNNNNNNNNNTNN)r2   r3   r4   _tied_weights_keysr   r   r   rf  r_   r6   r   r  r   r  r7   rC   r   r0   rD   r   r   r,   r,   rl   r-   r  A  sv    #	
r  )r  r  rA  r;  r9  r-  ri  )Ir5   r   r   r   dataclassesr   typingr   r   r   r6   r   activationsr	   modeling_layersr
   modeling_outputsr   r   modeling_utilsr   pytorch_utilsr   r   utilsr   r   r   r   r   configuration_flavar   r   r   r   r   
get_loggerr2   r  r  r  r  r   r   r9   rD   rf  rW   re   r   r   r   r   r  r	  r
  r  r'  r-  rA  ri  r9  r;  r  r  r  r  r  r8  r  r  r  __all__r,   r,   r,   r-   <module>   s   
		"	\d$9I*.*"`p_  $u(   #