U /e@sXdZddlZddlZddlZddlZddlmZedZGdddej j ej j Z dS)zBase class to manage commsN)Commzipykernel.commc@s:eZdZdZedZeZeZ ddZ ddZ dS) CommManagerzA comm manager.zipykernel.kernelbase.KernelcKs$tjj|tjjj|f|dS)zInitialize the manager.N)comm base_commr__init__ traitletsconfigLoggingConfigurable)selfkwargsr :/tmp/pip-unpacked-wheel-g43y689f/ipykernel/comm/manager.pyrszCommManager.__init__c Cs|d}|d}|d}|j|d}t|d|dd}|||dkrVtd|n6z|||WdStk rtjd|d d YnXz |Wn"tk rtjd d d YnXdS) zHandler for comm_open messagescontentcomm_id target_nameNF)rZprimaryrZ 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.)targetsgetrZ register_commloggererror Exceptionclose) r streamidentmsgrrrfrr r r comm_opens2   zCommManager.comm_openN) __name__ __module__ __qualname____doc__rZInstancekernelDictZcommsrrrr r r rrs  r) r!loggingZcomm.base_commrrZtraitlets.configr getLoggerrrrr r r r r rs