U /eg@sdZddlZddlZddlZddlZejdkr.raiseOSErrorerrorZenamer*r) tracebackr)test_control_messager_send_interrupt_childrenlen)r r r+r r r test_direct_interrupt_requestGsr1cs\|dtddIdH}|dddks,t|dtddIdH}|dddksXtdS)Nshutdown_requestF)ZrestartrrZshutdown_replyTrrr r r test_direct_shutdown_requestYsr3cs0|dtddIdH}|dddks,tdS)NZis_complete_requestr)rrrZis_complete_replyrrr r r test_is_complete_request`sr4cs*|diIdH}|dddks&tdS)N debug_requestrrZ debug_reply)r.rrr r r test_direct_debug_requestesr6c szthtdt|j}t|ts*t|j}t |dks@t|d|j ksRttdt |j |j g|_W5QRXdS)Nignorer) warningscatch_warnings simplefilterDeprecationWarningZ_parent_header isinstancerr shell_streamsr0 shell_streamRuntimeWarning)r rr>r r r test_deprecated_featuresjs   rAcsPddlm}Gddd}|||dgIdH|d}||IdHdS)NrDELIMc@seZdZddZdS)z%test_process_control..FakeMsgcSs ||_dSrbytesselfrEr r r __init__zsz.test_process_control..FakeMsg.__init__N__name__ __module__ __qualname__rHr r r r FakeMsgysrMr8does_not_exist)jupyter_client.sessionrCZprocess_control _prep_msgr rCrMmsgr r r test_process_controlvs   rScCs:|jdi}|j|dd||j|gr6tdS)Nr5rZmsg_id)sessionrRraddZ should_handleZcontrol_streamr)r rRr r r test_should_handlesrVcsPddlm}Gddd}|||dgIdH|d}||IdHdS)NrrBc@seZdZddZdS)z$test_dispatch_shell..FakeMsgcSs ||_dSrrDrFr r r rHsz-test_dispatch_shell..FakeMsg.__init__NrIr r r r rMsrMr8rN)rOrCZdispatch_shellrPrQr r r test_dispatch_shells   rWcst|_|IdHdSr)asyncioQueueZ msg_queueZdo_one_iterationrr r r test_do_one_iterations rZcs|idSr)Z_publish_debug_eventrr r r test_publish_debug_eventsr[cs||jdiIdHdS)NZfoo)Zconnect_requestr?rr r r test_connect_requestsr\cs |dSr)r/rr r r test_send_interrupt_childrensr])__doc__rXosr9Zpytestnameskipr rrrrrr&r'r1r3r4r6rArSrVrWrZr[r\r]r r r r s4