j"LdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddlZddlmZddlmZmZddlmZddlZddlmZddlmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%dd l&m'Z'm(Z(dd l)m*Z*dd l+m,Z,dd l-m.Z.d dl/m0Z0d dl1m2Z2d dl3m4Z4m5Z5m6Z6m7Z7e j8Z9ej:Z:dHdZ;dZdJdZ? ddl@Z@dZAe@jBe@jCzddKd ZDdJd!ZEn#eF$r d"ZAe>e?cZDZEYnwxYw ddlGZGdZHejIeGjJe6#ZKeGjLZMn #eF$rd"ZHYnwxYwdLd%ZNe jOZPd&ZQejRZSdMd(ZTdNd)ZUd*d+d,d-ZVd.eUd/d0id1fd.d2d/d0id3fd4ZWdOd7ZXdPd9ZYGd:d;e(ZZGd<d=Z[dQdDZ\dRdFZ]GdGd.e'Z^dS)SaSession object for building, serializing, sending, and receiving messages. The Session object supports serialization, HMAC signatures, and metadata on messages. Also defined here are utilities for working with Sessions: * A SessionFactory to be used as a base class for configurables that work with Sessions. * A Message object for convenience that allows attribute-access to the msg dict. ) annotationsN)b2a_hex)datetimetimezone)compare_digest)IOLoop) AnyBoolCallableCBytesCUnicodeDictDottedObjectNameInstanceIntegerSet TraitErrorUnicodeobserve) ConfigurableLoggingConfigurable) get_logger) import_item) ZMQStream)protocol_version)adapt) extract_dates json_clean json_default squash_datesobjt.Anyreturnct|trwt|D]T}t ||||<t|t r%|||t |<Ungt|tr(t|D]\}}t |||<n*t|t r|d}|S)z#coerce unicode back to bytestrings.utf8) isinstancedictlistkeyssquash_unicodestrpop enumerateencode)r"keyivs c/var/www/finuniver-perm.ru/html/student/venv/lib/python3.11/site-packages/jupyter_client/session.pyr+r+Cs#t ! ## 8 8C%c#h//CH#s## 8+.773<<N3''( 8 C  !cNN ' 'DAq#A&&CFF ' C  !jj   J@ibytescZ tj|tddddS#tt f$re}tjt |tdddd}tjd|dd |cYd }~Sd }~wwxYw) z!Convert a json object to a bytes.F)default ensure_ascii allow_nanr&surrogateescape)errorsz#Message serialization failed with: zk Supporting this message is deprecated in jupyter-client 7, please make sure your message is JSON-compliant stacklevelN) jsondumpsr r/ TypeError ValueErrorrwarningswarn)r"epackeds r3 json_packerrH_sz      & 1& 2 2  3 z " sOO     & 1& 2 2    21 2 2 2      !s14B*AB%B*%B*s str | bytesct|tr|dd}tj|S)z,Convert a json bytes or string to an object.r&replace)r'r6decoder@loadsrIs r3 json_unpackerrP{s5!U( HHVY ' ' :a==r4T)optionrQ int | Nonecz tj|t|S#t$rt |cYSwxYw)zKConvert a json object to a bytes using orjson with fallback to json_packer.)r8rQ)orjsonrAr ExceptionrH)r"rQs r3 orjson_packerrVsM $<\&III I $ $ $s## # # # $s ::cj tj|S#t$rt|cYSwxYw)zXConvert a json bytes or string to an object using orjson with fallback to json_unpacker.)rTrNrUrPrOs r3orjson_unpackerrXsD $<?? " $ $ $ ## # # # $s 22F)r8ocPtjt|tS)z'Pack an object using the pickle module.)picklerAr!PICKLE_PROTOCOL)rYs r3 pickle_packerr]s < Q 9 99r4s r,ctjd}dd|dd|ddfDS)zGenerate a new random id. Avoids problematic runtime import in stdlib uuid on Python 2. Returns ------- id string (16 random bytes as hex-encoded text, chunks separated by '-') -c3ZK|]&}t|dV'dS)asciiN)rrM).0xs r3 znew_id..s6KK1GAJJ%%g..KKKKKKr4N)osurandomjoin)bufs r3new_idrksG *R..C 88KKRaR#abb'8JKKK K KKr4cDtdS)zReturn new_id as ascii bytesrb)rkr/r4r3 new_id_bytesrns 88??7 # ##r4zSession.sessionzSession.usernamezSession.keyfile)identuserkeyfileSession)r0rqzUse HMAC digests for authentication of messages. Setting this flag will generate a new UUID to use as the HMAC key. r4zDon't authenticate messages.)securez no-securecfgNonectjdtdd|vrd|jvs d|jvrdSt |j_dS)zSet the default behavior for a config environment to be secure. If Session.key/keyfile have not been set, set Session.key to a new random UUID. zdefault_secure is deprecatedr=r>rrr0rqN)rDrEDeprecationWarningrrrnr0)rus r3default_securerysW  M02DQRSSSSCUck11Y#+5M5M"nnCKOOOr4rc4tjtS)z#Return timezone-aware UTC timestamp)rnowutcrmr4r3utcnowr}s <  r4ceZdZdZedZedddZed Z dd Z ed d Z edZ ddZ dfd ZxZS)SessionFactoryz[The Base class for configurables that have a Session, Context, logger, and IOLoop. rslognamechanger#r$rvcDtj|d|_dS)Nnew)logging getLoggerlogselfrs r3_logname_changedzSessionFactory._logname_changeds$VE]33r4 zmq.Contextc(tjSN)zmqContextrs r3_context_defaultzSessionFactory._context_defaults{}}r4zjupyter_client.session.SessionT allow_noneztornado.ioloop.IOLooprc(tjSr)rcurrentrs r3 _loop_defaultzSessionFactory._loop_default s~r4kwargsc ntjdi||jtdi||_dSdS)zInitialize a session factory.Nrm)super__init__sessionrrrr __class__s r3rzSessionFactory.__init__ sI""6""" < ",,V,,DLLL r4rr#r$rv)r$r)r$rrr#r$rv)__name__ __module__ __qualname____doc__rrrrrcontextrrlooprr __classcell__rs@r3rrsgbkkG WY4444h}%%Gh7DIIIG 8+ , ,D    ----------r4rcBeZdZdZddZddZdd Zdd ZddZddZ dS)MessagezA simple message object that maps dict keys to attributes. A Message can be created from a dict and a dict from a Message instance simply by calling dict(msg_obj).msg_dictdict[str, t.Any]r$rvc|j}t|D].\}}t|trt |}|||</dS)zInitialize a message.N)__dict__r(itemsr'r)rrdctkr2s r3rzMessage.__init__s`mNN((**  DAq!T"" AJJCFF  r4t.ItemsView[str, t.Any]cNt|jSr)iterrrrs r3__iter__zMessage.__iter__$sDM''))***r4r,c*t|jSr)reprrrs r3__repr__zMessage.__repr__'sDM"""r4c4tj|jSr)pprintpformatrrs r3__str__zMessage.__str__*s~dm,,,r4robjectboolc||jvSrrrrs r3 __contains__zMessage.__contains__-sDM!!r4r#c|j|Srrrs r3 __getitem__zMessage.__getitem__0s}Qr4N)rrr$rv)r$rr$r,)rrr$r)rr,r$r#) rrrrrrrrrrrmr4r3rrs(( ++++####----""""      r4rmsg_idmsg_typeusernamer Session | strrcHt}t}tS)zCreate a new message header)r}rlocals)rrrrdateversions r3 msg_headerr4s 88DG 88Or4 msg_or_headerc|siS |d}n+#t$r |d}|}n#t$rwxYwYnwxYwt|tst|}|S)z-Given a message or header, return the header.headerr)KeyErrorr'r()rhs r3extract_headerr=s    ( #  h'AAA      A a   GG Hs 7%7 177cveZdZdZedddZedddZeerdnddd Z eerdnddd Z e ere ne Ze ereneZed d dhdZedddZdidZeddhdZedZeejddddZeiddZ e!dZ"eddZ#djd!Z$ed"dhd#Z%ed$dd%Z&ed&dhd'Z'e(Z)dkd)Z*e+e,j-d*Z.dld+Z/e0Z1e!d,dd-Z2eddd.Z3ed/dhd0Z4e!Z5e!d,dd1Z6e!e7dd2Z8e!e9dd3Z:dmfd5 Z;dnd6Zdid7Z?dld8Z@dod;ZA dpdqdCZBdrdFZC dsdtdKZD dudvdUZE dwdxdZZFeGjHddfdyd^ZI dzd{daZJd|dcZKdlddZL d}d~deZMddgZNxZOS)rraObject for handling serialization and sending of messages. The Session object handles building messages and sending them with ZMQ sockets or ZMQStream objects. Objects can communicate with each other over the network via Session objects, and only need to work with the dict-based IPython message spec. The Session will handle serialization/deserialization, security, and metadata. Sessions support configurable serialization via packer/unpacker traits, and signing with HMAC digests via the key/keyfile traits. Parameters ---------- debug : bool whether to trigger extra debugging statements packer/unpacker : str : 'orjson', 'json', 'pickle', 'msgpack' or import_string importstrings for methods to serialize message parts. If just 'json' or 'pickle', predefined JSON and pickle packers will be used. Otherwise, the entire importstring must be used. The functions must accept at least valid JSON input, and output *bytes*. For example, to use msgpack: packer = 'msgpack.packb', unpacker='msgpack.unpackb' pack/unpack : callables You can also set the pack/unpack callables for serialization directly. session : bytes the ID of this Session object. The default is to generate a new UUID. username : unicode username added to message headers. The default is to ask the OS. key : bytes The key used to initialize an HMAC signature. If unset, messages will not be signed or checked. keyfile : filepath The file containing a key. If this is set, `key` will be initialized to the contents of the file. FTzDebug output in the Session)confighelpzWhether to check PID to protect against calls after fork. This check can be disabled if fork-safety is handled elsewhere. rTr@zThe name of the packer for serializing messages. Should be one of 'json', 'pickle', or an import name for a custom callable serializer.zjThe name of the unpacker for unserializing messages. Only used with custom functions for `packer`.packerunpackerrr#r$rvc|d}|dkr!trttc|_|_n|dks|dkrt tc|_|_n|dkrttc|_|_nq|dkr!trttc|_|_nJtt|d}|ddkrdnd }|||dS|dx|_|_dS) NrrTr@r[msgpacknamerpackunpack)lower has_orjsonrVrXrrrHrPr]pickle_unpacker has_msgpackmsgpack_packermsgpack_unpackerrr, set_traitrr)rrrr"rs r3_packer_unpacker_changedz Session._packer_unpacker_changedsUm!!## (??z?%2O "DIt{{ F]]cXoo%0- "DIt{{ H__%2O "DIt{{ I  + %35E "DIt{{c&-0011C#F^x7766XD NN4 % % % F&,Um3 dmmmr4rsz"The UUID identifying this session.r,cVt}|d|_|SNrb)rkr/bsession)rus r3_session_defaultzSession._session_defaults# HH)) r4rcD|jd|_dSr)rr/rrs r3_session_changedzSession._session_changeds ++G44 r4r4USERrz:Username for the Session. Default is your system username.)rrzZMetadata dictionary, which serves as the default top-level metadata dict for each message.rz$execution key, for signing messages.r6ctSr)rnrs r3 _key_defaultzSession._key_defaults ~~r4r0c.|dSr) _new_authrs r3 _key_changedzSession._key_changeds r4z hmac-sha256zcThe digest scheme used to construct the message signatures. Must have the form 'hmac-HASH'.signature_schemecF|d}|dstd|z|ddd} tt||_n%#t $r}td|z|d}~wwxYw|dS)Nrzhmac-z0signature_scheme must start with 'hmac-', got %rr`rz!hashlib has no such attribute: %s) startswithrsplitgetattrhashlib digest_modAttributeErrorr)rrr hash_namerFs r3_signature_scheme_changedz!Session._signature_scheme_changedsUm~~g&& WORUUVV VIIc1%%a(  U%gy99DOO U U U@9LMMST T U s A(( B 2BB  t.CallablectjSr)rsha256rs r3_digest_mod_defaultzSession._digest_mod_defaults ~r4rcp|jr'tj|j|j|_dSd|_dS)N) digestmod)r0hmacHMACrauthrs r3rzSession._new_auths5 8  $(doFFFDIIIDIIIr4izzThe maximum number of digests to remember. The digest history will be culled when it exceeds this value. z&path to file containing execution key.rqct|dd5}||_ddddS#1swxYwYdS)Nrrb)openreadstripr0)rrfs r3_keyfile_changedzSession._keyfile_changeds &- & & (!vvxx~~''DH ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s,AAAzJThreshold (in bytes) beyond which a buffer should be sent without copying.z[Threshold (in bytes) beyond which an object's buffer should be extracted to avoid pickling.zThe maximum number of items for a container to be introspected for custom serialization. Containers larger than this are pickled outright. rc Ptjdi|||i|_|jt j|_| |j s#t ddSdS)azcreate a Session object Parameters ---------- debug : bool whether to trigger extra debugging statements packer/unpacker : str : 'orjson', 'json', 'pickle', 'msgpack' or import_string importstrings for methods to serialize message parts. If just 'json' or 'pickle', predefined JSON and pickle packers will be used. Otherwise, the entire importstring must be used. The functions must accept at least valid JSON input, and output *bytes*. For example, to use msgpack: packer = 'msgpack.packb', unpacker='msgpack.unpackb' pack/unpack : callables You can also set the pack/unpack callables for serialization directly. session : unicode (must be ascii) the ID of this Session object. The default is to generate a new UUID. bsession : bytes The session as bytes username : unicode username added to message headers. The default is to ask the OS. key : bytes The key used to initialize an HMAC signature. If unset, messages will not be signed or checked. signature_scheme : str The message digest scheme. Currently must be of the form 'hmac-HASH', where 'HASH' is a hashing function available in Python's hashlib. The default is 'hmac-sha256'. This is ignored if 'key' is empty. keyfile : filepath The file containing a key. If this is set, `key` will be initialized to the contents of the file. zCMessage signing is disabled. This is insecure and not recommended!Nrm) rr_check_packersrnonerrggetpidpidrr0rwarningrs r3rzSession.__init__sP ""6""" IIbMM  9;; x  LL U       r4c t|}|D]!}t||t||"t |_|j|j|S)aCreate a copy of this Session Useful when connecting multiple times to a given kernel. This prevents a shared digest_history warning about duplicate digests due to multiple connections to IOPub in the same process. .. versionadded:: 5.1 )typetraitssetattrrsetdigest_historyupdate)r new_sessionrs r3clonez Session.cloneMsw!d4jjll KKMM < >>r4cp|j}|xjdz c_|jdtjd|S)Nr_) message_countrrgr)rmessage_numbers r3rzSession.msg_idasB+ a,????~???r4c|j|jdddgi} |}n/#t$r"}d|jd|}t ||d}~wwxYwt |t st dt|z |}||ksJn7#t$r*}d|jd |jd |}t ||d}~wwxYwd ti} |}t |d trd }t |dS#t$rfd |_fd|_YdSwxYw)z#check packers for datetime support.arhizpacker 'z(' could not serialize a simple message: Nz,message packed to %r, but bytes are requiredz unpacker z% could not handle output from packer z: tz!Shouldn't deserialize to datetimec4t|Sr)r!)rYrs r3z(Session._check_packers..s$$|A"7"7r4c|Srrm)rIrs r3r$z(Session._check_packers..sFF1IIr4) rrrUrrCr'r6rrr}r) rmsg_listrGrFmsgunpacked msg_datetimerrs @@r3r zSession._check_packersgsy!T# )T(^^FF ) ) )UT[UURSUUCS//q ( ) &%(( \KdSYllZ[[ [ )vf~~Hx''''' ) ) )hdmhhTXT_hhefhhCS//q ( ) VXX  .vdd<0011H(3-22 &9 oo% & & . . .7777DI----DKKKK .s? $ AA  AB C&%C  C$AD&&EErrcDt|j||j|jS)z#Create a header for a message type.)rrrr)rrs r3rzSession.msg_headers$+x MMMr4Ncontent dict | Noneparentdict[str, t.Any] | Nonermetadatac"i}|||n|}||d<|d|d<|d|d<|int||d<|in||d<|j|d<||d||S)zReturn the nested message dict. This format is different from what is sent over the wire. The serialize/deserialize methods converts this nested message dict to the wire format, which is a list of message parts. Nrrr parent_headerr+r/)rrr/copyr)rrr+r-rr/r's r3r'z Session.msgs.4n***&H x(H  ,J%+^rr9O9OO&GI-,,..J    O " "8 , , , r4r&r)c|jdS|j}|D]}|||S)zSign a message with HMAC digest. If no auth, return b''. Parameters ---------- msg_list : list The [p_header,p_parent,p_content] part of the message list. Nr4)rr2r hexdigestr/)rr&rms r3signz Session.signs\ 9 3 INN    A HHQKKKK{{}}##%%%r4r'rolist[bytes] | bytes | None list[bytes]c8|di}||j}nt|tr||}n`t|t rnJt|t r|d}ntdt|z||d||d||d|g}g}t|tr| |n|| || t||}| || ||S)a2Serialize the message components to bytes. This is roughly the inverse of deserialize. The serialize/deserialize methods work with full message lists, whereas pack/unpack work with the individual message parts in the message list. Parameters ---------- msg : dict or Message The next message dict as returned by the self.msg method. Returns ------- msg_list : list The list of bytes objects to be sent with the format:: [ident1, ident2, ..., DELIM, HMAC, p_header, p_parent, p_metadata, p_content, buffer1, buffer2, ...] In this list, the ``p_*`` entities are the packed or serialized versions, so if JSON is used, these are utf8 encoded JSON strings. r+Nr&zContent incorrect type: %srr1r/)getrr'r(rr6r,r/rBrr)extendappendDELIMr6)rr'ror+ real_messageto_send signatures r3 serializezSession.serializesy6'')R(( ?iGG  & & Jii((GG  ' ' J   % % JnnV,,GG84==HII I IIc(m $ $ IIc/* + + IIc*o & &    eT " " " NN5 ! ! ! !   NN5 ! ! !uIIl++ y!!!|$$$r4stream*zmq.sugar.socket.Socket | ZMQStream | None msg_or_typedict[str, t.Any] | strbytes | list[bytes] | Nonebuffers&list[bytes | memoryview[bytes]] | Nonetrackrc t|tjsd}t|tjjr(|Jtj|j}t|t tzr|} |p| dg}n| ||||| } |j r@tj |j kr$td| dS|gn|}t!|D]m\} } t| t"r| } n5 t#| } n$#t$$r}d}t%||d}~wwxYw| jst)d| | fzn|jrt-| |j} || |}||t3d|D}||jk}|r|r|r|s||dd }n(|rt8}||| nt8}|jrz Session.send..Zs///!s1vv///r4T)r2rIr2tracker)r'rSocketasyncioshadow underlyingrr(r:r' check_pidrgrrrrr. memoryviewrB contiguousrC adapt_versionrrAr;maxcopy_thresholdsend_multipartDONEdebugr)rrBrDr+r-rorGrIrr/r'idxrjviewrFemsgr?longestr2rOs r3sendz Session.sendsn&#*-- E fck0 1 1 :%%%Z&&v'899F k7T> 2 2 C7B!7!7GG((! C > bikkTX55 LL !SUX Y Y Y4""W!'** R RHC#z** 11%c??DD 111MD#D//q01? R !CsCj!PQQQ R   1T/00C..e,,w//w///00,,  g %  ++G%t+LLGG  G  ! !' ! 5 5 5 5G : # M#    M' " " " M' " " " I s0E E! EE!zmq.sugar.socket.Socketflagsintr2cg}t|tr|g}||||t|||dd||t|t jjr$t j |j }| |||dS)a0Send a raw message via ident path. This method is used to send a already serialized message. Parameters ---------- stream : ZMQStream or Socket The ZMQ stream or socket to use for sending the message. msg_list : list The serialized list of messages to send. This only includes the [p_header,p_parent,p_metadata,p_content,buffer1,buffer2,...] portion of the message. ident : ident or list A single ident or a list of idents to use in sending. NrrfrN) r'r6r;r<r=r6rrQrPrRrSrZ)rrBr&rcr2ror?s r3send_rawzSession.send_rawps. eU # # GE   NN5 ! ! !utyy!A#//000x   fck0 1 1 :Z&&v'899Fgu488888r4socketmode2tuple[list[bytes] | None, dict[str, t.Any] | None]ct|tr|j}t|tjjr$tj|j} |||}n3#tj $r!}|j tj krYd}~dSd}~wwxYw| ||\}} || |||fS#t$r}|d}~wwxYw)aYReceive and unpack a message. Parameters ---------- socket : ZMQStream or Socket The socket or stream to use in receiving. Returns ------- [idents], msg [idents] is a list of idents and msg is a nested message dict of same format as self.msg returns. rNN)NN)r+r2)r'rrgrrQrPrRrSrecv_multipartZMQErrorerrnoEAGAINfeed_identities deserializerU)rrgrhr+r2r&rFidentss r3recvz Session.recvs( fi ( ( #]F fck0 1 1 :Z&&v'899F ,,T,==HH|   w#*$$"zzzzz   //$?? 4++HgD+QQQ Q   G s6!A99B)B$#B$$B)C C1*C,,C1list[bytes] | list[zmq.Message]3tuple[list[bytes], list[bytes] | list[zmq.Message]]c|r[tjtjt|}|t }|d|||dzdfStjtjt j|}d}t|D]\}}|jt krd}n|rd}t||d|||dzd}}d|D|fS)aeSplit the identities from the rest of the message. Feed until DELIM is reached, then return the prefix as idents and remainder as msg_list. This is easily broken by setting an IDENT to DELIM, but that would be silly. Parameters ---------- msg_list : a list of Message or bytes objects The message to be split. copy : bool flag determining whether the arguments are bytes or Messages Returns ------- (idents, msg_list) : two lists idents will always be a list of bytes, each of which is a ZMQ identity. msg_list will be a list of bytes or zmq.Messages of the form [HMAC,p_header,p_parent,p_content,buffer1,buffer2,...] and should be unpackable/unserializable via self.deserialize at this point. NrTFzDELIM not in msg_listc6g|]}t|jSrmr6)rcr5s r3rMz+Session.feed_identities..s 333qE!'NN333r4) r"castListr6indexr=rrr.rC)rr&r2r]failedr5r'rqs r3rozSession.feed_identitiess2  >vafUmX66H..''CDSD>8C!GII#66 6vafS[18< > >  % % ' ' ' ' ' ? >r4cPt|j}tt|dz||jz }||krt |_dSt jtt|j|}|j |dS)z_cull the digest history Removes a randomly selected 10% of the digest history N) rLrrXrdr}rrandomsampletuplesorteddifference_update)rr n_to_cullto_culls r3rzSession._cull_digest_historys d)**GrM**Gd6N,NOO   "%%%D  F-fT-@&A&A B BINN --g66666r4chd}i}|sztjtjtj|}d|d|D}tjtjt |}|||dz}tjtjt |}|j|d}|sd}t|||jvrtd|z|r| || |dd} t|| sd|z}t|t||ksd |z}t|||d} t| |d <| d |d <| d |d <t||d |d<||d|d<|r||d|d<n |d|d<d|ddD} | rP| djCtjtjtj|}d|ddD} | |d<|jrt%j|t'|S)aUnserialize a msg_list to a nested message dict. This is roughly the inverse of serialize. The serialize/deserialize methods work with full message lists, whereas pack/unpack work with the individual message parts in the message list. Parameters ---------- msg_list : list of bytes or Message objects The list of message parts of the form [HMAC,p_header,p_parent, p_metadata,p_content,buffer1,buffer2,...]. content : bool (True) Whether to unpack the content dict (True), or leave it packed (False). copy : bool (True) Whether msg_list contains bytes (True) or the non-copying Message objects in each place (False). Returns ------- msg : dict The nested message dict with top-level keys [header, parent_header, content, buffers]. The buffers are returned as memoryviews. c6g|]}t|jSrmrw)rcr's r3rMz'Session.deserialize..%s"!P!P!Ps% "2"2!P!P!Pr4NrzUnsigned MessagezDuplicate Signature: %rrzInvalid Signature: %rz1malformed message, must have at least %i elementsrrrr=r1r/rfr+c,g|]}t|Srm)rUrcbs r3rMz'Session.deserialize..Ds777Q:a==777r4cPg|]#}tt|j$Srm)rUr6rs r3rMz'Session.deserialize..Hs(HHHaz%..11HHHr4rG)r"rxryrrr6rrCrrr6rrLrBrrshaper\rr) rr&r+r2minlenmessagemsg_list_beginningr@r'checkrrGs r3rpzSession.deserializes< >vafS[18<O!P!P!P vafUmX66H)HVWW,==H6!&-22 9   I &( oo%D/// !:Y!FGGG ,  +++IIhqsm,,E!)U33 &- 9 oo%8}}&&ENCC.. Xa[)))&11"8,$Z0 #0Xa[1I1I#J#J "kk(1+66   -!%Xa[!9!9GI  !)!GI 77(122,777  Iwqz'/vafS[18<)rDrErxrp)rrrs r3 unserializezSession.unserializeOs@  I      t0000r4rrr$r6)r$r)r$rvr)r$rr)rr,r$r)NNNN) rr,r+r,r-r.rr.r/r.r$r)r&r)r$r6r)r'rror7r$r8)NNNNFNN)rBrCrDrEr+r.r-r.rorFrGrHrIrrr.r/r.r$r.)rTN) rBrbr&r)rcrdr2rrorFr$rv) rgrbrhrdr+rr2rr$ri)T)r&rsr2rr$rt)r@r6r$rv)TT)r&rsr+rr2rr$r)rr#rr#r$r)Prrrrr r\rTrrrrr rVrHrrXrPrrrr rrrr rrrgenvironr:rrr/rrWr0rrrrr rrrrrrrrrr}rqr rrY MAX_BYTESbuffer_threshold MAX_ITEMSitem_thresholdrrrpropertyrr rr'r6rArarfrNOBLOCKrrrorrrprrrs@r3rrrrQs&&P Dt*K L L LE  I *F1F *F9H 8Z@MM[ A AD X%8=F WXz""444#"4"hr$-UVVVG  WY5555vc{{Hw vz** MH t  iHGAJJM &#M N N NC WU^^^w+ W      !  J 8DI$ / / /D SUUN!'  gb,XYYYG WY(((( '))CW  YN w j W N222222h$M @@@X@ ".".".".HNNNN $*.*.,0 4 & & & &$-1>>>>>H,0*.,0:>*.,0vvvvvx,0 #9#9#9#9#9PK )))))XGK(>(>(>(>(>T ( ( ( ( 7 7 7 7  KKKKKZ11111111r4)r"r#r$r#)r"r#r$r6)rIrJr$r#)r"r#rQrRr$r6)rYr#r$r6rr)rur#r$rv)r$r) rr,rr,rr,rrr$r)rrr$r)_r __future__r functoolsrrr@rrgr[rrtypingr"rDbinasciirrrr zmq.asynciortornado.ioloopr traitletsr r r r r rrrrrrrrtraitlets.config.configurablerr traitlets.logrtraitlets.utils.importstringrzmq.eventloop.zmqstreamr_versionradapterrjsonutilrrr r!DEFAULT_PROTOCOLr\r|r+rrrHrPrTr OPT_NAIVE_UTC OPT_UTC_ZrVrXModuleNotFoundErrorrrpartialpackbrunpackbrr]rNrr=MessageTrackerr[rkrnsession_aliases session_flagsryr}rrrrrrrmr4r3rs  #"""""  ''''''''!!!!!!LKKKKKKK$$$$$$444444------&&&&&&KKKKKKKKKKKK)l    (   8$MMM J-3,@6CS,S$$$$$$$$$$$@@@J%0-"M???@.'NNNK&Y&w}lKKKN KKK:::: , s L L L L$$$$    LLNNr::;  CB//0*    % % % %-----(---B        >    (F 1F 1F 1F 1F 1lF 1F 1F 1F 1F 1s$C!! C0/C04DD#"D#