
    iU                     v   d dl Z d Z ed          \  ZZ ed          \  ZZ ed          \  ZZ ed          \  ZZ	 ed          \  Z
Z ed          \  ZZ ed	          \  ZZ ed
          \  ZZ ed          \  ZZ ed          \  ZZ ed          \  ZZ e j        d          Zej        Zej        Z e j        d          Zej        Zej        Z d Z!d Z"d Z# e j        d          Z$ e j        d          Z% e j        d          Z& e j        d          Z'd Z(d Z)d Z*d Z+d Z,d Z-dS )    Nc                 L    t          j        |           j        }fd}||fS )Nc                 :                         |           d         S )Nr   )unpack)spackers    c/Users/user/workspace/sujinbaek/cqa-test-app/venv/lib/python3.11/site-packages/cassandra/marshal.py<lambda>z_make_packer.<locals>.<lambda>   s    v}}Q''*     )structStructpack)format_stringr   r   r   s      @r   _make_packerr      s1    ]=))F;D****F<r
   z>qz>iz>hz>bz>Qz>Iz<Iz>Hz>Bz>fz>dz>BBbBz>BBhBc                     t          d                    d | D                       d          }| d         dz  dk    rt          |           }|d|dz  z  z  }|S )N c              3       K   | ]	}d |z  V  
dS )z%02xN ).0is     r   	<genexpr>z varint_unpack.<locals>.<genexpr>2   s&      //Qfqj//////r
      r            )intjoinlen)termvallen_terms      r   varint_unpackr!   1   sb    
bgg//$/////
4
4CQ#!t99qX\""Jr
   c                 6    t                               |           S )N)r   
bit_lengthns    r   r#   r#   9   s    >>!r
   c                 ~   d}| dk    rdS | dk     r2t          t          |           dz
            dz  dz   }d|dz  z  | z   } d}t                      }| dk    r#|                    | dz             | dz  } | dk    #|r |d         d	z  r|                    d           |                                 t          |          S )
NTr       r   r   F   r   )r#   abs	bytearrayappendreversebytes)bigpos
bytelengthrevbytess       r   varint_packr3   =   s    
C
axxw
QwwC1--2Q6
JN"c){{H
''d
###	 ''  x|d" ??r
   z>ddz<ddz>dddz<dddc                     | dz  | dz	  z  S )Nr   ?   r   r$   s    r   encode_zig_zagr6   V   s    FqBwr
   c                     | dz	  | dz   z  S )Nr   r   r$   s    r   decode_zig_zagr8   Z   s    FAhr
   c                    g }d}|t          |           k     r| |         }|dz  dk    r|}nLd| dz                                  z
  }|d|z	  z  }||z   }||k     r|dz  }|dz  }|| |         dz  z  }||k     |dz  }|                    t          |                     |t          |           k     t	          |          S )Nr   r   r   r(   r   )r   r#   r,   r8   tuple)r   valuesr%   
first_byter   num_extra_bytesends          r   vints_unpackr?   ^   s    F	A
c$ii--!W
""CCJ;#5"A"A"C"CCO 78Co%Cc''Q	tAw~% c''
 	
QnS))*** c$ii--" ==r
   c                 P   t                      }d | d d d         D             } | D ]}t          |          }|dk     r|                    |           -d}|                                }|dz   }|d|z
  k    rC|dz  }|dz  }t	          |dz   d          }|                    |dz             |dz  }|d|z
  k    C|dk    rt          d|z            d|z
  }|d|z	  |z  z  }|                    t          |                     |                                 t          |          S )	Nc                 ,    g | ]}t          |          S r   )r   )r   vs     r   
<listcomp>zvints_pack.<locals>.<listcomp>v   s    +++c!ff+++r
   r)   r   r   r   r   r(   1Value %d is too big and cannot be encoded as vint)	r+   r6   r,   r#   min
ValueErrorr*   r-   r.   )r;   r2   valuerB   r=   num_bitsreserved_bitsr%   s           r   
vints_packrJ   t   sa   {{H++fTTrTl+++F $ $5!!s77OOAO||~~H ,a/Ma/001$A #Oa$7 ; ;D)))a a/00 "" !TW\!\]]] O#A$!)q.!AOOCFF####??r
   c                     | d         }|dz  dk    r|dfS d| dz                                   z
  }|d|z	  z  }t          d|dz             D ]}| |         }|dz  }||dz  z  }||dz   fS )Nr   r   r   r   r(   )r#   range)r.   r<   r=   rvidxnew_bytes         r   uvint_unpackrP      s    qJSQ1~J;-99;;;O	t.	/BQ*++  :
q
ho!#$$r
   c                    t                      }| dk     r|                    |            n| }d}|                                }|dz   }|d|z
  k    rC|dz  }|dz  }t          |dz   d          }|                    |dz             |dz  }|d|z
  k    C|dk    rt	          d| z            d|z
  }|d|z	  |z  z  }|                    t          |                     |                                 t          |          S )Nr   r   r   r   r(   rD   )r+   r,   r#   rE   rF   r*   r-   r.   )r   rM   rB   r=   rH   rI   r%   s          r   
uvint_packrR      s!   	B
Syy
		#<<>> (!+!]+,,q OMH! 3Q77MIIa$h!GA !]+,, QPSVVWWW 	dai1n
		#a&&JJLLL99r
   ).r   r   
int64_packint64_unpack
int32_packint32_unpack
int16_packint16_unpack	int8_packint8_unpackuint64_packuint64_unpackuint32_packuint32_unpackuint32_le_packuint32_le_unpackuint16_packuint16_unpack
uint8_packuint8_unpack
float_packfloat_unpackdouble_packdouble_unpackr   header_structr   header_packr   header_unpackv3_header_structv3_header_packv3_header_unpackr!   r#   r3   point_bepoint_le	circle_be	circle_ler6   r8   r?   rJ   rP   rR   r   r
   r   <module>rs      s  "    (<-- 
L'<-- 
L'<-- 
L%d++ 	;)\$// ])\$// ]#/<#5#5   )\$// ]'<-- 
L'<-- 
L)\$// ] g&& $ !6=)) !&#*       $ 6=6=FM&!!	FM&!!	         ,  @% % %    r
   