U be@sddlZddlZddlZddlmZddlmZdZdZdZ dZ dZ dZ ej Zdd d Zefed d d ZeZddZGdddZeZGdddZeZGdddZdS)N)partial)BytesIOcCsd}t|}|tkrnb|tkr2|tO}|d}nF|tkrL|tO}d|}n,|tO}t}t ||}| || }||fS)Nrutf8z%d) typebytesstr FLAG_TEXTencodeint FLAG_INTEGER FLAG_PICKLErpicklePicklerdumpgetvalue)keyvaluepickle_versionflagsZ value_typeoutputZpicklerrR/var/www/html/services/stratfitenv/lib/python3.8/site-packages/pymemcache/serde.py_python_memcache_serializer%s     rrcCs tt|dS)z3Return a serializer using a specific pickle versionr)rrrrrrget_python_memcache_serializer@srcCs|dkr |S|t@r|dS|t@r.t|S|t@r>t|S|t@rzt|}t|}| WSt k rt j dddYdSX|S)Nrr z Pickle errorT)exc_info) r decoderr FLAG_LONGrrr Unpicklerload Exceptionlogginginfo)rrrbufZ unpicklerrrrpython_memcache_deserializerHs"   r)c@s4eZdZdZefeddddZddZdd ZdS) PickleSerdea An object which implements the serialization/deserialization protocol for :py:class:`pymemcache.client.base.Client` and its descendants using the :mod:`pickle` module. Serialization and deserialization are implemented as methods of this class. To implement a custom serialization/deserialization method for pymemcache, you should implement the same interface as the one provided by this object -- :py:meth:`pymemcache.serde.PickleSerde.serialize` and :py:meth:`pymemcache.serde.PickleSerde.deserialize`. Then, pass your custom object to the pymemcache client object in place of `PickleSerde`. For more details on the serialization protocol, see the class documentation for :py:class:`pymemcache.client.base.Client` N)rreturncCst||_dSN)r_serialize_func)selfrrrr__init__sszPickleSerde.__init__cCs |||Sr,)r-r.rrrrr serializevszPickleSerde.serializecCs t|||Sr,)r)r.rrrrrr deserializeyszPickleSerde.deserialize) __name__ __module__ __qualname____doc__DEFAULT_PICKLE_VERSIONrr/r1r3rrrrr*asr*c@s6eZdZdZejejedfddZddZ ddZ d S) CompressedSerdez An object which implements the serialization/deserialization protocol for :py:class:`pymemcache.client.base.Client` and its descendants with configurable compression. icCs||_||_||_||_dSr,)_serde _compress _decompress_min_compress_len)r.compress decompressZserdeZmin_compress_lenrrrr/szCompressedSerde.__init__cCsd|j||\}}t||jkr,dkr\nn,|}||}t|t|krT|}n|tO}||fSNr)r:r1lenr=r;FLAG_COMPRESSED)r.rrr old_valuerrrr1s zCompressedSerde.serializecCs&|t@r||}|j|||}|Sr,)rBr<r:r3r2rrrr3s zCompressedSerde.deserializeN) r4r5r6r7zlibr>r? pickle_serder/r1r3rrrrr9s r9c@s.eZdZdZddddZddZdd ZdS) LegacyWrappingSerdea This class defines how to wrap legacy de/serialization functions into a 'serde' object which implements '.serialize' and '.deserialize' methods. It is used automatically by pymemcache.client.base.Client when the 'serializer' or 'deserializer' arguments are given. The serializer_func and deserializer_func are expected to be None in the case that they are missing. N)r+cCs|p|j|_|p|j|_dSr,)_default_serializer1_default_deserializer3)r.Zserializer_funcZdeserializer_funcrrrr/s zLegacyWrappingSerde.__init__cCs|dfSr@rr0rrrrGsz&LegacyWrappingSerde._default_serializecCs|Sr,rr2rrrrHsz(LegacyWrappingSerde._default_deserialize)r4r5r6r7r/rGrHrrrrrFs rF)N)r&rrD functoolsriorZ FLAG_BYTESrrr"rBr HIGHEST_PROTOCOLr8rrrZpython_memcache_serializerr)r*rEr9Zcompressed_serderFrrrrs(   +