ó
=OXc @ s’ d Z d d l Z d d l Z d d l Z d d l m Z d „ Z d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d
„ ƒ YZ
d „ Z d S( s
Abstraction of a one-way pipe where the read end can be used in
`select.select`. Normally this is trivial, but Windows makes it nearly
impossible.
The pipe acts like an Event, which can be set or cleared. When set, the pipe
will trigger as readable in `select <select.select>`.
iÿÿÿÿN( t bc C s, t j d d k r t ƒ } n t ƒ } | S( Ni t win( t syst platformt PosixPipet WindowsPipe( t p( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyt make_pipe" s R c B s> e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( c C s7 t j ƒ \ | _ | _ t | _ t | _ t | _ d S( N( t ost pipet _rfdt _wfdt Falset _sett _forevert _closed( t self( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyt __init__+ s c C s- t j | j ƒ t j | j ƒ t | _ d S( N( R t closeR
R t TrueR ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR 1 s c C s | j S( N( R
( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyt fileno7 s c C s7 | j s | j r d St j | j d ƒ t | _ d S( Ni ( R
R R t readR
R ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyt clear: s c C s6 | j s | j r d St | _ t j | j d ƒ d S( Nt *( R
R R R t writeR ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyt set@ s c C s t | _ | j ƒ d S( N( R R R ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyt set_foreverF s ( t __name__t
__module__R R R R R R ( ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR * s R c B sD e Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( s‡
On Windows, only an OS-level "WinSock" may be used in select(), but reads
and writes must be to the actual socket object.
c C s« t j t j t j ƒ } | j d ƒ | j d ƒ t j t j t j ƒ | _ | j j d | j ƒ d f ƒ | j ƒ \ | _ } | j
ƒ t | _ t | _
t | _ d S( Ns 127.0.0.1i i ( s 127.0.0.1i ( t sockett AF_INETt SOCK_STREAMt bindt listent _rsockt connectt getsocknamet acceptt _wsockR R R
R R ( R t servt addr( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR P s
c C s' | j j ƒ | j j ƒ t | _ d S( N( R" R R& R R ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR _ s
c C s
| j j ƒ S( N( R" R ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR e s c C s4 | j s | j r d S| j j d ƒ t | _ d S( Ni ( R
R R" t recvR ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR h s c C s3 | j s | j r d St | _ | j j d ƒ d S( NR ( R
R R R& t send( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR n s c C s t | _ | j ƒ d S( N( R R R ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR t s ( R R t __doc__R R R R R R ( ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR K s t OrPipec B s# e Z d „ Z d „ Z d „ Z RS( c C s t | _ d | _ | | _ d S( N( R R
t Nonet _partnert _pipe( R R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR z s c C s) t | _ | j j s% | j j ƒ n d S( N( R R
R. R/ R ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR s c C s) t | _ | j j s% | j j ƒ n d S( N( R R
R. R/ R ( R ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR „ s ( R R R R R ( ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyR, y s c C s4 t | ƒ } t | ƒ } | | _ | | _ | | f S( sØ
wraps a pipe into two pipe-like objects which are "or"d together to
affect the real pipe. if either returned pipe is set, the wrapped pipe
is set. when both are cleared, the wrapped pipe is cleared.
( R, R. ( R t p1t p2( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyt make_or_pipeŠ s
( R+ R R R t paramiko.py3compatR R t objectR R R, R2 ( ( ( s1 /usr/lib/python2.7/site-packages/paramiko/pipe.pyt <module> s !.