o NDi9@sddlZddlmZddlmZddlZddlZddlZddlZddl m Z m Z m Z ddl Z ddlZddlZddlZzddlmZWneyQddlmZYnwddlmZzddlZWn eyiedwddlmZmZmZmZmZeeZia d d Z!Gd d d eZ"Gd dde#Z$Gdddej%Z&Gddde&Z'Gddde&Z(Gddde#Z)Gddde#Z*da+e,ee!t+Gdddeej%Z-dS)N)deque)partial)LockThreadEvent)WeakSet)DependencyExceptionzUnable to import asyncore module. Note that this module has been removed in Python 3.12 so when using the driver with this version (or anything newer) you will need to use one of the other event loop implementations.) ConnectionConnectionShutdown NONBLOCKINGTimer TimerManagercCs|r|dSdSN)_cleanup)looprU/var/www/Datamplify/venv/lib/python3.10/site-packages/cassandra/io/asyncorereactor.pyr1s rc@s&eZdZddZddZdddZdS) WaitableTimercCs&t|||||_t|_d|_dSr)r __init__callbackreventfinal_exception)selftimeoutrrrrr7s zWaitableTimer.__init__c Cs^zt||}|r|jWdSWdSty.}z||_|jWYd}~dSd}~ww)NTF)r finishrset Exceptionr)rtime_nowfinishederrrr>s   zWaitableTimer.finishNcCs|j||jr |jdSr)rwaitrrrrrrr Ks zWaitableTimer.waitr)__name__ __module__ __qualname__rrr rrrrr6s rc@s.eZdZddZddZddZd dd ZdS) _PipeWrappercCs ||_dSrfd)rr'rrrrSs z_PipeWrapper.__init__cC|jSrr&rrrrfilenoVz_PipeWrapper.filenocCst|jdSr)oscloser'r)rrrr-Ysz_PipeWrapper.closeNcCs"|tjkr|tjkr|sdStNr)socket SOL_SOCKETSO_ERRORNotImplementedError)rleveloptnamebuflenrrr getsockopt\sz_PipeWrapper.getsockoptr)r"r#r$rr*r-r6rrrrr%Qs r%c@,eZdZddZddZddZddZd S) _AsyncoreDispatchercCs$tjj|td||d|_dS)N)mapF)asyncore dispatcherr_dispatcher_map set_socket _notified)rr/rrrres  z_AsyncoreDispatcher.__init__cCdSNFrr)rrrwritablekz_AsyncoreDispatcher.writablecCs4|jrJ||jsJ|d|jrJdS)N皙?)r> notify_looprr)rrrvalidatens   z_AsyncoreDispatcher.validatecCtj|dtdddS)NTruse_pollr9countr:rr<r!rrrruz_AsyncoreDispatcher.loopN)r"r#r$rrArErrrrrr8cs  r8c@r7) _AsyncorePipeDispatchercCs&t\|_|_t|t|jdSr)r,piperead_fdwrite_fdr8rr%r)rrrr{sz _AsyncorePipeDispatcher.__init__cCr?r@rr)rrrrArBz _AsyncorePipeDispatcher.writablecCs8tt|jddkr tt|jddks d|_dS)NiF)lenr,readrOr>r)rrr handle_reads z#_AsyncorePipeDispatcher.handle_readcCs"|jsd|_t|jddSdS)NTx)r>r,writerPr)rrrrDsz#_AsyncorePipeDispatcher.notify_loopN)r"r#r$rrArSrDrrrrrMys  rMc@s4eZdZdZdZddZddZddZd d Zd S) _AsyncoreUDPDispatchera Experimental alternate dispatcher for avoiding busy wait in the asyncore loop. It is not used by default because it relies on local port binding. Port scanning is not implemented, so multiple clients on one host will collide. This address would need to be set per instance, or this could be specialized to scan until an address is found. To use:: from cassandra.io.asyncorereactor import _AsyncoreUDPDispatcher, AsyncoreLoop AsyncoreLoop._loop_dispatch_class = _AsyncoreUDPDispatcher ) localhosti'cCs>ttjtj|_|j|j|jdt||jdSr.) r/AF_INET SOCK_DGRAM_socketbind bind_address setblockingr8rr)rrrrs z_AsyncoreUDPDispatcher.__init__c Csfz|jd}|r|dr|jd}|r|ds Wntjy-}zWYd}~nd}~wwd|_dS)NrGF)rZrecvfromr/errorr>)rdrrrrrSs      z"_AsyncoreUDPDispatcher.handle_readcCs$|jsd|_|jd|jdSdS)NT)r>rZsendtor\r)rrrrDsz"_AsyncoreUDPDispatcher.notify_loopcCrF)NFrGrHrKr!rrrrrLz_AsyncoreUDPDispatcher.loopN) r"r#r$__doc__r\rrSrDrrrrrrVs  rVc@s2eZdZdZ ddZddZddZdd Zd S) _BusyWaitDispatchergMbP?cCdSrrr)rrrrDrBz_BusyWaitDispatcher.notify_loopcCs0tstd||j}tj|jdt|ddS)Ng{Gzt?TrH)r<timesleepmax_write_latencyr:r)rrrJrrrrs  z_BusyWaitDispatcher.loopcCrerrr)rrrrErBz_BusyWaitDispatcher.validatecCrerrr)rrrr-rBz_BusyWaitDispatcher.closeN)r"r#r$rhrDrrEr-rrrrrds rdc@sZeZdZdZejdkr eneZddZ ddZ ddZ d d Z d d Z d dZddZdS) AsyncoreLooprCntcCst|_t|_d|_d|_d|_t|_ z| }| t d|j Wnty>t d|j |t}Ynw||_dS)NFzValidated loop dispatch with %szKFailed validating loop dispatch with %s. Using busy wait execution instead.)r,getpid_pidr _loop_lock_started _shutdown_threadr _timers_loop_dispatch_classrElogdebugr exceptionr-rd_loop_dispatcher)rr;rrrrs    zAsyncoreLoop.__init__cCs|d}d}z|jd}|r|jsd|_d}W|r|jn |r&|jww|rWYd}~dSn,||WYd}~dS|j dtvr_|j s^WYd}~dSn ||WYd}~dSWYd}~nd}~ww|j r||js|jsd|_dSdSdSdS)NTrF)recvin_buffer_size_iobufrUrQr/r_ isinstancerSSLErrorrrrtellrr process_io_buffer _requestsis_control_connectionr)rbufrrrrrSs<          zAsyncoreConnection.handle_readcCs|j}t||kr"g}tdt||D] }|||||qn|g}|j|j|d|_Wdn1ssN       'h