Ag|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 H/var/www/openai/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]] _},,.$)DIIK$7 $q="("5"5"77 OO000C_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._update9s __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.cancelLs __=="& ))$,,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.runningbs) __&Ac|j5|js1|js%|jj |j dddy#1swYyxYwr.)r rrr r"r#r/s r__del__z_ChannelReadyFuture.__del__s6 __??4== ))$,,7__s >AAr.)__name__ __module__ __qualname__rrr#r,r0r3r5r9r<r>rBrFrHrrrrsE"D$&$#=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,=% g8&--g8Tr