a
    .;b\/                     @   s   d dl mZ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 d dlmZ d dlmZ d dlmZ d dlmZ d d	lmZ d
d ZG dd deZG dd dejejZeje dS )    )jittypeof)cgutilstypes	serializesigutils)npydecl)AbstractTemplate	signature)	_internal)
Dispatcher)array_analysis)ufuncbuilder)numpy_supportc                    s:   ddl m} G  fddd|j   jjj7  _ S )Nr   npyimplc                       s.   e Zd ZdZZ fddZdd Z  ZS )z(make_dufunc_kernel.<locals>.DUFuncKernelz
        npyimpl._Kernel subclass responsible for lowering a DUFunc kernel
        (element-wise function) inside a broadcast loop (which is
        generated by npyimpl.numpy_ufunc_kernel()).
        c                    s.   t  | ||| | j|j\| _| _d S N)super__init__dufuncfind_ewise_functionargs	inner_sigcres)selfcontextbuilder	outer_sig)DUFuncKernel	__class__ 4lib/python3.9/site-packages/numba/np/ufunc/dufunc.pyr      s    z1make_dufunc_kernel.<locals>.DUFuncKernel.__init__c           
         s    j } j} fddt||j|jD } jjrT jjt	j
t	j
gt|j }n jj|j|j} jjjj}t|| jjj}|jd  jj j||j|j|\}}	 |	|j|jS )Nc                    s    g | ]\}}}  |||qS r    )cast).0valZintyZouttyr   r    r!   
<listcomp>   s   zEmake_dufunc_kernel.<locals>.DUFuncKernel.generate.<locals>.<listcomp>Zalwaysinline)r   r   zipr   r   Z
objectmoder   Z	call_convZget_function_typer   Zpyobjectlenreturn_typer   blockZfunctionmoduler   Zget_or_insert_functionZfndescZllvm_func_nameZ
attributesaddZcall_functionr"   )
r   r   ZisigZosigZ	cast_argsZ	func_typer+   Zentry_point_resr    r%   r!   generate   s.    
z1make_dufunc_kernel.<locals>.DUFuncKernel.generate)__name__
__module____qualname____doc__r   r   r/   __classcell__r    r   _dufuncr   r!   r      s   r   )numba.npr   Z_Kernelr0   ufunc)r6   r   r    r5   r!   make_dufunc_kernel   s    $r:   c                   @   s    e Zd ZdZdd Zdd ZdS )DUFuncLowererzHCallable class responsible for lowering calls to a specific DUFunc.
    c                 C   s   t || _g | _d S r   )r:   kernellibs)r   r   r    r    r!   r   :   s    
zDUFuncLowerer.__init__c                 C   s(   ddl m} |||||| jjj| jS )Nr   r   )r8   r   Znumpy_ufunc_kernelr<   r   r9   )r   r   r   sigr   r   r    r    r!   __call__>   s
    zDUFuncLowerer.__call__N)r0   r1   r2   r3   r   r?   r    r    r    r!   r;   7   s   r;   c                       s   e Zd ZdZedZddi fddZ fddZd	d
 Ze	dd Z
dd Zedd Zedd Zedd Zedd Zedd Zedd Zedd Zdd Zdd  Zd!d" Zd-d#d$Zd.d%d&Zd'd( Zd)d* Zd/d+d,Z  ZS )0DUFuncz
    Dynamic universal function (DUFunc) intended to act like a normal
    Numpy ufunc, but capable of call-time (just-in-time) compilation
    of fast loops specialized to inputs.
    )identity
_keepaliveninnoutNFc                 C   s8   t |tr|j}tf d|d||}| || d S )NZnpyufunc)Z_targetcache)
isinstancer   py_funcr   _initialize)r   rG   rA   rE   targetoptions
dispatcherr    r    r!   r   O   s    
zDUFunc.__init__c                    sP   t |}tt| j||d |   t| | _|   |j	j
| _
|j	j| _d S )N)rA   )r   Zparse_identityr   r@   r   _install_typer;   	_lower_me_install_cgrG   r0   r3   )r   rJ   rA   r7   r    r!   rH   W   s    


zDUFunc._initializec                 C   s&   t | jj }t| j| j| j|dS )4
        NOTE: part of ReduceMixin protocol
        )rJ   rA   frozensiglist)list_dispatcher	overloadskeysdictrA   _frozen)r   rP   r    r    r!   _reduce_statesb   s    zDUFunc._reduce_statesc                 C   s<   t j| }||| |D ]}|| q|r8|  |S )rN   )r   _DUFunc__new__rH   r,   disable_compile)clsrJ   rA   rO   rP   r   r>   r    r    r!   _rebuildn   s    zDUFunc._rebuildc                 C   s   | S )zK
        For compatibility with the various *UFuncBuilder classes.
        r    r%   r    r    r!   build_ufunc|   s    zDUFunc.build_ufuncc                 C   s   | j jS r   )rR   rI   r%   r    r    r!   rI      s    zDUFunc.targetoptionsc                 C   s   | j jS r   )r9   rC   r%   r    r    r!   rC      s    z
DUFunc.ninc                 C   s   | j jS r   )r9   rD   r%   r    r    r!   rD      s    zDUFunc.noutc                 C   s   | j jS r   )r9   nargsr%   r    r    r!   r^      s    zDUFunc.nargsc                 C   s   | j jS r   )r9   ntypesr%   r    r    r!   r_      s    zDUFunc.ntypesc                 C   s   | j jS r   )r9   r   r%   r    r    r!   r      s    zDUFunc.typesc                 C   s   | j jS r   )r9   rA   r%   r    r    r!   rA      s    zDUFunc.identityc                 C   s   t | jjdksJ d| _dS )zI
        Disable the compilation of new signatures at call time.
        r   TN)r(   rR   rS   rV   r%   r    r    r!   rZ      s    zDUFunc.disable_compilec                 C   s   t |\}}| ||S )z=
        Compile the DUFunc for the given signature.
        )r   Znormalize_signature_compile_for_argtys)r   r>   r   r)   r    r    r!   r,      s    z
DUFunc.addc           	      O   s   | j j}|rLd|v r(|d}||f7 }|rLtdddd t|D  t|}||ksp||| j j kspJ |rxJ g }|d | D ]4}t|}t	|t
jr|j}n
t|}|| q| t|S )Noutz)unexpected keyword arguments to ufunc: %sz, c                 s   s   | ]}t |V  qd S r   )repr)r#   kr    r    r!   	<genexpr>       z+DUFunc._compile_for_args.<locals>.<genexpr>)r9   rC   pop	TypeErrorjoinsortedr(   rD   r   rF   r   ArrayZdtyper   Zmap_arrayscalar_typeappendr`   tuple)	r   r   ZkwsrC   ra   Zargs_lenargtysargZargtyr    r    r!   _compile_for_args   s(    



zDUFunc._compile_for_argsc           	      C   s   | j rtd| f t|ts"J |du r0|}n|| }t| j| j|\}}}t|||}t	||\}}}| 
t|| | j||j|f | jj|j |S )a/  
        Given a tuple of argument types (these should be the array
        dtypes, and not the array types themselves), compile the
        element-wise function for those inputs, generate a UFunc loop
        wrapper, and register the loop with the Numpy ufunc object for
        this DUFunc.
        zcompilation disabled for %sN)rV   RuntimeErrorrF   rl   r   Z_compile_element_wise_functionrR   rI   Z_finalize_ufunc_signatureZ!_build_element_wise_ufunc_wrapperZ	_add_loopintrB   rk   ZlibraryrL   r=   )	r   rm   r)   r>   r   Z
actual_sigZ	dtypenumsZptrenvr    r    r!   r`      s&    


zDUFunc._compile_for_argtysc                 C   sB   |du r| j jj}td| jj tft| | jd}|	| | dS )a*  Constructs and installs a typing class for a DUFunc object in the
        input typing context.  If no typing context is given, then
        _install_type() installs into the typing context of the
        dispatcher object (should be same default context used by
        jit() and njit()).
        NZDUFuncTyping_)keyZgeneric)
rR   targetdescrZtyping_contexttyper9   r0   r	   rU   _type_meZinsert_user_function)r   Z	typingctxZ_ty_clsr    r    r!   rK      s    
zDUFunc._install_typec                 C   sj   | j r:t| |}|du rdS t|j|j dt| }| jj	 D ]\}}|j
|krF||f  S qFdS )a  
        Given a tuple of element-wise argument types, find a matching
        signature in the dispatcher.

        Return a 2-tuple containing the matching signature, and
        compilation result.  Will return two None's if no matching
        signature was found.
        N)NN)rV   r   Zufunc_find_matching_looprl   ZinputsZoutputsr(   rR   rS   itemsr   )r   ewise_typesZloopr>   r   r    r    r!   r      s    	
zDUFunc.find_ewise_functionc                 C   s  |rJ | j }tj|||}|\}}}}t|}	|	dkrRt|dt|  }
nt|}
| |
\}}|du r| jrtd| |f | 	|
 | |
\}}|dusJ |	dkrt
|}n8|jdkr|dkrt|j||g}q|jg}ntd|| t| S )z
        Implement AbstractTemplate.generic() for the typing class
        built by DUFunc._install_type().

        Return the call-site signature after either validating the
        element-wise signature or compiling for it.
        r   Nzcannot call %s with types %s   ztyping gufuncs (nout > 1))r9   r   ZNumpy_rules_ufuncZ_handle_inputsr(   rl   r   rV   rg   r`   rQ   rD   r   rj   r)   NotImplementedErrorextendr
   )r   rm   Zkwtysr9   Z_handle_inputs_resultZ
base_typesZexplicit_outputsZndimsZlayoutZexplicit_output_countrx   r>   r   Zouttysr    r    r!   rv     s8    




zDUFunc._type_mec                    sh   |du r j jj}tj}tj}|f jj |f jj  }|f jj }|	 fdd||fD  dS )a-  
        Install an implementation function for a DUFunc object in the
        given target context.  If no target context is given, then
        _install_cg() installs into the target context of the
        dispatcher object (should be same default context used by
        jit() and njit()).
        Nc                    s   g | ]} j  |fqS r    )rL   )r#   r>   r%   r    r!   r&   @  re   z&DUFunc._install_cg.<locals>.<listcomp>)
rR   rt   Ztarget_contextr   Anyrj   r9   rC   rD   Zinsert_func_defn)r   Z	targetctxZ_anyZ_arrZsig0Zsig1r    r%   r!   rM   0  s    
zDUFunc._install_cg)N)N)N)r0   r1   r2   r3   setZ_DUFunc__base_kwargsr   rH   rW   classmethodr\   r]   propertyrI   rC   rD   r^   r_   r   rA   rZ   r,   ro   r`   rK   r   rv   rM   r4   r    r    r7   r!   r@   E   s<   









(r@   N)Znumbar   r   Z
numba.corer   r   r   r   Znumba.core.typingr   Znumba.core.typing.templatesr	   r
   Znumba.np.ufuncr   Znumba.core.dispatcherr   Znumba.parforsr   r   r8   r   r:   objectr;   ZReduceMixinrX   r@   Z	MAP_TYPESrk   r    r    r    r!   <module>   s   +   