o 0׾gU@spdZddlmZddlZddlZddlmZddlmZddl m Z ddl Z ddlm Z eee ejdd ejZejZejZejZejZejZGd d d eZGd d d e jZGdddejZeZdddZee jdrxddZedee drdedfddZ n dZ!dZ"e#edfddZ eeeZ$dZ%e%D]Z&eee&re'ee&e(e&<e&e$vre$e&q[&dS)z Python 3 socket module. )absolute_importN) _socketcommon) copy_globals)PYPY)dup)names_to_ignoredunder_names_to_keepc@sdeZdZdZddZddZddZeZdd ZeZ Z Z Z Z ZeZd d ZeZd d ZdS) _closedsocketfamilytypeproto orig_fileno descriptioncCs"||_||_||_||_||_dSNr )selfr r rrrrrY/var/www/html/backend_erp/backend_erp_env/lib/python3.10/site-packages/gevent/_socket3.py__init__'s  z_closedsocket.__init__cCdS)Nrrrrrfileno.z_closedsocket.filenocCr)zNo-opNrrrrrclose1sz_closedsocket.closecOs ttd)NzBad file descriptor)OSErrorEBADF)argskwargsrrr_dummy6s z_closedsocket._dummycCr)NFrrrrr__bool__<rz_closedsocket.__bool__cCsdt||j|jfS)Nz/)idrrrrrr__repr__As z_closedsocket.__repr__N)__name__ __module__ __qualname__ __slots__rrrdetachrsendrecv recv_intosendtorecvfrom recvfrom_into getsocknamer __getattr__r"rrrrr $s r c@s*eZdZdZereddddZdSdS) _wrefsocket) __weakref__cCs|Sr) gettimeout)srrrUsz_wrefsocket.cCs ||Sr) settimeout)r3nvrrrr4Vs N)r#r$r%r&rpropertytimeoutrrrrr0Hsr0cszeZdZdZeZdZdJfdd ZddZd d Z e e d r$e d d Z ddZddZddZddZddZddZddZdKddddddZd d!Zd"d#Zd$d%Ze jfd&d'Zd(d)Ze d*d+Zd,d-Ze e jd.rud/d0Ze e jd1rd2d3Ze e jd4rdLd7d8Z dMd9d:Z!dMd;d<Z"d=d>Z#dMd?d@Z$e%j&dAkrdBdCZ'dDdEZ(ndFdCZ'dGdEZ(dHe'_dIe(_Z)S)Nsocketa{ gevent `socket.socket `_ for Python 3. This object should have the same API as the standard library socket linked to above. Not all methods are specifically documented here; when they are they may point out a difference to be aware of or may document a method the standard library does not. )_io_refs_closedrNcstd|_|dur|dkrtj}|dkrt}|dkrd}||||||_d|_d|_ t j |jdt j |j}t|_|jjj}||d|_||d|_t |_dS)NFrr)superrr; AddressFamilyAF_INET SOCK_STREAM_gevent_sock_class_sockr8r:_socketr9 setblockingrget_hubhubloopio _read_event _write_eventgetdefaulttimeout)rr r rrio_class __class__rrrss&    zsocket.__init__cCs t|j|Sr)getattrrC)rnamerrrr/s zsocket.__getattr__cCs |jSr)rC_acceptrrrrrRs zsocket._accept SOCK_NONBLOCKcCs"|jdkr |jjtj@S|jjS)N)r8rCr rDrSrrrrr s z socket.typecCs|Srrrrrr __enter__rzsocket.__enter__cGs|js |dSdSr)r;r)rrrrr__exit__s zsocket.__exit__c Cszt|j}Wnty}z d|}WYd}~nd}~ww|drAd|jj|jjt|ddr2dp3dt|| |d df}|S) z.Wrap __repr__() to reveal the real class name.z Nz socket object Return a new socket object connected to the same system resource. r)rrrOr r rr5r2)rfdsockrrrrs z socket.dupcCsz z|\}}Wnty|jdkrYnw||jqt|j|j|j|d}t dur9| r9| d||fS)zaccept() -> (socket object, address info) Wait for an incoming connection. Return a new socket representing the connection, and the address of the client. For IP sockets, the address info is a pair (hostaddr, port). TrTr`N) rRBlockingIOErrorr8_waitrJr9r r rrLr2rE)rraaddrrbrrraccepts     z socket.acceptr)encodingerrorsnewlinecCs |D] }|dvr tdqd|v}d|vp| }|s|sJd|v} d} |r*| d7} |r0| d7} t|| } |jd7_|durBd }|d krItj}|d krU| sStd | S|ra|rat| | |} n|rjt| |} n |snJt| |} | rx| St| |||} || _ | S) zReturn an I/O stream connected to the socket The arguments are as for io.open() after the filename, except the only mode characters supported are 'r', 'w' and 'b'. The semantics are similar too. >brgwz&invalid mode %r (only r, w, b allowed)rlrgrkrWr<Nrrz!unbuffered streams must be binary) ValueErrorSocketIOr:rIDEFAULT_BUFFER_SIZEBufferedRWPairBufferedReaderBufferedWriter TextIOWrappermode)rrt bufferingrhrirjcwritingreadingbinaryrawmoderawbuffertextrrrmakefilesD    zsocket.makefilecCs.|jdkr |jd8_|jr|dSdS)Nrr<)r:r;rrrrr_decref_socketios s  zsocket._decref_socketioscCs6|jj|}|r|jj|jdS|dSr)rGrH closing_fdr run_callbackr)rrb scheduled_newrrr_drop_ref_on_closes zsocket._drop_ref_on_closecCsx|jsdS|j}d}d}d}d}z|j}|j}|j}|}Wn ty(Ynw|j|dkdt||||||_dS)Nrclosed)closefd)rCr r rrr_drop_events_and_closer )rreasonrbr r rrrrr_detach_socket!s"  zsocket._detach_socketcCs|jsdS|ddS)Nr)rCr)r_ssrrr _real_close?szsocket._real_closecCs d|_|jdkr|dSdS)NTr)r;r:rrrrrrGs  z socket.closecCs|jSr)r;rrrrrMsz socket.closedcCsd|_|j}|d|S)a detach() -> file descriptor Close the socket object without closing the underlying file descriptor. The object cannot be used after this call; when the real file descriptor is closed, the number that was previously used here may be reused. The fileno() method, after this call, will return an invalid socket id. The previous descriptor is returned. .. versionchanged:: 1.5 Also immediately drop any native event loop resources. Tdetached)r;rCrr')rrbrrrr'Qs z socket.detachrecvmsgc Gs^ z|jj|WSty'}z|jdtks|jdkrWYd}~nd}~ww||jqNTrrT)rCrerrorr EWOULDBLOCKr8rdrJ)rrr]rrrrjs  zsocket.recvmsg recvmsg_intoc Gsx z|r|jj|g|RWS|j|WSty4}z|jdtks)|jdkr*WYd}~nd}~ww||jqr)rCrrrrr8rdrJ)rbuffersrr]rrrrus  zsocket.recvmsg_intosendmsgrrc Csz |j||||WStyc}zM|ttdd@r|jdtks'|jdkr(||j z|j||||WWYd}~Sty^}z|jdtkrYWYd}~WYd}~dSd}~wwd}~ww)N MSG_DONTWAITrrT) rCrrrPrDrrr8rdrK)rrancdataflagsaddressr]ex2rrrrs$  zsocket.sendmsgcCstr) __socket___GiveupOnSendfilerfileoffsetcountrrr_sendfile_use_sendfileszsocket._sendfile_use_sendfilec Cs|||||dkrtd|r|||rt|dnd}d}|j}|j}zR |r9t|||}|dkr9n.t||}|sBn% z||} Wn tyRYqBw|| 7}| t |krd|| d}nnqCq+|W|dkrzt |dr{|||SSS|dkrt |dr|||www)Nrz&non-blocking sockets are not supportedi Tseek) _check_sendfile_paramsr2rmrminreadr( memoryviewrclenhasattr) rrrr blocksize total_sent file_read sock_senddatasentrrr_sendfile_use_sendsH      zsocket._sendfile_use_sendcCshdt|ddvr td|jt@std|dur0t|ts%td||dkr2td|dSdS)Nrkrtz$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r)rPrmr rA isinstanceintr^formatrrrrrs  zsocket._check_sendfile_paramscCs||||S)asendfile(file[, offset[, count]]) -> sent Send a file until EOF is reached by using high-performance os.sendfile() and return the total number of bytes which were sent. *file* must be a regular file object opened in binary mode. If os.sendfile() is not available (e.g. Windows) or file is not a regular file socket.send() will be used instead. *offset* tells from where to start reading the file. If specified, *count* is the total number of bytes to transmit as opposed to sending the file until EOF is reached. File position is updated on return or also in case of error in which case file.tell() can be used to figure out the number of bytes which were sent. The socket must be of SOCK_STREAM type. Non-blocking sockets are not supported. .. versionadded:: 1.1rc4 Added in Python 3.5, but available under all Python 3 versions in gevent. )rrrrrsendfileszsocket.sendfilentcCt|Sr)osget_handle_inheritablerrrrrget_inheritablezsocket.get_inheritablecCt||dSr)rset_handle_inheritablerr inheritablerrrset_inheritablezsocket.set_inheritablecCrr)rrrrrrrrrcCrr)rrrrrrrrrz&Get the inheritable flag of the socketz&Set the inheritable flag of the socket)rrrN)rgN)rrN)rN)*r#r$r%__doc__r0rBr&rr/rRrrDr7r rUrVr"r\r_rrfr~rrrr9rrrr'rrrrrrrrrQrr __classcell__rrrNrr9YsZ      .      $  r9cCst|}t||||S)z fromfd(fd, family, type[, proto]) -> socket object Create a socket object from a duplicate of the given file descriptor. The remaining arguments are the same as for socket(). )rr9)rar r rnfdrrrfromfdsrsharecCstddd|S)z fromshare(info) -> socket object Create a socket object from a the bytes object returned by socket.share(pid). r)r9)inforrr fromshare sr socketpaircCsf|durzt}Wn tyt}Ynwt|||\}}t||||}t||||}||fS)asocketpair([family[, type[, proto]]]) -> (socket object, socket object) Create a pair of socket objects from the sockets returned by the platform socketpair() function. The arguments are the same as for socket() except the default family is AF_UNIX if defined on the platform; otherwise, the default is AF_INET. .. versionchanged:: 1.2 All Python 3 versions on Windows supply this function (natively supplied by Python 3.5 and above). N)AF_UNIX NameErrorr@rDrr9r')r r rarkrrrrs  z 127.0.0.1z::1c Cs|tkrt}n |tkrt}ntd|tkrtd|dkr"tdt|||}zT||df|| dd\}}t|||}z'| dz | ||fWn t t fy^Ynw| d|\}} Wn|W|||fS|w)Nz?Only AF_INET and AF_INET6 socket address families are supportedz)Only SOCK_STREAM socket type is supportedrzOnly protocol zero is supportedr=FT)r@ _LOCALHOSTAF_INET6 _LOCALHOST_V6rmrAr9bindlistenr.rEconnectrcInterruptedErrorrfr) r r rhostlsockreportcsockssock_rrrr5s>     )r TCP_KEEPALIVE TCP_KEEPCNT)r))r __future__rrIrgeventr gevent._utilrgevent._compatrrDrglobals__extensions__r _implements__implements__ __imports____dns__rnobjectr r9r0 SocketMixin SocketTyperrrappendrArrrr@__all____version_specific___xrPvarsrrrrsX     $%     &