�
��abc @ s d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z y
e j Z Wn e
e f k
r� e j Z n Xd# Z d$ Z
e Z e � Z d a d e f d � � YZ d � Z e j d% k r� d
� Z n d � Z e d d
d d d g � Z d e f d � � YZ d e f d � � YZ e e d � rad e f d � � YZ n e e d � r�d e f d � � YZ n e e d � r�d e f d � � YZ n e e d � r�d e f d � � YZ n e e d � s�e! Z n d! � Z" d" � Z# d S(& i����N( t
namedtuplet Mappingi i t
SelectorErrorc B s# e Z d � Z d � Z d � Z RS( c C s t t | � j � | | _ d S( N( t superR t __init__t errno( t selft errcode( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR s c C s d j | j � S( Ns ( t formatR ( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyt __repr__" s c C s
| j � S( N( R ( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyt __str__% s ( t __name__t
__module__R R R
( ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR s c C s� t | t � r | } nH y t | j � � } Wn/ t t t f k
r_ t d j | � � � n X| d k r� t d j | � � � n | S( sl Return a file descriptor from a file object. If
given an integer will simply return that integer back. s Invalid file object: {0!r}i s Invalid file descriptor: {0}( t
isinstancet intt filenot AttributeErrort TypeErrort
ValueErrorR ( t fileobjt fd( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyt _fileobj_to_fd) s i i c O sd y | | | � SWnL t t t j f k
r_ } d } t | d � rP | j } n t | � � n Xd S( s� This is the short-circuit version of the below logic
because in Python 3.5+ all system calls automatically restart
and recalculate their timeouts. R N( t OSErrort IOErrort selectt errort Nonet hasattrR R ( t funct _t argst kwargst eR ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyt _syscall_wrapper; s c O s� | j d d � } | d k r- d } t } n. t | � } | d k rN d } n
t � | } t | � } | r� d | k r� t d � � n t } x5| t k r�y | | | � } Wq� t t t
j f k
r�} d } t | d � r� | j
} n t | d � r| j d } n | t
j k p8t t
d � o8| t
j k } | r�| d k r� t � }
|
| k rwt d t
j � � n | r�d | k r�| |
| d ( ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR4 � s
t BaseSelectorc B s� e Z d Z d � Z d � Z d
d � Z d � Z d
d � Z d
d � Z d � Z
d � Z d � Z d
� Z
d � Z d � Z RS( s/ Abstract Selector class
A selector supports registering file objects to be monitored
for specific I/O events.
A file object is a file descriptor or any object with a
`fileno()` method. An arbitrary object can be attached to the
file object which can be used for example to store context info,
a callback, etc.
A selector can use various implementations (select(), poll(), epoll(),
and kqueue()) depending on the platform. The 'DefaultSelector' class uses
the most efficient implementation for the current platform.
c C s i | _ t | � | _ d S( N( R8 R4 t _map( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR � s c C sY y t | � SWnD t k
rT x- | j j � D] } | j | k r. | j Sq. W� n Xd S( sa Return a file descriptor from a file object.
This wraps _fileobj_to_fd() to do an exhaustive
search in case the object is invalid but we still
have it in our map. Used by unregister() so we can
unregister an object that was previously registered
even if it is closed. It is also used by _SelectorMapping
N( R R R8 t valuesR R ( R R t key( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR: � s
c C s� | s | t t B@r. t d j | � � � n t | | j | � | | � } | j | j k r| t d j | | j � � � n | | j | j <| S( s8 Register a file object for a set of events to monitor. s Invalid events: {0!r}s$ {0!r} (FD {1}) is already registered( t
EVENT_READt EVENT_WRITER R R1 R: R R8 R; ( R R R2 R3 RC ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyt register� s c C s� y | j j | j | � � } Wn� t k
rG t d j | � � � n� t j k
r� } | j t j k rq � q� xV | j j � D], } | j
| k r� | j j | j � Pq� q� Wt d j | � � � n X| S( s0 Unregister a file object from being monitored. s {0!r} is not registered( R8 t popR: R; R t socketR R t EBADFRB R R ( R R RC R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyt
unregister� s
c C s� y | j | j | � } Wn& t k
rB t d j | � � � n X| | j k rw | j | � | j | | | � } n4 | | j k r� | j d | � } | | j | j | j j | j � n | t @r^ | j j | j � n | S( N( R RW RF RD RY t addR RE RZ ( R R R2 R3 RC ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRF & s
c C sB t t | � j | � } | j j | j � | j j | j � | S( N( R RW RJ RY t discardR RZ ( R R RC ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRJ . s c C s t j | | g | � S( s? Wrapper for select.select because timeout is a positional arg ( R ( R t rt wR" ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyt _select4 s c C s t | j � r$ t | j � r$ g S| d k r6 d n t | d � } g } t | j t | j | j | � \ } } } t | � } t | � } x| | | BD]p } d } | | k r� | t O} n | | k r� | t
O} n | j | � } | r� | j | | | j
@f � q� q� W| S( Ng i ( R7 RY RZ R t maxR! R_ t TrueRX RD RE RT t appendR2 ( R R" t readyR] R^ R R R2 RC ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR 8 s$ !
!N( R R R? R R RF RJ R_ R ( ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRW s t pollt PollSelectorc B sD e Z d Z d � Z d d � Z d � Z d d � Z d d � Z RS( s Poll-based selector c C s& t t | � j � t j � | _ d S( N( R Re R R Rd t _poll( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR S s c C sr t t | � j | | | � } d } | t @r> | t j O} n | t @rX | t j O} n | j j | j | � | S( Ni (
R Re RF RD R t POLLINRE t POLLOUTRf R ( R R R2 R3 RC t
event_mask( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRF W s
c C s/ t t | � j | � } | j j | j � | S( N( R Re RJ Rf R ( R R RC ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRJ a s c C sM | d k r7 | d k r! d } q7 t j | d � } n | j j | � } | S( sj Wrapper function for select.poll.poll() so that
_syscall_wrapper can work with only seconds. i g @�@N( R t matht ceilRf Rd ( R R" R. ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyt
_wrap_pollf s c C s� g } t | j t d | �} x� | D]z \ } } d } | t j @rR | t O} n | t j @rm | t O} n | j | � } | r% | j | | | j
@f � q% q% W| S( NR" i ( R! Rl Ra R Rg RE Rh RD RT Rb R2 ( R R" Rc t fd_eventsR Ri R2 RC ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR t s
!N( R R R? R R RF RJ Rl R ( ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRe Q s
t epollt
EpollSelectorc B sJ e Z d Z d � Z d � Z d d � Z d � Z d d � Z d � Z RS( s Epoll-based selector c C s& t t | � j � t j � | _ d S( N( R Ro R R Rn t _epoll( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR � s c C s
| j j � S( N( Rp R ( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR � s c C sx t t | � j | | | � } d } | t @r> | t j O} n | t @rX | t j O} n t | j j t
| j | � | S( Ni ( R Ro RF RD R t EPOLLINRE t EPOLLOUTR! Rp R% R ( R R R2 R3 RC t events_mask( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRF � s
c C sM t t | � j | � } y t | j j t | j � Wn t k
rH n X| S( N( R Ro RJ R! Rp R% R R ( R R RC ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRJ � s
c C s | d k rG | d k r! d } n t j | d � d } t | � } n d } t t | j � d � } g } t | j j t
d | d | �} x� | D]z \ } } d } | t j @r� | t
O} n | t j @r� | t O} n | j | � } | r� | j | | | j @f � q� q� W| S( Ni g g @�@g����MbP?g �i R" t maxevents( R Rj Rk R& R` R7 R8 R! Rp Rd Ra R Rq RE Rr RD RT Rb R2 ( R R" t
max_eventsRc Rm R Ri R2 RC ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR � s*
!c C s$ | j j � t t | � j � d S( N( Rp RO R Ro ( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRO � s
N(
R R R? R R R RF RJ R RO ( ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRo � s
!t kqueuet KqueueSelectorc B sJ e Z d Z d � Z d � Z d d � Z d � Z d d � Z d � Z RS( s Kqueue / Kevent-based selector c C s& t t | � j � t j � | _ d S( N( R Rw R R Rv t _kqueue( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR � s c C s
| j j � S( N( Rx R ( R ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyR � s c C s� t t | � j | | | � } | t @rh t j | j t j t j � } t | j
j t | g d d � n | t
@r� t j | j t j t j � } t | j
j t | g d d � n | S( Ni ( R Rw RF RD R t keventR t KQ_FILTER_READt KQ_EV_ADDR! Rx t controlR% RE t KQ_FILTER_WRITE( R R R2 R3 RC Ry ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRF � s
"
"c C s� t t | � j | � } | j t @r} t j | j t j t j � } y# t
| j j t
| g d d � Wq} t k
ry q} Xn | j t @r� t j | j t j t j � } y# t
| j j t
| g d d � Wq� t k
r� q� Xn | S( Ni ( R Rw RJ R2 RD R Ry R Rz t KQ_EV_DELETER! Rx R| R% R RE R} ( R R RC Ry ( ( sF /usr/lib/python2.7/site-packages/pip/_vendor/urllib3/util/selectors.pyRJ � s$
#
#
c C s9 | d k r t | d � } n t | j � d } i } t | j j t d | | � } x� | D]� } | j } | j } d } | t
j k r� | t O} n | t
j
k r� | t O} n | j | � } | r\ | j | k r� | | | j @f | | j sF
8�14BR