^hp#SrSSKJr SSKrSSKrSSKrSSKrSSKJ r SSK J r J r J r SSKrSSKJr SSKJr SS KJr SS KJr "S S 5rg) z!Manager of subshells in a kernel.) annotationsN)partial)Lockcurrent_thread main_thread)IOLoop) SocketPair)SubshellThread)SHELL_CHANNEL_THREAD_NAMEc\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr S r SS jrSS jrSSjrSSjrS SjrSSjrS!SjrSrg)"SubshellManageraeA manager of subshells. Controls the lifetimes of subshell threads and their associated ZMQ sockets and streams. Runs mostly in the shell channel thread. Care needed with threadsafe access here. All write access to the cache occurs in the shell channel thread so there is only ever one write access at any one time. Reading of cache information can be performed by other threads, so all reads are protected by a lock so that they are atomic. Sending reply messages via the shell_socket is wrapped by another lock to protect against multiple subshells attempting to send at the same time. .. versionadded:: 7 c[5[5:XdeXlX lX0l0Ul[ 5Ul[URS5Ul URRURURSS9 [URS5Ul [URS5Ul URRURUR5 g)z Initialize the subshell manager.controlT)copymainz main-reverseN)rr_context_shell_channel_io_loop _shell_socket_cacher _lock_cacher control_to_shell_channelon_recv_process_control_request_shell_channel_to_main_main_to_shell_channel_send_on_shell_channel)selfcontextshell_channel_io_loop shell_sockets T/home/james-whalen/.local/lib/python3.13/site-packages/ipykernel/subshell_manager.py__init__SubshellManager.__init__%s;=000,3 &;#)13 6)34==)(L% %%--  ' ')F)FT . '1&G#'1&O# ##++  ' ')D)D c[5R[:XdeUR URR 5upURU5 M0![ a Of=fSSS5 O!,(df  O=fURR5 URR5 URR5 g)z+Stop all subshells and close all resources.N) rnamer rrpopitemKeyError_stop_subshellrcloserr)r_subshell_threads r#r,SubshellManager.closeFs$$(AAAA   )-)<)<)>&A##O4      %%++- ##))+ ##))+s.A6A A6 A*'A6)A**A66 BcUc UR$UR URURsSSS5 $!,(df  g=f)zrReturn the inproc socket pair used to send messages from the shell channel to a particular subshell or main shell.N)rrrshell_channel_to_subshellr subshell_ids r#"get_shell_channel_to_subshell_pair2SubshellManager.get_shell_channel_to_subshell_pairUs=  .. .   ;;{+EE  s ? A cUcURR$UR URURRsSSS5 $!,(df  g=f)zeReturn the socket used by a particular subshell or main shell to send messages to the shell channel. N)r from_socketrrsubshell_to_shell_channelr2s r#$get_subshell_to_shell_channel_socket4SubshellManager.get_subshell_to_shell_channel_socket]sI  ..:: :   ;;{+EEQQ  s #A A!c8URU5R$)zeReturn the socket used by the shell channel to send messages to a particular subshell or main shell. )r4r7r2s r#$get_shell_channel_to_subshell_socket4SubshellManager.get_shell_channel_to_subshell_socketfs66{COOOr&cUR URURsSSS5 $!,(df  g=f)z8Get the boolean aborting flag of the specified subshell.Nrrabortingr2s r#get_subshell_aborting%SubshellManager.get_subshell_abortingls)   ;;{+44  0 >cUR URURsSSS5 $!,(df  g=f)zcdr&cvUR X RUlSSS5 g!,(df  g=f)z0Set the aborting flag of the specified subshell.Nr?)rr3r@s r#set_subshell_aborting%SubshellManager.set_subshell_abortings&   08KK $ -  s* 8c&UR U[5R:Xa SSS5 gURR 5H"up#URU:XdMUs sSSS5 $ SU<S3n[ U5e!,(df  g=f)zReturn subshell_id of the specified thread_id. Raises RuntimeError if thread_id is not the main shell or a subshell. Only used by %subshell magic so does not have to be fast/cached. Nz Thread id z1 does not correspond to a subshell of this kernel)rridentritems RuntimeError)r thread_ididsubshellmsgs r#subshell_id_from_thread_id*SubshellManager.subshell_id_from_thread_ids  KM/// !% 1 1 3 >>Y.I  !4ym+\]Cs# # sB-B!B.B Bc&[5R[:Xde[[R "55n[ XR5nUR XR;deX RU'SSS5 URRUR[URU55 URRUR UR"5 UR%5 U$!,(df  N=f)z'Create and start a new subshell thread.N)rr(r struuiduuid4r rrrr1rio_looprrMr8rrstart)rr3r.s r#_create_subshell SubshellManager._create_subshells$$(AAAA$**,' (mmD   kk1 11'6KK $ 1199  # # D**K 8 1199  ' ')D)D   s  D Dc[5R[:XdeUR URR U5nSSS5 UR W5 g!,(df  N =f)zZDelete subshell identified by subshell_id. Raises key error if subshell_id not in cache. N)rr(r rrpopr+)rr3subshell_threwads r#_delete_subshell SubshellManager._delete_subshellsW $$(AAAA   #{{{;  ,- s A!! A/c[5R[:Xde[R"US5nUSnSS0nUS:XaUR 5US'OHUS:XaUSnUR U5 O+US:XaUR5US'OS U<3n[U5eURRRU5 g ![anS [U5S .nS nANCS nAff=f) zProcess a control request message received on the control inproc socket and return the reply. Runs in the shell channel thread. rtypestatusokcreater3deleterIzUnrecognised message type error)rnevalueN)rr(r jsonloadsrerjrJrX BaseExceptionr`r to_socket send_json)rrequestdecodedrmreplyr3r\errs r#r(SubshellManager._process_control_requests$$(AAAA jj,G6?D'/&6Ex'+'<'<'>m$!%m4 %%k2'+'9'9';m$24(;"3'' %%//99%@ !c(E s);C C 9C C C,C''C,cv[5R[:XdeURR U5 g)N)rr(r rsend_multipart)rr\s r#r&SubshellManager._send_on_shell_channels.$$(AAAA ))#.r&c[5R[:XdeUR5(a!UR 5 UR 5 gg)z6Stop a subshell thread and close all of its resources.N)rr(r is_alivestopjoin)rr.s r#r+SubshellManager._stop_subshellsF$$(AAAA  # # % %  "  " &r&) rrrrrMrrrrN)r zzmq.Context[t.Any]r!rr"zmq.Socket[t.Any])returnNone)r3 str | Nonerr )r3rrr)r3r`rbool)r3r`rz asyncio.Lock)rz list[str])r3r`r@rrr)rYintrr)rr`)r3r`rr)ryz list[t.Any]rr)r.r rr)__name__ __module__ __qualname____firstlineno____doc__r$r,r4r9r<rArFrJrPrSr]rerjrrr+__static_attributes__r&r#rrs  #  & (  B ,FRP 5 9 %e9 $ . .AA AB/#r&r)r __future__rasynciorttypingtra functoolsr threadingrrrzmqtornado.ioloopr socket_pairr r[r threadr rrr&r#rs;'"  77 !#$-U#U#r&