B
^†€ÝïdOã @ sl d dl Z d dl T d dlZd dlZd dlZd dlZd dlmZmZ y d dlZW n e k
rd dZY nX e
eddƒZ e
eddƒZ e
eddƒZ
d d
d d d
gZe e e ¡¡ e d edd„ ¡ e d
edd„ ¡ e dedd„ ¡ e dedd„ ¡ dZdZdd„ ZeZej ¡ d¡rœi Zded< d ed < d ed < d ed!< d"ed#< d$ed%< d&ed'< d(ed)< d*ed+< d,ed-< d.ed/< d0ed1< d2ed3< d4ed5< d6ed7< e d8¡ G d9d:„ d:e ƒZ G d;d<„ dƒrèd?d@„ Z!e d@¡ e e dAƒrde"d fdBdA„Z#ne$e"d fdCdA„Z#e dA¡ dDe#_%e e
hZ&G dEdF„ dFej'ƒZ(dMdHd
„Z)e*ƒ Z+e+dfdId „Z,dNdJdK„Z-dS )Oé N)Ú*)ÚIntEnumÚIntFlagÚEBADFé ÚEAGAINé Ú EWOULDBLOCKÚfromfdÚgetfqdnÚcreate_connectionÚ
AddressFamilyÚ
SocketKindc C s | ¡ o| d¡S )NZAF_)ÚisupperÚ
startswith)ÚC© r ú+/opt/alt/python37/lib64/python3.7/socket.pyÚL ó r c C s | ¡ o| d¡S )NZSOCK_)r r )r r r r r Q r ZMsgFlagc C s | ¡ o| d¡S )NZMSG_)r r )r r r r r V r Z AddressInfoc C s | ¡ o| d¡S )NZAI_)r r )r r r r r [ r z 127.0.0.1z::1c C s" y|| ƒS t k
r | S X d S )N)Ú
ValueError)ÚvalueZ
enum_klassr r r Ú_intenum_convertera 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 Zd ZdS )Ú_GiveupOnSendfileN)Ú__name__Ú
__module__Ú __qualname__r r r r r ‚ s r c s( e Zd ZdddgZd8dd„Zdd „ Zd
d „ Zd d
„ Zdd„ Zdd„ Z dd„ Z
d9ddddœdd„Z e e
dƒrvd:dd„Zn
d;d d„ZdÚsocketÚ __weakref__Ú_io_refsÚ_closedéÿÿÿÿNc C sP |d kr,|dkrt }|dkr t}|dkr,d}tj | ||||¡ d| _d| _d S )Nr# r F)ÚAF_INETÚ SOCK_STREAMÚ_socketr Ú__init__r! r" )ÚselfÚfamilyÚtypeÚprotoÚfilenor r r r' ‹ s zsocket.__init__c C s | S )Nr )r( r r r Ú __enter__› s zsocket.__enter__c G s | j s| ¡ d S )N)r" Úclose)r( Úargsr r r Ú__exit__ž s zsocket.__exit__c C s¸ t | ddƒ}d| jj| jj|r"dnd| ¡ | j| j| jf }|s¬y | ¡ }|r^|dt |ƒ 7 }W n t
k
rt Y nX y | ¡ }|r”|dt |ƒ 7 }W n t
k
rª Y nX |d7 }|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+ Ú getsocknameÚstrÚerrorZ getpeername)r( ÚclosedÚsZladdrZraddrr 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 s6 t | ¡ ƒ}| j| j| j| j|d}| | ¡ ¡ |S )N)r, )Údupr, r4 r) r* r+ Ú
settimeoutÚ
gettimeout)r( ÚfdÚsockr r r r= Â s z
socket.dupc C sF | ¡ \}}t| j| j| j|d}tƒ d kr>| ¡ r>| d¡ ||fS )N)r, T)Z_acceptr r) r* r+ Zgetdefaulttimeoutr? Ú setblocking)r( r@ ÚaddrrA r r r ÚacceptÍ s
z
socket.acceptÚr)ÚencodingÚerrorsÚnewlinec
C sü t |ƒdddhks td|f ƒ‚d|k}d|kp4| }d|k}d} |rN| d7 } |rZ| d7 } t| | ƒ}
| jd7 _|d kr~d}|dk rŒtj}|dkr¤|s td ƒ‚|
S |r¼|r¼t |
|
|¡} n |rÎt |
|¡} n t |
|¡} |râ| S t | |||¡} || _
| S )
NrE ÚwÚbz&invalid mode %r (only r, w, b allowed)r1 é r# r z!unbuffered streams must be binary) Úsetr ÚSocketIOr! ÚioÚDEFAULT_BUFFER_SIZEÚBufferedRWPairÚBufferedReaderÚBufferedWriterÚ
TextIOWrapperÚmode)
r( rT Ú bufferingrF rG rH ZwritingZreadingZbinaryZrawmodeÚrawÚbufferÚtextr r r ÚmakefileÝ s<
zsocket.makefileÚsendfiler c
C sê | |||¡ | ¡ }y | ¡ }W n0 ttjfk
rR } z t|ƒ‚W d d }~X Y nX yt |¡j}W n* t k
rŽ } z t|ƒ‚W d d }~X Y nX |s˜dS |s |n|}|
¡ } | dkr¼t dƒ‚t t
dƒrÐt
¡ }
nt
¡ }
|
|t
j¡ d} |
j} tj}
zÌxÆ| r| | ƒst d¡‚|r.|| }|dkr.P y|
||||ƒ}W n^ tk
rd | s^| ƒ wúY qú t k
rž } z | dkrˆt|ƒ‚|d ‚W d d }~X Y qúX |dkr¬P ||7 }| |7 } qúW | S | dkrät |dƒrä| |¡ X d S )Nr z&non-blocking sockets are not supportedÚ PollSelectorz timed outÚseek)Ú_check_sendfile_paramsr, ÚAttributeErrorrN ÚUnsupportedOperationr ÚosÚfstatÚst_sizeÚOSErrorr? r ÚhasattrÚ selectorsr[ ZSelectSelectorÚregisterZ EVENT_WRITEZselectrZ r& ÚtimeoutÚBlockingIOErrorr\ )r( ÚfileÚoffsetÚcountZsocknor, ÚerrZfsizeÚ blocksizerg ZselectorÚ
total_sentZselector_selectZ os_sendfileÚsentr 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( ri rj rk r r r rp J s c
C s | |||¡ | ¡ dkr"tdƒ‚|r0| |¡ |r>t|dƒnd}d}|j}| j}z†x€|rrt|| |ƒ}|dkrrP t||ƒƒ}|s„P xLy ||ƒ} W n tk
r¨ w†Y q†X || 7 }| t |ƒk rÌ|| d … }q†P q†W qVW |S |dkrút
|dƒrú| || ¡ X d S )Nr z&non-blocking sockets are not supportedi r\ ) r] r? r r\ ÚminÚreadÚsendÚ
memoryviewrh Úlenrd )
r( ri rj rk rm rn Z file_readZ sock_sendÚdataro r r r Ú_sendfile_use_sendN s<
zsocket._sendfile_use_sendc C sd dt |ddƒkrtdƒ‚| jt@ s*tdƒ‚|d k r`t|tƒsJtd |¡ƒ‚|dkr`td |¡ƒ‚d S )NrJ rT z$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r )r3 r r* r% Ú
isinstanceÚintr; Úformat)r( ri rj rk r r r r] r s
z socket._check_sendfile_paramsc C s2 y| |||¡S tk
r, | |||¡S X d S )N)rp r rw )r( ri rj rk r r r rZ s zsocket.sendfilec C s* | j dkr| j d8 _ | jr&| ¡ d S )Nr rK )r! r" r. )r( r r r Ú_decref_socketios– s
zsocket._decref_socketiosc C s | | ¡ d S )N)r. )r( Z_ssr r r Ú _real_closeœ s zsocket._real_closec C s d| _ | jdkr| ¡ d S )NTr )r" r! r| )r( r r r r. s
z socket.closec s d| _ tƒ ¡ S )NT)r" ÚsuperÚdetach)r( )r4 r r r~ ¦ s z
socket.detachc s t tƒ jtƒS )N)r r} r) r
)r( )r4 r r r) ° s z
socket.familyc s t tƒ jtƒS )N)r r} r* r )r( )r4 r r r* ¶ s z socket.typeÚntc C s t | ¡ ¡S )N)r` Zget_handle_inheritabler, )r( r r r Úget_inheritable½ s zsocket.get_inheritablec C s t | ¡ |¡ d S )N)r` Zset_handle_inheritabler, )r( Ú inheritabler r r Úset_inheritable¿ s zsocket.set_inheritablec C s t | ¡ ¡S )N)r` r€ r, )r( r r r r€ Â s c C s t | ¡ |¡ d S )N)r` 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# N)rE N)r N)r N)r N)r N) r r r Ú __slots__r' r- r0 r: r< r= rD rY rd r` rp rw r] rZ r{ r& r r| r. r~ Úpropertyr) r* Únamer€ r‚ Ú__doc__Ú
__classcell__r r )r4 r r … s:
)
A
$
r c C s t | ƒ}t||||ƒS )N)r= r )r@ r) r* r+ Znfdr r r r
É s Zsharec C s t ddd| ƒS )Nr )r )Úinfor r r Ú fromshareÓ s r‰ Ú
socketpairc C sh | d kr*yt } W n tk
r( t} Y nX t | ||¡\}}t| ||| ¡ ƒ}t| ||| ¡ ƒ}||fS )N)ZAF_UNIXÚ NameErrorr$ r& rŠ r r~ )r) r* r+ ÚarJ r r r rŠ Þ s
c
C s | t krt}n| tkr t}ntdƒ‚|tkr4tdƒ‚|dkrDtdƒ‚t| ||ƒ}z¢| |df¡ | ¡ | ¡ d d… \}}t| ||ƒ}yP|
d¡ y| ||f¡ W n t t
fk
r¾ Y nX |
d¡ | ¡ \}} W n | ¡ ‚ Y nX W d | ¡ X ||fS )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$ Ú
_LOCALHOSTZAF_INET6Ú
_LOCALHOST_V6r r% r ÚbindZlistenr5 rB Úconnectrh ÚInterruptedErrorrD r. )
r) r* r+ ÚhostZlsockrC Ú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 sl e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Z‡ fd d „Zd
d„ Z e
dd„ ƒZ e
dd„ ƒZ dd„ Z
‡ ZS )rM c C sZ |dkrt d| ƒ‚tj | ¡ || _d|kr6|d7 }|| _d|k| _d|k| _d| _d S )N)rE rI ÚrwÚrbÚwbZrwbzinvalid mode: %rrJ rE rI F) r rN Ú RawIOBaser' Ú_sockÚ_modeÚ_readingÚ_writingÚ_timeout_occurred)r( rA rT r r r r' 3 s
zSocketIO.__init__c
C s† | ¡ | ¡ | jr tdƒ‚xby | j |¡S tk
rH d| _‚ Y q tk
r| } z|jd t krjd S ‚ W d d }~X Y q X q W d S )Nz!cannot read from timed out objectTr )
Ú _checkClosedÚ_checkReadablerž rc rš Z recv_intorg r7 r/ Ú_blocking_errnos)r( rJ Úer r r Úreadinto? s zSocketIO.readintoc
C sX | ¡ | ¡ y | j |¡S tk
rR } z|jd tkr@d S ‚ W d d }~X Y nX d S )Nr )rŸ Ú_checkWritablerš rs r7 r/ r¡ )r( rJ r¢ r r r ÚwriteV s zSocketIO.writec C s | j rtdƒ‚| jS )Nz I/O operation on closed socket.)r8 r rœ )r( r r r Úreadablef s zSocketIO.readablec C s | j rtdƒ‚| jS )Nz I/O operation on closed socket.)r8 r r )r( r r r Úwritablem s zSocketIO.writablec s | j rtdƒ‚tƒ ¡ S )Nz I/O operation on closed socket.)r8 r r} Úseekable)r( )r4 r r r¨ t s zSocketIO.seekablec C s | ¡ | j ¡ S )N)rŸ rš r, )r( r r r r, { s zSocketIO.filenoc C s | j s| ¡ S dS d S )Nr# )r8 r, )r( r r r r… s z
SocketIO.namec C s | j S )N)r› )r( r r r rT ˆ s z
SocketIO.modec C s* | j r
d S tj | ¡ | j ¡ d | _d S )N)r8 rN r™ r. rš r{ )r( r r r r. Œ s
zSocketIO.close)r r r r' r£ r¥ r¦ r§ r¨ r, r„ r… rT r. r‡ r r )r4 r rM " s rM r1 c C sn | ¡ } | r| dkrtƒ } yt| ƒ\}}}W n tk
r@ Y n*X | d|¡ x|D ]} d| krTP qTW |} | S )Nz0.0.0.0r Ú.)ÚstripZ gethostnameZ
gethostbyaddrr7 Úinsert)r… ZhostnameÚaliasesZipaddrsr r r r — s
c C sÒ | \}}d }xžt ||dtƒD ]Œ}|\}}} }
} d } y>t||| ƒ} |tk rR| |¡ |r`| |¡ | | ¡ d }| S tk
r¦ }
z|
}| d k r–| ¡ W d d }
~
X Y q X q W |d k rÆz|‚W d d }X ntdƒ‚d S )Nr z!getaddrinfo returns an empty list) Ú getaddrinfor% r Ú_GLOBAL_DEFAULT_TIMEOUTr> r r‘ r7 r. )Zaddressrg Zsource_addressr“ r” rl ÚresÚafÚsocktyper+ Ú canonnameÚsarA r• r r r r ³ s.
c C sT g }xJt | |||||¡D ]2}|\}} }}
} | t|tƒt| tƒ||
| f¡ qW |S )N)r& r Úappendr r
r ) r“ r” r) r* r+ ÚflagsZaddrlistr¯ r° r± r² r³ r r r r ß s r )r )r1 )r r r r ).r& r` ÚsysrN re Úenumr r ÚerrnoÚ ImportErrorr3 r r r Ú__all__ÚextendÚ_get_exports_listÚ_convertr rŽ r r r Z _realsocketÚplatformÚlowerr r r´ Ú Exceptionr r
rd r‰ r% rŠ r$ r† r¡ r™ rM r Úobjectr® r r r r r r Ú1 sŽ
F
$
u
+