
    <ЦiA                        % S r SSKrSSKrSSKJr  SSKJrJrJrJ	r	J
r
JrJr  SSKrSSKrSSKJr  SSKJrJr  SSKJr  SS	KJrJr  S
q\R4                  " 5       r\R8                  " 5       r/ q\	\\/ S4   \	\   4      \ S'   \!" \RD                  SS 5      r#\\\\$S4   r%\" 5       q&Sr'\\RD                  RP                     \ S'   S\)4S jr*\*" 5       (       aC  \RD                  RV                  r+\RD                  RX                  r-\RD                  R\                  r/O\" S5      r+S\$S\$4S jr-S\$S\$4S jr/\" SS9S\$4S j5       r0S\)4S jr1S r2S r3S r4S r5S r6 " S S5      r7 " S  S5      r " S! S"\5      r8S\%SS4S# jr9S;S\
\%   S\4S$ jjr:\" S5      S;S\
\%   S\\\4   4S% jj5       r;S;S\
\%   S\+4S& jjr<S\$4S' jr=S\\$\\R                  4   S\R                  4S( jr> " S) S*5      r?S+\
S,   S\?4S- jr@S. rAS+\4S/ jrBS;S\
\%   S\4S0 jjrCS;S\%SS4S1 jjrDS\	\   4S2 jrES\4S3 jrFS\R                  S\RD                  RP                  4S4 jrG S<S5\$S\\$\\R                  4   SS4S6 jjrHS<S\\$\\R                  4   S\$4S7 jjrISS8KJJKrKJLrLJMrMJNrNJOrOJPrPJQrQJRrRJSrSJTrT  SS9KUJVrVJWrWJXrXJYrYJZrZJ[r[J\r\J]r]J^r^  / S:Qr_g)=z
This package introduces support for the XPU backend, specifically tailored for
Intel GPU optimization.

This package is lazily initialized, so you can always import it, and use
:func:`is_available()` to determine if your system supports XPU.
    N)	lru_cache)AnyCallableDictListOptionalTupleUniondevice)_dummy_type_LazySeedTracker   )_get_device_index)EventStreamF_queued_calls_xpu_isInBadForkc                      gNF r       Q/var/www/html/ai-image-ml/venv/lib/python3.13/site-packages/torch/xpu/__init__.py<lambda>r      s    r   r   default_generatorsreturnc                  6    [         R                  R                  $ )z(Return true if compile with XPU support.)torch_C_has_xpur   r   r   _is_compiledr!   #   s    88r   _XpuDevicePropertiesr   c                     [        S5      eNz(PyTorch was compiled without XPU supportNotImplementedErrorr   s    r   _exchange_devicer'   0       !"LMMr   c                     [        S5      er$   r%   r   s    r   _maybe_exchange_devicer*   3   r(   r   )maxsizec                  ^    [        5       (       d  g[        R                  R                  5       $ )z*Return the number of XPU device available.r   )r!   r   r   _xpu_getDeviceCountr   r   r   device_countr.   7   s!     >>88''))r   c                      [        5       S:  $ )z7Return a bool indicating if XPU is currently available.r   )r.   r   r   r   is_availabler0   ?   s     >Ar   c                      g)zKReturn a bool indicating if the current XPU device supports dtype bfloat16.Tr   r   r   r   is_bf16_supportedr2   E   s    r   c                  :    [         =(       a    [        5       (       + $ )z8Return whether PyTorch's XPU state has been initialized.)_initialized_is_in_bad_forkr   r   r   is_initializedr6   J   s    1 111r   c                    [        5       (       a  U " 5         g UR                  SS5      (       a*  [        R                  U [        R
                  " 5       5        g UR                  SS5      (       a*  [        R                  U [        R
                  " 5       5        g [        R                  U [        R
                  " 5       45        g )Nseed_allFseed)	r6   get_lazy_seed_trackerqueue_seed_all	tracebackformat_stack
queue_seedr   append)callablekwargss     r   
_lazy_callrC   O   s    
 ::j%((--h	8N8N8PQZZ&&))(I4J4J4LM   (I,B,B,D!EFr   c                      [        5         g)zInitialize PyTorch's XPU state.
This is a Python API about lazy initialization that avoids initializing
XPU until the first time it is accessed. Does nothing if the XPU state is
already initialized.
N)
_lazy_initr   r   r   initrF   ]   s	     Lr   c            	         [        5       (       d  [        [        S5      (       a  g [           [        5       (       a
   S S S 5        g [	        5       (       a  [        S5      e[        5       (       d  [        S5      e[        R                  R                  5         S[        l        [        R                  S [        R                  5        5       5         [         H  u  p U " 5         M     ['        [        S5        SqS S S 5        g ! [          a1  nS[#        U5       SSR%                  U5       3n[!        U5      UeS nAff = f! ['        [        S5        f = f! , (       d  f       g = f)	Nis_initializingzuCannot re-initialize XPU in forked subprocess. To use XPU with multiprocessing, you must use the 'spawn' start methodz#Torch not compiled with XPU enabledTc              3   6   #    U  H  o(       d  M  Uv   M     g 7fNr   ).0callss     r   	<genexpr>_lazy_init.<locals>.<genexpr>}   s     X0NuRWUU0Ns   
	z5XPU call failed lazily at initialization with error: z'

XPU call was originally invoked at:

 )r6   hasattr_tls_initialization_lockr5   RuntimeErrorr!   AssertionErrorr   r   	_xpu_initrH   r   extendr;   	get_calls	Exceptionstrjoindelattrr4   )queued_callorig_tracebackemsgs       r   rE   rE   f   s=   74):;;	 	 
	 I  ~~ !FGG  $X0B0L0L0NXX	-/<+0M 0= D+,C 
	2 ! 0OPSTUPVx XBBD''.BYAZ\  $C.a/0 D+,A 
	sN   EBEED%E)E
D?,D::D??EEE
E%c                   >    \ rS rSrS\4S jrS rS\S\S\4S jrS	r	g
)_DeviceGuard   indexc                     Xl         SU l        g Nidxprev_idx)selfrc   s     r   __init___DeviceGuard.__init__   s    r   c                 `    [         R                  R                  U R                  5      U l        g rJ   r   xpur'   rh   ri   rj   s    r   	__enter___DeviceGuard.__enter__       		22488<r   typevaluer=   c                 `    [         R                  R                  U R                  5      U l        gr   r   ro   r*   ri   rh   rj   rt   ru   r=   s       r   __exit___DeviceGuard.__exit__       9933DMMBr   rg   N)
__name__
__module____qualname____firstlineno__intrk   rq   r   ry   __static_attributes__r   r   r   ra   ra      s-    c =S   r   ra   c                   B    \ rS rSrSrS \4S jrS rS\S\S\4S jrS	r	g
)r      zContext-manager that changes the selected device.

Args:
    device (torch.device or int or str): device index to select. It's a no-op if
        this argument is a negative integer or ``None``.
c                 0    [        USS9U l        SU l        g )NToptionalrf   )r   rh   ri   )rj   r   s     r   rk   device.__init__   s    $Vd;r   c                 `    [         R                  R                  U R                  5      U l        g rJ   rn   rp   s    r   rq   device.__enter__   rs   r   rt   ru   r=   c                 `    [         R                  R                  U R                  5      U l        gr   rw   rx   s       r   ry   device.__exit__   r{   r   rg   N)
r|   r}   r~   r   __doc__r   rk   rq   ry   r   r   r   r   r   r      s2    s =S   r   c                   ,   ^  \ rS rSrSrU 4S jrSrU =r$ )	device_of   a	  Context-manager that changes the current device to that of given object.

You can use both tensors and storages as arguments. If a given object is
not allocated on a XPU, this is a no-op.

Args:
    obj (Tensor or Storage): object allocated on the selected device.
c                 j   > UR                   (       a  UR                  5       OSn[        TU ]  U5        g re   )is_xpu
get_devicesuperrk   )rj   objrh   	__class__s      r   rk   device_of.__init__   s$    "%**cnn"r   r   )r|   r}   r~   r   r   rk   r   __classcell__)r   s   @r   r   r      s     r   r   c                 z    [        5         [        U 5      n U S:  a   [        R                  R	                  U 5        gg)zSet the current device.

Args:
    device (torch.device or int or str): selected device. This function is a
        no-op if this argument is negative.
r   N)rE   r   r   r   _xpu_setDevicer   s    r   
set_devicer      s1     Lv&F{' r   c                 ,    [        U 5      R                  $ )am  Get the name of a device.

Args:
    device (torch.device or int or str, optional): device for which to
        return the name. This function is a no-op if this argument is a
        negative integer. It uses the current device, given by :func:`~torch.xpu.current_device`,
        if :attr:`device` is ``None`` (default).

Returns:
    str: the name of the device
)get_device_propertiesnamer   s    r   get_device_namer      s     !(---r   c                     [        U 5      n[        U5       Vs0 s H'  nUR                  S5      (       a  M  U[        X5      _M)     sn$ s  snf )a  Get the xpu capability of a device.

Args:
    device (torch.device or int or str, optional): device for which to
        return the device capability. This function is a no-op if this
        argument is a negative integer. It uses the current device, given by
        :func:`~torch.xpu.current_device`, if :attr:`device` is ``None``
        (default).

Returns:
    Dict[str, Any]: the xpu capability dictionary of the device
)__
_pybind11_)r   dir
startswithgetattr)r   propsprops      r   get_device_capabilityr      sR     "&)E JD34 	#ge""  s
   A
A
c                 ~    [        5         [        U SS9n U S:  d  U [        5       :  a  [        S5      e[	        U 5      $ )zGet the properties of a device.

Args:
    device (torch.device or int or str): device for which to return the
        properties of the device.

Returns:
    _XpuDeviceProperties: the properties of the device
Tr   r   zInvalid device index)rE   r   r.   rT   _get_device_propertiesr   s    r   r   r      s<     Lv5FzV|~-344!&))r   c                  R    [        5         [        R                  R                  5       $ )z0Return the index of a currently selected device.)rE   r   r   _xpu_getDevicer   r   r   current_devicer     s    L88""$$r   c                     [        U [        5      (       a  [        R                  " U 5      n U $ [        U [        5      (       a  [        R                  " SU 5      n U $ )zReturn the torch.device type object from the passed in device.

Args:
    device (torch.device or int or str): selected device.
ro   )
isinstancerY   r   r   r   r   s    r   _get_devicer     sJ     &#f% M 
FC	 	 eV,Mr   c                   Z    \ rS rSr% Sr\S   \S'   S\S   4S jrS rS\	S	\	S
\	4S jr
Srg)StreamContexti  a   Context-manager that selects a given stream.

All XPU kernels queued within its context will be enqueued on a selected
stream.

Args:
    Stream (Stream): selected stream. This manager is a no-op if it's
        ``None``.
.. note:: Streams are per-device.
torch.xpu.Stream
cur_streamstreamc                 \    Xl         [        S S5      U l        U R                  c  SU l        g g )NTrf   )r   r   rh   )rj   r   s     r   rk   StreamContext.__init__&  s+    $T4088DH r   c                    U R                   nUb  U R                  S:X  a  g [        R                  R	                  S 5      U l        U R
                  R                  UR                  :w  aL  [        UR                  5         [        R                  R	                  UR                  5      U l        S S S 5        [        R                  R                  U5        g ! , (       d  f       N.= fre   )	r   rh   r   ro   current_streamsrc_prev_streamr   dst_prev_stream
set_stream)rj   r   s     r   rq   StreamContext.__enter__,  s    [[
R$yy77= &&**;*;;
))*',yy'?'?
@Q@Q'R$ +		Z( +*s   >/C
C#rt   ru   r=   c                 0   U R                   nUb  U R                  S:X  a  g U R                  R                  UR                  :w  a)  [        R
                  R                  U R                  5        [        R
                  R                  U R                  5        g re   )r   rh   r   r   r   ro   r   r   )rj   rt   ru   r=   r   s        r   ry   StreamContext.__exit__8  sj    [[
R &&**;*;;II  !5!56		T112r   )r   rh   r   r   N)r|   r}   r~   r   r   r   __annotations__rk   rq   r   ry   r   r   r   r   r   r     sF    	 +,,x(:; 
)3S 3 3 3r   r   r   r   c                     [        U 5      $ )zWrap around the Context-manager StreamContext that selects a given stream.

Arguments:
    stream (Stream): selected stream. This manager is a no-op if it's ``None``.
)r   r   s    r   r   r   C  s       r   c                 B    [         R                  R                  U UUS9  g)zset stream specified by the stream id, device index and device type

Args: stream_id (int): not visible to the user, used to assigned to the specific stream.
      device_index (int): selected device index.
      device_type (int): selected device type.
	stream_iddevice_indexdevice_typeN)r   r   _xpu_setStreamr   s      r   _set_stream_by_idr   L  s$     
HH!  r   c                 r    U c  g[        5         [        U R                  U R                  U R                  S9  g)a  Set the current stream.This is a wrapper API to set the stream.
    Usage of this function is discouraged in favor of the ``stream``
    context manager.

Args:
    stream (Stream): selected stream. This function is a no-op
        if this argument is ``None``.
Nr   )rE   r   r   r   r   r   s    r   r   r   Z  s4     ~L""((&&r   c                     [        5         [        R                  R                  [	        U SS95      n[        US   US   US   S9$ )a:  Return the currently selected :class:`Stream` for a given device.

Args:
    device (torch.device or int, optional): selected device. Returns
        the currently selected :class:`Stream` for the current device, given
        by :func:`~torch.xpu.current_device`, if :attr:`device` is ``None``
        (default).
Tr   r   r      r   )rE   r   r   _xpu_getCurrentStreamr   r   )r   
streamdatas     r   r   r   m  sJ     L//&40J Q-jmTU r   c                 h    [        5         [        U SS9n [        R                  R	                  U 5      $ )a  Wait for all kernels in all streams on a XPU device to complete.

Args:
    device (torch.device or int, optional): device for which to synchronize.
        It uses the current device, given by :func:`~torch.xpu.current_device`,
        if :attr:`device` is ``None`` (default).
Tr   )rE   r   r   r   _xpu_synchronizer   s    r   synchronizer     s*     Lv5F88$$V,,r   c                      [        5       (       d  / $ [        R                  R                  5       n U c  / $ U R	                  5       $ )z<Return list XPU architectures this library was compiled for.)r0   r   r   _xpu_getArchFlagssplit)
arch_flagss    r   get_arch_listr     s:    >>	++-J	r   c                  l    [        5       n [        U 5      S:X  a  gSSR                  S U  5       5       3$ )zIReturn XPU AOT(ahead-of-time) build flags this library was compiled with.r   rO   z-device ,c              3   $   #    U  H  ov   M     g 7frJ   r   )rK   archs     r   rM   $get_gencode_flags.<locals>.<genexpr>  s     :	t	s   )r   lenrZ   )	arch_lists    r   get_gencode_flagsr     s5    I
9~chh:	::;<<r   c                 n    U R                   nUc
  [        5       n[        R                  R                  U   $ )ziReturn the XPU Generator object for the given device.

Args:
    device (torch.device): selected device.
)rc   r   r   ro   r   )r   rh   s     r   _get_generatorr     s/     ,,C
{99'',,r   offsetc                 B   ^ ^ [        U5      mUU 4S jn[        U5        g)a  Set the random number generator state offset of the specified GPU.

Args:
    offset (int): The desired offset
    device (torch.device or int, optional): The device to set the RNG state.
        Default: ``'xpu'`` (i.e., ``torch.device('xpu')``, the current XPU device).
c                  >   > [        T5      n U R                  T5        g rJ   )r   
set_offset)default_generatorfinal_devicer   s    r   cb!_set_rng_state_offset.<locals>.cb  s    *<8$$V,r   N)r   rC   )r   r   r   r   s   `  @r   _set_rng_state_offsetr     s     v&L- rNr   c                 b    [        5         [        U 5      n[        U5      nUR                  5       $ )a4  Return the random number generator state offset of the specified GPU.

Args:
    device (torch.device or int, optional): The device to return the RNG state offset of.
        Default: ``'xpu'`` (i.e., ``torch.device('xpu')``, the current XPU device).

.. warning::
    This function eagerly initializes XPU.
)rE   r   r   
get_offset)r   r   r   s      r   _get_rng_state_offsetr     s-     Lv&L&|4''))r   )
empty_cachemax_memory_allocatedmax_memory_reservedmem_get_infomemory_allocatedmemory_reservedmemory_statsmemory_stats_as_nested_dictreset_accumulated_memory_statsreset_peak_memory_stats)	get_rng_stateget_rng_state_allinitial_seedmanual_seedmanual_seed_allr9   r8   set_rng_stateset_rng_state_all)+r   r   r   r   r   r   r   r   r.   r   r   r   r   r   r   r   r   
get_streamrF   r   r0   r2   r6   r   r   r   r   r   r   r   r   r   r   r   r9   r8   r   r   r   r   r   streamsr   rJ   )ro   )`r   	threadingr=   	functoolsr   typingr   r   r   r   r   r	   r
   r   torch._Cr   _devicetorch._utilsr   r   _utilsr   r   r   r   r4   localrQ   LockrR   r   rY   r   r   r   r5   r   	_device_tr;   r   	Generatorboolr!   r"   _xpu_exchangeDevicer'   _xpu_maybeExchangeDevicer*   r.   r0   r2   r6   rC   rF   rE   ra   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   memoryr   r   r   r   r   r   r   r   r   r   randomr   r   r   r   r   r9   r8   r   r   __all__r   r   r   <module>r     sr      D D D   # 6 % "  ~~'   t	(2t8
d3i
'(  %(($6F'3T)*	%' 02 E%((,,- 2d 
 >> 8888xx33"XX>> ''=>N N NNs Ns N 1*c * *d 
2
G%P
 
 ( 
(y 
(T 
(.HY/ .3 . 4(9"5 c3h  4*(9"5 *AU *"% %
c345 
%,, 
'3 '3T!8./ !M !v &8I. & $
-	 
-T 
-tCy =3 =	-5<< 	-EHH,>,> 	- :?sC56	&*%S%,,(>"? *C *"  
 
 
,r   