ó j4Vdc@€sddlmZddlZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z m Z ddlZddlmZmZddlmZddlmZe rÙddlZnd „Zd „Zd „Zd efd „ƒYZd„ZdS(iÿÿÿÿ(twith_statementN(tselect(tenvtoutputtwin32(t get_passwordt set_password(tssht normalize(t RingBuffer(tCommandTimeoutcC€s*|dt|ƒ}t|ƒ}||kS(Niÿÿÿÿ(tlentlist(t char_listt substringttail((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyt _endswiths cC€sd|kpd|kS(Ns s ((tbytelist((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyt _has_newlinescO€st||ŽjƒdS(N(t OutputLoopertloop(targstkwargs((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyt output_loopsRcB€s>eZd„Zd„Zd„Zd„Zd„Zd„ZRS(cC€sË||_||_||_||_t||ƒ|_dtj|dkrQdndf|_tt |dkrvdndƒ|_ tj p‘tj |_ t |_d|_tgdt|jƒƒ|_dS( Ns [%s] %s: trecvtoutterrtstdouttstderritmaxlen(tchantstreamtcapturettimeouttgetattrt read_funcRt host_stringtprefixRtprintingtlinewisetparalleltFalsetrepromptt read_sizeR R t write_buffer(tselfRtattrRR R!((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyt__init__$s    $  cC€s=|jj|ƒtjs)|jjƒn|jj|ƒdS(N(RtwriteRR'tflushR,textend(R-ttext((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyt_flush4s cC€s¯t}t}g}tjs'd|_ntjƒ}xAtrvy|j|jƒ}WnZtj k r®tjƒ|}|j d k r6||j kr6t d|j ƒ‚q6q6nX|dkr÷|j ró|ró|j |jƒ|j dj|ƒƒnPn|jd kr|j |ƒq6|jr‹|}|ddkr>t}n|ddkrg|rg|d}t}nxÙt|ƒrB|dkrBtjd|ƒ}|d kr¤Pn||jdƒ } ||jdƒ}|sã|j |jƒnt| ƒrød} n|j r(|j dj|ƒ| dƒg}n|j | dƒt}qjW|j r\||g7}q‹|s{|j |jƒt}n|j |ƒntjd |ƒ} xÓ| D]Ë} |j| 7_|jƒ\} } | r|jdt| ƒ3|jjt| ƒdƒq¤t|jtjƒ}t|jtjdƒpFt|jtjd ƒ}|r\|jƒq¤|r¤|j ƒq¤q¤Wq6W|jr«dj|j!ƒ|jkr«|j dƒnd S( s‰ Loop, reading from .(), writing to and buffering to . Will raise `~fabric.exceptions.CommandTimeout` if network timeouts continue to be seen past the defined ``self.timeout`` threshold. (Timeouts before then are considered part of normal short-timeout fast network reading; see Fabric issue #733 for background.) tR!iÿÿÿÿs is is( | | )s (\r|\n|\r\n)s N("R)Rt output_prefixR%ttimetTrueR#R+tsocketR!tNoneR R'R4tjoinR R&Rtretsearchtstarttendtsplitt_get_prompt_responseR RtsendalltstrRt sudo_promptt again_prompttpromptt try_againR,(R-tinitial_prefix_printedtseen_crtlineR>Rtelapsedtprintable_bytestcrt end_of_linet read_linestfragmenttexpectedtresponseRFRG((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyR=s‚                    $cC€stttjƒŒ}|jdttjƒ3| s<|jr|js|j |j ƒ|jr||j tj d|j ƒn|j tjƒnt |j _tjjdddtd|jƒ}t|j _ttjƒ\}}}t||||ƒt |_n|j j|dƒdS(Niÿÿÿÿs RFt tno_colonR(RRRR$R R RDR*R&R4R%RER)Rt input_enabledtfabrictnetworktprompt_for_passwordR8RRRB(R-tpasswordtuserthosttport((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyRF¨s       cC€s&|jttjƒ |_t|_dS(N(R R RRER8R*(R-((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyRGÍscC€s8x1tjjƒD] }t|j|dƒr|SqWdS(s‚ Iterate through the request prompts dict and return the response and original request if we find a match iN(NN(Rtpromptst iteritemsRR R:(R-ttup((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyRAÓs(t__name__t __module__R/R4RRFRGRA(((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyR#s   k % cC€sìxå|jƒsçtr$tjƒ}n=ttjgggdƒ\}}}|o^|dtjk}|rÔ|jrÔtr‚tjƒntjj dƒ}|j |ƒ| rÔt j rÔtj j|ƒtj jƒqÔntjtjƒqWdS(Ngii(texit_status_readyRtmsvcrttkbhitRtsyststdinRUtgetchtreadRBRt echo_stdinRR0R1R7tsleepRtio_sleep(Rt using_ptyt have_chartrtwtxtbyte((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyt input_loopÞs$$ (t __future__RReR7R<R9Rt fabric.stateRRRt fabric.authRRtfabric.networkRVRRt fabric.utilsR tfabric.exceptionsR RcRRRtobjectRRr(((sW/var/www/html/phendo-backend/phendo_python/env/lib/python2.7/site-packages/fabric/io.pyts$        »