ó ÐH/\c@@sXddlmZdddddgZddd d d d gZee7Zd dddgZdddddddddddddddd d!d"d#gZd$d%d&d'd(d)d*d+d,g Zejeƒdd-lZdd-l Z dd.l m Z dd/l mZmZmZdd0lmZe jd1kZe jd2kZer§dd3lmZdd4lmZdd5lmZdd6lmZdd7lmZ dd8l!m"Z#eZ$npdd9lmZdd:lmZdd;lmZdd<lmZdd=lm$Z$dd>lm Z dd?l%m#Z#ydd@lm&Z&Wne'k rDdAZ&nXefZ(ertddBlm)Z)e(e)f7Z(ndd-l*Z*e*j+Z,dd-l+Z-d-Z/Z0ee-e1ƒdCedDe2ƒZxRe-j3D]GZ/e4e-e/ƒZ0e5e0eefƒrÇe0e1ƒe/Z>e:j?Z?e:j@Z@dFeAfdG„ƒYZBeBdH„ZCdI„ZDdJ„ZEdddddK„ZFeräeFjGZHdddddL„ZFeHeF_G[HdM„ZIndN„ZJdO„ZKdPdQ„ZLe8dR„ZMe-jNe-jOdS„ZPe-jQfZRe-jSrKeRe-jTf7ZRndT„ZUd-S(Ui(tabsolute_importtcreate_connectiontsockett SocketTypetfromfdt socketpairt getaddrinfot gethostbynametgethostbyname_ext gethostbyaddrt getnameinfotgetfqdnt cancel_waitt wait_readt wait_writetwait_readwriteterrortgaierrortherrorthtonlthtonstntohltntohst inet_atont inet_ntoat inet_ptont inet_ntopttimeoutt gethostnametgetprotobynamet getservbynamet getservbyporttgetdefaulttimeouttsetdefaulttimeoutterrorTabt AddressFamilyt SocketKindtCMSG_LENt CMSG_SPACEtduptif_indextonamet if_nameindextif_nametoindext sethostnameN(tget_hub_noargs(t string_typest integer_typestPY3(t copy_globalstwin32tdarwin(t WSAEINVAL(tWSAEWOULDBLOCK(tWSAEINPROGRESS(t WSAEALREADY(t WSAEISCONN(t formatError(tEINVAL(t EWOULDBLOCK(t EINPROGRESS(tEALREADY(tEAGAIN(tEISCONN(tstrerror(tEBADFi (t EPROTOTYPEt only_namestignore_missing_names(t_hub_primitivestcancel_wait_excB@seZd„ZRS(cC@stt|ƒjtdƒdS(Ns.File descriptor was closed in another greenlet(tsuperREt__init__R@(tself((s3lib/python2.7/site-packages/gevent/_socketcommon.pyRGs(t__name__t __module__RG(((s3lib/python2.7/site-packages/gevent/_socketcommon.pyREscC@stƒj||ƒdS(s&See :meth:`gevent.hub.Hub.cancel_wait`N(tget_hubR (twatcherR((s3lib/python2.7/site-packages/gevent/_socketcommon.pyR –scC@stƒjj|ƒS(s– gethostbyname(host) -> address Return the IP address (a string of the form '255.255.255.255') for a host. .. seealso:: :doc:`/dns` (RKtresolverR(thostname((s3lib/python2.7/site-packages/gevent/_socketcommon.pyR›scC@stƒjj|ƒS(s< 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` (RKRMR(RN((s3lib/python2.7/site-packages/gevent/_socketcommon.pyR¦s cC@s"tƒjj||||||ƒS(sÝ 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` (RKRMR(thosttporttfamilytsocktypetprototflags((s3lib/python2.7/site-packages/gevent/_socketcommon.pyR³sc C@sqtƒjj||||||ƒ}g|D]<\}}}} } t|tƒt|tƒ|| | f^q+} | S(N(RKRMRt_intenum_converterR#R$( RORPRQttypeRSRTtaddrlisttafRRt canonnametsatresult((s3lib/python2.7/site-packages/gevent/_socketcommon.pyRÏs$FcC@s'y||ƒSWntk r"|SXdS(N(t ValueError(tvaluet enum_klass((s3lib/python2.7/site-packages/gevent/_socketcommon.pyRUás cC@stƒjj|ƒS(s 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` (RKRMR (t ip_address((s3lib/python2.7/site-packages/gevent/_socketcommon.pyR ès cC@stƒjj||ƒS(s{ getnameinfo(sockaddr, flags) -> (host, port) Get host and port for a sockaddr. .. seealso:: :doc:`/dns` (RKRMR (tsockaddrRT((s3lib/python2.7/site-packages/gevent/_socketcommon.pyR ôstcC@sµ|jƒ}| s|dkr+tƒ}nyt|ƒ\}}}Wntk rWnZX|jd|ƒxF|D]8}t|tƒr—d|kr§Pq§qod|kroPqoqoW|}|S(sGet 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. s0.0.0.0it.(tstripRR Rtinsertt isinstancetbytes(tnameRNtaliasest_((s3lib/python2.7/site-packages/gevent/_socketcommon.pyR ÿs      c C@s±d}t|ƒ}d}x’||kr¬||} |dkrV||j| |ƒ7}q|rw|dkrw|dƒ‚qd}||j| |d|ƒ7}|tjƒ}qW|S(sö 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. is timed outiRN(tlentNonetsendttime( Rt data_memoryRTttimelefttendRt data_senttlen_data_memoryt started_timertchunk((s3lib/python2.7/site-packages/gevent/_socketcommon.pyt __send_chunks    c C@sÍt|ƒ}|sdSt|j||ƒdƒ}d}d}d} |jdk rn|j} tjƒ| }nxX||krÈt|||ƒ} ||| !} t|| || |ƒ} |t| ƒ7}qqWdS(sw Send the *data_memory* (which should be a memoryview) using the gevent *socket*, performing well on PyPy. iiNi(Rjtmaxt getsockoptRkRRmtminRu( RRnRTt SOL_SOCKETt SO_SNDBUFRrt chunk_sizeRqRpRot chunk_endRt((s3lib/python2.7/site-packages/gevent/_socketcommon.pyt_sendall?s#   cC@s|jtkst|tƒ r#|S|d \}}t|d|jƒ}|dd}t|ƒdkr{|d|f}n|d||d|df}|S(Niiiÿÿÿÿi(RQt_RESOLVABLE_FAMILIESRettupleRRkRj(tsocktaddressRORPtr((s3lib/python2.7/site-packages/gevent/_socketcommon.pyt _resolve_addr~s(Vt __future__Rt _implementst__dns__t__extensions__t __imports__t__py3_imports__textendRmtsystgevent._hub_localR,RKtgevent._compatR-R.R/t gevent._utilR0tplatformt is_windowstis_macosterrnoR3R9R4R:R5R;R6R<R7R>tgevent.win32utilR8R?R=tosR@t ImportErrort GSENDAGAINRAt_socketRt _realsockett __socket__Rkt_namet_valuetglobalstTruet__all__tgetattrRetappendRt_timeout_errortgeventRDtset_default_timeout_errortwait_on_watchertwaitR RRRRER RRRt__doc__tdRUR R R RuRyRzR}tAF_INETR~thas_ipv6tAF_INET6Rƒ(((s3lib/python2.7/site-packages/gevent/_socketcommon.pytsè                               $9