grthtrhthjhtyjytjytkergtrhtrjytjerhrfh4:24 29/09/2026 ]i@sddlZddlTddlZddlZddlZddlZddlmZyddlZWnek rdZYnXe eddZ e eddZ e eddZ d d d d d gZ e jejeejd eddejd edddZdZddZeZejjjdriZdedd=Z"n"e#e!dd?d=Z"e jd=d@e"_$e e hZ%GdAdBdBej&Z'dCdDd Z(e)Z*e*ddEd Z+dddddFdGZ,dS)HN)*)IntEnumEBADF EAGAIN EWOULDBLOCKfromfdgetfqdncreate_connection AddressFamily SocketKindcCs|jo|jdS)NZAF_)isupper startswith)Cr+/opt/alt/python35/lib64/python3.5/socket.pyLsrcCs|jo|jdS)NZSOCK_)rr)rrrrrQsz 127.0.0.1z::1c Cs+y||SWntk r&|SYnXdS)N) ValueError)value enum_klassrrr_intenum_converterWs rwinzThe operation was interrupted.i'zA bad file handle was passed.i'zPermission denied.i'z!A fault occurred on the network??i'z#An invalid operation was attempted.i&'z The socket operation would blocki3'z,A blocking operation is already in progress.i4'zThe network address is in use.i@'zThe connection has been reset.iF'zThe network has been shut down.iJ'zThe operation timed out.iL'zConnection refused.iM'zThe name is too long.iO'zThe host is down.iP'zThe host is unreachable.iQ'errorTabc@seZdZdS)_GiveupOnSendfileN)__name__ __module__ __qualname__rrrrrxs rc seZdZdddgZeeddddZdd Zd d Zd d Z ddZ ddZ ddZ ddddddddddZ eedrddddZnddddZddddZd d!Zddd"d#Zd$d%Zejd&d'Zd(d)Zfd*d+Zefd,d-Zefd.d/Zejd0krd1d2Zd3d4Znd5d2Zd6d4Zd7e_ d8e_ S)9socket __weakref___io_refs_closedrNcCs2tjj|||||d|_d|_dS)NrF)_socketr__init__r r!)selffamilytypeprotofilenorrrr#s zsocket.__init__cCs|S)Nr)r$rrr __enter__szsocket.__enter__cGs|js|jdS)N)r!close)r$argsrrr__exit__s zsocket.__exit__cCst|dd}d|jj|jj|r3dnd|j|j|j|jf}|sy*|j}|r|dt |7}Wnt k rYnXy*|j }|r|dt |7}Wnt k rYnX|d7}|S) Nr!Fz,<%s.%s%s fd=%i, family=%s, type=%s, proto=%iz [closed]z , laddr=%sz , raddr=%s>) getattr __class__rrr(r%r&r' getsocknamestrerror getpeername)r$closedsladdrraddrrrr__repr__s0         zsocket.__repr__cCstddS)NzCannot serialize socket object) TypeError)r$rrr __getstate__szsocket.__getstate__cCsMt|j}|j|j|j|jd|}|j|j|S)Nr()dupr(r0r%r&r' settimeout gettimeout)r$fdsockrrrr<s$z socket.dupcCs|j\}}|jtjdd@}t|j||jd|}tdkru|jru|j d||fS)N SOCK_NONBLOCKrr(T) _acceptr&globalsgetrr%r'getdefaulttimeoutr> setblocking)r$r?addrr&r@rrraccepts  z socket.acceptrencodingerrorsnewlinec Csft|dddhks.td|fd|k}d|kpJ| }d|k}d} |ro| d7} |r| d7} t|| } |jd7_|dkrd }|dkrtj}|dkr|std| S|r |r tj| | |} n-|r%tj| |} ntj| |} |rA| Stj | |||} || _ | S) NrIwbz&invalid mode %r (only r, w, b allowed)r-rz!unbuffered streams must be binary) setrSocketIOr ioDEFAULT_BUFFER_SIZEBufferedRWPairBufferedReaderBufferedWriter TextIOWrappermode) r$rY bufferingrJrKrLwritingreadingbinaryrawmoderawbuffertextrrrmakefiles<           zsocket.makefilesendfilec2Csm|j||||j}y|j}Wn:ttjfk rk}zt|WYdd}~XnXytj|j}Wn1t k r}zt|WYdd}~XnX|sdS|s|n|}|j } | dkrt dt t drt j} n t j} | j|t jd} | j} tj} zx| rs| |  rstjd|r|| }|dkrPy| ||||}Wngtk r| s| wQYqQt k r}z&| dkrt||dWYdd}~XqQX|dkr P||7}| |7} qQW| SWd| dkrht |drh|j|XdS)Nrz&non-blocking sockets are not supported PollSelectorz timed outseek)_check_sendfile_paramsr(AttributeErrorrSUnsupportedOperationrosfstatst_sizeOSErrorr>rhasattr selectorsrdSelectSelectorregister EVENT_WRITEselectrcr"timeoutBlockingIOErrorre)r$fileoffsetcountsocknor(errfsize blocksizersselector total_sentselector_select os_sendfilesentrrr_sendfile_use_sendfiles`              zsocket._sendfile_use_sendfilecCstddS)Nz,os.sendfile() not available on this platform)r)r$rurvrwrrrr=sc CsX|j||||jdkr1td|rD|j||rYt|dnd}d}|j}|j}zx|rt|||}|dkrPt||}|sPx\y||} Wntk rwYqX|| 7}| t |kr|| d}qPqWq}W|SWd|dkrSt |drS|j||XdS)Nrz&non-blocking sockets are not supportedi re) rfr>rreminreadsend memoryviewrtlenrm) r$rurvrwr{r} file_read sock_senddatarrrr_sendfile_use_sendAs<        zsocket._sendfile_use_sendcCsdt|ddkr$td|jt@s=td|dk rt|tsmtdj||dkrtdj|dS)NrNrYz$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r)r/rr& SOCK_STREAM isinstanceintr:format)r$rurvrwrrrrfes     zsocket._check_sendfile_paramsc CsCy|j|||SWn%tk r>|j|||SYnXdS)N)rrr)r$rurvrwrrrrcrs zsocket.sendfilecCs5|jdkr|jd8_|jr1|jdS)NrrO)r r!r*)r$rrr_decref_socketioss zsocket._decref_socketioscCs|j|dS)N)r*)r$_ssrrr _real_closeszsocket._real_closecCs&d|_|jdkr"|jdS)NTr)r!r r)r$rrrr*s z socket.closecsd|_tjS)NT)r!superdetach)r$)r0rrrs z socket.detachcsttjtS)N)rrr%r )r$)r0rrr%sz socket.familycsttjtS)N)rrr&r )r$)r0rrr&sz socket.typentcCstj|jS)N)riZget_handle_inheritabler()r$rrrget_inheritableszsocket.get_inheritablecCstj|j|dS)N)riZset_handle_inheritabler()r$ inheritablerrrset_inheritableszsocket.set_inheritablecCstj|jS)N)rirr()r$rrrrscCstj|j|dS)N)rirr()r$rrrrrsz&Get the inheritable flag of the socketz&Set the inheritable flag of the socket)!rrr __slots__AF_INETrr#r)r,r9r;r<rHrbrmrirrrfrcrr"rrr*rpropertyr%r&namerr__doc__rr)r0rr{s:       )A$        rcCst|}t||||S)N)r<r)r?r%r&r'nfdrrrr s sharecCstddd|S)Nr)r)inforrr fromsharesr socketpairc Cs|dkr1y t}Wntk r0t}YnXtj|||\}}t||||j}t||||j}||fS)N)AF_UNIX NameErrorrr"rrr)r%r&r'arNrrrrs    c CsY|tkrt}n!|tkr*t}n td|tkrNtd|dkrftdt|||}z|j|df|j|j dd\}}t|||}yb|j dy|j ||fWnt t fk rYnX|j d|j\}} Wn|jYnXWd|jX||fS)Nz?Only AF_INET and AF_INET6 socket address families are supportedz)Only SOCK_STREAM socket type is supportedrzOnly protocol zero is supportedFT)r _LOCALHOSTAF_INET6 _LOCALHOST_V6rrrbindlistenr1rFconnectrtInterruptedErrorrHr*) r%r&r'hostZlsockrGportZcsockZssock_rrrrs8               a8socketpair([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. cseZdZddZddZddZddZd d Zfd d Zd dZ e ddZ e ddZ ddZ S)rRcCs|d krtd|tjj|||_d|krK|d7}||_d|k|_d|k|_d |_dS) NrIrMrwrbwbrwbzinvalid mode: %rrNF)rIrMrrrr) rrS RawIOBaser#_sock_mode_reading_writing_timeout_occurred)r$r@rYrrrr#&s     zSocketIO.__init__cCs|j|j|jr)tdxwy|jj|SWq,tk r`d|_Yq,tk r}z|jdt krdSWYdd}~Xq,Xq,WdS)Nz!cannot read from timed out objectTr) _checkClosed_checkReadablerrlr recv_intorsr3r+_blocking_errnos)r$rNerrrreadinto2s      zSocketIO.readintocCsn|j|jy|jj|SWn?tk ri}z|jdtkrTdSWYdd}~XnXdS)Nr)r_checkWritablerrr3r+r)r$rNrrrrwriteIs  zSocketIO.writecCs|jrtd|jS)NzI/O operation on closed socket.)r5rr)r$rrrreadableYs  zSocketIO.readablecCs|jrtd|jS)NzI/O operation on closed socket.)r5rr)r$rrrwritable`s  zSocketIO.writablecs"|jrtdtjS)NzI/O operation on closed socket.)r5rrseekable)r$)r0rrrgs  zSocketIO.seekablecCs|j|jjS)N)rrr()r$rrrr(ns zSocketIO.filenocCs|js|jSdSdS)NrOrP)r5r()r$rrrrts  z SocketIO.namecCs|jS)N)r)r$rrrrY{sz SocketIO.modecCs7|jr dStjj||jjd|_dS)N)r5rSrr*rr)r$rrrr*s   zSocketIO.close)rrrr#rrrrrr(rrrYr*rr)r0rrRs      rRr-c Cs|j}| s|dkr(t}yt|\}}}Wntk rUYn5X|jd|x!|D]}d|krmPqmW|}|S)Nz0.0.0.0r.)strip gethostname gethostbyaddrr3insert)rhostnamealiasesipaddrsrrrr s     cCs |\}}d}xt||dtD]}|\}}} } } d} ySt||| } |tk rw| j||r| j|| j| | SWq(tk r} z!| }| dk r| jWYdd} ~ Xq(Xq(W|dk r|n tddS)Nrz!getaddrinfo returns an empty list) getaddrinforr_GLOBAL_DEFAULT_TIMEOUTr=rrr3r*)addressrssource_addressrrryresafsocktyper' canonnamesar@rrrrr s(      !  c Csvg}xitj||||||D]I}|\}} }} } |jt|tt| t|| | fq%W|S)N)r"rappendrr r ) rrr%r&r'flagsaddrlistrrrrrrrrrs% r)-r"risysrSrnenumrerrno ImportErrorr/rrr__all__extend_get_exports_list_convertrrrrr _realsocketplatformlowerrrr Exceptionrr rmrrrrrrrrRr objectrr rrrrr1s|  0                       B   $   u %