U
    |e                     @   s  d Z ddlZddl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mZmZmZmZmZmZmZ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m Z m!Z! dd Z"dd Z#dZ$dZ%dZ&dZ'dZ(dZ)dd Z*e!dd Z+dd Z,dd Z-dd Z.dd  Z/e0d!d"Z1G d#d$ d$e2Z3G d%d& d&e2Z4G d'd( d(e2Z5d)d* Z6ee7d+d, Z8ee7e
j9d-d. Z:ee;e
j<d/d0 Z=eej>e
j<e
j?d1d2 Z@ed3e
j<d4d5 ZAed6e
jBeejCd7d8 ZDed9e
j<e
j?d:d; ZEe!d<d= ZFe e
j<d>d?d@ ZGe!dAdB ZHe e
j<dCdDdE ZIe!dFdG ZJe e
j<dHdIdJ ZKe!dKdL ZLe e
j<dMdNdO ZMe!dPdQ ZNe e
j<dRdSdT ZOdUdV ZPe!dWdX ZQe e
j<dYdZd[ ZRd\d] ZSe!d^d_ ZTe e
j<d`dadb ZUdcdd ZVe!dedf ZWe e
j<dgdhdi ZXedje
j<e
j9dkdl ZYdmdn ZZej[eSfej\eYfej]ePfej^eVffD ]\Z_Z`eZe_e` qPeejae e
j<dodpdq Zbeejce e
j<drdsdt Zdeejee e
j<dudvdw Zfeejge e
j<dxdydz Zhe!d{d| Zie e
j<d}d~d Zje!dd Zkeejle e
j<ddd Zmeejne e
j<ddd Zoe!dd Zpeejqdd Zreejsdd Zte!dd Zueejvdd Zweejxdd Zyeejze
j<e
j<dd Z{ee
j<e
j<dd Z|dS )z&
Support for native homogeneous sets.
    N)cached_property)ir)typestypingcgutils)	lower_builtin
lower_castiternext_implimpl_ret_borrowedimpl_ret_new_refimpl_ret_untrackedfor_itercall_lenRefType)	quicksort)slicing)NumbaValueErrorTypingError)overloadoverload_method	intrinsicc                 C   s4   t |}| | }|||}| j|||dS )zx
    Given a set value and type, get its payload structure (as a
    reference, so that mutations are seen by all).
    ref)r   
SetPayloadget_data_type
as_pointerbitcastmake_data_helper)contextbuilderset_typeptrpayload_typeptrtypayload r%   Q/var/www/website-v5/atlas_env/lib/python3.8/site-packages/numba/cpython/setobj.pyget_payload_struct   s    
r'   c                 C   s   |  t|}| |S )z7
    Return the entry size for the given set type.
    )r   r   SetEntryget_abi_sizeof)r   r    lltyr%   r%   r&   get_entry_size#   s    r+   i      Fc                 C   s`   | j }|t}|||fi }| ||}|||f}t| ||}	t|jt	}
|
|	||
S )z.
    Compute the hash of the given value.
    )typing_contextresolve_value_typehashget_call_typeget_functionis_hash_usedr   ConstanttypeFALLBACKselect)r   r   typvalue	typingctxfntysigfnhis_okfallbackr%   r%   r&   get_hash_value;   s    
rC   c                    s.    fdd}|  t}||  fi }||fS )Nc                    s   t | | |d S Nr   )rC   )r   r   r:   argsr;   r%   r&   implL   s    z'_get_hash_value_intrinsic.<locals>.impl)r1   r2   r3   )r<   r;   rG   r=   r>   r%   rF   r&   _get_hash_value_intrinsicJ   s    
rH   c                 C   s   t |jt}|d||S )z8
    Whether the hash value denotes an empty entry.
    ==)r   r6   r7   EMPTYicmp_unsigned)r   r   r@   emptyr%   r%   r&   is_hash_emptyS   s    rM   c                 C   s   t |jt}|d||S )z9
    Whether the hash value denotes a deleted entry.
    rI   r   r6   r7   DELETEDrK   r   r   r@   deletedr%   r%   r&   is_hash_deletedZ   s    rR   c                 C   s   t |jt}|d||S )z9
    Whether the hash value denotes an active entry.
    <rN   rP   r%   r%   r&   r5   a   s    r5   c                     sH   t dd  D s td  t  fdd D sDtd  d S )Nc                 S   s   g | ]}t |tjqS r%   )
isinstancer   Set).0r:   r%   r%   r&   
<listcomp>k   s     z!check_all_set.<locals>.<listcomp>z All arguments must be Sets, got c                    s   g | ]} d  j |j kqS )r   dtype)rV   srE   r%   r&   rW   n   s     z'All Sets must be of the same type, got )allr   r[   r%   r[   r&   check_all_setj   s    r]   SetLoopindexentrydo_breakc                   @   s   e Zd Zdd Zedd Zejdd Zedd Zejdd Zed	d
 Zejdd
 Zedd Z	e	jdd Z	edd Z
e
jdd Z
edd Zedd Zdd Zd ddZejd!ddZejdd ZdS )"_SetPayloadc                 C   s<   t ||||}|| _|| _|| _|| _|d| _|| _d S )Nentries)r'   _context_builder_ty_payload_get_ptr_by_name_entries_ptr)selfr   r   r    r!   r$   r%   r%   r&   __init__w   s    z_SetPayload.__init__c                 C   s   | j jS Nrh   maskrl   r%   r%   r&   rp      s    z_SetPayload.maskc                 C   s   || j _d S rn   ro   rl   r;   r%   r%   r&   rp      s    c                 C   s   | j jS rn   rh   usedrq   r%   r%   r&   rt      s    z_SetPayload.usedc                 C   s   || j _d S rn   rs   rr   r%   r%   r&   rt      s    c                 C   s   | j jS rn   rh   fillrq   r%   r%   r&   rv      s    z_SetPayload.fillc                 C   s   || j _d S rn   ru   rr   r%   r%   r&   rv      s    c                 C   s   | j jS rn   rh   fingerrq   r%   r%   r&   rx      s    z_SetPayload.fingerc                 C   s   || j _d S rn   rw   rr   r%   r%   r&   rx      s    c                 C   s   | j jS rn   rh   dirtyrq   r%   r%   r&   rz      s    z_SetPayload.dirtyc                 C   s   || j _d S rn   ry   rr   r%   r%   r&   rz      s    c                 C   s   | j S )z>
        A pointer to the start of the entries array.
        )rj   rq   r%   r%   r&   rd      s    z_SetPayload.entriesc                 C   s   | j S )zC
        A pointer to the start of the NRT-allocated area.
        )rk   rq   r%   r%   r&   r!      s    z_SetPayload.ptrc                 C   s2   t | j| j|}| jj| jt| j|d}|S )z)
        Get entry number *idx*.
        r   )	r   geprf   rj   re   r   r   r(   rg   )rl   idxZ	entry_ptrra   r%   r%   r&   	get_entry   s    

z_SetPayload.get_entryFc                    s  
j 
jj}
j}
jj}j}|tj	}|
|||fi }	||	t|d}
t|d}t}t|}r|dtd}d dd} 	
fdd	}tt|t< |}|| ||
}||}|| W 5 Q R X | |x |}|| |}||}|
||}|||}|| || | W 5 Q R X N r|}}d
|||}|| | W 5 Q R X   | W 5 Q R X | tdd}| tj!  | tj" ||fS )ag  
        Lookup the *item* with the given hash values in the entries.

        Return a (found, entry index) tuple:
        - If found is true, <entry index> points to the entry containing
          the item.
        - If found is false, <entry index> points to the empty entry that
          the item can be written to (only if *for_insert* is true)
              r,   zlookup.bodyzlookup.foundzlookup.not_foundz
lookup.endc              
      s   
 | }|j}d|6 	|jf}|   W 5 Q R X W 5 Q R X t|  W 5 Q R X r؈t|4 }	d|| |}
| W 5 Q R X dS )zO
            Check entry *i* against the value being searched for.
            rI   N)r}   r2   if_thenrK   keybranchrM   rR   loadr9   store)ira   Z
entry_hasheqjZbb_foundZbb_not_foundr   r   Zeqfn
for_insertZ
free_indexZfree_index_sentinelr@   itemrl   r%   r&   check_entry   s     

 z(_SetPayload._lookup.<locals>.check_entryrI   found)#re   rf   r7   rp   rg   rY   r0   r1   operatorr   r3   r4   r   r6   r   alloca_once_valueand_append_basic_block	for_rangeLINEAR_PROBESr   addr   r   
goto_blocklshrmulr9   rK   position_at_endphiIntTypeadd_incomingtrue_bit	false_bit)rl   r   r@   r   intp_trp   rY   tyctxr=   r>   oneZfiveZperturbr`   bb_bodybb_endr   r   pr   r   r%   r   r&   _lookup   sr    






 





 
z_SetPayload._lookupNc              
   c   s   | j }| j}|tj}t|d}|| j|}t	j
|||dN}| |j}t|||j}	||	 t|j||jd}
|
V  W 5 Q R X W 5 Q R X dS )zG
        Iterate over the payload's entries.  Yield a SetLoop.
        r~   startr_   N)re   rf   get_value_typer   intpr   r6   r   rp   r   r   r}   r`   r5   r2   r   r^   rb   )rl   r   r   r   r   r   sizeZ
range_loopra   is_usedloopr%   r%   r&   _iterate7  s    z_SetPayload._iteratec              	   c   s   | j }| j}|tj}t|d}t|d}| j}|d}|d}t	
|| j}	|| ||V ||	}
||||
|}
||
|	 | |
}t|||j}|||| W 5 Q R X || ||	}
|
| _| |
V  dS )z
        Yield a random entry from the payload.  Caller must ensure the
        set isn't empty, otherwise the function won't end.
        r   r~   Znext_entry_bodyZnext_entry_endN)re   rf   r   r   r   r   r6   rp   r   r   r   rx   r   r   r   r   r   r   r}   r5   r2   cbranchr   )rl   r   r   r   zeror   rp   r   r   r`   r   ra   r   r%   r%   r&   _next_entryK  s*    






z_SetPayload._next_entry)F)N)__name__
__module____qualname__rm   propertyrp   setterrt   rv   rx   rz   rd   r!   r}   r   
contextlibcontextmanagerr   r   r%   r%   r%   r&   rc   u   s>   	













vrc   c                   @   s  e Z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	j
dd Z	dd Zdd ZdUddZdVddZdWddZdXddZdYddZdZddZdd  Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. Zd/d0 Zd[d2d3Zd4d5 Zd6d7 Zed\d9d:Z ed]d;d<Z!ed=d> Z"ed?d@ Z#dAdB Z$dCdD Z%dEdF Z&dGdH Z'd^dIdJZ(dKdL Z)dMdN Z*dOdP Z+dQdR Z,dSdT Z-d8S )_SetInstancec                 C   s2   || _ || _|| _t||| _||||| _d S rn   )re   rf   rg   r+   
_entrysizemake_helper_set)rl   r   r   r    set_valr%   r%   r&   rm   v  s
    zSetInstance.__init__c                 C   s   | j jS rn   )rg   rY   rq   r%   r%   r&   rY   }  s    zSetInstance.dtypec                 C   s.   | j }| j}| j j|| j}t||| j|S )z/
        The _SetPayload for this set.
        )re   rf   nrtmeminfo_datameminforc   rg   )rl   r   r   r!   r%   r%   r&   r$     s    zSetInstance.payloadc                 C   s
   | j  S rn   )r   	_getvaluerq   r%   r%   r&   r;     s    zSetInstance.valuec                 C   s   | j jS rn   )r   r   rq   r%   r%   r&   r     s    zSetInstance.meminfoc                 C   s   | j jS rn   r   parentrq   r%   r%   r&   r     s    zSetInstance.parentc                 C   s   || j _d S rn   r   rr   r%   r%   r&   r     s    c                 C   s   | j jS )z<
        Return the number of elements in the size.
        )r$   rt   rq   r%   r%   r&   get_size  s    zSetInstance.get_sizec                 C   s    | j jr|rtjntj| j_d S rn   )rg   	reflectedr   r   r   r$   rz   rl   valr%   r%   r&   	set_dirty  s    zSetInstance.set_dirtyTc              	   C   s   | j }| j}|j}||_| | ||_|j}	t|	jd}
|	|	|
 }	|_|j
t|||dd |	|j|
|_W 5 Q R X |r| |	 | d d S )Nr~   Tlikely)re   rf   r2   incref_valuer   rt   r   r6   r7   r   r   rM   rv   upsizer   )rl   r$   ra   r   r@   	do_resizer   r   old_hashrt   r   r%   r%   r&   
_add_entry  s     

zSetInstance._add_entryc              
   C   s   | j }| j}|j||dd\}}	||}
||
 ||	}|j}||_|rZ| | ||_|j	}t
|jd}||| }|_	|jt|||dd ||j||_W 5 Q R X |r| | | d W 5 Q R X d S )NTr   r~   r   )re   rf   r   not_r   r}   r2   r   r   rt   r   r6   r7   r   rM   rv   r   r   )rl   r$   r   r@   r   	do_increfr   r   r   r   	not_foundra   r   rt   r   r%   r%   r&   _add_key  s*    



zSetInstance._add_keyc                 C   sf   t |jjt|_|r"| |j |j}t |jd}| j	|| }|_|rX| 
| | d d S )Nr~   T)r   r6   r2   r7   rO   decref_valuer   rt   rf   subdownsizer   )rl   r$   ra   r   	do_decrefrt   r   r%   r%   r&   _remove_entry  s    
zSetInstance._remove_entryc           
   	   C   sN   | j }| j}|||\}}|| ||}	| ||	| W 5 Q R X |S rn   )re   rf   r   r   r}   r   )
rl   r$   r   r@   r   r   r   r   r   ra   r%   r%   r&   _remove_key  s    
zSetInstance._remove_keyc                 C   s8   | j }| j}| j}t||| jj|}| |||| d S rn   )re   rf   r$   rC   rg   rY   r   )rl   r   r   r   r   r$   r@   r%   r%   r&   r     s
    zSetInstance.addc                 C   s6   | j }| j}| j}| ||||}| |||| dS )z`A version of .add for use inside functions following Python calling
        convention.
        N)re   rf   r$   _pyapi_get_hash_valuer   )rl   pyapir   r   r   r   r$   r@   r%   r%   r&   	add_pyapi  s
    zSetInstance.add_pyapic              	   C   sl   | j jg}tj}dd }|g}tj|f| }	|||	|\}
}|j|
dd ||	  W 5 Q R X |S )z=Python API compatible version of `get_hash_value()`.
        c                 S   s   t | S rn   )rH   )r   r%   r%   r&   wrapper  s    z2SetInstance._pyapi_get_hash_value.<locals>.wrapperFr   )
rg   rY   r   r   r   	signaturecall_jit_coder   retget_null_object)rl   r   r   r   r   argtypesrestyr   rE   r>   is_errorretvalr%   r%   r&   r     s    
z!SetInstance._pyapi_get_hash_valuec                 C   s8   | j }| j}| j}t||| jj|}|||\}}|S rn   )re   rf   r$   rC   rg   rY   r   )rl   r   r   r   r$   r@   r   r   r%   r%   r&   contains  s    zSetInstance.containsc                 C   s6   | j }| j}| j}t||| jj|}| |||}|S rn   )re   rf   r$   rC   rg   rY   r   )rl   r   r   r   r$   r@   r   r%   r%   r&   discard   s    zSetInstance.discardc              	   C   sh   | j }| j}|| jj}t||}| j}| $}|	|j
| | j||dd W 5 Q R X ||S )NF)r   )re   rf   r   rg   rY   r   alloca_oncer$   r   r   r   r   r   )rl   r   r   ltyr   r$   ra   r%   r%   r&   pop)  s    
zSetInstance.popc                 C   s<   | j }| j}|tj}t|t}| | | 	d d S )NT)
re   rf   r   r   r   r   r6   MINSIZE_replace_payloadr   )rl   r   r   r   minsizer%   r%   r&   clear8  s    
zSetInstance.clearc                 C   s:  | j }| j}| j}|j}|j}t| ||| jd}|d||}|j|dd\}}	|@ |	|}
|j
||
dd |j|td W 5 Q R X W 5 Q R X |	 | |||}||}
|j
||
dd |j|td W 5 Q R X |j}| "}|j}|j||j|jdd W 5 Q R X W 5 Q R X W 5 Q R X |S )z,
        Return a copy of this set.
        NrI   Tr   F)zcannot copy setr   )re   rf   r$   rt   rv   r7   rg   rK   if_else_copy_payloadr   r   	call_convreturn_user_excMemoryErrorchoose_alloc_size_allocate_payloadr   ra   r   r   r2   )rl   r   r   r$   rt   rv   otherZno_deleted_entriesZif_no_deletedZ
if_deletedoknentriesother_payloadr   ra   r%   r%   r&   copyA  s:    




$zSetInstance.copyc           
   
   C   s   | j }| j}| j}|j}| L}|j}||j|j\}}	||	| | j
||dd W 5 Q R X W 5 Q R X | |j dS )z9
        In-place intersection with *other* set.
        Fr   N)re   rf   r$   r   ra   r   r   r2   r   r   r   r   rt   )
rl   r   r   r   r$   r   r   ra   r   _r%   r%   r&   	intersecth  s    
$zSetInstance.intersectc              	   C   sX   | j }| j}| j}|j}| "}|j}| j||j|jdd W 5 Q R X | |j	 dS )z7
        In-place difference with *other* set.
        Fr   N)
re   rf   r$   r   ra   r   r   r2   r   rt   )rl   r   r   r   r$   r   r   ra   r%   r%   r&   
differencez  s    
 zSetInstance.differencec                 C   s   | j }| j}|j}| }|jj}|jj}| j}|j||dd\}	}
||
}|	|	J\}}| | j
||dd W 5 Q R X | | |||| W 5 Q R X W 5 Q R X W 5 Q R X | | jj dS )zA
        In-place symmetric difference with *other* set.
        Tr   Fr   N)re   rf   r$   r   ra   r   r2   r   r}   r   r   r   r   rt   )rl   r   r   r   r   r   r   r@   r$   r   r   ra   Z	if_commonZif_not_commonr%   r%   r&   symmetric_difference  s    

.z SetInstance.symmetric_differenceFc                 C   s   | j }| j}| j}|j}|r dnd}t|tj}||||j|j\}	}
|
 |	tj
| W 5 Q R X |	f | R}|j}||j|j\}}||| |	tj
| |  W 5 Q R X W 5 Q R X W 5 Q R X W 5 Q R X ||S )NrS   <=)re   rf   r$   r   r   r   r   rK   rt   r   r   r   ra   r   r   r2   r   r   rb   r   )rl   r   strictr   r   r$   r   cmp_opresZ
if_smaller	if_largerr   ra   r   r   r%   r%   r&   issubset  s(    
0zSetInstance.issubsetc              
      s   | j }| j | j}|j}t tj fdd}  d|j|j>\}}| ||| W 5 Q R X | ||| W 5 Q R X W 5 Q R X  	S )Nc              
      s^   |   L}|j}||j|j\}} |  tj |	  W 5 Q R X W 5 Q R X d S rn   )
r   ra   r   r   r2   r   r   r   r   rb   )ZsmallerZlargerr   ra   r   r   r   r  r%   r&   check  s    
z%SetInstance.isdisjoint.<locals>.check>)
re   rf   r$   r   r   r   r   rK   rt   r   )rl   r   r   r$   r   r  r  	otherwiser%   r  r&   
isdisjoint  s    	zSetInstance.isdisjointc                 C   s   | j }| j}| j}|j}t|tj}||d|j|j\}}|f |	 R}	|	j
}
||
j|
j\}}||| |tj| |	  W 5 Q R X W 5 Q R X W 5 Q R X | |tj| W 5 Q R X W 5 Q R X ||S )NrI   )re   rf   r$   r   r   r   r   rK   rt   r   ra   r   r   r2   r   r   r   r   rb   r   )rl   r   r   r   r$   r   r  Zif_same_sizer  r   ra   r   r   r%   r%   r&   equals  s&    
&"zSetInstance.equalsNc           	      C   sf   | tj}|dkr"t|t}n$t|tr8t||}| |||}| |||d}|	|}||fS )z
        Allocate a SetInstance with its storage.
        Return a (ok, instance) tuple where *ok* is a LLVM boolean and
        *instance* is a SetInstance object (the object's contents are
        only valid when *ok* is true).
        N)
r   r   r   r   r6   r   rT   intr   r   )	clsr   r   r    nitemsr   r   rl   r   r%   r%   r&   allocate_ex  s    

zSetInstance.allocate_exc              	   C   sH   |  ||||\}}|j||dd |j|td W 5 Q R X |S )z
        Allocate a SetInstance with its storage.  Same as allocate_ex(),
        but return an initialized *instance*.  If allocation failed,
        control is transferred to the caller using the target's current
        call convention.
        Fr   )zcannot allocate set)r  r   r   r   r   r   )r  r   r   r    r  r   rl   r%   r%   r&   allocate  s    
zSetInstance.allocatec                 C   s<   | |||d}||j _|tj|j _|j|||j |S )z
        Allocate a new set instance pointing to an existing payload
        (a meminfo pointer).
        Note the parent field has to be filled by the caller.
        N)	r   r   get_constant_nullr   pyobjectr   r   increfr;   )r  r   r   r    r   rl   r%   r%   r&   from_meminfo  s
    zSetInstance.from_meminfoc              
   C   s   |j }t|d}t|t}|||}t||}|d}	|d}
||	 |	|	d |
|}|d||}|j|dd ||
 W 5 Q R X |||}||| ||	 W 5 Q R X ||
 |
|S )zT
        Choose a suitable number of entries for the given number of items.
        r~   calcsize.bodycalcsize.end>=Fr   )r7   r   r6   r   shlr   r   r   r   r   r   rK   r   r   r   )r  r   r   r  r   r   r   min_entriesZsize_pr   r   r   Zis_large_enoughZ	next_sizer%   r%   r&   r   $  s$    




zSetInstance.choose_alloc_sizec              
   C   s0  | j }| j}|j}t|d}t|d}| j}|||}||j|}	|	d||	}
|j
|
dd t||	}|d}|d}|| ||D ||}|||}||| |	d||}|||| W 5 Q R X || ||}tr||d||	|| | ||d	 W 5 Q R X d
S )zs
        When adding to the set, ensure it is properly sized for the given
        number of used entries.
        r~      r  Fr   r  r  zKupsize to %zd items: current size = %zd, min entries = %zd, new size = %zd
zcannot grow setN)re   rf   r7   r   r6   r$   r  r   rp   rK   r   r   r   r   r   r   r   r   r   r   DEBUG_ALLOCSprintf_resize)rl   r  r   r   r   r   twor$   r  r   need_resize
new_size_pr   r   new_sizeis_too_smallr%   r%   r&   r   C  s>    





   zSetInstance.upsizec                 C   s  | j }| j}|j}t|d}t|d}t|t}| j}|||}	||	d|	||	|}	||	|}
|
|j|}||	d|
||	d||}|j|dd t||}|d}|d	}|| ||` ||}|||}|	d
|	|}|| || W 5 Q R X ||| || W 5 Q R X || ||}trr||d|||	| | ||d W 5 Q R X dS )zw
        When removing from the set, ensure it is properly sized for the given
        number of used entries.
        r~   r  r  r   rS   Fr   r  r  r  zMdownsize to %zd items: current size = %zd, min entries = %zd, new size = %zd
zcannot shrink setN)re   rf   r7   r   r6   r   r$   r  r9   rK   r   rp   r   r   r   r   r   r   r   r   r   r   r   r  r  r  )rl   r  r   r   r   r   r  r   r$   r  max_sizer   r  r  r   r   r  r   r%   r%   r&   r   q  sT     





   zSetInstance.downsizec           
   	   C   s   | j }| j}|}| j|dd}|j||dd |j|t|f W 5 Q R X | j}|	 $}|j
}	| j||	j|	jddd W 5 Q R X | |j dS )zw
        Resize the payload to the given number of entries.

        CAUTION: *nentries* must be a power of 2!
        TreallocFr   )r   r   N)re   rf   r   r   r   r   r   r   r$   r   ra   r   r   r2   _free_payloadr!   )
rl   r$   r   errmsgr   r   Zold_payloadr   r   ra   r%   r%   r&   r    s     

 zSetInstance._resizec              	   C   s   | j }| j}| j }|j}| |j W 5 Q R X | | jj | j	|dd}|j
||dd |j|td W 5 Q R X dS )z
        Replace the payload with a new empty payload with the given number
        of entries.

        CAUTION: *nentries* must be a power of 2!
        Tr"  Fr   )zcannot reallocate setN)re   rf   r$   r   ra   r   r   r$  r!   r   r   r   r   r   r   )rl   r   r   r   r   ra   r   r%   r%   r&   r     s    
zSetInstance._replace_payloadc                 C   s   | j }| j}t|tj}|tj}t	|d}t	|d}|
t| j}	||	}
| j}|
|8 }
t||t	||t	||
\}}|j|dd |tj| W 5 Q R X |j||dd& |r| jj}|jj|||d}t||}n4| ||j}|j||||tj}t||}|j|dd\}}| |tj| W 5 Q R X |z |s|| j_|tj | j_!| j"}t#||j$|d ||_%||_&||_'|(||}||_)t*r|+|d||j$| W 5 Q R X W 5 Q R X W 5 Q R X ||S )	z
        Allocate and initialize payload for the given number of entries.
        If *realloc* is True, the existing meminfo is reused.

        CAUTION: *nentries* must be a power of 2!
        r   r~   Fr   T)r      .allocated %zd bytes for set at %p: mask = %zd
),re   rf   r   r   r   r   r   r   r   r6   r   r   rg   r)   r   muladd_with_overflowr   r   r   r   r   r   r   Zmeminfo_varsize_alloc_uncheckedis_null	_imp_dtormodule"meminfo_new_varsize_dtor_uncheckedr   	voidptr_tr   r  r  r   r$   memsetr!   rt   rv   rx   r   rp   r  r  )rl   r   r#  r   r   r   r   r   r   r"   payload_size
entry_size	allocsizeovfr   r!   alloc_okdtorif_errorif_okr$   new_maskr%   r%   r&   r     sp    


    "zSetInstance._allocate_payloadc                 C   s   | j j| j| j| dS )z9
        Free an allocated old payload at *ptr*.
        N)re   r   Zmeminfo_varsize_freerf   r   )rl   r!   r%   r%   r&   r$  "  s    zSetInstance._free_payloadc                 C   s  | j }| j}t|tj}|tj}t	|d}t	|d}|
t| j}||}	| j}
|	|
8 }	|j}|||}|t	||	|t	||
|}|j||dd | ||j}|j||||tj}t||}|j|dd\}}| |tj| W 5 Q R X | || j_| j }|j!|_!|j"|_"||_#||_t$||j%|j%||
 |& }| '|j(j) W 5 Q R X t*r|+|d||j,| W 5 Q R X W 5 Q R X W 5 Q R X ||S )z7
        Raw-copy the given payload into self.
        r   r~   Tr   Fr'  )-re   rf   r   r   r   r   r   r   r   r6   r   r   rg   r)   r   rp   r   r   r   r   r*  r+  r   r,  r   r-  r)  r   r   r   r   r   r$   rt   rv   rx   
raw_memcpyrd   r   r   ra   r   r  r  r!   )rl   Zsrc_payloadr   r   r   r   r   r   r"   r/  r0  rp   r   r1  r4  r   r3  r5  r6  r$   r   r%   r%   r&   r   (  sd    
  
 
  "zSetInstance._copy_payloadc              	   C   s   t j}|tj}tt |||g}d| jj	 }t j
|||d}|jrd|_t| }t||| j|jd }	|	 "}
|
j}|j|| jj	|j W 5 Q R X |  |S )z Define the dtor for set
        z
.dtor.set.)namelinkonce_odrr   )r   r-  r   r   size_tr   FunctionTypeVoidTyperg   rY   get_or_insert_functionis_declarationlinkage	IRBuilderr   rc   rE   r   ra   r   decrefr   ret_void)rl   r   r+  	llvoidptrZllsize_tr=   fnamer?   r   r$   r   ra   r%   r%   r&   r*  i  s"    
 zSetInstance._imp_dtorc                 C   s   | j j| j| jj| dS )z Incref an element value
        N)re   r   r  rf   rg   rY   r   r%   r%   r&   r     s    zSetInstance.incref_valuec                 C   s   | j j| j| jj| dS )z Decref an element value
        N)re   r   rB  rf   rg   rY   r   r%   r%   r&   r     s    zSetInstance.decref_value)T)TT)TT)T)T)T)F)N)N)F).r   r   r   rm   r   rY   r$   r;   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r  r	  classmethodr  r  r  r   r   r   r  r   r   r$  r   r*  r   r   r%   r%   r%   r&   r   t  sf   











			'


.<
CAr   c                   @   sZ   e Zd Zdd Zedd Zedd Zedd Zed	d
 Z	e	j
dd
 Z	dd ZdS )SetIterInstancec                 C   sL   || _ || _|| _||||| _| j j|| j}t||| jj	|| _
d S rn   )re   rf   rg   r   _iterr   r   r   rc   	containerrh   )rl   r   r   	iter_typeiter_valr!   r%   r%   r&   rm     s    zSetIterInstance.__init__c                 C   sJ   t |||j|}| |||d }|tjd}t|||j_|j	|j_	|S rD   )
r   rI  get_constantr   r   r   r   rH  r`   r   )r  r   r   rJ  r   Zset_instrl   r`   r%   r%   r&   from_set  s    
zSetIterInstance.from_setc                 C   s
   | j  S rn   )rH  r   rq   r%   r%   r&   r;     s    zSetIterInstance.valuec                 C   s   | j jS rn   )rH  r   rq   r%   r%   r&   r     s    zSetIterInstance.meminfoc                 C   s   | j | jjS rn   )rf   r   rH  r`   rq   r%   r%   r&   r`     s    zSetIterInstance.indexc                 C   s   | j || jj d S rn   )rf   r   rH  r`   rr   r%   r%   r&   r`     s    c              	   C   sr   | j }| j}t|jd}|  |j|d:}|j}|  |	|j
 | j|j || _ |  W 5 Q R X d S )Nr~   r   )r`   rh   r   r6   r7   set_exhaustedr   ra   	set_validyield_r   rf   r   rb   )rl   resultr`   r$   r   r   ra   r%   r%   r&   iternext  s    zSetIterInstance.iternextN)r   r   r   rm   rF  rM  r   r;   r   r`   r   rR  r%   r%   r%   r&   rG    s   




rG  c              	   C   s   t |}t| |||}|dkrt||}t||}| tj|}t	||(}	|
t||d|	j}
||
 W 5 Q R X t| |||jS )zD
    Build a set of the given type, containing the given items.
    r   )lenr   r  r   
pack_arrayr   rL  r   r   r   r   r{   r`   r   r   r;   )r   r   r    itemsr  instarray	array_ptrcountr   r   r%   r%   r&   	build_set  s    rZ  c                 C   s$   |j }t| ||}t| |||jS rn   )return_typer   r  r   r;   )r   r   r>   rE   r    rV  r%   r%   r&   set_empty_constructor  s    r\  c           
   	   C   s|   |j }|j\}|\}t| |||}t| |||}t| |||&}	||	j | j	||j
|	j W 5 Q R X t| |||jS rn   )r[  rE   r   r   r  r   r   r;   r   rB  rY   r   )
r   r   r>   rE   r    
items_typerU  nrV  r   r%   r%   r&   set_constructor  s    r_  c                 C   s    t | ||jd |d }| S rD   )r   rE   r   r   r   r>   rE   rV  r%   r%   r&   set_len  s    ra  c                 C   s&   t | ||jd |d }||d S Nr   r~   )r   rE   r   r`  r%   r%   r&   in_set  s    rc  getiterc                 C   s(   t | ||j|d }t| ||j|jS rD   )rG  rM  r[  r
   r;   r`  r%   r%   r&   getiter_set  s    re  rR  c                 C   s&   t | ||jd |d }|| d S rD   )rG  rE   rR  )r   r   r>   rE   rQ  rV  r%   r%   r&   iternext_listiter	  s    rf  zset.addc                 C   s2   t | ||jd |d }|d }|| |  S rb  )r   rE   r   get_dummy_valuer   r   r>   rE   rV  r   r%   r%   r&   set_add  s    
ri  c                 C   s   t ||}dd }||fS )Nc                 S   s2   t | ||jd |d }|d }|| |  S rb  )r   rE   r   rg  rh  r%   r%   r&   set_discard"  s    
z!_set_discard.<locals>.set_discardr   none)r<   rZ   r   r>   rj  r%   r%   r&   _set_discard  s    rm  r   c                 C   s   dd S )Nc                 S   s
   t | |S rn   )rm  rZ   r   r%   r%   r&   <lambda>.      z ol_set_discard.<locals>.<lambda>r%   rn  r%   r%   r&   ol_set_discard,  s    rq  c                 C   s   | |}dd }||fS )Nc              	   S   sZ   t | ||jd |d }|jj}|jt||dd | j|t	d W 5 Q R X |
 S )Nr   Fr   )zset.pop(): empty set)r   rE   r$   rt   r   r   r)  r   r   KeyErrorr   )r   r   r>   rE   rV  rt   r%   r%   r&   set_pop5  s    
z_set_pop.<locals>.set_poprX   )r<   rZ   r>   rs  r%   r%   r&   _set_pop1  s    
	rt  r   c                 C   s   dd S )Nc                 S   s   t | S rn   )rt  rZ   r%   r%   r&   ro  C  rp  zol_set_pop.<locals>.<lambda>r%   ru  r%   r%   r&   
ol_set_popA  s    rv  c                 C   s   t ||}dd }||fS )Nc              	   S   sb   t | ||jd |d }|d }||}|j||dd | j|td W 5 Q R X |  S )Nr   r~   Fr   )zset.remove(): key not in set)	r   rE   r   r   r   r   r   rr  rg  )r   r   r>   rE   rV  r   r   r%   r%   r&   
set_removeJ  s    

z_set_remove.<locals>.set_removerk  )r<   rZ   r   r>   rw  r%   r%   r&   _set_removeF  s    
rx  removec                 C   s   | j |krdd S d S )Nc                 S   s
   t | |S rn   )rx  rn  r%   r%   r&   ro  Z  rp  zol_set_remove.<locals>.<lambda>rX   rn  r%   r%   r&   ol_set_removeW  s    
rz  c                 C   s   t |}dd }||fS )Nc                 S   s(   t | ||jd |d }|  |  S rD   )r   rE   r   rg  r`  r%   r%   r&   	set_clearc  s    z_set_clear.<locals>.set_clearrk  )r<   rZ   r>   r{  r%   r%   r&   
_set_clear_  s    
r|  r   c                 C   s   dd S )Nc                 S   s   t | S rn   )r|  ru  r%   r%   r&   ro  m  rp  zol_set_clear.<locals>.<lambda>r%   ru  r%   r%   r&   ol_set_cleark  s    r}  c                 C   s   ||}dd }||fS )Nc                 S   s2   t | ||jd |d }| }t| ||j|jS rD   )r   rE   r   r   r[  r;   r   r   r>   rE   rV  r   r%   r%   r&   set_copyt  s    z_set_copy.<locals>.set_copyr%   )r<   rZ   r>   r  r%   r%   r&   	_set_copyp  s    r  r   c                 C   s   dd S )Nc                 S   s   t | S rn   )r  ru  r%   r%   r&   ro  ~  rp  zol_set_copy.<locals>.<lambda>r%   ru  r%   r%   r&   ol_set_copy|  s    r  c                 C   sB   t | ||jd |d }t | ||jd |d }|| |  S rb  )r   rE   r   rg  r~  r%   r%   r&   set_difference_update  s    
r  c                 C   s   t ||}|tfS rn   )r   rl  r  r<   abr>   r%   r%   r&   _set_difference_update  s    r  difference_updatec                 C   s   t | | dd S )Nc                 S   s
   t | |S rn   )r  r  r  r%   r%   r&   ro    rp  z,set_difference_update_impl.<locals>.<lambda>r]   r  r%   r%   r&   set_difference_update_impl  s    
r  c                 C   sB   t | ||jd |d }t | ||jd |d }|| |  S rb  )r   rE   r   rg  r~  r%   r%   r&   set_intersection_update  s    
r  c                 C   s   t ||}|tfS rn   )r   rl  r  r  r%   r%   r&   _set_intersection_update  s    r  intersection_updatec                 C   s   t | | dd S )Nc                 S   s
   t | |S rn   )r  r  r%   r%   r&   ro    rp  z.set_intersection_update_impl.<locals>.<lambda>r  r  r%   r%   r&   set_intersection_update_impl  s    
r  c                 C   sB   t | ||jd |d }t | ||jd |d }|| |  S rb  )r   rE   r   rg  r~  r%   r%   r&   set_symmetric_difference_update  s    
r  c                 C   s   t ||}|tfS rn   )r   rl  r  r  r%   r%   r&    _set_symmetric_difference_update  s    r  symmetric_difference_updatec                 C   s   t | | dd S )Nc                 S   s
   t | |S rn   )r  r  r%   r%   r&   ro    rp  z6set_symmetric_difference_update_impl.<locals>.<lambda>r  r  r%   r%   r&   $set_symmetric_difference_update_impl  s    
r  z
set.updatec              	   C   s   t | ||jd |d }|jd }|d }t| |||}|d k	rZ||jj|}|| t| |||:}	| ||	j	|j
|j
}
||
 | j||j
|	j	 W 5 Q R X |d k	r||jj |  S rb  )r   rE   r   r   r$   rt   r   r   castr;   rY   r   rB  r   rg  )r   r   r>   rE   rV  r]  rU  r^  r  r   castedr%   r%   r&   
set_update  s    


r  c                    s(   t fdd t|  fdd}d S )Nc                    s   |||} fdd}||fS )Nc                    s:   |j |jd kst | ||| t| ||jd |d S rD   )r[  rE   AssertionErrorr
   )r   r   r>   rE   rG   r%   r&   codegen  s    z>gen_operator_impl.<locals>._set_operator_intr.<locals>.codegenr%   r<   r  r  r>   r  r  r%   r&   _set_operator_intr  s    
z-gen_operator_impl.<locals>._set_operator_intrc                    s   t | |  fddS )Nc                    s
    | |S rn   r%   r  r  r%   r&   ro    rp  z=gen_operator_impl.<locals>._ol_set_operator.<locals>.<lambda>r  r  r  r%   r&   _ol_set_operator  s    
z+gen_operator_impl.<locals>._ol_set_operator)r   r   )oprG   r  r%   )r  rG   r&   gen_operator_impl  s    r  r   c                 C   s   t | | dd }|S )Nc                 S   s   |   }|| |S rn   )r   r  r  r  rZ   r%   r%   r&   difference_impl  s    
z,impl_set_difference.<locals>.difference_implr  )r  r  r  r%   r%   r&   impl_set_difference  s    
r  intersectionc                 C   s   t | | dd }|S )Nc                 S   s@   t | t |k r&|  }|| |S | }||  |S d S rn   )rS  r   r  r  r%   r%   r&   intersection_impl  s    

z+set_intersection.<locals>.intersection_implr  )r  r  r  r%   r%   r&   set_intersection  s    

r  r   c                 C   s   t | | dd }|S )Nc                 S   s@   t | t |kr&|  }|| |S | }||  |S d S rn   )rS  r   r  r  r%   r%   r&   symmetric_difference_impl  s    

z;set_symmetric_difference.<locals>.symmetric_difference_implr  )r  r  r  r%   r%   r&   set_symmetric_difference  s    

r  unionc                 C   s   t | | dd }|S )Nc                 S   s@   t | t |kr&|  }|| |S | }||  |S d S rn   )rS  r   updater  r%   r%   r&   
union_impl(  s    

zset_union.<locals>.union_implr  )r  r  r  r%   r%   r&   	set_union#  s    

r  c                 C   s   t ||}dd }||fS )Nc                 S   s:   t | ||jd |d }t | ||jd |d }||S rb  )r   rE   r  r~  r%   r%   r&   r  ;  s    z _set_isdisjoint.<locals>.codegenr   booleanr  r%   r%   r&   _set_isdisjoint7  s    r  r  c                 C   s   t | | dd S )Nc                 S   s
   t | |S rn   )r  r  r%   r%   r&   ro  H  rp  z set_isdisjoint.<locals>.<lambda>r  r  r%   r%   r&   set_isdisjointD  s    
r  c                 C   s   t ||}dd }||fS )Nc                 S   s:   t | ||jd |d }t | ||jd |d }||S rb  r   rE   r  r~  r%   r%   r&   r  O  s    z_set_issubset.<locals>.codegenr  r  r%   r%   r&   _set_issubsetK  s    r  r  c                 C   s   t | | dd S )Nc                 S   s
   t | |S rn   )r  r  r%   r%   r&   ro  \  rp  zset_issubset.<locals>.<lambda>r  r  r%   r%   r&   set_issubsetW  s    
r  
issupersetc                 C   s   t | | dd }|S )Nc                 S   s
   | | S rn   )r  r  r%   r%   r&   superset_impld  s    z%set_issuperset.<locals>.superset_implr  )r  r  r  r%   r%   r&   set_issuperset_  s    
r  c                 C   s   t ||}dd }||fS )Nc                 S   s:   t | ||jd |d }t | ||jd |d }||S rb  )r   rE   r	  r~  r%   r%   r&   r  m  s    z_set_eq.<locals>.codegenr  r  r%   r%   r&   _set_eqi  s    r  c                 C   s   t | | dd S )Nc                 S   s
   t | |S rn   )r  r  r%   r%   r&   ro  y  rp  zset_eq.<locals>.<lambda>r  r  r%   r%   r&   set_equ  s    
r  c                 C   s   t | | dd }|S )Nc                 S   s
   | |k S rn   r%   r  r%   r%   r&   ne_impl  s    zset_ne.<locals>.ne_implr  )r  r  r  r%   r%   r&   set_ne{  s    
r  c                 C   s   t ||}dd }||fS )Nc                 S   s>   t | ||jd |d }t | ||jd |d }|j|ddS )Nr   r~   T)r   r  r~  r%   r%   r&   r    s    z_set_lt.<locals>.codegenr  r  r%   r%   r&   _set_lt  s    r  c                 C   s   t | | dd S )Nc                 S   s
   t | |S rn   )r  r  r%   r%   r&   ro    rp  zset_lt.<locals>.<lambda>r  r  r%   r%   r&   set_lt  s    
r  c                 C   s   t | | dd }|S )Nc                 S   s   || k S rn   r%   r  r%   r%   r&   gt_impl  s    zset_gt.<locals>.gt_implr  )r  r  r  r%   r%   r&   set_gt  s    
r  c                 C   s^   t | ||jd |d }t | ||jd |d }||jtj}||jtj}|d||S )Nr   r~   rI   )r   rE   ptrtointr   r   r   icmp_signed)r   r   r>   rE   r  r  mambr%   r%   r&   set_is  s
    r  c                 C   s   |j |j kst|S rn   )rY   r  )r   r   fromtytotyr   r%   r%   r&   
set_to_set  s    r  )}__doc__collectionsr   mathr   	functoolsr   llvmliter   
numba.corer   r   r   numba.core.imputilsr   r   r	   r
   r   r   r   r   r   
numba.miscr   numba.cpythonr   numba.core.errorsr   r   numba.core.extendingr   r   r   r'   r+   rJ   rO   r8   r   r   r  rC   rH   rM   rR   r5   r]   
namedtupler^   objectrc   r   rG  rZ  setr\  IterableTyper_  rS  rU   ra  r   Anyrc  re  SetIterBORROWEDrf  ri  rm  rq  rt  rv  rx  rz  r|  r}  r  r  r  r  r  r  r  r  r  r  r  r  r  iandiorisubixorZop_Zop_implr   r  r   r  xorr  or_r  r  r  r  ler  ger  r  r   r  ner  r  ltr  gtr  is_r  r  r%   r%   r%   r&   <module>   s  ,
	        "6

























	



























