Mh&dZddlZddlZddlZddlZddlmZejdZGddej j ej j Z dS)zBase class to manage commsN)Commzipykernel.commczeZdZdZejdZejZejZ dZ dZ dS) CommManagerzA comm manager.zipykernel.kernelbase.Kernelc tjj|t jjj|fi|dS)zInitialize the manager.N)comm base_commr__init__ traitletsconfigLoggingConfigurable)selfkwargss V/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/ipykernel/comm/manager.pyr zCommManager.__init__sB "++D111,5dEEfEEEEEc|d}|d}|d}|j|d}t|d|d}|||td|n< |||dS#t $r td|d YnwxYw |jdS#t $r td d YdSwxYw) zHandler for comm_open messagescontentcomm_id target_nameNF)rprimaryr show_warningz"No such comm target registered: %sz&Exception opening comm with target: %sT)exc_infozqCould not close comm during `comm_open` failure clean-up. The comm may not have been opened yet.)targetsgetr register_commloggererror Exceptionclose) rstreamidentmsgrrrfrs r comm_openzCommManager.comm_opensHi.)$m, L  [$ / /#     4   9 LL={ K K K K c$  c c c E{]a bbbbb c  DJLLLLL    LLE        s$; B 'B32B37C&C21C2N) __name__ __module__ __qualname____doc__r InstancekernelDictcommsrr r$rrrrsl Y  = > >F IN  EinGFFF     rr) r(loggingcomm.base_commrr traitlets.configr getLoggerrr rr r r-rrr2s   + , ,-----$.,i.>.R-----r