Hi\ddlZddlZddlmZddlmZddlmZddlmZddlm Z ej dfdZ Gdd e ZGd d e Zej d d dfdZGddeZdZddZdZ ddlmZejZdS#e$r# ddlmZ ddZYdS#e$rdZYYdSwxYwwxYw)N) greenpool) greenthread)support)socket) greenletsctj|tj}||||||S)afConvenience function for opening client sockets. :param addr: Address of the server to connect to. For TCP sockets, this is a (host, port) tuple. :param family: Socket family, optional. See :mod:`socket` documentation for available families. :param bind: Local address to bind to, optional. :return: The connected green socket object. )r SOCK_STREAMbindconnect)addrfamilyr socks Y/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/eventlet/convenience.pyr r sD =!3 4 4D  $LL KceZdZdS)ReuseRandomPortWarningN__name__ __module__ __qualname__rrrrDrrceZdZdS)ReusePortUnavailableWarningNrrrrrrrrr2Tctj|tj}|rCtjdddkr+|tjtjd|tjtjfvr+|ddkr|rtj dtdn|d}|rttd rv |tjtj dnI#t$r<}tj|d vrtj d t"dYd}~nd}~wwxYw|||||S) aBConvenience function for opening server sockets. This socket can be used in :func:`~eventlet.serve` or a custom ``accept()`` loop. Sets SO_REUSEADDR on the socket to save on annoyance. :param addr: Address to listen on. For TCP sockets, this is a (host, port) tuple. :param family: Socket family, optional. See :mod:`socket` documentation for available families. :param backlog: The maximum number of queued connections. Should be at least 1; the maximum value is system-dependent. :return: The listening green socket object. Nwinrzlisten on random port (0) with SO_REUSEPORT is dangerous. Double check your intent. Example problem: https://github.com/eventlet/eventlet/issues/411) stacklevelT SO_REUSEPORT)\a socket.SO_REUSEPORT is defined but not supported. On Windows: known bug, wontfix. On other systems: please comment in the issue linked below. More information: https://github.com/eventlet/eventlet/issues/380)rr sysplatform setsockopt SOL_SOCKET SO_REUSEADDRAF_INETAF_INET6warningswarnrhasattrr!OSErrorr get_errnorr listen)r r backlog reuse_addr reuse_portrexs rr0r0"su =!3 4 4DCcl2A2&%// )6+>BBB &.&/222tAw!||  6 MT'1  6 6 6 6   ?gfn55? ? OOF-v/BA F F F F ? ? ? $$00 Y0A ???? ? IIdOOOKK Ks+C22 D8<2D33D8ceZdZdZdS) StopServezEException class used for quitting :func:`~eventlet.serve` gracefully.N)rrr__doc__rrrr6r6SsOODrr6c ||dS#|wxYw#tj$rYdSt$r't j|gtjRYdSwxYw)N) waitclosegreenlet GreenletExit Exceptionrkillr$exc_info)t server_gtconns r _stop_checkerrCXs5  FFHHH JJLLLLLDJJLLLL       5554S\^^44444445s&-AAAB,BBctj|}tj} |\}}||||}|t||d\}}}n#t$rYdSwxYwd)aRuns a server on the supplied socket. Calls the function *handle* in a separate greenthread for every incoming client connection. *handle* takes two arguments: the client socket object, and the client address:: def myhandle(client_sock, client_addr): print("client connected", client_addr) eventlet.serve(eventlet.listen(('127.0.0.1', 9999)), myhandle) Returning from *handle* closes the client socket. :func:`serve` blocks the calling greenthread; it won't return until the server completes. If you desire an immediate return, spawn a new greenthread for :func:`serve`. Any uncaught exceptions raised in *handle* are raised as exceptions from :func:`serve`, terminating the server, so be sure to be aware of the exceptions your application can raise. The return value of *handle* is ignored. Raise a :class:`~eventlet.StopServe` exception to gracefully terminate the server -- that's the only way to get the server() function to return rather than raise. The value in *concurrency* controls the maximum number of greenthreads that will be open at any time handling requests. When the server hits the concurrency limit, it stops accepting new connections until the existing ones complete. T)NNNN) r GreenPoolr getcurrentacceptspawnlinkrCr6)rhandle concurrencypoolrArBr gts rserverOds<  { + +D&((I JD$FD$//B GGM9d 3 3 3-ND$    FF  sAA;; B B c"t|g|Ri|S)axConvenience function for converting a regular socket into an SSL socket. Has the same interface as :func:`ssl.wrap_socket`, but can also use PyOpenSSL. Though, note that it ignores the `cert_reqs`, `ssl_version`, `ca_certs`, `do_handshake_on_connect`, and `suppress_ragged_eofs` arguments when using PyOpenSSL. The preferred idiom is to call wrap_ssl directly on the creation method, e.g., ``wrap_ssl(connect(addr))`` or ``wrap_ssl(listen(addr), server_side=True)``. This way there is no "naked" socket sitting around to accidentally corrupt the SSL session. :return Green SSL object. ) wrap_ssl_impl)rakws rwrap_sslrTs"  ( ( ( (R ( ((r)ssl)SSLFc `tjtj} || ||| || tjdtj| |} |r| n| | S)NcdS)NTr)xs rzwrap_ssl_impl..s4r) rVContext SSLv23_METHODuse_certificate_fileuse_privatekey_file set_verify VERIFY_NONE Connectionset_accept_stateset_connect_state) rkeyfilecertfile server_side cert_reqs ssl_versionca_certsdo_handshake_on_connectsuppress_ragged_eofscipherscontext connections rrQrQs k#"344G#,,X666"++G444   s @ @ @66J /++----,,... rc td)NzPTo use SSL with Eventlet, you must install PyOpenSSL or use Python 2.7 or later.) ImportError)rRrSs rrQrQsbdd dr)rD) NNFNNNTTN)r$r+eventletrrreventlet.greenreventlet.supportrr;r)r Warningrrr0r=r6rCrOrTrU wrap_socketrQrpeventlet.green.OpenSSLrVrrrrws4  !!!!!!222222 d         W        '   tPT....b        5 5 5((((V)))$""""""OMMM...... JOEI26=A        ddd d d d d d d dd s04 BB+ BB+B'"B+&B''B+