XhdZddlZddlZddlmZddlmZddlmZddl m Z m Z m Z m Z ddlmZ ddlmZdd lmZdd lmZd d lmZdZdZddZdZGddeZej<ey#e$r dd lmZYJwxYw)zKernel connection helpers.N)Any)Session)WebSocketHandler)FloatInstanceUnicodedefault)LoggingConfigurable) json_default) date_default) extract_dates)_i18n)KernelWebsocketConnectionABCc|j}t|jd}tj|t j d}|jd|t|}d|dzzg}|ddD]"}|j|dt|z$tjd d |dzzz|g|}|jd|d j|S) a1serialize a message as a binary blob Header: 4 bytes: number of msg parts (nbufs) as 32b int 4 * nbufs bytes: offset for each buffer as integer as 32b int Offsets are from the start of the buffer, including the header. Returns ------- The message serialized to bytes. buffers)r utf8rrN!I) copylistpopjsondumpsr encodeinsertlenappendstructpackjoin)msgrbmsgnbufsoffsetsbuf offsets_bufs c/var/www/html/myenv/lib/python3.12/site-packages/jupyter_server/services/kernels/connection/base.pyserialize_binary_messager,s ((*C3779%&G ::c< 0 7 7 ?D NN1d LEEAIGs|/wr{SX-./++cC519$55uGwGK NN1k" 88G rc tjd|ddd}ttjdd|zz|dd|dzz}|jdg}t |dd|ddD]\}}|j|||t j |djd }t|d |d <t|d |d <|dd|d <|S) a&deserialize a message from a binary blog Header: 4 bytes: number of msg parts (nbufs) as 32b int 4 * nbufs bytes: offset for each buffer as integer as 32b int Offsets are from the start of the buffer, including the header. Returns ------- message dictionary z!iNrrrrrrrheader parent_headerr) r"unpackrr!ziprloadsdecoder )r&r'r(bufsstartstopr%s r+deserialize_binary_messager75s MM$Ra )! ,E6==sU{!2DQ%!)_4MNOG NN4 D73B<5& t Dt$%& **T!W^^F+ ,C!#h-0CM(_)=>C!"XC N Jrc|r+||d||d||d||dg}n|}|jd}g}|jddt|zdzz|jt||d z|D]"}|jt||d z$t|jdd }|Dcgc]}|jdd }}d j |g|||}|Scc}w) z*Serialize a message using the v1 protocol.r.r/metadatacontentutf-8rrlittle) byteorderr)rr!r to_bytesr$) msg_or_listchannelr#msg_listr(r% offset_numberoffsetbin_msgs r+serialize_msg_to_ws_v1rGPs X& ' _- . Z( ) Y' (  nnW%GG NN1H -123 NN3w<'"+-./s3x'"+-./L))!x)@MDKL&vqH5LGLhh DDD8DEG NMs Dc Jtj|ddd}t|Dcgc]'}tj|d|dzzd|dzzd)}}||d|djd}td|dz Dcgc]}|||||dz}}||fScc}wcc}w)z,Deserialize a message using the v1 protocol.Nr<r>rr=rr;)int from_bytesranger3)ws_msgrDir(rBrCs r+deserialize_msg_from_ws_v1rNgsNN6"1:x8MMRS`MaHIva1q5kAQK8(CGWQZ'!*-44W=G=B1mVWFW=XYwqzGAEN3YHY H  Zs ,BB ceZdZdZedddedZedZedZ edZ ed Z e Z ed d Zeed Zed dZeeZdZdZdeddfdZdedeeddfdZy)BaseKernelWebsocketConnectionzJA configurable base class for connecting Kernel WebSockets to ZMQ sockets.NTaPreferred kernel message protocol over websocket to use (default: None). If an empty string is passed, select the legacy protocol. If None, the selected protocol will depend on what the front-end supports (usually the most recent protocol supported by the back-end and the front-end).) allow_noneconfighelpc|jS)zThe kernel manager.)parentselfs r+kernel_managerz,BaseKernelWebsocketConnection.kernel_managers{{rc.|jjS)zThe multi kernel manager.)rXrUrVs r+multi_kernel_managerz2BaseKernelWebsocketConnection.multi_kernel_managers"")))rc.|jjS)zThe kernel id.)rX kernel_idrVs r+r\z'BaseKernelWebsocketConnection.kernel_ids"",,,rc.|jjS)zThe session id.)sessionrVs r+ session_idz(BaseKernelWebsocketConnection.session_ids||###rkernel_info_timeoutc.|jjSN)rZr`rVs r+_default_kernel_info_timeoutz:BaseKernelWebsocketConnection._default_kernel_info_timeouts((<<rs *.770E42+-:6.@"$7@"F&%%&CDOEDEsA33 BB