B H/\4@s0ddlmZdddddgZddd d d d gZee7Zd dddgZdddddddddddddddd d!d"d#gZd$d%d&d'd(d)d*d+d,g Zeedd-lZdd-l Z dd.l m Z dd/l mZmZmZdd0lmZe jd1kZe jd2kZer,dd3lmZdd4lmZdd5lmZdd6lmZdd7lmZ dd8l!m"Z#eZ$nTdd9lmZdd:lmZdd;lmZddlm Z dd?l%m#Z#ydd@lm&Z&Wne'k rdAZ&YnXefZ(erddBlm)Z)e(e)f7Z(dd-l*Z*e*j+Z,dd-l+Z-d-Z.Z/ee-e0edCdDZx>e-j1D]4Z.e2e-e.Z/e3e/eefre/e0e.<e4e.qW[.[/e5Z6ddEl7m8Z8e89e6e8j:Z;e8jZ>GdFdGdGe?Z@e@fdHd ZAdIdZBdJd ZCdYdKdZDereDjEZFdZdLdZDeFeD_E[FdMdNZGdOd ZHdPd ZId[dRd ZJe6fdSdTZKe-jLe-jMfdUdVZNe-jOfZPe-jQr$ePe-jRf7ZPdWdXZSd-S)\)absolute_importZcreate_connectionsocketZ SocketTypeZfromfdZ socketpair getaddrinfo gethostbynamegethostbyname_ex gethostbyaddr getnameinfogetfqdn cancel_wait wait_read wait_writewait_readwriteerrorZgaierrorZherrorZhtonlZhtonsZntohlZntohsZ inet_atonZ inet_ntoaZ inet_ptonZ inet_ntoptimeout gethostnameZgetprotobynameZ getservbynameZ getservbyportZgetdefaulttimeoutZsetdefaulttimeoutZerrorTab AddressFamily SocketKindZCMSG_LENZ CMSG_SPACEdupZif_indextonameZ if_nameindexZif_nametoindexZ sethostnameN)get_hub_noargs) string_types integer_typesPY3) copy_globalsZwin32darwin) WSAEINVAL)WSAEWOULDBLOCK)WSAEINPROGRESS) WSAEALREADY) WSAEISCONN) formatError)EINVAL) EWOULDBLOCK) EINPROGRESS)EALREADY)EAGAIN)EISCONN)strerror)EBADF ) EPROTOTYPET)Z only_namesZignore_missing_names)_hub_primitivescseZdZfddZZS)cancel_wait_excstt|tddS)Nz.File descriptor was closed in another greenlet)superr+__init__r')self) __class__3lib/python3.7/site-packages/gevent/_socketcommon.pyr-s zcancel_wait_ex.__init__)__name__ __module__ __qualname__r- __classcell__r0r0)r/r1r+sr+cCst||dS)z&See :meth:`gevent.hub.Hub.cancel_wait`N)get_hubr )Zwatcherrr0r0r1r scCstj|S)z gethostbyname(host) -> address Return the IP address (a string of the form '255.255.255.255') for a host. .. seealso:: :doc:`/dns` )r6resolverr)hostnamer0r0r1rscCstj|S)a< gethostbyname_ex(host) -> (name, aliaslist, addresslist) Return the true host name, a list of aliases, and a list of IP addresses, for a host. The host argument is a string giving a host name or IP number. Resolve host and port into list of address info entries. .. seealso:: :doc:`/dns` )r6r7r)r8r0r0r1rs cCstj||||||S)a Resolve host and port into list of address info entries. Translate the host/port argument into a sequence of 5-tuples that contain all the necessary arguments for creating a socket connected to that service. host is a domain name, a string representation of an IPv4/v6 address or None. port is a string service name such as 'http', a numeric port number or None. By passing None as the value of host and port, you can pass NULL to the underlying C API. The family, type and proto arguments can be optionally specified in order to narrow the list of addresses returned. Passing zero as a value for each of these arguments selects the full range of results. .. seealso:: :doc:`/dns` )r6r7r)hostportfamilysocktypeprotoflagsr0r0r1rscCs*tj||||||}dd|D}|S)NcSs0g|](\}}}}}t|tt|t|||fqSr0)_intenum_converterrr).0Zafr<r=Z canonnameZsar0r0r1 szgetaddrinfo..)r6r7r)r9r:r;typer=r>Zaddrlistresultr0r0r1rscCs"y||Stk r|SXdS)N) ValueError)valueZ enum_klassr0r0r1r?sr?cCstj|S)a gethostbyaddr(ip_address) -> (name, aliaslist, addresslist) Return the true host name, a list of aliases, and a list of IP addresses, for a host. The host argument is a string giving a host name or IP number. .. seealso:: :doc:`/dns` )r6r7r)Z ip_addressr0r0r1rs cCstj||S)z{ getnameinfo(sockaddr, flags) -> (host, port) Get host and port for a sockaddr. .. seealso:: :doc:`/dns` )r6r7r)Zsockaddrr>r0r0r1rscCs|}|r|dkrt}yt|\}}}Wntk r@Yn@X|d|x0|D]$}t|trnd|krxPqTd|krTPqTW|}|S)aGet fully qualified domain name from name. An empty argument is interpreted as meaning the local host. First the hostname returned by gethostbyaddr() is checked, then possibly existing aliases. In case no FQDN is available, hostname from gethostname() is returned. z0.0.0.0r..)striprrrinsert isinstancebytes)namer8aliases_r0r0r1r s     c Csd}t|}d}xl||kr|||d} |dkr@||| |7}q|rV|dkrV|dqd}||j| ||d7}|t}qW|S)a Send the complete contents of ``data_memory`` before returning. This is the core loop around :meth:`send`. :param timeleft: Either ``None`` if there is no timeout involved, or a float indicating the timeout to use. :param end: Either ``None`` if there is no timeout involved, or a float giving the absolute end time. :return: An updated value for ``timeleft`` (or None) :raises timeout: If ``timeleft`` was given and elapsed while sending this chunk. rNz timed out)r)lensendtime) r data_memoryr>timeleftendr data_sentlen_data_memoryZ started_timerchunkr0r0r1 __send_chunks     rZc Cst|}|sdSt|||d}d}d}d} |jdk rJ|j} t| }xB||krt|||} ||| } t|| || |} |t| 7}qLWdS)zw Send the *data_memory* (which should be a memoryview) using the gevent *socket*, performing well on PyPy. riN)rQmaxZ getsockoptrrSminrZ) rrTr> SOL_SOCKET SO_SNDBUFrXZ chunk_sizerWrVrUZ chunk_endrYr0r0r1_sendall?s#    r_cCsx|jtkst|ts|S|dd\}}t|d|j}|dd}t|dkr\|d|f}n|d||d|df}|S)Nr)r;_RESOLVABLE_FAMILIESrKtuplerrQ)ZsockZaddressr9r:rr0r0r1 _resolve_addr~s  rf)rrrr)rrrr)rF)TZ __future__rZ _implementsZ__dns__Z__extensions__Z __imports__Z__py3_imports__extendrSsysZgevent._hub_localrr6Zgevent._compatrrrZ gevent._utilrplatformZ is_windowsZis_macoserrnorr rr!rr"rr#rr%Zgevent.win32utilrr&r$osr' ImportErrorZ GSENDAGAINr)Z_socketrZ _realsocketZ __socket___nameZ_valueglobals__all__getattrrKappendrZ_timeout_errorZgeventr*Zset_default_timeout_errorZwait_on_watcherwaitr r r rr+r rrr__doc__dr?rrr rZr]r^r_ZAF_INETrcZhas_ipv6ZAF_INET6rfr0r0r0r1s                                  $9