+
    :ic                         ^ RI t ^ RIt^ RIt^ RIt^ RIHt ^ RIHtH	t	H
t
 R t]
! R4       ! R R]	4      4       t]
! R4       ! R R	]	4      4       t]R
8X  d   ]P                  ! 4        R# R# )    N)cuda)unittestCUDATestCaseskip_on_cudasimc                 F   a  \         P                  ! S 4      V 3R  l4       pV# )c                     < \         P                  ! 4       pVP                  R 4        VP                  S! V / VB 4      VP	                  4        #   TP	                  4        i ; i)T)asyncionew_event_loop	set_debugrun_until_completeclose)argskwdsloopfs   *, c/var/www/html/photoedit/myenv/lib/python3.14/site-packages/numba/cuda/tests/cudadrv/test_streams.pyrunner!with_asyncio_loop.<locals>.runner
   sM    %%'t	**1d+;d+;<JJLDJJLs   A A")	functoolswraps)r   r   s   f r   with_asyncio_loopr   	   s%    __Q  M    z,CUDA Driver API unsupported in the simulatorc                   |   a  ] tR t^t o R tR t]R 4       t]R 4       t]R 4       t	]R 4       t
]R 4       tRtV tR	# )
TestCudaStreamc                    R  p\         P                  ! 4       p\        P                  ! 4       pVP	                  W4       V P                  VP                  R4      4       R# )c                 &    VP                  4        R # N)set)streamstatusevents   &&&r   callback2TestCudaStream.test_add_callback.<locals>.callback   s    IIKr         ?N)r   r   	threadingEventadd_callback
assertTruewaitselfr"   r   callback_events   &   r   test_add_callback TestCudaStream.test_add_callback   sE    	 "*H5++C01r   c                   a a \         P                  ! 4       oVV 3R  lp\        P                  ! 4       pVP	                  V4       S P                  SP                  R4      4       R# )c                 J   < SP                  V4       SP                  4        R # r   )assertIsNoner   )r   r    argr,   r+   s   &&&r   r"   CTestCudaStream.test_add_callback_with_default_arg.<locals>.callback#   s    c" r   r$   N)r%   r&   r   r   r'   r(   r)   r*   s   f  @r   "test_add_callback_with_default_arg1TestCudaStream.test_add_callback_with_default_arg    sF    "*	! H%++C01r   c                l   "   \         P                  ! 4       pVP                  4       G R j  xL
  R #  L5ir   )r   r   
async_done)r+   r   s   & r   test_async_doneTestCudaStream.test_async_done+   s"     !!!s   )424c                  a "   R  V 3R llp. ROpV Uu. uF  p\         P                  ! V! V4      4      NK!  	  pp\         P                  ! V!  G Rj  xL
 pS P                  \        P
                  ! W%4      4       R# u upi  L05i)c                0    V ^8  d   QhR\         R\         /# )   value_inreturn)float)formats   "r   __annotate__8TestCudaStream.test_parallel_tasks.<locals>.__annotate__2   s     	  	 % 	 E 	 r   c                 \  <"   \         P                  ! 4       p\         P                  ! ^4      \         P                  ! ^4      r2WR&   \         P                  ! W!R7      pVP	                  W1R7       VP                  4       G Rj  xL
 pSP                  WQ4       VP                  4       #  L%5i)   :NNNr   N)r   r   pinned_array	to_devicecopy_to_hostr7   assertEqualmean)r=   r   h_srch_dstd_arydone_resultr+   s   &     r   async_cuda_fn9TestCudaStream.test_parallel_tasks.<locals>.async_cuda_fn2   s     [[]F,,Q/1B1B11E5!HNN58Eu4 & 1 1 33K[1::< 4s   BB,B*&B,N)   r<         )r	   create_taskgatherr(   npallclose)r+   rO   	values_invtasks
values_outs   f     r   test_parallel_tasks"TestCudaStream.test_parallel_tasks0   sj     	  	  !	@IJ	1$$]1%56	J">>511
I:; K1s   B%A?BB1Bc                   "   \         P                  ! 4       p\        ^4       Uu. uF  q!P                  4       NK  	  pp\        P
                  ! V!  G Rj  xL
 pV F  pV P                  WQ4       K  	  R# u upi  L%5irS   N)r   r   ranger7   r	   rU   rI   )r+   r   _done_awsdoneds   &     r   test_multiple_async_done'TestCudaStream.test_multiple_async_doneA   s`     16q:A%%':^^X..AQ'  ;.s   #A>A7A>A<&A>c                <  "   \        ^4       Uu. uF  p\        P                  ! 4       NK  	  ppV Uu. uF  q3P                  4       NK  	  pp\        P
                  ! V!  G Rj  xL
 pV P                  \        V4      \        V4      4       R# u upi u upi  L45ir_   )r`   r   r   r7   r	   rU   assertSetEqualr   )r+   ra   streamsr   rb   rc   s   &     r   )test_multiple_async_done_multiple_streams8TestCudaStream.test_multiple_async_done_multiple_streamsI   st     */(3(Q4;;=(36=>gF%%'g>^^X.. 	CIs7|4 4>.s&   BBBBB%B&5Bc                *  "   \         P                  ! 4       pVP                  4       VP                  4       r2VP                  4        VG R j  xL
  V P	                  VP                  4       4       V P	                  VP                  4       4       R #  LD5ir   )r   r   r7   cancelr(   	cancelledrc   )r+   r   done1done2s   &   r   test_cancelled_future$TestCudaStream.test_cancelled_futureR   sc     ((*F,=,=,?u)*

% 	s   A
BBAB N)__name__
__module____qualname____firstlineno__r-   r4   r   r8   r\   re   rj   rq   __static_attributes____classdictcell____classdict__s   @r   r   r      ss     2	2 " " < <  ( ( 5 5 & &r   r   c                   N   a  ] tR t^\t o ]P
                  ]R 4       4       tRtV t	R# )TestFailingStreamc                  "   \         P                  ! 4       pVP                  R 4      pVP                  R4      p\         P                  ! 4       pVP                  RRVR7      P                  4        VP                  4       pV P                  \        4      ;_uu_ 4        VG Rj  xL
  RRR4       V P                  VP                  4       4       R#  L-  + '       g   i     L3; i5i)z
            .version 6.5
            .target sm_30
            .address_size 64
            .visible .entry failing_kernel() { trap; }
        failing_kernelrE   N)rQ   )r   current_contextcreate_module_ptxget_functionr   	configure__call__r7   assertRaises	ExceptionassertIsNotNone	exception)r+   ctxmoduler   r   rc   s   &     r   test_failed_stream$TestFailingStream.test_failed_streame   s      ""$&& (   ,,-=>  tF ;DDF  "y))JJ *T^^-.  *)s0   BC'C$C%C))C'CC$	C'rs   N)
rt   ru   rv   rw   r   skipr   r   rx   ry   rz   s   @r   r}   r}   \   s%      ]]/  /r   r}   __main__)r	   r   r%   numpyrV   numbar   numba.cuda.testingr   r   r   r   r   r}   rt   mainrs   r   r   <module>r      s         F F	 ?@C&\ C& AC&L ?@/ / A/8 zMMO r   