!niBddlZddlZddlZddlZddlZddlZddlZddlmZm Z m Z ddl m Z gdZ dZejej ej"hZdej&hZej*dddk(rej-ej.ej0j3djZej6d k\r ej8Zn%ej8j=ej8Zd Zd Z d Z!ej*dddk(r   ""  Q<5,, , s A==AcN |j}|dy#t$r ddl}n#t$r t dwxYw|j }|j||j }|tjz}||k7r|j||j|YyYywxYw)z Sets the descriptor to be nonblocking. Works on many file-like objects as well as sockets. Only sockets can be nonblocking on Windows, however. rNznset_nonblocking() on a file object with no setblocking() method (Windows pipes don't support non-blocking I/O)) setblockingAttributeErrorfcntl ImportErrorNotImplementedErrorfilenoF_GETFLos O_NONBLOCKF_SETFL)fdr,r.r1 orig_flags new_flagss rr r Ns nn 2 A1 : X  X &'WX X  X[[7 .  " KK y 9 #):s"  B$&B$;A$B$#B$)rceZdZdZdZej fdZedZ dZ dZ ee e Z dZ d dZd Zd Zd Zd Zd ZdZdZdZdZdZd!dZd!dZd"dZd"dZdZd!dZdZd!dZ dZ!dZ"dZ#dZ$dZ%y)#ra Green version of socket.socket class, that is intended to be 100% API-compatible. It also recognizes the keyword parameter, 'set_nonblocking=True'. Pass False to indicate that socket is already in non-blocking mode to save syscalls. Nc|jdd}t|tr)t|g|i|}t |j n|} |j xstj|_ |r|j dk7r t|||_ d|_ |j|_|j|_|j |_|j |_|j"|_|j$|_|j&|_|j(|_d|_y#t$rtj|_ YwxYw)Nr TF)pop isinstanceint_original_socketrr1 gettimeoutrgetdefaulttimeout_timeoutr-r r6act_non_blockingbindclose getsocknamer"listen setsockoptshutdown_closed)selffamilyargskwargsshould_set_nonblockingr6s r__init__zGreenSocket.__init__s!',=t!D fc "!&:4:6:B "))+ &B 7MMOIv/G/G/IDM "biikR&7 B !&GG XX ii >>--ii --   3 7"446DM 7s+D88"EEc|Sr!rKs r_sockzGreenSocket._socks rc.|jjSr!r6_io_refsrSs r _get_io_refszGreenSocket._get_io_refsswwrc&||j_yr!rV)rKvalues r _set_io_refszGreenSocket._set_io_refss rcz|j t|t|j|}t||||Sr!)r6r-getattrsetattr)rKnameattrs r __getattr__zGreenSocket.__getattr__s7 77? & &tww%dD! rc|jr t t||||||jS#t$r|jwxYw)z We need to trampoline via the event hub. We catch any signal back from the hub indicating that the operation we were waiting on was associated with a filehandle that's since been invalidated. )readwritetimeout timeout_excmark_as_closed)rJrr_mark_as_closed)rKr6rcrdrerfs r _trampolinezGreenSocket._trampolines] <<*  bt5'*5-1-A-AC C   "  s 3Ac|jr8|jj}t|dj |S|j}t d} t |}|<|\}}t|j t|t|||fS|j|d|j|m)Nr timed outTrcrerf) rCr6r'rr1rr*r typerir@)rKresr6 _timeout_excclientaddrs rr'zGreenSocket.accepts  ''.."C #a&--/ *J WW%k2 #C" fmmo.'!tDz&)4//   RdDOO4ES_  `rcd|_y)z" Mark this socket as being closed TN)rJrSs rrhzGreenSocket._mark_as_closeds  rc2t|dd}||yy)NrE)r])rKrEs r__del__zGreenSocket.__del__s gt,   G rc|jr|jj|S|j}td}|j :t ||s- |j |dt|t ||s,yytj|j z} t ||rytj|k\r||tjz } |j |d||t|_#t$rttjwxYw#t$rttjwxYw)NrkTrdrdrerf) rCr6connectrr@rrirrrEBADFDr%time)rKrr6roendres rrxzGreenSocket.connects.  77??7+ + WW%k2 ??  $$R10$$Rt$4 # %R1))+ 11C!"g.99;#%&& +0$$RtWR^$_ #  0!%,,//0 0!%,,//0sD-D4#D14#Ec|jr|jj|S|j}|j-t ||s |j |dt |yytj|jz}tjtj} t ||rytj|k\r||j |d|tjz |t |y#t$r}t|cYd}~Sd}~wt$rtjcYSwxYw#t$r}t|cYd}~Sd}~wt$rtjcYSwxYw)NTrvrrw)rCr6rr@rrir%rrrrryrzrreEAGAIN)rKrr6exr{rfs rrzGreenSocket.connect_ex sM  77%%g. . WW ??  $$R1($$Rt$4#B' 2))+ 11C ..6K (%b'2 yy{c)))$$RtS499;=N1<%>#B' +)$R=(( <<'()$R=(( <<'(sOD; EAE E D0*E0EE F  E+%F +F  F c|jj|i|}t||d}|j|j |S)NF)r )r6duprm settimeoutr@)rKrMkwsocknewsocks rrzGreenSocket.dup+sGtww{{D'B'$t*T594??,-rc4tj|g|i|Sr!)r?makefile)rKrMrNs rrzGreenSocket.makefile1s((????rc^tjdtd|j|i|S)Nz>makeGreenFile has been deprecated, please use makefile instead) stacklevel)warningswarnDeprecationWarningr)rKrMrs r makeGreenFilezGreenSocket.makeGreenFile4s/ )*< Lt}}d)b))rcp|j|jd|jtdy)NTrkrl)rir6r@rrSs r_read_trampolinezGreenSocket._read_trampoline9s1  GGOO%&{3  5rc:|jr||S |ds|j||S#t$r5}t|tvrnt|t vr|cYd}~SYd}~nd}~wwxYw |jn#t $r}td}~wwxYwNr)rCrrrr r rEOFError)rK recv_meth empty_valrMr)s r _recv_loopzGreenSocket._recv_loop@s  d# # Aw))+ $'' QO-9!; We..0UVV Ws , A&'A!!A&*-B$B<cP|j|jj||Sr!)rr6send)rKrrs rrzGreenSocket.send~stww||T599rcR|j|jj|g|Sr!)rr6sendto)rKrrMs rrzGreenSocket.sendtos"ttww~~t;d;;rc|j||}t|}||kr||j||d|z }||kryyr!)rlen)rKrrtaillen_datas rsendallzGreenSocket.sendallsFyyu%t9Xo DIId45k51 1DXorcB|rd|_d|_yd|_d|_y)NFT)rCrB)rKflags rr,zGreenSocket.setblockings# $)D ! DM$(D !DMrc| |tk(r|jdy |j}|}|dkr t d|dk(rd|_d|_yd|_||_y#t$r t dwxYw)NTza float is requiredrzTimeout value out of rangeF)rr, __float__r- TypeError ValueErrorrCrB)rKhowlongfs rrzGreenSocket.settimeouts ?g)@@   T "  3!!A# S=9: : c>$(D !DM$)D !#DM 312 2 3s A%%A:c|jSr!)rBrSs rr@zGreenSocket.gettimeouts }}rc|Sr!rRrSs r __enter__zGreenSocket.__enter__s rc$|jyr!)rE)rKrMs r__exit__zGreenSocket.__exit__s  r)FFNN)r)rr)&__name__ __module__ __qualname____doc__r6rAF_INETrPpropertyrTrXr[rWrarir'rhrtrxrrrrrrrrrrrrrrr,rr@rrrRrrrrws B$nn%N ! l3H&a  $6@ @* 5!>BFLPW&:<2  $$rrctd)NzI/O operation on closed file)r)rMrNs r_operation_on_closed_filers 3 44ra GreenPipe is a cooperative replacement for file class. It will cooperate on pipes. It will block on regular file. Differences from file class: - mode is r/w property. Should re r/o - encoding property not implemented - write/writelines will not raise TypeError exception when non-string data is written it will write str(data) instead - Universal new lines are not supported and newlines property not implementeded - file argument can be descriptor, file name or file object. )rcdeZdZGddeZGddeZGddeZGddeZy ) rc eZdZy)SSL.WantWriteErrorNrrrrRrrWantWriteErrorr rrc eZdZy)SSL.WantReadErrorNrrRrr WantReadErrorrrrrc eZdZy)SSL.ZeroReturnErrorNrrRrrZeroReturnErrorrrrrc eZdZy)SSL.SysCallErrorNrrRrr SysCallErrorrrrrN)rrr ExceptionrrrrrRrrrrs2 Y  I  i  9 rrc$ |jtjS#t$r|jcYSwxYw#t$rE}t |t jt jt jfvrYd}~yd}~wwxYw)aShuts down the socket. This is a convenience method for code that wants to gracefully handle regular sockets, SSL.Connection sockets from PyOpenSSL and ssl.SSLSocket objects from Python 2.7 interchangeably. Both types of ssl socket require a shutdown() before close, but they have different arity on their shutdown method. Regular sockets don't need a shutdown before close, but it doesn't hurt. N) rIr SHUT_RDWRrrrrrEBADFENOTSOCK)rr)s rrrsw  #==!1!12 2 #==? " #  Q< U^^L L  Ms(">A>A B ;B  B)3rr3rsysrzreventlet eventlet.hubsrrreventlet.supportr__all__ BUFFER_SIZE EINPROGRESSEALREADYr(r EISCONNr platformadd WSAEINVALpatcheroriginalr? version_inforerwrap_is_timeoutrr%r*r}r rr ESHUTDOWNr EPIPEr rr/objectrr greenpipe_docOpenSSLrrrRrrrs ==&    %..%2C2CD emm$<<uOOEOO$##,,X6==w^^N%%55fnnEN 1 <<u||U%6%67O%%u~~uGM||U%6%6GO%%u DM F'. ttn 5  "} '$h'\    ! s$F8.G 8 GG GG