korsygfhrtzangaiide
Elepffwdsff
/
lib64
/
python2.7
/
site-packages
/
mercurial
/
Upload FileeE
HOME
� Hq�Qc @ sb 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 e f d � � YZ d S( i����Nt sshserverc B s� e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z i e e 6e e j 6e e j 6e e j 6e e j 6Z d � Z d � Z d � Z d � Z d � Z RS( c C sz | | _ | | _ d | _ | j | _ | j | _ t j t � | j | _ | j _ t j | j � t j | j � d S( N( t uit repot Nonet lockt fint foutt hookt redirectt Truet ferrt utilt setbinary( t selfR R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt __init__ s c C s6 i } | j � } xt t | � � D]� } | j j � d } | j � \ } } | | k rr t j d | � � n | d k r� i } xa t t | � � D]M } | j j � d } | j � \ } } | j j t | � � } | | | <q� W| | d <q% | j j t | � � } | | | <q% Wg | D] } | | ^ q"S( Ni����s unexpected parameter %rt *( t splitt xranget lenR t readlineR t Abortt intt read( R t argst datat keyst nt arglinet argt lt start kt val( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt getargs s$ c C s | j | � d S( Ni ( R! ( R t name( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt getarg0 s c C sa | j d � t | j j � � } x8 | r\ | j | j j | � � t | j j � � } q% Wd S( Nt ( t sendresponseR R R t writeR ( R t fpoutt count( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt getfile3 s c C s d S( N( ( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyR : s c c s/ x( t r* | j d � } | s" Pn | Vq Wd S( Ni ( R R ( R t changegroupt d( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt groupchunks= s c C s; | j j d t | � � | j j | � | j j � d S( Ns %d ( R R& R t flush( R t v( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyR% D s c C s; | j j } x | j D] } | | � q W| j j � d S( N( R R& t genR- ( R t sourceR& t chunk( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt sendstreamI s c C s' | j d � | j t | j � � d S( NR$ ( R% t strt res( R t rsp( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt sendpushresponseO s c C s | j | j � d S( N( R% R4 ( R R5 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt sendpusherrorS s c C sK | j j j d | j � | j j j � | j j d � | j j � d S( Ns %s - s ( R R R& t messageR- R ( R R5 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt sendooberrorV s c C sK z x | j � r q WWd | j d k r9 | j j � n Xt j d � d S( Ni ( t serve_oneR R t releaset syst exit( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt serve_forever\ s c C s� | j j � d } | rZ | t j k rZ t j | j | | � } | j | j | | � nZ | r� t | d | d � } | r� | � } | d k r� | j | � q� q� | j d � n | d k S( Ni����t do_R$ ( R R t wireprotot commandst dispatchR t handlerst __class__t getattrR R% ( R t cmdR5 t implt r( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyR: m s c C s | j j � | _ d S( s< DEPRECATED - allowing remote client to lock repo is not safeR$ ( R R ( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt do_lock{ s c C s& | j r | j j � n d | _ d S( t DEPRECATEDR$ N( R R; R ( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt do_unlock� s c C sq | j s | j d � d S| j d � t j | j d � } | j j | d | j � � } | j j � t | � S( RJ s not lockedNR$ t UNt serve( R R% R* t unbundle10R R t addchangegroupt _clientR; R3 ( R t cgRH ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt do_addchangegroup� s c C s- t j j d d � j d d � d } d | S( Nt SSH_CLIENTR$ t i i s remote:ssh:( t ost environt getR ( R t client( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyRP � s %( t __name__t __module__R R! R# R) R R, R% R2 R6 R7 R9 R> R3 R@ t streamrest pushrest pusherrt ooberrorRC R: RI RK RR RP ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyR s. ( R R R@ R* RU R< t objectR ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/sshserver.pyt <module> s 0