g ddlZddlZddlZddlZddlZddlZddlZddgZGddeZ dej ddfdd d d d d de dffdZ dS)Nfind_available_port SocketFactoryceZdZdZejZejZejZ de fdZ e e je je je jffde fdZededffdZdejdejfdZdd Z d ddZdZdS)rz Object used to create a socket and connect it. This is, more or less, a specialized partial() for socket creation. Additionally, it provides methods and attributes for abstracting exception management on socket operation. returnc|j|juSN) __class__timeout_exception)selferrs N/granary/edev/quantum/lib/python3.11/site-packages/postgresql/python/socket.py timed_outzSocketFactory.timed_outs $0 00c4t|dd}|dS||vS)zz Does the error indicate that the operation should be tried again? More importantly, the connection is *not* dead. errnoNF)getattr)r codesrs r try_againzSocketFactory.try_agains) #w % %% ] % %rNcR||rdSt|ddS)z_ If the exception was fatal to the connection, what message should be given to the user? Nstrerrorz)rr)typr s r fatal_exception_messagez%SocketFactory.fatal_exception_message+s0  ]]3 $ j": ; ;;rsocketcf|jtj|fi|jStj|S)zsecure a socket with SSL) socket_securessl wrap_socket)r rs r securezSocketFactory.secure5s6 # /& 7 7D$6 7 77 /& ! !!rc tj|j} ||t|nd||j|dn##t $r|wxYw|Sr)r socket_create settimeoutfloatconnectsocket_connect Exceptionclose)r timeoutss r __call__zSocketFactory.__call__<s mT'(! <<'"5g4@@@99T !!!<<    77999  (s AA++ B r .positional parameters given to socket.socket()r$#parameter given to socket.connect()r!keywords given to ssl.wrap_socketc0||_||_||_dSr)r r$r)r r r$rs r __init__zSocketFactory.__init__Gs" %$&$$$rc0dt|jzS)Nr)reprr$)r s r __str__zSocketFactory.__str__Ps D,-- --rr)r r*r$r+rr,)__name__ __module__ __qualname____doc__rr'r errorfatal_exceptiontry_again_exceptionboolr staticmethodrEAGAINEINTR EWOULDBLOCK ETIMEDOUTr classmethodstrrr SSLSocketrr)r.r1rr rrs;^<|1T1111"\5;8I5?[  `d   , <3+<<<+<"6="S]""""     9=%B%8%6%%%%.....r localhosti)ii interfacezattempt to bind to interfaceaddress_familyz(address family to use (default: AF_INET)limitz%Number tries to make before giving uprcd}||kr|dz }tjtj|d|dz z|dz}tj|tj} |d|f|n_#tj$rM}||jtj tj tj fvrYd}~Yd}~nd}~wwxYwnd}|S)z Find an available port on the given interface for the given address family. Returns a port number that was successfully bound to or `None` if the attempt limit was reached. rrCN) mathfloorrandomr SOCK_STREAMbindr&r6rEACCES EADDRINUSEr<)rDrErF port_rangeiportr(es r rrSs 5yyq&!: MOOz!}z!}45!}  mNF$688! 66; 779999    77999g%, 0%+>>> HHHH?>>>>  $ s.+BC6)>C11C6) sysosrKrrIrr__all__objectrAF_INETintrrBrr rZs / 2C.C.C.C.C.FC.C.C.L/:?E~37 ! ! +! <!  1!  4[ ! ! ! ! ! ! r