Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

triliodata-3-4 / contego deb

Repository URL to install this package:

Version: 
3.4.36  ▾
Details    
contego / home / tvault / .virtenv / lib / python2.7 / site-packages / urllib3 / util / selectors.pyc
Size: Mime: 
ó
èEYc@sddlZddlZddlZddlZddlZddlZddlmZmZy
ej	Z	Wn e
efk
rejZ	nXd#Zd$Z
eZeƒZdadefd„ƒYZd„Zejd%kréd
„Zn	d„Zedd
dddgƒZdefd„ƒYZdefd„ƒYZeedƒradefd„ƒYZneedƒr‰defd„ƒYZneedƒr±defd„ƒYZneedƒrÙdefd „ƒYZ needƒsñe!Znd!„Z"d"„Z#dS(&iÿÿÿÿN(t
namedtupletMappingiit
SelectorErrorcBs#eZd„Zd„Zd„ZRS(cCs tt|ƒjƒ||_dS(N(tsuperRt__init__terrno(tselfterrcode((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRscCsdj|jƒS(Ns<SelectorError errno={0}>(tformatR(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt__repr__"scCs
|jƒS(N(R	(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt__str__%s(t__name__t
__module__RR	R
(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRs		cCsˆt|tƒr|}nHyt|jƒƒ}Wn/tttfk
r_tdj|ƒƒ‚nX|dkr„tdj|ƒƒ‚n|S(sl Return a file descriptor from a file object. If
    given an integer will simply return that integer back. sInvalid file object: {0!r}isInvalid file descriptor: {0}(t
isinstancetinttfilenotAttributeErrort	TypeErrort
ValueErrorR(tfileobjtfd((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt_fileobj_to_fd)s	iicOsdy|||ŽSWnLtttjfk
r_}d}t|dƒrP|j}nt|ƒ‚nXdS(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. RN(tOSErrortIOErrortselectterrortNonethasattrRR(tfunct_targstkwargsteR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt_syscall_wrapper;scOsÊ|jddƒ}|dkr-d}t}n.t|ƒ}|dkrNd}n
tƒ|}t|ƒ}|rˆd|krˆtdƒ‚nt}x5|tkrÅy|||Ž}Wq‘tt	t
jfk
rÁ}d}t|dƒrï|j
}nt|dƒr|jd}n|t
jkp8tt
dƒo8|t
jk}	|	r¦|dk	r‘tƒ}
|
|krwtdt
jƒ‚n|r d|kr||
|d<qq q‘q‘n|r»t|ƒ‚q‚q‘Xq‘W|S(	s® Wrapper function for syscalls that could fail due to EINTR.
        All functions should be retried if there is time left in the timeout
        in accordance with PEP 475. ttimeoutgs4Timeout must be in args or kwargs to be recalculatedRRitWSAEINTRN(tgetRtFalsetfloatt	monotonictlistRt_SYSCALL_SENTINELRRRRRRRtEINTRR#t	ETIMEDOUTR(Rtrecalc_timeoutRRR"texpirestresultR Rtis_interrupttcurrent_time((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR!GsJ		
	tSelectorKeyRRteventstdatat_SelectorMappingcBs2eZdZd„Zd„Zd„Zd„ZRS(s* Mapping of file objects to selector keys cCs
||_dS(N(t	_selector(Rtselector((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR…scCst|jjƒS(N(tlenR5t
_fd_to_key(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt__len__ˆscCsQy$|jj|ƒ}|jj|SWn&tk
rLtdj|ƒƒ‚nXdS(Ns{0!r} is not registered.(R5t_fileobj_lookupR8tKeyErrorR(RRR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt__getitem__‹s

cCst|jjƒS(N(titerR5R8(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt__iter__’s(RRt__doc__RR9R<R>(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR4‚s
			tBaseSelectorcBsƒeZdZd„Zd„Zd
d„Zd„Zd
d„Zd
d„Z	d„Z
d„Zd	„Zd
„Z
d„Zd„ZRS(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.
    cCsi|_t|ƒ|_dS(N(R8R4t_map(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR¥s	cCsYyt|ƒSWnDtk
rTx-|jjƒD]}|j|kr.|jSq.W‚nXdS(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(RRR8tvaluesRR(RRtkey((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR:¬s
cCs|s|ttB@r.tdj|ƒƒ‚nt||j|ƒ||ƒ}|j|jkr|tdj||jƒƒ‚n||j|j<|S(s8 Register a file object for a set of events to monitor. sInvalid events: {0!r}s${0!r} (FD {1}) is already registered(	t
EVENT_READtEVENT_WRITERRR1R:RR8R;(RRR2R3RC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pytregisterÀs	cCsÎy|jj|j|ƒƒ}Wn¨tk
rGtdj|ƒƒ‚nƒtjk
rÉ}|jtjkrq‚qÊxV|jj	ƒD],}|j
|kr|jj|jƒPqqWtdj|ƒƒ‚nX|S(s0 Unregister a file object from being monitored. s{0!r} is not registered(R8tpopR:R;RtsocketRRtEBADFRBRR(RRRCR ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt
unregisterÎs
cCs¯y|j|j|ƒ}Wn&tk
rBtdj|ƒƒ‚nX||jkrw|j|ƒ|j|||ƒ}n4||jkr«|jd|ƒ}||j|j	<n|S(s< Change a registered file object monitored events and data. s{0!r} is not registeredR3(
R8R:R;RR2RJRFR3t_replaceR(RRR2R3RC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pytmodifyâs

cCs
tƒ‚dS(sj Perform the actual selection until some monitored file objects
        are ready or the timeout expires. N(tNotImplementedError(RR"((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRõscCs|jjƒd|_dS(sd Close the selector. This must be called to ensure that all
        underlying resources are freed. N(R8tclearRRA(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pytcloseús
cCs`|jƒ}|dkr'tdƒ‚ny||SWn&tk
r[tdj|ƒƒ‚nXdS(s: Return the key associated with a registered file object. sSelector is closeds{0!r} is not registeredN(tget_mapRtRuntimeErrorR;R(RRtmapping((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pytget_keys
cCs|jS(s3 Return a mapping of file objects to selector keys (RA(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRP
scCs(y|j|SWntk
r#dSXdS(s_ Return the key associated to a given file descriptor
         Return None if it is not found. N(R8R;R(RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt_key_from_fds
cCs|S(N((R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt	__enter__scGs|jƒdS(N(RO(RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt__exit__sN(RRR?RR:RRFRJRLRRORSRPRTRURV(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR@–s					
			RtSelectSelectorcBsDeZdZd„Zdd„Zd„Zdd„Zdd„ZRS(s Select-based selector. cCs/tt|ƒjƒtƒ|_tƒ|_dS(N(RRWRtsett_readerst_writers(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR!scCsbtt|ƒj|||ƒ}|t@r>|jj|jƒn|t@r^|jj|jƒn|S(N(	RRWRFRDRYtaddRRERZ(RRR2R3RC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRF&s

cCsBtt|ƒj|ƒ}|jj|jƒ|jj|jƒ|S(N(RRWRJRYtdiscardRRZ(RRRC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRJ.scCstj||g|ƒS(s? Wrapper for select.select because timeout is a positional arg (R(RtrtwR"((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt_select4sc	Cst|jƒr$t|jƒr$gS|dkr6dnt|dƒ}g}t|jt|j|j|ƒ\}}}t|ƒ}t|ƒ}x|||BD]p}d}||kr½|t	O}n||krÖ|t
O}n|j|ƒ}|r˜|j|||j
@fƒq˜q˜W|S(Ngi(R7RYRZRtmaxR!R_tTrueRXRDRERTtappendR2(	RR"treadyR]R^RRR2RC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR8s$ !

!N(	RRR?RRRFRJR_R(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRWs		tpolltPollSelectorcBsDeZdZd„Zdd„Zd„Zdd„Zdd„ZRS(s Poll-based selector cCs&tt|ƒjƒtjƒ|_dS(N(RReRRRdt_poll(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRSscCsrtt|ƒj|||ƒ}d}|t@r>|tjO}n|t@rX|tjO}n|jj|j	|ƒ|S(Ni(
RReRFRDRtPOLLINREtPOLLOUTRfR(RRR2R3RCt
event_mask((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRFWs

cCs/tt|ƒj|ƒ}|jj|jƒ|S(N(RReRJRfR(RRRC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRJascCsM|dk	r7|dkr!d}q7tj|dƒ}n|jj|ƒ}|S(sj Wrapper function for select.poll.poll() so that
            _syscall_wrapper can work with only seconds. ig@@N(RtmathtceilRfRd(RR"R.((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt
_wrap_pollfs	cCs§g}t|jtd|ƒ}x‚|D]z\}}d}|tj@rR|tO}n|tj@rm|tO}n|j|ƒ}|r%|j	|||j
@fƒq%q%W|S(NR"i(R!RlRaRRgRERhRDRTRbR2(RR"Rct	fd_eventsRRiR2RC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRts

!N(	RRR?RRRFRJRlR(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyReQs	
	tepollt
EpollSelectorcBsJeZdZd„Zd„Zdd„Zd„Zdd„Zd„Z	RS(s Epoll-based selector cCs&tt|ƒjƒtjƒ|_dS(N(RRoRRRnt_epoll(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRˆscCs
|jjƒS(N(RpR(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRŒscCsxtt|ƒj|||ƒ}d}|t@r>|tjO}n|t@rX|tjO}nt|j	jt
|j|ƒ|S(Ni(RRoRFRDRtEPOLLINREtEPOLLOUTR!RpR%R(RRR2R3RCtevents_mask((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRFs

cCsMtt|ƒj|ƒ}yt|jjt|jƒWntk
rHnX|S(N(RRoRJR!RpR%RR(RRRC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRJ™s
c	Cs|dk	rG|dkr!d}ntj|dƒd}t|ƒ}nd}tt|jƒdƒ}g}t|jj	t
d|d|ƒ}x‚|D]z\}}d}|tj@rÀ|t
O}n|tj@rÛ|tO}n|j|ƒ}|r“|j|||j@fƒq“q“W|S(	Nigg@@gü©ñÒMbP?gð¿iR"t	maxevents(RRjRkR&R`R7R8R!RpRdRaRRqRERrRDRTRbR2(	RR"t
max_eventsRcRmRRiR2RC((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyR¢s*		

!cCs$|jjƒtt|ƒjƒdS(N(RpRORRo(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyROÃs
N(
RRR?RRRRFRJRRO(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRo†s		
		!tkqueuetKqueueSelectorcBsJeZdZd„Zd„Zdd„Zd„Zdd„Zd„Z	RS(s  Kqueue / Kevent-based selector cCs&tt|ƒjƒtjƒ|_dS(N(RRwRRRvt_kqueue(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRËscCs
|jjƒS(N(RxR(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRÏscCs¶tt|ƒj|||ƒ}|t@rhtj|jtjtjƒ}t	|j
jt|gddƒn|t
@r²tj|jtjtjƒ}t	|j
jt|gddƒn|S(Ni(RRwRFRDRtkeventRtKQ_FILTER_READt	KQ_EV_ADDR!RxtcontrolR%REtKQ_FILTER_WRITE(RRR2R3RCRy((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRFÒs
"
"cCsætt|ƒj|ƒ}|jt@r}tj|jtjtj	ƒ}y#t
|jjt
|gddƒWq}tk
ryq}Xn|jt@râtj|jtjtj	ƒ}y#t
|jjt
|gddƒWqâtk
rÞqâXn|S(Ni(RRwRJR2RDRRyRRztKQ_EV_DELETER!RxR|R%RRER}(RRRCRy((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRJäs$
#

#
cCs9|dk	rt|dƒ}nt|jƒd}i}t|jjtd||ƒ}xÑ|D]É}|j}|j	}d}|t
jkr–|tO}n|t
j
kr²|tO}n|j|ƒ}	|	r\|	j|kró|	||	j@f||	j<q%||	jd}
|	||
B|	j@f||	j<q\q\Wt|jƒƒS(Niii(RR`R7R8R!RxR|RatidenttfilterRRzRDR}RERTRR2R(RB(RR"Rut	ready_fdstkevent_listRyRRiR2RCt
old_events((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRùs*
		

%cCs$|jjƒtt|ƒjƒdS(N(RxRORRw(R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyROs
N(
RRR?RRRRFRJRRO(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyRwÉs			cCsgyF|dkr+tjƒ}|jdƒntt|ƒƒjƒtSWnttfk
rb}tSXdS(s
 Checks that select structs can be allocated by the underlying
    operating system, not just advertised by the select module. We don't
    check select() because we'll be hopeful that most platforms that
    don't have it available will not advertise it. (ie: GAE) RdiN(RRdtgetattrRORaRRR%(tstructtpR ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt
_can_allocatescCsytdkrrtdƒr!taqrtdƒr6taqrtdƒrKtaqrttdƒrctaqrt	dƒ‚ntƒS(sº This function serves as a first call for DefaultSelector to
    detect if the select module is being monkey-patched incorrectly
    by eventlet, greenlet, and preserve proper behavior. RvRnRdRs!Platform does not have a selectorN(
t_DEFAULT_SELECTORRR‡RwRoReRRRWR(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pytDefaultSelector5s				ii(ii($RRjRRHtsysttimetcollectionsRRR'RtImportErrorRDRERat
HAS_SELECTtobjectR)RRˆt	ExceptionRRtversion_infoR!R1R4R@RRWReRoRwR%R‡R‰(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/urllib3/util/selectors.pyt<module>sF

			8ˆ14BR		

Products

About

Resources

Contact Gemfury