`i \ddlZGddZGddZGddZdS)Nc*eZdZdZdZdZdZdZdS)Proxyz` Class for wrapping a shared resource object and getting notified when it's deleted c J||_|dd|_dS)N on_delete)objectgetr)selfrkwargss m/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/supervisor/socket_manager.py__init__zProxy.__init__s" K66c@|jr|dSdSNrr s r __del__z Proxy.__del__ s, >  NN       r c,t|j|Sr)getattrr)r names r __getattr__zProxy.__getattr__st{D)))r c|jSr)rrs r _getz Proxy._gets {r N)__name__ __module__ __qualname____doc__r rrrr r rrsZ777***r rc*eZdZdZdZdZdZdZdS)ReferenceCounterz8 Class for tracking references to a shared resource c H|d|_|d|_d|_dS)N on_non_zeroon_zeror)r!r" ref_count)r r s r r zReferenceCounter.__init__s&!-0i( r c|jSr)r#rs r get_countzReferenceCounter.get_counts ~r cd|jdkr||xjdz c_dS)Nr)r#r!rs r incrementzReferenceCounter.increment"s5 >Q         !r c|jdkrtd|xjdzc_|jdkr|dSdS)Nrz.Illegal operation: cannot decrement below zeror')r# Exceptionr"rs r decrementzReferenceCounter.decrement'sT >Q  LMM M ! >Q   LLNNNNN  r N)rrrrr r%r(r+rr r rrsZ  r rcHeZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) SocketManagera Class for managing sockets in servers that create/bind/listen before forking multiple child processes to accept() Sockets are managed at the process group level and referenced counted at the process level b/c that's really the only place to hook in c |dd|_d|_d|_||_t |j|j|_dS)NloggerF)r"r!) rr/socketprepared socket_configr_close_prepare_socketref_ctr)r r2r s r r zSocketManager.__init__5sQjj400   *'KT-A r cRd|jdt|d|jjdS)N) __class__idr2urlrs r __repr__zSocketManager.__repr__>s3&*nnn&(hhhh&*&8&<&<&<> >r c|jSr)r2rs r configzSocketManager.configCs !!r c|jSr)r1rs r is_preparedzSocketManager.is_preparedFs }r c|j|t|j|jjS)Nr)r5r(_require_preparedrr0r+rs r get_socketzSocketManager.get_socketIsB        T[DL,BCCCCr c\||jSr)rBr5r%rs r get_socket_ref_countz"SocketManager.get_socket_ref_countNs(    |%%'''r c2|jstddS)NzSocket has not been prepared)r1r*rs r rBzSocketManager._require_preparedRs%} <:;; ; < >DK!--// 5 ""4#5#A#A#C#CDDDD ""6#3444 DMMM ! !r c||jr"|jd|jz|jd|_dS)NzClosing socket %sF)rBr/rHr2r0closer1rs r r3zSocketManager._closeas]    ; G K  043EE F F F  r N) rrrrr r<r>r@rCrErBr4r3rr r r-r-.s >>> """DDD (((<<< ! ! !r r-)r0rrr-rr r rOs &08888888888r