B 9‹dÞã@sŽdZddlZddlmZddlmZmZddlmZddl m Z ddl m Z m Z ddlmZmZdd lmZd d lmZGd d „d eeƒZdS)zgA MultiTerminalManager for use in the notebook webserver - raises HTTPErrors - creates REST API models éN)Ú timedelta)ÚutcnowÚ isoformat)ÚNamedTermManager)Úweb)ÚIOLoopÚPeriodicCallback)ÚIntegerÚvalidate)ÚLoggingConfigurableé)Ú TERMINAL_CURRENTLY_RUNNING_TOTALcs®eZdZdZdZdZeddddZdZeedd dZ ‡fd d „Z d d „Z dd„Z dd„Z dd„Zdd„Zd$‡fdd„ Zdd„Zdd„Zdd„Zdd„Zd d!„Zd"d#„Z‡ZS)%ÚTerminalManagerz NFrTz€Timeout (in seconds) in which a terminal has been inactive and ready to be culled. Values of 0 or lower disable culling.)ÚconfigÚhelpi,z_The interval (in seconds) on which to check for terminals exceeding the inactive timeout value.cstƒj||ŽdS)N)ÚsuperÚ__init__)ÚselfÚargsÚkwargs)Ú __class__©ún/work/yifan.wang/ringdown/master-ringdown-env/lib/python3.7/site-packages/notebook/terminal/terminalmanager.pyr)szTerminalManager.__init__cCs| ¡\}}| ||¡S)zCreate a new terminal.)Znew_named_terminalÚ_finish_create)rÚnameÚtermrrrÚcreate,s zTerminalManager.createcCs4||jkrt dd|›d¡‚| |¡}| ||¡S)zCreate a new terminal.i™zA terminal with name 'z' already exists.)Ú terminalsrÚ HTTPErrorZ get_terminalr)rrrrrrÚcreate_with_name1s  z TerminalManager.create_with_namecCs&tƒ|_| |¡}t ¡| ¡|S)N)rÚ last_activityÚget_terminal_modelr ÚincÚ_initialize_culler)rrrÚmodelrrrr8s  zTerminalManager._finish_createcCs| |¡}|S)zGet terminal 'name'.)r!)rrr$rrrÚgetDs zTerminalManager.getcs&‡fdd„ˆjDƒ}t t|ƒ¡|S)z$Get a list of all running terminals.csg|]}ˆ |¡‘qSr)r!)Ú.0r)rrrú Ksz(TerminalManager.list..)rr ÚsetÚlen)rÚmodelsr)rrÚlistIs zTerminalManager.listcƒs,| |¡tƒj||dIdHt ¡dS)zTerminate terminal 'name'.)ÚforceN)Ú_check_terminalrÚ terminater Údec)rrr,)rrrr.Ss zTerminalManager.terminatecÃs6dd„|jDƒ}x |D]}|j|ddIdHqWdS)zTerminate all terminals.cSsg|]}|‘qSrr)r&rrrrr'^sz1TerminalManager.terminate_all..T)r,N)rr.)rZtermsrrrrÚ terminate_all\s zTerminalManager.terminate_allcCs(| |¡|j|}|t|jƒdœ}|S)zuReturn a JSON-safe dict representing a terminal. For use in representing terminals in the JSON APIs. )rr )r-rrr )rrrr$rrrr!bs   z"TerminalManager.get_terminal_modelcCs ||jkrt dd|›¡‚dS)z9Check a that terminal 'name' exists and raise 404 if not.i”zTerminal not found: N)rrr)rrrrrr-ns zTerminalManager._check_terminalcCs„|jsz|jdkrz|jdkrzt ¡}|jdkrH|j d|j|j¡|j|_t |j d|jƒ|_|j  d|j|j¡|j  ¡d|_dS)z‡Start culler if 'cull_inactive_timeout' is greater than zero. Regardless of that value, set flag that we've been here. rNzKInvalid value for 'cull_interval' detected (%s) - using default value (%s).ièzICulling terminals with inactivity > %s seconds at %s second intervals ...T) Ú_initialized_cullerÚcull_inactive_timeoutÚ_culler_callbackrÚcurrentÚ cull_intervalÚlogÚwarningÚcull_interval_defaultrÚ_cull_terminalsÚinfoÚstart)rÚlooprrrr#ss     z"TerminalManager._initialize_cullerc Ãs||j d|j|j¡xbt|jƒD]T}y| |¡IdHWq tk rr}z|j d|›d|›¡Wdd}~XYq Xq WdS)NzCPolling every %s seconds for terminals inactive for > %s seconds...zPThe following exception was encountered while checking the activity of terminal z: ) r6Údebugr5r2r+rÚ_cull_inactive_terminalÚ ExceptionÚ exception)rrÚerrrr9†s zTerminalManager._cull_terminalscÃs˜y|j|}Wntk r"dSX|j d||j¡t|dƒr”tƒ}||j}|t|jdk}|r”t |  ¡ƒ}|j  d||¡|j |ddIdHdS)Nzname=%s, last_activity=%sr )Úsecondsz6Culling terminal '%s' due to %s seconds of inactivity.T)r,) rÚKeyErrorr6r=r Úhasattrrrr2ÚintÚ total_secondsr7r.)rrrZdt_nowZ dt_inactiveZis_timeZ inactivityrrrr>’s   z'TerminalManager._cull_inactive_terminal)F)Ú__name__Ú __module__Ú __qualname__Ú__doc__r3r1r r2r8r5rrrrr%r+r.r0r!r-r#r9r>Ú __classcell__rr)rrrs*      r)rJÚwarningsÚdatetimerZ notebook._tzrrZ terminadorÚtornadorZtornado.iolooprrZ traitletsr r Ztraitlets.configr Zprometheus.metricsr rrrrrÚs