`f @ddlZddlZddlmZdZdZdZdZdZ dS)N)asyncioc|dkrdSt|tr|d}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 F/var/www/html/env/lib/python3.11/site-packages/channels_redis/utils.py_consistent_hashrsn A~~q%% V$$ ^E " "U *F% ***L v $ % %%c\jfd}tj|_dS)Ncjvr<j}j=||_|j|i|S)N)_layersrun_until_completeflushclose)selfargskwargslayerloop original_implproxys r_wrapperz_wrap_close.._wrappers` 5= M$'E d#  # #EKKMM 2 2 2" tz4*6***r)rtypes MethodType)r!rr"r s`` @r _wrap_closer%sIJM+++++++!(D11DJJJrcK |dd{VdS#t$r |dd{VYdSwxYw)zF Handle compatibility with redis-py 4.x and 5.x close methods T)close_connection_poolN)acloseAttributeErrorr) connections r _close_redisr+&s;d;;;;;;;;;;; ;;;T::::::::::::;s"&A  A c~|sddigSt|ttfrtdg}|D]}t|tr||-t|t tfr%||d|ddn|d|i|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 74566%#u&&  M   F.. eT " " . MM% t} - - . MM58U1X>> ? ? ? ? MM9e, - - - - Mrc|}d|vr,|d}tjj|fi|S|dd}|b|d}|dd}tjj|tj||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;; 7    & &y/ & R R      " * *T * **r) r r#redisrrArr%r+r9rGr>rrrIs~ %%%%%% & & & 2 2 2;;;4+++++r