
    HmdR                        d dl Z d dlZd dlZd dlZd dlmZ d dlmZ e j        dk    r0d Z	d Z
d Zd Zd#d	Zd
 Zd Zd Zd Zd Zd Zd Zd Zd Zd ZdS d Z	d Z
d Zd Zd#dZd Zd Zd Zd Zd Zd Zd Zd  Zd! Zd" ZdS )$    N)umaskcreate_string_buffer)   c                      t          j                    \  } }t          j        | d           t          j        |d           | |fS )NT)ospipeset_inheritablerws     ?/usr/lib/x86_64-linux-gnu/glusterfs/python/syncdaemon/py2py3.pyr	   r	      s@    A
1d###
1d###1v    c                 @    d                     d | D                       S )N c                 ,    g | ]}t          |          S  )chr).0bs     r   
<listcomp>z$bytearray_to_str.<locals>.<listcomp>    s    1111A111r   )joinbyte_arrs    r   bytearray_to_strr      s#    ww11111222r   c                 4    t          d | D                       S )Nc                 ,    g | ]}t          |          S r   )ord)r   cs     r   r   z$str_to_bytearray.<locals>.<listcomp>'   s    ---c!ff---r   )bytesstrings    r   str_to_bytearrayr#   &   s    --f---...r   c                 "    t          d|           S )N    r   sizes    r   gr_create_string_bufferr(   )   s    #E4000r   c                     |r<|                      |                                |||                                          S |                      |                                ||          S N)_query_xattrencodeclspathr'   syscallattrs        r   gr_query_xattrr2   ,   s^     	B##DKKMM4$(KKMM3 3 3 ##DKKMM4AAAr   c                     | j                             |                                |                                |t          |          d          S Nr   )libc	lsetxattrr,   lenr.   r/   r1   vals       r   gr_lsetxattrr:   3   s=    x!!$++--"%c((A/ / 	/r   c                     | j                             |                                |                                          S r*   )r5   lremovexattrr,   r.   r/   r1   s      r   gr_lremovexattrr>   7   s*    x$$T[[]]DKKMMBBBr   c                     |                      |                                |                                |                                ||          S r*   )gf_changelog_registerr,   libgfapibrickr/   log_file	log_levelretriess         r   gr_cl_registerrG   :   sD    --ellnn.2kkmm.6oo.?.?.7B B 	Br   c                 P    |                      |                                          S r*   )gf_changelog_doner,   rB   clfiles     r   
gr_cl_donerL   @   s    ))&--//:::r   c                 X    |                      |                                ||||          S r*   )gf_history_changelogr,   rB   changelog_pathstartendnum_parallel
actual_ends         r   gr_cl_history_changelogrU   C   s2    ,,^-B-B-D-D-2C-79 9 	9r   c                 P    |                      |                                          S r*   )gf_history_changelog_doner,   rJ   s     r   gr_cl_history_donerX   I   s    11&--//BBBr   c                    |                                 }t          |          }t          j        |                     |          |||                                 ||t          j        |          dt                      	  	        S r4   r,   r7   structpack
_fmt_mknodstatS_IMODEr   r.   gfbnmouidgid
bn_encodedblens           r   entry_pack_regrh   N   sd    YY[[
:{3>>$//RYY[["j<++Q9 9 	9r   c                 .   |                                 }t          |          }|d         }t          j        |                     |          |d         |d         |                                 ||t          j        |          dt                      	  	        S Nmoderd   re   r   rZ   )r.   ra   rb   strf   rg   rc   s          r   entry_pack_reg_statrm   U   sv    YY[[
:Z{3>>$//e9bi99;;J<++Q9 9 	9r   c                    |                                 }t          |          }t          j        |                     |          |||                                 ||t          j        |          t                                S r*   )r,   r7   r[   r\   
_fmt_mkdirr^   r_   r   r`   s           r   entry_pack_mkdirrp   _   sb    YY[[
:{3>>$//RYY[["j<++UWW6 6 	6r   c           	      2   |                                 }t          |          }|                                 }t          |          }t          j        |                     ||          |d         |d         |                                 |d         ||          S Nrd   re   rk   )r,   r7   r[   r\   _fmt_symlink)	r.   ra   rb   lnkrl   rf   rg   lnk_encodedllens	            r   entry_pack_symlinkrw   g   s}    YY[[
:jjll;{3++D$77e9bi99;;6
J&( ( 	(r   c                  6    t          j                    \  } }| |fS r*   )r   r	   r   s     r   r	   r	   q   s    A1vr   c                     | S r*   r   r   s    r   r   r   v   s    r   c                     | S r*   r   r!   s    r   r#   r#   z   s    r   c                 "    t          d|           S )N r   r&   s    r   r(   r(   }   s    #D$///r   c                 d    |r|                      ||||          S |                      |||          S r*   )r+   r-   s        r   r2   r2      s<     	9##D$>>>##D$888r   c                 X    | j                             |||t          |          d          S r4   )r5   r6   r7   r8   s       r   r:   r:      s&    x!!$c3s88Q???r   c                 8    | j                             ||          S r*   )r5   r<   r=   s      r   r>   r>      s    x$$T4000r   c                 4    |                      |||||          S r*   )r@   rA   s         r   rG   rG      s(    --eT8.7B B 	Br   c                 ,    |                      |          S r*   )rI   rJ   s     r   rL   rL      s    ))&111r   c                 4    |                      |||||          S r*   )rN   rO   s         r   rU   rU      s(    ,,^UC-9:G G 	Gr   c                 ,    |                      |          S r*   )rW   rJ   s     r   rX   rX      s    11&999r   c                     t          |          }t          j        |                     |          |||||t	          j        |          dt                      	  	        S r4   r7   r[   r\   r]   r^   r_   r   r.   ra   rb   rc   rd   re   rg   s          r   rh   rh      sO    2ww{3>>$//RR<++Q9 9 	9r   c                     t          |          }|d         }t          j        |                     |          |d         |d         |||t	          j        |          dt                      	  	        S rj   r   )r.   ra   rb   rl   rg   rc   s         r   rm   rm      sa    2wwZ{3>>$//e9bir2<++Q9 9 	9r   c                     t          |          }t          j        |                     |          |||||t	          j        |          t                                S r*   )r7   r[   r\   ro   r^   r_   r   r   s          r   rp   rp      sM    2ww{3>>$//RR<++UWW6 6 	6r   c           	          t          |          }t          |          }t          j        |                     ||          |d         |d         ||d         ||          S rr   )r7   r[   r\   rs   )r.   ra   rb   rt   rl   rg   rv   s          r   rw   rw      sX    2ww3xx{3++D$77e9bir&z2s4 4 	4r   r*   )sysr   r^   r[   
syncdutilsr   ctypesr   version_infor	   r   r#   r(   r2   r:   r>   rG   rL   rU   rX   rh   rm   rp   rw   r   r   r   <module>r      sS   


 				         ' ' ' ' ' 't  3 3 3/ / /1 1 1B B B B/ / /C C CB B B; ; ;9 9 9C C C
9 9 99 9 96 6 6( ( ( ( (  
    0 0 09 9 9 9@ @ @1 1 1B B B2 2 2G G G
: : :
9 9 99 9 96 6 64 4 4 4 4r   