korsygfhrtzangaiide
Elepffwdsff
/
lib64
/
python2.7
/
site-packages
/
mercurial
/
Upload FileeE
HOME
� 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| d k s t � | j j t j d | | � � | j j � | j j d � } t j d | � d } | sz d S| j j | � Sd S( Nt i s >cIi s >I( t AssertionErrorR 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" ( RG 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 requestRE RC RB R5 t chdirR7 RF 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( RF 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" ( RG R' t capabilitiest getRH RI R ( R t cmdt handler( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt serveone� s R[ 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\ RC R Rb RL ( R t hellomsg( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt serve� s ( R R R R R R[ R] Rb R^ Rg ( ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyR, � s ( t i18nR R R: R5 RT R\ RH R9 R R t objectR R R, ( ( ( s= /usr/lib64/python2.7/site-packages/mercurial/commandserver.pyt <module> s $ P