|
Server : Apache System : Linux cs317.bluehost.com 4.19.286-203.ELK.el7.x86_64 #1 SMP Wed Jun 14 04:33:55 CDT 2023 x86_64 User : andertr9 ( 1047) PHP Version : 8.2.18 Disable Function : NONE Directory : /lib64/python2.7/site-packages/mercurial/ |
Upload File : |
�
Hq�Qc @ s� d d l m Z 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 a d � Z
d e f d � � YZ d e f d � � YZ
d e f d � � YZ d S(
i����( t _Nc G s< t s
d Sx! | D] } t j t | � � q Wt j � d S( N( t logfilet writet strt flush( t argst a( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt log s
t channeledoutputc B s) e Z d Z d � Z d � Z d � Z RS( sg
Write data from in_ to out in the following format:
data length (unsigned int),
data
c C s | | _ | | _ | | _ d S( N( t in_t outt channel( t selfR R
R ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt __init__ s c C sS | s
d S| j j t j d | j t | � � � | j j | � | j j � d S( Ns >cI( R
R t structt packR t lenR ( R t data( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR $ s
(c C s+ | d k r t | � � n t | j | � S( Nt isattyt fileno( s isattys fileno( t AttributeErrort getattrR ( R t attr( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt __getattr__+ s ( t __name__t
__module__t __doc__R
R R ( ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR s t channeledinputc B sY e Z d Z d Z d � Z d d � Z d � Z d d � Z d � Z d � Z d
� Z
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
i i c C s | | _ | | _ | | _ d S( N( R R
R ( R R R
R ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR
? s i����c C sw | d k r` | j } | j | | j � } | } x) | r[ | j | | j � } | | 7} q3 W| S| j | | j � Sd S( Ni ( t maxchunksizet _readR ( R t sizet st buf( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt readD s c C s| | s
d S| j j t j d | | � � | j j � | j j d � } t j d | � d } | sh d S| j j | � Sd S( Nt s >cIi s >Ii ( R
R R R R R R! t unpack( R R R t length( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR S s
c C s~ | d k rj | j } | j | d � } | } x6 | re | d d k re | j | d � } | | 7} q0 W| S| j | d � Sd S( Ni t Li����s
( R R ( R R R R ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt readlinec s c C s | S( N( ( R ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt __iter__r s c C s | j � } | s t � n | S( N( R& t
StopIteration( R t l( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt nextu s c C s+ | d k r t | � � n t | j | � S( NR R ( s isattys fileno( R R R ( R R ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR { s i ( R R R R R
R! R R& R' R* R ( ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR 0 s t serverc B sX e Z d Z d � Z d � Z d � Z d � Z d � Z i e d 6e d 6Z d � Z RS( sq
Listens for commands on stdin, runs them and writes the output on a channel
based stream to stdout.
c C s( t j � | _ | j d d d � } | rc | d k rQ t t j t j d � a qc t | d � a n | j
| _ | | _ | j | _
| d k r t t j t j d � | _ t t j t j d � | _ t t j t j d � | _ t t j t j d
� | _ t j | _ n t j t d � | � � d S( Nt cmdserverR t -t dR t pipet et ot It rs unknown mode %s( t ost getcwdt cwdt configt NoneR t syst stdoutR t opent baseuit uit repot repouit stderrt cerrt coutR t stdint cint cresultt clientt utilt AbortR ( R R= R> t modet logpath( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR
� s c C s/ | s
d S| j j | � } | s+ t � n | S( NR" ( RF R! t EOFError( R R R ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR � s c C s" t j d | j d � � d } | s. g } n | j | � j d � } | j j � } | | j _ | j j � | j _ | j j _
| j j � | j j � t
j | | | j | j | j | j � } t
j
| � p� d } d | k r� t j | j � n | j j t j d t | � � � d S( sk reads a list of terminated arguments, executes
and writes the return code to the result channel s >Ii i t s --cwds >iN( R R# R t splitR= t copyR> R< R? t dirstatet _uit
invalidatet invalidatedirstatet dispatcht requestRD RB RA R4 t chdirR6 RE R R t int( R R$ R t copieduit reqt ret( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt
runcommand� s "
c C s | j j t j � d S( s3 writes the current encoding to the result channel N( RE R t encoding( R ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt getencoding� s c C sd | j j � d } | rZ | j j | � } | r> | | � qZ t j t d � | � � n | d k S( Ni����s unknown command %sR" ( RF R& t capabilitiest getRG RH R ( R t cmdt handler( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt serveone� s
RZ R\ c C sw d d j t | j � � } | d 7} | d t j 7} | j j | � y x | j � r\ qM WWn t k
rr d SXd S( Ns capabilities: t s
s
encoding: i i ( t joint sortedR] R[ RB R Ra RK ( R t hellomsg( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt serve� s
(
R R R R
R RZ R\ Ra R] Rf ( ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR+ � s
( t i18nR R R9 R4 RS R[ RG R8 R R t objectR R R+ ( ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt <module> s $ P