o ^i@sddlZddlZddlZddlmZddlmZddZddZdd Z d d Z dej dfd d Z dddZ dddZejfddZddZdej dfddZdS)N)log)hide_thread_from_debuggerc CXzttjtj}|tjtjd|d|WdStjt t fy+YdSw)z'Check if we can bind to IPv4 localhost.) 127.0.0.1rTF) socketAF_INET SOCK_STREAM setsockopt SOL_SOCKET SO_REUSEADDRbindcloseerrorOSErrorAttributeErrorsockrQ/home/ubuntu/hpml_nyu/venv/lib/python3.10/site-packages/debugpy/common/sockets.pycan_bind_ipv4_localhost  rc Cr)z'Check if we can bind to IPv6 localhost.r)::1rTF) rAF_INET6r r r r r rrrrrrrrcan_bind_ipv6_localhostrrcCstrdStr dSdS)z~Get the default localhost address. Defaults to IPv4 '127.0.0.1', but falls back to IPv6 '::1' if IPv4 is unavailable. rr)rrrrrrget_default_localhost$s rc CsRz|dd\}}W||fSty(}z tdtd||d}~ww)z&Gets the socket address host and port.NzFailed to get socket address:zFailed to get socket address: ) getsockname Exceptionrswallow_exception RuntimeError)rhostportexcrrr get_address4s r$c Cs|dksJ|dur t}|durd}|ddk}zFt|}|dkrItjdkr2|tjtjdnz |tjtj dWn t t fyHYnw| ||f|durY| |||W|Styl|w)z9Return a local server socket listening on the given port.rN:rwin32)rcount _new_socksysplatformr rr SO_EXCLUSIVEADDRUSEr rrr settimeoutlistenrr)r!r"backlogtimeoutipv6serverrrr create_server>s2     r2FcCst|S)zAReturn a client socket that may be connected to a remote address.)r()r0rrr create_client_sr3c Cs|rtjntj}t|tjtj}z |tjtjdWn tt fy'Ynwz |tjtj dWn tt fy>Ynwz |tjtj dWn tt fyUYnwz |tjtj dW|Stt fynY|Sw)Nr) rrrr IPPROTO_TCPr r SO_KEEPALIVErr TCP_KEEPIDLE TCP_KEEPINTVL TCP_KEEPCNT)r0address_familyrrrrr(ds0r(cCs||dS)zShut down the given socket.N)shutdown)rhowrrr shut_downsr>cCs,zt|Wn tyYnw|dS)zShutdown and close the socket.N)r>rrrrrr close_sockets    r?c s|dksJz t||||Wnty td||Ynwt\}}td||fdd}tj|d}d|_t || S)zAccepts 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 sX z\}}|dd\}}Wn ttjfyYdSwtd|||q)NTrz.Accepted incoming {0} connection from {1}:{2}.)acceptrrrrinfo)raddress other_host other_porthandlerlistenernamerr accept_workers zserve..accept_worker)targetT) r2rrreraise_exceptionr$rA threadingThreaddaemonrstart)rHrFr!r"r.r/rIthreadrrErserves    rQ)F)rr)rLdebugpy.commonrdebugpy.common.utilrrrrr$ SOMAXCONNr2r3r( SHUT_RDWRr>r?rQrrrrs     !