ó S \c@@sˆdZddlmZmZddlZejddkrDeZnd„ZeZ ddl m Z ddl Z ddl Z ddlZddlZyddlmZWn!ek rÊddlmZnXdd lmZdd lmZd Zd Zd efd„ƒYZd„Zdefd„ƒYZdefd„ƒYZde fd„ƒYZ!defd„ƒYZ"defd„ƒYZ#dS(sMTerminal management for exposing terminals to a web interface using Tornado. i(tabsolute_importtprint_functionNicC@s|S(N((tx((s3lib/python2.7/site-packages/terminado/management.pyt t(tdeque(tPtyProcessUnicode(t PtyProcess(tgen(tIOLooptPYXTERM_txtermtPtyWithClientscB@sMeZd„Zd„Zejd„Zejd„Zej e d„ƒZ RS(cC@s+||_g|_tgddƒ|_dS(Ntmaxleni (tptyproctclientsRt read_buffer(tselfR((s3lib/python2.7/site-packages/terminado/management.pyt__init__#s  cC@sÒd}}xb|jD]W}|j\}}|dk rJ||krJ|}n|dk r||kr|}qqW|dks‡|dkr‹dS|jjƒ\}}||f||fkrÎ|jj||ƒndS(sSet the terminal size to that of the smallest client dimensions. A terminal not using the full space available is much nicer than a terminal trying to use more than the available space, so we keep it sized to the smallest client. i'N(RtsizetNoneRt getwinsizet setwinsize(Rtminrowstmincolstclienttrowstcols((s3lib/python2.7/site-packages/terminado/management.pytresize_to_smallest+s   cC@s|jj|ƒdS(s'Send a signal to the process in the ptyN(Rtkill(Rtsig((s3lib/python2.7/site-packages/terminado/management.pyRAscC@sHtjdkr|jj|ƒStj|jjƒ}tj||ƒdS(s<Send a signal to the process group of the process in the ptytntN(tostnameRRtgetpgidtpidtkillpg(RRtpgid((s3lib/python2.7/site-packages/terminado/management.pyR$Esc#@sytjdkr$tjtjg}ntjtjtjtjg}tjƒ}‡fd†}ˆj j ƒs~t j t ƒ‚ny«xD|D]<}ˆj|ƒ|ƒVˆj j ƒsˆt j t ƒ‚qˆqˆW|rˆjtjƒ|ƒVˆj j ƒst j t ƒ‚qt j tƒ‚nt j tƒ‚WnItk rt|ƒVˆj j ƒsbt j t ƒ‚qut j tƒ‚nXdS(sÿThis forces a child process to terminate. It starts nicely with SIGHUP and SIGINT. If "force" is True then moves onto SIGKILL. This returns True if the child was terminated. This returns False if the child could not be terminated. Rc@stjˆjjƒS(N(RtsleepRtdelayafterterminate((R(s3lib/python2.7/site-packages/terminado/management.pyRYRN(R R!tsignaltSIGINTtSIGTERMtSIGHUPtSIGCONTR tcurrentRtisaliveRtReturntTrueRtSIGKILLtFalsetOSError(RtforcetsignalstloopR&R((Rs3lib/python2.7/site-packages/terminado/management.pyt terminateLs4     ( t__name__t __module__RRR(R*RR$Rt coroutineR2R7(((s3lib/python2.7/site-packages/terminado/management.pyR "s   cC@sJxC|jƒD]5\}}|dkr8|j|dƒq |||Called by the event loop when there is pty data ready to read.iN( RJRtreadRtappendRt on_pty_readtEOFErrorRst on_pty_died(RRjteventsRntsR((s3lib/python2.7/site-packages/terminado/management.pyRlÀs   cC@s t‚dS(s?Override in a subclass to give a terminal to a new websocket connection The :class:`TermSocket` handler works with zero or one URL components (capturing groups in the URL spec regex). If it receives one, it is passed as the ``url_component`` parameter; otherwise, this is None. N(tNotImplementedError(Rt url_component((s3lib/python2.7/site-packages/terminado/management.pyt get_terminalÍscC@sdS(sFOverride this to e.g. kill terminals on client disconnection. N((Rt websocket((s3lib/python2.7/site-packages/terminado/management.pytclient_disconnectedÖscc@s|jƒVdS(N(tkill_all(R((s3lib/python2.7/site-packages/terminado/management.pytshutdownÛscc@sSg}x0|jjƒD]}|j|jdtƒƒqWx|D] }|Vq@WdS(NR4(RJtvaluesRuR7R0(Rtfuturesttermtf((s3lib/python2.7/site-packages/terminado/management.pyR€ßs  N(R8R9t__doc__RRRbRiRoRsRlR}RRR:RR€(((s3lib/python2.7/site-packages/terminado/management.pyRBs  tSingleTermManagercB@s5eZdZd„Zdd„Zejd„ƒZRS(s9All connections to the websocket share a common terminal.cK@s#tt|ƒj|d|_dS(N(tsuperR‡RRtterminal(RR_((s3lib/python2.7/site-packages/terminado/management.pyRëscC@s8|jdkr1|jƒ|_|j|jƒn|jS(N(R‰RRiRo(RR|((s3lib/python2.7/site-packages/terminado/management.pyR}ïscc@s!tt|ƒjƒVd|_dS(N(RˆR‡R€RR‰(R((s3lib/python2.7/site-packages/terminado/management.pyR€õsN( R8R9R†RRR}RR:R€(((s3lib/python2.7/site-packages/terminado/management.pyR‡és  tMaxTerminalsReachedcB@seZd„Zd„ZRS(cC@s ||_dS(N(t max_terminals(RR‹((s3lib/python2.7/site-packages/terminado/management.pyRûscC@s d|jS(Ns$Cannot create more than %d terminals(R‹(R((s3lib/python2.7/site-packages/terminado/management.pyt__str__þs(R8R9RRŒ(((s3lib/python2.7/site-packages/terminado/management.pyRŠús tUniqueTermManagercB@s/eZdZdd„Zdd„Zd„ZRS(s-Give each websocket a unique terminal to use.cK@s#tt|ƒj|||_dS(N(RˆRRR‹(RR‹R_((s3lib/python2.7/site-packages/terminado/management.pyRscC@sP|jr3t|jƒ|jkr3t|jƒ‚n|jƒ}|j|ƒ|S(N(R‹tlenRJRŠRiRo(RR|R„((s3lib/python2.7/site-packages/terminado/management.pyR}s !  cC@si|jjdƒ|jretjdkrO|jjƒ|j|jjjƒdS|jj t j ƒndS(s-Send terminal SIGHUP when client disconnects.s-Websocket closed, sending SIGHUP to terminal.RN( RIRpR‰R R!RRlRRjR$R(R+(RR~((s3lib/python2.7/site-packages/terminado/management.pyRs  N(R8R9R†RRR}R(((s3lib/python2.7/site-packages/terminado/management.pyRs  tNamedTermManagercB@szeZdZd d„Zd„ZdZd„Zd„Ze j d„Z e j ed„ƒZd„Ze j d „ƒZRS( sGShare terminals between websockets connected to the same endpoint. cK@s,tt|ƒj|||_i|_dS(N(RˆRRR‹t terminals(RR‹R_((s3lib/python2.7/site-packages/terminado/management.pyRs cC@s¥|dk st‚||jkr,|j|S|jr_t|jƒ|jkr_t|jƒ‚n|jjd|ƒ|jƒ}||_ ||j|<|j |ƒ|S(Ns$New terminal with specified name: %s( RtAssertionErrorRR‹RŽRŠRIRpRit term_nameRo(RR’R„((s3lib/python2.7/site-packages/terminado/management.pyR}$s !    s%dcC@sAx:tjddƒD]&}|j|}||jkr|SqWdS(Ntstarti(t itertoolstcountt name_templateR(RtnR!((s3lib/python2.7/site-packages/terminado/management.pyt_next_available_name7s cC@sX|jƒ}|jƒ}|jjd|ƒ||_||j|<|j|ƒ||fS(Ns$New terminal with automatic name: %s(R˜RiRIRpR’RRo(RR!R„((s3lib/python2.7/site-packages/terminado/management.pytnew_named_terminal=s     cC@s|j|}|j|ƒdS(N(RR(RR!RR„((s3lib/python2.7/site-packages/terminado/management.pyRFs cc@s"|j|}|jd|ƒVdS(NR4(RR7(RR!R4R„((s3lib/python2.7/site-packages/terminado/management.pyR7Js cC@sItt|ƒj|ƒ|j}|jjd|ƒ|jj|dƒdS(NsTerminal %s closed( RˆRRsR’RIRpRR<R(RRnR!((s3lib/python2.7/site-packages/terminado/management.pyRsOs cc@s!tt|ƒjƒVi|_dS(N(RˆRR€R(R((s3lib/python2.7/site-packages/terminado/management.pyR€UsN(R8R9R†RRR}R–R˜R™R(R*RRR:R2R7RsR€(((s3lib/python2.7/site-packages/terminado/management.pyRs     ($R†t __future__RRtsyst version_infotordt byte_codeRZtunicodet collectionsRR”RGR R(t ptyprocessRt ImportErrortwinptyRRNRRLR RYRXtobjectR RARBR‡t ExceptionRŠRR(((s3lib/python2.7/site-packages/terminado/management.pyts4        T j