h >ddlZddlZddlmZdZdZdZdZdZ y)N)asyncioc|dk(ryt|tr|jd}tj|dz}dt |z }t ||z S)zn Maps the value to a node value between 0 and 4095 using CRC, then down to one of the ring nodes. rutf8ii) isinstancestrencodebinasciicrc32floatint)value ring_sizebigval ring_divisors P/var/www/Befach/backend/env/lib/python3.12/site-packages/channels_redis/utils.py_consistent_hashrsX A~% V$ ^^E "U *F% **L v $ %%cfjfd}tj|_y)Ncjvr;j}j=j|j|_|j|i|S)N)_layersrun_until_completeflushclose)selfargskwargslayerloop original_implproxys r_wrapperz_wrap_close.._wrappersZ 5== MM$'E d#  # #EKKM 2" tzz4*6**r)rtypes MethodType)r!rr"r s`` @r _wrap_closer%s'JJM+!!(D1DJrcK |jdd{y7#t$r|jdd{7YywxYww)zF Handle compatibility with redis-py 4.x and 5.x close methods T)close_connection_poolN)acloseAttributeErrorr) connections r _close_redisr+&sG;d;;; ;T:::;s<A !!A !AAAA AA c4|sddigSt|ttfr tdg}|D]h}t|tr|j |%t|t tfr|j |d|ddV|j d|ij|S)z Takes the value of the "hosts" argument and returns a list of kwargs to use for the Redis connection constructor. addresszredis://localhost:6379z?You must pass a list of Redis hosts, even if there is only one.rr)hostport)rrbytes ValueErrordictappendtuplelist)hostsresultentrys r decode_hostsr90s 4566%#u& M  F eT " MM% t} - MM58U1X> ? MM9e, -  Mrc|j}d|vr1|jd}tjj|fi|S|jdd}|c|jd}|jdd}tj j |tj j||fi|Stjdi|S)z~ Takes the value of the "host" argument and returns a suited connection pool to the corresponding redis instance. r- master_nameN sentinelssentinel_kwargs)r=)copypopaioredisConnectionPoolfrom_urlsentinelSentinelConnectionPoolSentinel)r.r-r;r<r=s r create_poolrGJs 99;DD((9%&&//@4@@((=$/KHH[) ((#4d;  77     & &y/ & R    " " *T **r) r r#redisrrArr%r+r9rGr>rrrIs' % & 2;4+r