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/commandserver.pyc

Xc@@sddlmZddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlm
Z
ddlmZmZmZdadZdefdYZd	efd
YZdefdYZd
ZdZdefdYZdZdZdefdYZdefdYZied6ed6Z dZ!dS(i(tabsolute_importNi(t_(tencodingterrortutilcG@s<ts
dSx!|D]}tjt|qWtjdS(N(tlogfiletwritetstrtflush(targsta((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytlogs

tchanneledoutputcB@s8eZdZdZedZdZdZRS(s^
    Write data to out in the following format:

    data length (unsigned int),
    data
    cC@s||_||_dS(N(touttchannel(tselfR
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt__init__.s	cC@sd|jS(Ns<%c-channel>(R(R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytname2scC@sS|s
dS|jjtjd|jt||jj||jjdS(Ns>cI(R
RtstructtpackRtlenR(Rtdata((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR6s
(cC@s+|dkrt|nt|j|S(Ntisattytfilenottelltseek(RRRR(tAttributeErrortgetattrR
(Rtattr((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt__getattr__=s(t__name__t
__module__t__doc__RtpropertyRRR(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR's
		tchanneledinputcB@sheZdZdZdZedZddZdZddZ	d	Z
d
ZdZRS(
s/
    Read data from in_.

    Requests for input are written to out in the following format:
    channel identifier - 'I' for plain input, 'L' line based (1 byte)
    how many bytes to send at most (unsigned int),

    The client replies with:
    data length (unsigned int), 0 meaning EOF
    data
    iicC@s||_||_||_dS(N(tin_R
R(RR#R
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRQs		cC@sd|jS(Ns<%c-channel>(R(R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRVsicC@sw|dkr`|j}|j||j}|}x)|r[|j||j}||7}q3W|S|j||jSdS(Ni(tmaxchunksizet_readR(Rtsizetstbuf((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytreadZs		cC@s|s
dS|dkst|jjtjd|||jj|jjd}tjd|d}|szdS|jj|SdS(Ntis>cIis>I(	tAssertionErrorR
RRRRR#R)tunpack(RR&Rtlength((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR%is
cC@s~|dkrj|j}|j|d}|}x6|re|ddkre|j|d}||7}q0W|S|j|dSdS(NitLis
(R$R%(RR&R'R(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytreadlineys	cC@s|S(N((R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt__iter__scC@s|j}|stn|S(N(R/t
StopIteration(Rtl((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytnexts	cC@s+|dkrt|nt|j|S(NRRRR(RRRR(RRR#(RR((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRsi(
RRR R$RR!RR)R%R/R0R3R(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR"Bs				tservercB@sseZdZdZdZdZdZdZdZdZ	dZ
ied	6e	d
6ZdZRS(sm
    Listens for commands on fin, runs them and writes the output on a channel
    based stream to fout.
    cC@stj|_|jddd}|rZ|dkrHt|daqZt|dan|r|j|_	||_
|j	|_n||_	d|_
|_t|d|_t|d|_
t||d|_t|d	|_||_dS(
Nt	cmdserverRt-tdR
tetotItr(tostgetcwdtcwdtconfigtNoneRRtopentbaseuituitrepotrepouitcerrtcoutR"tcintcresulttclient(RRCRDtfintfouttlogpath((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRs"		cC@sdS(s9release and restore resources taken during server sessionN((R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytcleanupscC@s/|s
dS|jj|}|s+tn|S(NR*(RJR)tEOFError(RR&R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR%s	cC@s6tjd|jdd}|s)dS|j|S(s[read a string from the channel

        format:
        data length (uint32), data
        s>IiiR*(RR,R%(RR-((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt_readstrscC@s'|j}|r|jdSgSdS(s6read a list of NULL separated strings from the channelsN(RPtsplit(RR'((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt	_readlists
c	C@srddlm}|j}|jj}|g}|jr||j_|jj|j}|j|_|j	|||j_|jj
_|jjnxF|D]>}|j
tj|jds|jddddqqW|j|||j|j|j|j}|j|p&dd	@}d
|krLtj|jn|jjtjdt|dS(
sk reads a list of  terminated arguments, executes
        and writes the return code to the result channel i(tdispatchRRCtnonttyttruet
commandserveriis--cwds>iN(R*RSRRRCtcopyRDRBREt	__class__tappendtdirstatet_uit
invalidateallt
resetstateRtsafehasattrRHt	setconfigtrequestRGRFR<tchdirR>RIRRRtint(	RRSR	tcopieduituisRERCtreqtret((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
runcommands*		


cC@s|jjtjdS(s3 writes the current encoding to the result channel N(RIRR(R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytgetencodingscC@sd|jjd }|rZ|jj|}|r>||qZtjtd|n|dkS(Nisunknown command %sR*(RJR/tcapabilitiestgetRtAbortR(Rtcmdthandler((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytserveones
RgRhcC@sddjt|j}|d7}|dtj7}|d7}|dtj7}tjtdr|d7}|dtjd7}n|j	j
|yx|jrqWWntk
rd	SXdS(
Nscapabilities: t s
s
encoding: spid: %dtgetpgidspgid: %dii(
tjointsortedRiRRtgetpidR^R<RpRGRRnRO(Rthellomsg((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytserves



(
RRR RRNR%RPRRRgRhRnRiRu(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR4s						'		

cC@s|jg}tjtjtj}x|jtjdf|jtj	dfgD]h\}}}||krtj
|j}tj||jtj
||}n|j|qSWtj|t|S(sC duplicates streams and redirect original to null if ui uses stdio trbtwb(RR<RAtdevnulltO_RDWRRKtsyststdinRLtstdouttdupRtdup2tfdopenRYtclosettuple(RCtnewfilestnullfdtftsysftmodetnewfd((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
_protectio.s
%
cC@sr|jxa||jf||jfgD]A\}}||k	r)tj|j|j|jq)q)WdS(s' restores streams from duplicated ones N(RRKRLR<R~RR(RCRKRLRtuif((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
_restoreio=s

+tpipeservicecB@s#eZdZdZdZRS(cC@s||_||_dS(N(RCRD(RRCRDtopts((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRFs	cC@sdS(N((R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytinitJscC@sc|j}t|\}}z&t||j||}|jSWd|jt|||XdS(N(RCRR4RDRuRNR(RRCRKRLtsv((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytrunMs	
(RRRRR(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyREs		cC@stjddtjdS(Ni(R<tsetpgidtrandomtseed(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt_initworkerprocessYsc	C@sW|jd}|jd}d}zy|||||}z|y|jWngtjk
r}|jtd|n;tk
r}|jtj	krqnt
k
rnXWd|jXWn;|r|j}nt
|d}tjd|nXWd|jy|jWn+tk
rQ}|jtj	krRqRnXXdS(NRvRws
abort: %s
R8tfile(tmakefileR@RuRRktwarnRtIOErrorterrnotEPIPEtKeyboardInterruptRNRFRt	tracebackt	print_excR(	RCRDtconntcreatecmdserverRKRLRtinstRF((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
_serverequestjs:	

tunixservicehandlercB@sSeZdZdZdZdZdZdZdZ	dZ
dZRS(	sSet of pluggable operations for unix-mode services

    Almost all methods except for createcmdserver() are called in the main
    process. You can't pass mutable resource back from createcmdserver().
    cC@s
||_dS(N(RC(RRC((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRscC@stj||dS(N(Rtbindunixsocket(Rtsocktaddress((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
bindsocketscC@stj|dS(N(R<tunlink(RR((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytunlinksocketscC@s+|jjtd||jjdS(Nslistening at %s
(RCtstatusRR(RR((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytprintbannerscC@stS(s9True if server should shut down; checked per pollinterval(tFalse(R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
shouldexitscC@sdS(s/Called when main process notices new connectionN((R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
newconnectionscC@st|j|||S(shCreate new command server instance; called in the process that
        serves for the current connection(R4RC(RRDRRKRL((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRsN(RRR R@tpollintervalRRRRRRR(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRs						tunixforkingservicecB@sYeZdZd	dZdZdZdZdZdZ	dZ
dZRS(
sG
    Listens on unix domain socket and forks server per connection
    cC@s||_||_|d|_tjtdsItjtdn|jsjtjtdn|pyt	||_
d|_d|_
t|_dS(NRtAF_UNIXsunsupported platforms'no socket path specified with --address(RCRDRRR^tsocketRRkRRt_servicehandlerR@t_sockt_oldsigchldhandlertsett_workerpids(RRCRDRRm((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRs		
			cC@sytjtj|_|jj|j|j|jjtjtjtj	|j
}||_|jj|jdS(N(
RRRRRRtlistent	SOMAXCONNtsignaltSIGCHLDt_sigchldhandlerRR(RR9((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRs	cC@sGtjtj|j|jj|jj|j|jddS(Ni(	RRRRRRRRt_reapworkers(R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt_cleanups
cC@s z|jWd|jXdS(N(t	_mainloopR(R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRscC@sZ|j}xJ|jsUyJtj|jggg|jd}|sLwn|jj\}}Wn>tjtjfk
r}|jdt	j
krqnnXtj}|rz2|j
jd||jj||jWd|jXqy(|j||jtjdWqz|j
jdtWdtjdXqXqWdS(Nisforked worker process (pid=%d)
tforcei(RRtselectRRtacceptRRR	RtEINTRR<tforkRCtdebugRtaddRRt
_runworkert_exitRtTrue(RthtreadyRt_addrRtpid((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRs4	%

cC@s|jtjdS(N(RR<tWNOHANG(RRtframe((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRscC@sx|jrytjd|\}}WnQtk
r{}|jtjkrRqn|jtjkrjn|jjdSX|dkrdS|jj	d||jj
|qWdS(Niisworker process exited (pid=%d)
(RR<twaitpidtOSErrorRRtECHILDtclearRCRtdiscard(RtoptionsRt_statusR((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRs
cC@sXtjtj|jt|j}z t|j|j||jWdt	j
XdS(N(RRRRRRRCRDRtgctcollect(RRR((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR
s	 N(RRR R@RRRRRRRR(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRs
				 		tpipetunixcC@sS|d}yt||||SWn*tk
rNtjtd|nXdS(NR5sunknown mode %s(t_servicemaptKeyErrorRRkR(RCRDRR((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
createservices


("t
__future__RRRR<RRRRRRzRti18nRR*RRRR@RRtobjectRR"R4RRRRRRRRR(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt<module>s8		T				$#e