]i @ s d d l Z d d l Td d l Z d d l Z d d l Z d d l Z d d l m Z y d d l Z Wn e k
r d Z Yn Xe e d d Z
e e d d Z e e d d Z d d
d d d
g Z
e
j e j e e j d e d d e j d
e d d d Z d Z d d Z e Z e j j j d ri Z d e d d= Z" n" e# e! d d? d= Z" e
j d= d@ e" _$ e e h Z% GdA dB dB e j& Z' dC dD d
Z( e) Z* e* d dE d Z+ d d d d dF dG Z, d S)H N)*)IntEnumEBADF EAGAIN EWOULDBLOCKfromfdgetfqdncreate_connection
AddressFamily
SocketKindc C s | j o | j d S)NZAF_)isupper
startswith)C r +/opt/alt/python35/lib64/python3.5/socket.pyL s r c C s | j o | j d S)NZSOCK_)r r )r r r r r Q s z 127.0.0.1z::1c C s+ y | | SWn t k
r& | SYn Xd S)N)
ValueError)value
enum_klassr r r _intenum_converterW s
r winz The operation was interrupted.i' z A 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' z The network address is in use.i@' z The connection has been reset.iF' z The 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 @ s e Z d Z d S)_GiveupOnSendfileN)__name__
__module__ __qualname__r r r r r x s r c
s e Z d Z d d d g Z e e d d d d Z d d Z d
d Z d d
Z d d Z
d d Z d d Z d d d d d d d d d d Z
e e d r d d d d Z n d d d d Z d d d d Z d d! Z d d d" d# Z d$ d% Z e j d& d' Z d( d) Z f d* d+ Z e f d, d- Z e f d. d/ Z e j d0 k rd1 d2 Z d3 d4 Z n d5 d2 Z d6 d4 Z d7 e _ d8 e _ S)9socket __weakref___io_refs_closedr Nc C s2 t j j | | | | | d | _ d | _ d S)Nr F)_socketr __init__r r! )selffamilytypeprotofilenor r r r# s zsocket.__init__c C s | S)Nr )r$ r r r __enter__ s zsocket.__enter__c G s | j s | j d S)N)r! close)r$ argsr r r __exit__ s zsocket.__exit__c C s t | d d } d | j j | j j | r3 d n d | j | j | j | j f } | s y* | j } | r | d t | 7} Wn t
k
r Yn Xy* | j } | r | d t | 7} Wn t
k
r Yn X| d 7} | S) Nr! Fz,<%s.%s%s fd=%i, family=%s, type=%s, proto=%iz [closed] z
, laddr=%sz
, raddr=%s>) getattr __class__r r r( r% r& r' getsocknamestrerror getpeername)r$ closedsladdrraddrr r r __repr__ s0
zsocket.__repr__c C s t d d S)Nz Cannot serialize socket object) TypeError)r$ r r r __getstate__ s zsocket.__getstate__c C sM t | j } | j | j | j | j d | } | j | j | S)Nr( )dupr( r0 r% r& r'
settimeout
gettimeout)r$ fdsockr r r r< s $z
socket.dupc C s | j \ } } | j t j d d @} t | j | | j d | } t d k ru | j ru | j d | | f S)N
SOCK_NONBLOCKr r( T)
_acceptr& globalsgetr r% r' getdefaulttimeoutr> setblocking)r$ r? addrr& r@ r r r accept s
z
socket.acceptrencodingerrorsnewlinec
C sf t | d d d h k s. t d | f d | k } d | k pJ | } d | k } d } | ro | d 7} | r | d 7} t | | }
| j d 7_ | d k r d } | d k r t j } | d k r | s t d |
S| r
| r
t j |
|
| } n- | r%t j |
| } n t j |
| } | rA| St j | | | | } | | _
| S)
NrI wbz&invalid mode %r (only r, w, b allowed)r- r z!unbuffered streams must be binary) setr SocketIOr ioDEFAULT_BUFFER_SIZEBufferedRWPairBufferedReaderBufferedWriter
TextIOWrappermode)
r$ rY bufferingrJ rK rL writingreadingbinaryrawmoderawbuffertextr r r makefile s<
zsocket.makefilesendfilec 2 C sm | j | | | | j } y | j } Wn: t t j f k
rk } z t | WYd d } ~ Xn Xy t j | j } Wn1 t k
r } z t | WYd d } ~ Xn X| s d S| s | n | } | j
} | d k r t d t t
d rt
j }
n t
j }
|
j | t
j d } |
j } t j }
z x | rs| | rst j d | r| | } | d k rPy |
| | | | } Wng t k
r| s| wQYqQt k
r} z& | d k rt | | d WYd d } ~ XqQX| d k r P| | 7} | | 7} qQW| SWd | d k rht | d rh| j | Xd S)Nr z&non-blocking sockets are not supported PollSelectorz timed outseek)_check_sendfile_paramsr( AttributeErrorrS UnsupportedOperationr osfstatst_sizeOSErrorr> r hasattr selectorsrd SelectSelectorregister EVENT_WRITEselectrc r" timeoutBlockingIOErrorre )r$ fileoffsetcountsocknor( errfsize blocksizers selector
total_sentselector_select os_sendfilesentr r r _sendfile_use_sendfile s`
z socket._sendfile_use_sendfilec C s t d d S)Nz,os.sendfile() not available on this platform)r )r$ ru rv rw r r r r = s c
C sX | j | | | | j d k r1 t d | rD | j | | rY t | d n d } d } | j } | j } z x | r t | | | } | d k r Pt | | } | s Px\ y | | } Wn t k
r w Yq X| | 7} | t | k r| | d } q Pq Wq} W| SWd | d k rSt
| d rS| j | | Xd S)Nr z&non-blocking sockets are not supportedi re ) rf r> r re minreadsend
memoryviewrt lenrm )
r$ ru rv rw r{ r} file_read sock_senddatar r r r _sendfile_use_sendA s<
zsocket._sendfile_use_sendc C s d t | d d k r$ t d | j t @s= t d | d k r t | t sm t d j | | d k r t d j | d S)NrN rY z$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r )r/ r r& SOCK_STREAM
isinstanceintr: format)r$ ru rv rw r r r rf e s
z socket._check_sendfile_paramsc C sC y | j | | | SWn% t k
r> | j | | | SYn Xd S)N)r r r )r$ ru rv rw r r r rc r s
zsocket.sendfilec C s5 | j d k r | j d 8_ | j r1 | j d S)Nr rO )r r! r* )r$ r r r _decref_socketios s zsocket._decref_socketiosc C s | j | d S)N)r* )r$ _ssr r r _real_close s zsocket._real_closec C s& d | _ | j d k r" | j d S)NTr )r! r r )r$ r r r r* s z socket.closec s d | _ t j S)NT)r! superdetach)r$ )r0 r r r s z
socket.detachc s t t j t S)N)r r r% r )r$ )r0 r r r% s z
socket.familyc s t t j t S)N)r r r& r
)r$ )r0 r r r& s z socket.typentc C s t j | j S)N)ri Zget_handle_inheritabler( )r$ r r r get_inheritable s zsocket.get_inheritablec C s t j | j | d S)N)ri Zset_handle_inheritabler( )r$ inheritabler r r set_inheritable s zsocket.set_inheritablec C s t j | j S)N)ri r r( )r$ r r r r s c C s t j | j | d S)N)ri r r( )r$ r r r r r s z&Get the inheritable flag of the socketz&Set the inheritable flag of the socket)!r r r __slots__AF_INETr r# r) r, r9 r; r< rH rb rm ri r r rf rc r r" r r r* r propertyr% r& namer r __doc__r r )r0 r r { s: )A$
r c C s t | } t | | | | S)N)r< r )r? r% r& r' nfdr r r r s sharec C s t d d d | S)Nr )r )infor r r fromshare s r
socketpairc
C s | d k r1 y
t } Wn t k
r0 t } Yn Xt j | | | \ } } t | | | | j } t | | | | j } | | f S)N)AF_UNIX NameErrorr r" r r r )r% r& r' arN r r r r s
c
C sY | t k r t } n! | t k r* t } n t d | t k rN t d | d k rf t d t | | | } z | j | d f | j | j d d \ } } t | | | } yb | j
d y | j | | f Wn t t
f k
rYn X| j
d | j \ } } Wn | j Yn XWd | j X| | f S)Nz?Only AF_INET and AF_INET6 socket address families are supportedz)Only SOCK_STREAM socket type is supportedr z Only protocol zero is supported FT)r
_LOCALHOSTAF_INET6
_LOCALHOST_V6r r r bindlistenr1 rF connectrt InterruptedErrorrH r* )
r% r& r' hostZlsockrG portZcsockZssock_r r r r s8
a8 socketpair([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.
c s e Z d Z d d Z d d Z d d Z d d Z d d
Z f d d Z d
d Z e
d d Z e
d d Z d d Z
S)rR c C s | d
k r t d | t j j | | | _ d | k rK | d 7} | | _ d | k | _ d | k | _ d | _ d S) NrI rM rwrbwbrwbzinvalid mode: %rrN F)rI rM r r r r ) r rS RawIOBaser# _sock_mode_reading_writing_timeout_occurred)r$ r@ rY r r r r# & s
zSocketIO.__init__c C s | j | j | j r) t d xw y | j j | SWq, t k
r` d | _ Yq, t k
r } z | j d t k r d S WYd d } ~ Xq, Xq, Wd S)Nz!cannot read from timed out objectTr )
_checkClosed_checkReadabler rl r recv_intors r3 r+ _blocking_errnos)r$ rN er r r readinto2 s
zSocketIO.readintoc C sn | j | j y | j j | SWn? t k
ri } z | j d t k rT d S WYd d } ~ Xn Xd S)Nr )r _checkWritabler r r3 r+ r )r$ rN r r r r writeI s
zSocketIO.writec C s | j r t d | j S)Nz I/O operation on closed socket.)r5 r r )r$ r r r readableY s zSocketIO.readablec C s | j r t d | j S)Nz I/O operation on closed socket.)r5 r r )r$ r r r writable` s zSocketIO.writablec s" | j r t d t j S)Nz I/O operation on closed socket.)r5 r r seekable)r$ )r0 r r r g s zSocketIO.seekablec C s | j | j j S)N)r r r( )r$ r r r r( n s
zSocketIO.filenoc C s | j s | j Sd Sd S)NrO rP )r5 r( )r$ r r r r t s
z
SocketIO.namec C s | j S)N)r )r$ r r r rY { s z
SocketIO.modec C s7 | j r
d St j j | | j j d | _ d S)N)r5 rS r r* r r )r$ r r r r* s
zSocketIO.close)r r r r# r r r r r r( r r rY r* r r )r0 r rR s rR r- c C s | j } | s | d k r( t } y t | \ } } } Wn t k
rU Yn5 X| j d | x! | D] } d | k rm Pqm W| } | S)Nz0.0.0.0r .)strip gethostname
gethostbyaddrr3 insert)r hostnamealiasesipaddrsr r r r
s
c C s | \ } } d } x t | | d t D] } | \ } } } }
} d } yS t | | | } | t k rw | j | | r | j | | j | | SWq( t k
r }
z! |
} | d k r | j WYd d }
~
Xq( Xq( W| d k r | n t d d S)Nr z!getaddrinfo returns an empty list) getaddrinfor r _GLOBAL_DEFAULT_TIMEOUTr= r r r3 r* )addressrs source_addressr r ry resafsocktyper' canonnamesar@ r r r r r s(
! c C sv g } xi t j | | | | | | D]I } | \ } } } }
} | j t | t t | t | |
| f q% W| S)N)r" r appendr r r
) r r r% r& r' flagsaddrlistr r r r r r r r r s % r )-r" ri sysrS rn enumr errno ImportErrorr/ r r r __all__extend_get_exports_list_convertr r r r r _realsocketplatformlowerr r r Exceptionr r rm r r r r r r r rR r
objectr r r r r r r 1 s|
0
B
$
u %