o >h @sHddlZddlZddlmZddZddZddZd d Zd d Z dS) N)asynciocCsF|dkrdSt|tr|d}t|d@}dt|}t||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_divisorrt/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/channels_redis/utils.py_consistent_hashs    rcs(jfdd}t|_dS)Ncs@jvrj}j=||_|j|i|S)N)_layersrun_until_completeflushclose)selfargskwargslayerloop original_implproxyrr_wrappers  z_wrap_close.._wrapper)rtypes MethodType)rrrrrr _wrap_closes r"csBz |jddIdHWdSty |jddIdHYdSw)zF Handle compatibility with redis-py 4.x and 5.x close methods T)close_connection_poolN)acloseAttributeErrorr) connectionrrr _close_redis&s  r'cCs|sddigSt|ttfrtdg}|D](}t|tr#||qt|ttfr7||d|ddq|d|iq|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)hostsresultentryrrr decode_hosts0s   r4cCs|}d|vr|d}tjj|fi|S|dd}|dur=|d}|dd}tjj|tjj||dfi|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)r7r)copypopaioredisConnectionPoolfrom_urlsentinelSentinelConnectionPoolSentinel)r)r(r5r6r7rrr create_poolJs    r@) rr redisrr:rr"r'r4r@rrrrs