mxi|dZddlZddlZddlmZddlmZddlmZddlmZdZ Gdd ejZ d Z y) z'Utilities for the gRPC Python Beta API.N)implementations) interfaces) callable_util)futurez6Exception calling connectivity future "done" callback!c`eZdZdZdZdZdZdZdZdZ dd Z dd Z dd Z d Z d ZdZy)_ChannelReadyFuturecntj|_||_d|_d|_g|_y)NF) threading Condition _condition_channel_matured _cancelled_done_callbacks)selfchannels J/home/htdocs/ttos/venv/lib/python3.12/site-packages/grpc/beta/utilities.py__init__z_ChannelReadyFuture.__init__s/#--/  !c|dntj|z}|j5 |jrtj|j r dddy||jj nL|tjz }|dkrtj|jj |#1swYyxYw)Nr)timeout)timer rrCancelledErrorrwait TimeoutError)rruntil remainings r_blockz_ChannelReadyFuture._block'sTYY[7-B __ @?? //11]] @ @ ]OO((* % 3I 1}$1133,,Y,? @ @s/C  A*C  Cc|j5|js|tjjurcd|_|j j|j|jjt|j}d|_ n dddy dddD]}tj|t|y#1swY,xYw)NT)r rrChannelConnectivityREADYrr unsubscribe_update notify_alltuplerrcall_logging_exceptions$_DONE_CALLBACK_EXCEPTION_LOG_MESSAGE)r connectivitydone_callbacks done_callbacks rr#z_ChannelReadyFuture._update8s __ OO J$B$B$H$HH $  ))$,,7**,!&t';';!<'+$  % , M  1 1CT    s B CCc~|j5|jscd|_|jj |j |jj t|j}d|_n dddy dddD]}tj|t|y#1swY,xYw)NTF) r rrr r"r#r$r%rrr&r')rr)r*s rcancelz_ChannelReadyFuture.cancelKs __ =="& ))$,,7**,!&t';';!<'+$   %  , M  1 1CT     s A1B33B<c^|j5|jcdddS#1swYyxYwN)r rrs r cancelledz_ChannelReadyFuture.cancelled]s% __ #?? # # #s #,c~|j5|j xr |j cdddS#1swYyxYwr.r rrr/s rrunningz_ChannelReadyFuture.runningas4 __ =&Ac|j5|js1|js%|jj |j dddy#1swYyxYwr.)r rrr r"r#r/s r__del__z_ChannelReadyFuture.__del__~sA __ 8??4== ))$,,7 8 8 8s >AAr.)__name__ __module__ __qualname__rrr#r,r0r3r5r9r<r>rBrFrHrrrrsE"@"&$#=4G8rrc<t|}|j|S)a&Creates a future.Future tracking when an implementations.Channel is ready. Cancelling the returned future.Future does not tell the given implementations.Channel to abandon attempts it may have been making to connect; cancelling merely deactivates the return future.Future's subscription to the given implementations.Channel's connectivity. Args: channel: An implementations.Channel. Returns: A future.Future that matures when the given Channel has connectivity interfaces.ChannelConnectivity.READY. )rrF)r ready_futures rchannel_ready_futurerOs 'w/L r) __doc__r r grpc.betarrgrpc.framework.foundationrrr'FuturerrOrLrrrTs@. & 3,=% c8&--c8Lr