Ñò ýɪWc @sƒddkZddkZddkZddkZddkZddkZdefd„ƒYZd„Ze djo eƒndS(iÿÿÿÿNt SSHCommandercBsweZdZd„Zd„Zd„Zd„Zd„Zd„Zd dd„Z d „Z d „Z d „Z d „ZRS(s class docscCsÔ||_||_||_d|_d|_d|_tidƒ|_ |i i ti ƒd}ti |ƒ}ti ƒ}|i|ƒ|i i|ƒ|i i|_|i i|_|i i|_|iƒdS(NiiRs<%(asctime)s SSHCommander:%(funcName)s:%(lineno)d %(message)s(t _usernamet _passwordt_hostt_porttNonet transporttbufsizetloggingt getLoggertloggertsetLeveltINFOt Formattert StreamHandlert setFormattert addHandlertinfotdebugterrortconnect(tselftserveriptusernametpasswordtfmttformaterthandler((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pyt__init__s"        cCs.|idj o|iiƒd|_ndS(N(RRtclose(R((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pyt__del__&s cCs+|iƒp|iiƒd|_ndS(N(tisClosedtclientRR(R((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pytlogout+s  cCsÁtiƒ|_|iiƒ|iitiƒƒyK|ii|i|i|i |i ƒ|ii ƒ|_ |i i tƒWn=tij od|_ n tij od|_ nXdS(sTry to connect, maybe again.N(tparamikot SSHClientR tload_system_host_keystset_missing_host_key_policyt AutoAddPolicyRRRRRt get_transportRtuse_compressiontTruetsocketRRtBadAuthenticationType(R((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pyR0s % cCs`|idjotS|iiƒ}|djp|iƒ p|iƒ o|iƒtStS(s.Try to judge whether connect is closed or not.N(R RR)R't is_activeR!tFalse(RR((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pyRBs) cCs¡|id|ƒ|ii|ƒ\}}}|iƒ}x%|o|i|ƒ|iƒ}q;W|iƒ}x%|o|i|ƒ|iƒ}qoW|iiƒS(Ns Start to execute SSH command: %s(RR t exec_commandtreadlineRtreadtchanneltrecv_exit_status(Rtcmdt ssh_stdint ssh_stdoutt ssh_stderrtlinestr((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pytexecuteNs    icCsŒ|idjodd|fS|i|ƒ}|iiƒ}|itƒ|iƒ|i|ƒ|i|||ƒ}|i ƒ}||fS(NiÿÿÿÿsSSH command: %s executed failed( RRt_run_fix_input_datat open_sessiontset_combine_stderrR)tget_ptyR.t _run_pollR2(RR3t input_datattimeouttsessiontoutputtstatus((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pytexecute_interactive[s    cCsk|idid|d|ƒƒ|iiƒ}|i||ƒ|iƒ|idid|d|ƒƒdS(Ns&SFTP Get: {remotepath} {localpath} ...t remotepatht localpaths(SFTP Get: {remotepath} {localpath} done.(RtformatR t open_sftptgetR(RRDREtsftp((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pytexecuteSftpGetls  cCsk|idid|d|ƒƒ|iiƒ}|i||ƒ|iƒ|idid|d|ƒƒdS(Ns&SFTP Put: {localpath} {remotepath} ...RERDs'SFTP Put: {localpath} {remotepath} done(RRFR RGtputR(RRERDRI((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pytexecuteSftpPutss  cCse|dj oTt|ƒdjo3d|jo"|idƒ}di|ƒ}qSn|idƒSgS(s­ Fix the input data supplied by the user for a command. @param input_data The input data (default is None). @returns the fixed input data. is\ns N(Rtlentsplittjoin(RR>tlines((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pyR9zs  cCsd}|}||}d}t}tiiƒ} ti| iƒƒ} d} |idƒxto|iƒo|i |i ƒ} | | 7} |i dt | ƒt | ƒfƒ|i ƒo@|t |ƒjo)||d} |d7}|i| ƒqüqn|iƒoPntiiƒ} ti| iƒƒ}|| }||jo|idƒt}Pntidƒq\W|i d ƒ|iƒoC|i |i ƒ} | | 7} |i dt | ƒt | ƒfƒn|i d t | ƒƒ|o)|i d ƒ| d |7} |iƒn| S( sÖ Poll until the command completes. @param session The session. @param timeout The timeout in seconds. @param input_data The input data. @returns the output gš™™™™™¹?itsread %d bytes, total %ds ispolling finished - timeoutgš™™™™™É?spolling loop endeds"polling finished - %d output bytessappending timeout messages! ERROR: timeout after %d seconds (R-tdatetimetnowttimetmktimet timetuplet setblockingR)t recv_readytrecvRRRMt send_readytsendtexit_status_readyRtsleepR(RR@R?R>tintervalt maxsecondstmaxcountt input_idxt timeout_flagtstartt start_secsRAtdataRStnow_secstet_secs((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pyR=ŠsR     #         ' N(t__name__t __module__t__doc__RRR!RRR8RRCRJRLR9R=(((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pyR s        c Cs¢d }zyItdddƒ}|iddƒ\}}|djot|ƒnWn/tj o#dtiƒGHtidƒnXWd |o|iƒnXd S( smain function.s 127.0.0.1tcmstcms1234s9su root -c 'export PATH=$PATH:/sbin; service cms status'troot1234isUnexpected error:iN( RRRCtexitt Exceptiont tracebackt format_exctsysR!(R3tretCodeRA((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pytmainÊs t__main__( R"RpR*RTRRRtobjectRRtRh(((sf/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/SSHCommander.pyts      ¿