o h@s~ddlZddlZddlZddlmZddlmZdejdfddZddZ dd Z ej fd d Z d d Z dejdfddZdS)N)log)hide_thread_from_debuggerc Cs|dksJ|dur d}|durd}zEt}|dkr@tjdkr)|tjtjdnz |tjtjdWn tt fy?Ynw| ||f|durP| || |W|St yc|w)z9Return a local server socket listening on the given port.rNz 127.0.0.1win32) _new_socksysplatform setsockoptsocket SOL_SOCKETSO_EXCLUSIVEADDRUSE SO_REUSEADDRAttributeErrorOSErrorbind settimeoutlisten Exceptionclose)hostportbacklogtimeoutserverrLc:\Users\shubh\Videos\agent\nova\Lib\site-packages\debugpy/common/sockets.py create_server s0     rcCstS)zAReturn a client socket that may be connected to a remote address.)rrrrr create_client-src Csttjtjtj}z |tjtjdWn ttfy Ynwz |tjtj dWn ttfy7Ynwz |tjtj dWn ttfyNYnwz |tjtj dW|SttfygY|Sw)Nr) r AF_INET SOCK_STREAM IPPROTO_TCPr r SO_KEEPALIVErr TCP_KEEPIDLE TCP_KEEPINTVL TCP_KEEPCNTsockrrrr2s.rcCs||dS)zShut down the given socket.N)shutdown)r(howrrr shut_downLsr+cCs,zt|Wn tyYnw|dS)zShutdown and close the socket.N)r+rrr'rrr close_socketQs    r,c s|dksJz t||||Wnty td||Ynw\}}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 sL z \}\}}Wn ttjfyYdSwtd|||q)NTz.Accepted incoming {0} connection from {1}:{2}.)acceptrr errorrinfo)r(Z other_hostZ other_porthandlerlistenernamerr accept_workerlszserve..accept_worker)targetT) rrrZreraise_exception getsocknamer/ threadingThreaddaemonrstart)r3r1rrrrr4threadrr0rserveZs    r<)r rr7Zdebugpy.commonrZdebugpy.common.utilr SOMAXCONNrrr SHUT_RDWRr+r,r<rrrrs