HEX

Warning: set_time_limit() [function.set-time-limit]: Cannot set time limit - prohibited by configuration in /home/u547966/brikov.ru/www/wp-content/plugins/admin-menu-editor/menu-editor.php on line 745
Server: Apache
System: Linux 4.19.0-0.bpo.9-amd64 x86_64 at red40
User: u547966 (5490)
PHP: 5.3.29-mh2
Disabled: syslog, dl, popen, proc_open, proc_nice, proc_get_status, proc_close, proc_terminate, posix_mkfifo, chown, chgrp, accelerator_reset, opcache_reset, accelerator_get_status, opcache_get_status, pcntl_alarm, pcntl_fork, pcntl_waitpid, pcntl_wait, pcntl_wifexited, pcntl_wifstopped, pcntl_wifsignaled, pcntl_wifcontinued, pcntl_wexitstatus, pcntl_wtermsig, pcntl_wstopsig, pcntl_signal, pcntl_signal_dispatch, pcntl_get_last_error, pcntl_strerror, pcntl_sigprocmask, pcntl_sigwaitinfo, pcntl_sigtimedwait, pcntl_exec, pcntl_getpriority, pcntl_setpriority
Upload Files
File: //usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyc
ó
ÛXc@@sdZddlmZyddlZejWn ek
rOddljZnXddlZej	e
ƒZdefd„ƒYZ
dejfd„ƒYZdefd	„ƒYZd
efd„ƒYZdefd
„ƒYZdefd„ƒYZdefd„ƒYZdS(s¨Reader objects to abstract out different body response types.

This module is package-private. It is not expected that these will
have any clients outside of httpplus.
i(tabsolute_importNtReadNotReadycB@seZdZRS(s>Raised when read() is attempted but not enough data is loaded.(t__name__t
__module__t__doc__(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR/stHTTPRemoteClosedErrorcB@seZdZRS(s@The server closed the remote socket in the middle of a response.(RRR(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR3stAbstractReadercB@sbeZdZd„Zd„Zd„Zd„Zd„Zd„Zd
d„Z
d„Zd	„ZRS(sòAbstract base class for response readers.

    Subclasses must implement _load, and should implement _close if
    it's not an error for the server to close their socket without
    some termination condition being detected during _load.
    cC@st|_g|_d|_dS(Ni(tFalset	_finishedt_done_chunkstavailable_data(tself((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt__init__>s		cC@s)|jj|ƒ|jt|ƒ7_dS(N(R	tappendR
tlen(Rtdata((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt	_addchunkCscC@s,|jjd|ƒ|jt|ƒ7_dS(Ni(R	tinsertR
R(RR((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt
_pushchunkGscC@s+|jjdƒ}|jt|ƒ8_|S(Ni(R	tpopR
R(Rtb((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt	_popchunkKscC@s|jS(s3Returns true if the response body is entirely read.(R(R((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pytdoneQscC@sö|j|kr%|jr%tƒ‚ng}|}x||jr¯|jƒ}t|ƒ|kr|| }|j||ƒ|}n|j|ƒ|t|ƒ8}|dkr4Pq4q4Wdj|ƒ}t|ƒ|ksò|jrìt|ƒ|ksòt	‚|S(s&Read amt bytes from the response body.it(
R
RRR	RRRR
tjointAssertionError(RtamttblockstneedRtnbtresult((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pytreadUs"
	
3cC@sœ|dkrg}nx€|jr—|jƒ}|j|ƒt|ƒ}|r‡|t|ƒkrr|j||ƒn|j|| ƒPq|j|ƒqW|S(slreturn available data chunks up to the first one in which
        delimstr occurs. No data will be returned after delimstr --
        the chunk in which it occurs will be split and the remainder
        pushed back onto the available data queue. If blocks is
        supplied chunks will be added to blocks, otherwise a new list
        will be allocated.
        N(tNoneR	RtfindRRR
(RtdelimstrRRti((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pytreadtojs	cC@s
t‚dS(s5Subclasses must implement this.

        As data is available to be read out of this object, it should
        be placed into the _done_chunks list. Subclasses should not
        rely on data remaining in _done_chunks forever, as it may be
        reaped if the client is parsing data as it comes in.
        N(tNotImplementedError(RR((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt_load‚scC@s|jstdƒ‚ndS(s¬Default implementation of close.

        The default implementation assumes that the reader will mark
        the response as finished on the _finished attribute once the
        entire response body has been read. In the event that this is
        not true, the subclass should override the implementation of
        close (for example, close-is-end responses have to set
        self._finished in the close handler.)
        s5server appears to have closed the socket mid-responseN(RR(R((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt_closeŒs
	N(
RRRRRRRRRR R$R&R'(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR7s							
tAbstractSimpleReadercB@seZdZd„ZRS(sÄAbstract base class for simple readers that require no response decoding.

    Examples of such responses are Connection: Close (close-is-end)
    and responses that specify a content length.
    cC@sP|r#|js#td|ƒ‚ntjd|jt|ƒƒ|j|ƒdS(Ns*tried to add data (%r) to a closed reader!s%s read an additional %d data(RRtloggertdebugtnameRR(RR((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR&¡s
	(RRRR&(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR(›stCloseIsEndReadercB@seZdZdZd„ZRS(s?Reader for responses that specify Connection: Close for length.sclose-is-endcC@stjdƒt|_dS(Ns&Marking close-is-end reader as closed.(R)tinfotTrueR(R((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR'®s
(RRRR+R'(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR,ªstContentLengthReadercB@s&eZdZdZd„Zd„ZRS(s:Reader for responses that specify an exact content length.scontent-lengthcC@s;tj|ƒ||_|dkr.t|_nd|_dS(Ni(R(Rt_amountR.Rt_amount_seen(Rtamount((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR·s

	cC@sTtj||ƒ|jt|ƒ7_|j|jkrPt|_tjdƒndS(Nscontent-length read complete(	R(R&R1RR0R.RR)R*(RR((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR&¾s
	(RRRR+RR&(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR/³s	t
ChunkedReadercB@s eZdZd„Zd„ZRS(s/Reader for chunked transfer encoding responses.cC@s,tj|ƒ||_d|_d|_dS(NiR(RRt_eolt_leftover_skip_amtt_leftover_data(Rteol((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyRÈs
		cC@s‡|jstdƒ‚tjdt|ƒƒd}|jrstjdƒ|j|}|j}d|_d|_nt|ƒ}x||kr‚|j|j|ƒ}|dkrÅ||_||_dSt	|||!ddƒ}|t|jƒ}||t|jƒt|ƒkr*||_||_dS|dkrPt
|_tjd	ƒdS|j||||!ƒ||t|jƒ}q‚WdS(
Ns%tried to add data to a closed reader!s"chunked read an additional %d datais8chunked reader trying to finish block from leftover dataRiÿÿÿÿtbaseis/closing chunked reader due to chunk of length 0(RRR)R*RR6R5R!R4tintR.R(RRtpositiontdatalentsplitRtblock_start((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR&Îs:	
				#			
(RRRRR&(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyR3Æs	(Rt
__future__Rthttplibt
HTTPExceptiontImportErrorthttp.clienttclienttloggingt	getLoggerRR)t	ExceptionRRtobjectRR(R,R/R3(((sA/usr/lib/python2.7/dist-packages/mercurial/httpclient/_readers.pyt<module>!s
d