iF \ dZddlZddlZddlmZmZmZmZmZddl Z ddl m Z ddl m Z ddl mZejeZe j$j&e j(j*e j$j,e j(j.e j$j0e j(j2e j$j4e j(j6e j$j8e j(j:iZie j>j@e j>jBe j>jDe j>jFe j>jHe j>jJe j>jLe j>jNe j>jPe j>jRe j>jTe j>jVe j>jXe j>jZe j>j\e j>j^e j>j`e j>jbe j>jde j>jfe j>jhe j>jje j>jle j>jne j>jpe j>jre j>jte j>jve j>jxe j>jze j>j|e j>j~e j>je j>jZBeBjDcic]\}}|| c}}ZDdZEdZFd ed eGfd ZHd ed eIfd ZJdedeee dfdeId efdZKdedeed eGfdZLdeGdee d efdZMdeIdeId eIfdZNdedeOfdePdeegdffdZQ d$dedeOfdegeOfdeePdeegdfd eOf d ZRd!eId"eSd eSfd#ZTycc}}w)%zShared implementation.N)AnyAnyStrCallableOptionalUnion)cygrpc)DeserializingFunction)SerializingFunctiong?zjFailed to bind to address %s; set GRPC_VERBOSITY=debug environment variable to see detailed error message.sreturncHt|tr|S|jdS)Nutf8) isinstancebytesencode)r s a/Volumes/fast/ai/experiments/voice-extract-mac/.venv/lib/python3.12/site-packages/grpc/_common.pyrrCs !U 88F bcJt|tr|jddS|S)Nzutf-8replace)rrdecode)rs rrrIs"!Uxx++ Hrmessage transformerexception_messagecd||S ||S#t$rtj|YywxYw)N) Exception_LOGGER exception)rrrs r _transformrOs@ 7## +,s // serializerct||dS)NzException serializing message!r)rr s r serializer#]s gz+K LLrserialized_message deserializerct||dS)Nz Exception deserializing message!r")r$r%s r deserializer'as L*L rgroupmethodc&dj||S)Nz/{}/{})format)r(r)s rfully_qualified_methodr,is ??5& ))rwait_fn.timeoutspin_cbc*||||yy)N)r.)r-r.r/s r _wait_oncer2ms  G rwait_complete_fnc|!|st|t||sytj|z}|s@t|tjz t}|dkryt||||s@y)adBlocks waiting for an event without blocking the thread indefinitely. See https://github.com/grpc/grpc/issues/19464 for full context. CPython's `threading.Event.wait` and `threading.Condition.wait` methods, if invoked without a timeout kwarg, may block the calling thread indefinitely. If the call is made from the main thread, this means that signal handlers may not run for an arbitrarily long period of time. This wrapper calls the supplied wait function with an arbitrary short timeout to ensure that no signal handler has to wait longer than MAXIMUM_WAIT_TIMEOUT before executing. Args: wait_fn: A callable acceptable a single float-valued kwarg named `timeout`. This function is expected to be one of `threading.Event.wait` or `threading.Condition.wait`. wait_complete_fn: A callable taking no arguments and returning a bool. When this function returns true, it indicates that waiting should cease. timeout: An optional float-valued number of seconds after which the wait should cease. spin_cb: An optional Callable taking no arguments and returning nothing. This callback will be called on each iteration of the spin. This may be used for, e.g. work related to forking. Returns: True if a timeout was supplied and it was reached. False otherwise. rTF)r2MAXIMUM_WAIT_TIMEOUTtimemin)r-r3r.r/end remainings rwaitr:ws}B"$ w 4g >#$  iikG#"$C$))+-/CDI1} w 7 3 #$ raddressportc4|dk(rtt|z|S)akValidates if the port binding succeed. If the port returned by Core is 0, the binding is failed. However, in that case, the Core API doesn't return a detailed failing reason. The best we can do is raising an exception to prevent further confusion. Args: address: The address string to be bound. port: An int returned by core r) RuntimeError"_ERROR_MESSAGE_PORT_BINDING_FAILED)r;r<s rvalidate_port_binding_resultr@s# qy=GHH Kr)NN)U__doc__loggingr6typingrrrrrgrpc grpc._cythonr grpc._typingr r getLogger__name__rConnectivityStateidleChannelConnectivityIDLE connecting CONNECTINGreadyREADYtransient_failureTRANSIENT_FAILUREshutdownSHUTDOWN1CYGRPC_CONNECTIVITY_STATE_TO_CHANNEL_CONNECTIVITY StatusCodeokOK cancelled CANCELLEDunknownUNKNOWNinvalid_argumentINVALID_ARGUMENTdeadline_exceededDEADLINE_EXCEEDED not_found NOT_FOUNDalready_existsALREADY_EXISTSpermission_deniedPERMISSION_DENIEDunauthenticatedUNAUTHENTICATEDresource_exhaustedRESOURCE_EXHAUSTEDfailed_preconditionFAILED_PRECONDITIONabortedABORTED out_of_range OUT_OF_RANGE unimplemented UNIMPLEMENTEDinternalINTERNAL unavailable UNAVAILABLE data_loss DATA_LOSS!CYGRPC_STATUS_CODE_TO_STATUS_CODEitems!STATUS_CODE_TO_CYGRPC_STATUS_CODEr5r?rrstrrrr#r'r,boolfloatr2r:intr@) cygrpc_code grpc_codes00rrs 99 ., '  H % !!4#;#;#@#@ '')A)A)L)L ""D$<$<$B$B ..0H0H0Z0Z %%t'?'?'H'H 51% $//,,% !:!:% t66% &&(H(H %  '')J)J %  !:!: % $$doo&D&D% '')J)J% %%t'F'F% (($//*L*L% ))4??+N+N% t66% ""DOO$@$@% ##T__%B%B%  8 8%  !!4??#>#>!%" !:!:#%!*#D"I"I"K%"K Y{"K%! O# f  f    *,A4GH   MsM1D(EM%M-56K-L*#*s*s* c4i  hr4x( ) $,0 + c4i +r4x(+e_+hr4x( ) +  +\#SS_%s R(