U ‡ª/e€ã@s~ddlZddlZddlZddlmZddlmZdejdfdd„Zdd„Z dd „Z ej fd d „Z d d „Z dejdfdd„ZdS)éN)Úlog)Úhide_thread_from_debuggerc CsÒ|dks t‚|dkrd}|dkr$d}zŠtƒ}|dkr‚tjdkrR| tjtjd¡n0z| tjtjd¡Wnt t fk r€YnX|  ||f¡|dk r¢|  |¡|  |¡Wntk rÌ| ¡‚YnX|S)z9Return a local server socket listening on the given port.rNz 127.0.0.1Úwin32é)ÚAssertionErrorÚ _new_sockÚsysÚplatformÚ setsockoptÚsocketÚ SOL_SOCKETZSO_EXCLUSIVEADDRUSEÚ SO_REUSEADDRÚAttributeErrorÚOSErrorÚbindÚ settimeoutÚlistenÚ ExceptionÚclose)ÚhostÚportÚbacklogÚtimeoutÚserver©rú:/tmp/pip-unpacked-wheel-dg3irmqq/debugpy/common/sockets.pyÚ create_server s,   rcCstƒS)zAReturn a client socket that may be connected to a remote address.)rrrrrÚ create_client-src CsØt tjtjtj¡}z| tjtjd¡Wnttfk rBYnXz| tjtj d¡Wnttfk rrYnXz| tjtj d¡Wnttfk r¢YnXz| tjtj d¡Wnttfk rÒYnX|S)Nréé) r ÚAF_INETÚ SOCK_STREAMÚ IPPROTO_TCPr r Ú SO_KEEPALIVErrÚ TCP_KEEPIDLEÚ TCP_KEEPINTVLÚ TCP_KEEPCNT©Úsockrrrr2s$rcCs| |¡dS)zShut down the given socket.N)Úshutdown)r(ÚhowrrrÚ shut_downLsr+cCs.z t|ƒWntk r YnX| ¡dS)zShutdown and close the socket.N)r+rrr'rrrÚ close_socketQs  r,c s–|dks t‚zt||||ƒ‰Wn$tk rBt dˆ||¡YnXˆ ¡\}}t dˆ||¡‡‡‡fdd„}tj|d}d|_ t |ƒ|  ¡ˆS)z¬Accepts TCP connections on the specified host and port, and invokes the provided handler function for every new connection. Returns the created server socket. rz8Error listening for incoming {0} connections on {1}:{2}:z4Listening for incoming {0} connections on {1}:{2}...c sRzˆ ¡\}\}}Wnttjfk r2YqNYnXt dˆ||¡ˆ|ƒqdS)Nz.Accepted incoming {0} connection from {1}:{2}.)Úacceptrr ÚerrorrÚinfo)r(Z other_hostZ other_port©ÚhandlerZlistenerÚnamerrÚ accept_workerls üzserve..accept_worker)ÚtargetT) rrrrZreraise_exceptionÚ getsocknamer/Ú threadingÚThreadÚdaemonrÚstart)r2r1rrrrr3Úthreadrr0rÚserveZs$ ÿ   r;)r rr6Zdebugpy.commonrZdebugpy.common.utilrÚ SOMAXCONNrrrÚ SHUT_RDWRr+r,r;rrrrÚs