Файловый менеджер - Редактировать - /usr/lib64/python3.6/site-packages/samba/__pycache__/drs_utils.cpython-36.opt-1.pyc
Ðазад
3 �I�dPO � @ s� d dl mZmZmZ d dlmZ d dlmZ d dlm Z d dlm Z d dlm Z d dlZd dl Z d dl mZmZmZ d dlZG d d � d e�Zdd d �Zd d� Zdd� Zdd� Zdd� ZG dd� de�ZG dd� de�ZdS )� )�drsuapi�misc�drsblobs)�Net)� ndr_unpack)�dsdb)�werror)� WERRORErrorN)�DRSUAPI_ATTID_name�(DRSUAPI_SUPPORTED_EXTENSION_GETCHGREQ_V8�)DRSUAPI_SUPPORTED_EXTENSION_GETCHGREQ_V10c @ s e Zd ZdZdd� Zdd� ZdS )� drsExceptionzBase element for drs errorsc C s || _ d S )N)�value)�selfr � r �!/usr/lib64/python3.6/drs_utils.py�__init__% s zdrsException.__init__c C s d| j S )NzdrsException: )r )r r r r �__str__( s zdrsException.__str__N)�__name__� __module__� __qualname__�__doc__r r r r r r r " s r c C s� d}|j � dkr|d7 }|dk rB|d| � �7 }d|� d|� d�}n d | |f }y tj|||�}t|�\}}W n2 tk r� } ztd | | f ��W Y dd} ~ X nX |||fS ) a� Make a DRSUAPI connection to the server. :param server: the name of the server to connect to :param lp: a samba line parameter object :param creds: credential used for the connection :param ip: Forced target server name :return: A tuple with the drsuapi bind object, the drsuapi handle and the supported extensions. :raise drsException: if the connection fails Zseal� z,printNz,target_hostname=z ncacn_ip_tcp:�[�]zncacn_ip_tcp:%s[%s]z DRS connection to %s failed: %s)Z log_levelr � drs_DsBind� Exceptionr ) Zserver�lp�credsZipZbinding_options�binding_string� drsuapiBindZ drsuapiHandleZbindSupportedExtensions�er r r �drsuapi_connect, s "r" c C st t j� }||_t j� }||_||_tj|�|_y| j |d|� W n. t k rn } zt d| ��W Y dd}~X nX dS )a� Send DS replica sync request. :param drsuapiBind: a drsuapi Bind object :param drsuapi_handle: a drsuapi handle on the drsuapi connection :param source_dsa_guid: the guid of the source dsa for the replication :param naming_context: the DN of the naming context to replicate :param req_options: replication options for the DsReplicaSync call :raise drsException: if any error occur while sending and receiving the reply for the dsReplicaSync � zDsReplicaSync failed %sN) r �DsReplicaObjectIdentifier�dnZDsReplicaSyncRequest1�naming_contextZoptionsr �GUID�source_dsa_guidZ DsReplicaSyncr r )r Zdrsuapi_handler( r& Z req_optionZncZreq1Zestrr r r �sendDsReplicaSyncL s r) c C s4 t j� }d|_t j� |_|j jt jO _|j jt jO _|j jt jO _|j jt j O _|j jt j O _|j jt j O _|j jt j O _|j jt j O _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt jO _|j jt j O _|j jt j O _|j jt j O _|j jt j O _|j jt j O _|j jt j!O _| j"t#j$t j%�|�\}}||jjfS )z0make a DsBind call, returning the binding handle� )&r Z DsBindInfoCtrZlengthZ DsBindInfo28�infoZsupported_extensionsZ DRSUAPI_SUPPORTED_EXTENSION_BASEZ-DRSUAPI_SUPPORTED_EXTENSION_ASYNC_REPLICATIONZ%DRSUAPI_SUPPORTED_EXTENSION_REMOVEAPIZ&DRSUAPI_SUPPORTED_EXTENSION_MOVEREQ_V2Z+DRSUAPI_SUPPORTED_EXTENSION_GETCHG_COMPRESSZ%DRSUAPI_SUPPORTED_EXTENSION_DCINFO_V1Z4DRSUAPI_SUPPORTED_EXTENSION_RESTORE_USN_OPTIMIZATIONZ'DRSUAPI_SUPPORTED_EXTENSION_KCC_EXECUTEZ'DRSUAPI_SUPPORTED_EXTENSION_ADDENTRY_V2Z4DRSUAPI_SUPPORTED_EXTENSION_LINKED_VALUE_REPLICATIONZ%DRSUAPI_SUPPORTED_EXTENSION_DCINFO_V2Z8DRSUAPI_SUPPORTED_EXTENSION_INSTANCE_TYPE_NOT_REQ_ON_MODZ'DRSUAPI_SUPPORTED_EXTENSION_CRYPTO_BINDZ)DRSUAPI_SUPPORTED_EXTENSION_GET_REPL_INFOZ-DRSUAPI_SUPPORTED_EXTENSION_STRONG_ENCRYPTIONZ&DRSUAPI_SUPPORTED_EXTENSION_DCINFO_V01Z1DRSUAPI_SUPPORTED_EXTENSION_TRANSITIVE_MEMBERSHIPZ+DRSUAPI_SUPPORTED_EXTENSION_ADD_SID_HISTORYZ&DRSUAPI_SUPPORTED_EXTENSION_POST_BETA3Z,DRSUAPI_SUPPORTED_EXTENSION_GET_MEMBERSHIPS2Z(DRSUAPI_SUPPORTED_EXTENSION_GETCHGREQ_V6Z)DRSUAPI_SUPPORTED_EXTENSION_NONDOMAIN_NCSr Z*DRSUAPI_SUPPORTED_EXTENSION_GETCHGREPLY_V5Z*DRSUAPI_SUPPORTED_EXTENSION_GETCHGREPLY_V6Z,DRSUAPI_SUPPORTED_EXTENSION_ADDENTRYREPLY_V3Z*DRSUAPI_SUPPORTED_EXTENSION_GETCHGREPLY_V7Z)DRSUAPI_SUPPORTED_EXTENSION_VERIFY_OBJECTZDsBindr r' ZDRSUAPI_DS_BIND_GUID)�drsZ bind_infor+ Zhandler r r r g sB r c C s� t j� }d|_g }| j� }| j|tjddddgd�}x�|D ]�}t|d d �}d|kr||d d }t|�t j j t j j B @ r|q:d|kr�|d d }t|�t j j @ r�q:| j|�} |jt| �� q:W |j� ||_t|�|_|S )z-get a list of attributes for RODC replicationr# zobjectClass=attributeSchemaZlDAPDisplayNameZ systemFlagsZ searchFlags)�base�scopeZ expression�attrsr )r ZDsPartialAttributeSet�versionZget_schema_basedn�search�ldbZ SCOPE_SUBTREE�str�int�sambar ZDS_FLAG_ATTR_NOT_REPLICATEDZDS_FLAG_ATTR_IS_CONSTRUCTEDZSEARCH_FLAG_RODC_ATTRIBUTEZ get_attid_from_lDAPDisplayName�append�sort�attids�lenZ num_attids) �samdb�partial_attribute_setr8 Z schema_dn�res�rZldap_display_nameZ system_flagsZ search_flags�attidr r r �"drs_get_rodc_partial_attribute_set� s2 r? c C s |j | _ |j| _|j| _dS )z� Copies the highwater mark by value, rather than by object reference. (This avoids lingering talloc references to old GetNCChanges reply messages). N)�tmp_highest_usn� reserved_usn� highest_usn)�hwmZnew_hwmr r r �drs_copy_highwater_mark� s rD c @ sV e Zd ZdZdd� Zdd� Zedd� �Zdd � Zd d � Z d e j d d dd dfdd�Z d S )� drs_ReplicatezDRS replication callsc C s� t j |||�| _t| j�\| _| _t||d�| _|| _t|t j �sJt d��|t j d�kr`t d��| jj | j|| j|�| _ d| _d S )N)r r z"Must supply GUID for invocation_idz$00000000-0000-0000-0000-000000000000zGMust not set GUID 00000000-0000-0000-0000-000000000000 as invocation_idr )r r, r � drs_handle� supports_extr �netr: � isinstancer r' � RuntimeErrorZreplicate_init�replication_state� more_flags)r r r r r: � invocation_idr r r r � s zdrs_Replicate.__init__c C s( | j }|tjko&|t@ o&|jtj@ dkS )Nr )rG r ZWERR_DS_DRA_RECYCLED_TARGETr rL r �DRSUAPI_DRS_GET_TGT)r � error_code�reqrG r r r �_should_retry_with_get_tgt� s z(drs_Replicate._should_retry_with_get_tgtc C s | t jko|jtj@ dkS )Nr )r ZWERR_DS_DRA_MISSING_PARENT� replica_flagsr �DRSUAPI_DRS_GET_ANC)rO rP r r r �%_should_calculate_missing_anc_locally� s z3drs_Replicate._should_calculate_missing_anc_locallyc C s� t � | _|j}x�|d krP | jjt|jjj�� |jd k r�|jt j d�kr�t|j�| jkr�t j | j |jjj�}|j� }td|� d|j� d�� |j}qW d S )Nz$00000000-0000-0000-0000-000000000000zObject z with GUID z) was not sent by the server in this chunk)�setZ guids_seen� first_object�addr3 �object� identifierZguidZparent_object_guidr r' r2 �Dnr: r% �parent�printZ next_object)r �ctrZobject_to_checkZobj_dnZ parent_dnr r r � _calculate_missing_anc_locally� s z,drs_Replicate._calculate_missing_anc_locallyc C s | j j| j|||||d� dS )z5Processes a single chunk of received replication data)�schema� req_levelrP N)rH Zreplicate_chunkrK )r �levelr] r_ r` rP � first_chunkr r r � process_chunk� s zdrs_Replicate.process_chunkFNTr c C s� | j t@ r$tj� } | | jB | _d} n d} tj� } || _|| _tj� | _ || j _ d} tj � }d|_ d|_ d|_|�s>| jj|tjdgd�}d|d kr�x4|d d D ]$}ttj|�}|jj|kr�|jj}q�W tj� } d| _d| _d| _g }t j | j| jj � �}x0|D ](}tj � }|j|_|j|_|j |� �qW || _!t"|�| _#|| _| | _$|dk �r\|| _%n\|tj&k�rpd| _%nHtj'tj(B tj)B tj*B tj+B | _%|�r�| j%tj,O _%n| j%tj-O _%| �r�| j%tj.O _%d| _/d | _0|| _1d| _2d| _3d| _4d| j5_6d| j5_7| �r |�r t8| j�| _3| j t9@ �sld } tj:� }x2t;|�D ]&}|d d k�r>t<||t=| |�� �q>W |} d}d}d }�x.| j>j?| j@| | �\}} | jAdk�r�| jBdk�r�tCd | jB ��y| jD|| || | |� W n� tEk �rR } zd| jF| jGd | ��rtHd� | jtjIO _d }�w|| jJ| jGd | ��r>tHd� | jK| � | �W Y dd} ~ X nX d}|| jB7 }y|| jL7 }W n tMk �r� Y nX | jNdk�r�P tO| j| jP� �q|W ||fS )zreplicate a single DN� � Nr ZrepsFrom)r- r. r/ r# i� i�" � �_Tz6DsGetNCChanges: NULL first_object with object_count=%uz1Missing target object - retrying with DRS_GET_TGTz;Missing parent object - calculating missing objects locallyF)QrG r r ZDsGetNCChangesRequest10rL ZDsGetNCChangesRequest8�destination_dsa_guid�source_dsa_invocation_idr$ r& r% ZDsReplicaHighWaterMarkr@ rA rB r: r1 r2 Z SCOPE_BASEr r ZrepsFromToBlobr] Z highwatermarkZDsReplicaCursorCtrExr0 Z reserved1Z reserved2r Z_dsdb_load_udv_v2Zget_default_basednZDsReplicaCursorr6 Zcursorsr9 �countZuptodateness_vectorrR ZDRSUAPI_EXOP_REPL_SECRETZDRSUAPI_DRS_INIT_SYNCZDRSUAPI_DRS_PER_SYNCrS ZDRSUAPI_DRS_NEVER_SYNCEDZ$DRSUAPI_DRS_GET_ALL_GROUP_MEMBERSHIPZ%DRSUAPI_DRS_SPECIAL_SECRET_PROCESSINGZDRSUAPI_DRS_WRIT_REPZDRSUAPI_DRS_SYNC_FORCEDZmax_object_countZ max_ndr_sizeZ extended_opZ fsmo_infor; Zpartial_attribute_set_exZ mapping_ctrZ num_mappingsZmappingsr? r ZDsGetNCChangesRequest5�dir�setattr�getattrr, ZDsGetNCChangesrF rV � object_countrJ rc r rQ �argsr\ rN rT r^ Zlinked_attributes_count�AttributeErrorZ more_datarD Znew_highwatermark) r r% ri rh r_ ZexopZrodcrR Z full_syncZ sync_forcedrL rP r` ZudvrC r< Zreps_from_packedZ reps_from_objZ cursors_v1Z cursors_v2Z cursor_v2Z cursor_v1Zreq5�aZ num_objectsZ num_linksrb ra r] r! r r r � replicate s� zdrs_Replicate.replicate) r r r r r rQ � staticmethodrT r^ rc r ZDRSUAPI_EXOP_NONErr r r r r rE � s rE c sD e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Z� fd d �Z� Z S ) �drs_ReplicateRenamerz,Uses DRS replication to rename the entire DBc s0 t t| �j|||||� || _|| _tj| _d S )N)�superrt r � old_base_dn� new_base_dnr rN rL )r r r r r: rM rv rw )� __class__r r r � s z drs_ReplicateRenamer.__init__c C s t jd| j | j|�S )z/Uses string substitution to replace the base DNz%s$)�re�subrv rw )r Zdn_strr r r � rename_dn� s z drs_ReplicateRenamer.rename_dnc C sN xH|j jD ]<}|jtkr tj| j|jj�}|j � }|j d�|j j d _ q W dS )z3Updates the 'name' attribute for the base DN objectz utf-16-ler N)Z attribute_ctrZ attributesr> r r2 rZ r: rY r% Z get_rdn_value�encodeZ value_ctr�valuesZblob)r Zbase_obj�attrZbase_dn�new_namer r r �update_name_attr� s z%drs_ReplicateRenamer.update_name_attrc C sJ |j j}| j|j j�|j _td||j jf � |j j| jkrF| j|� dS )z1Renames the first/top-level object in a partitionz Renaming partition %s --> %sN)rY r% r{ r\ rw r� )r Z first_objZold_dnr r r �rename_top_level_object� s z,drs_ReplicateRenamer.rename_top_level_objectc sR |j r| j|j j�|j _|r4|jdkr4| j|jj� tt| �j ||||||� dS )z5Processes a single chunk of received replication datar N) r& r{ r% rn r� rV rX ru rt rc )r ra r] r_ r` rP rb )rx r r rc � s z"drs_ReplicateRenamer.process_chunk) r r r r r r{ r� r� rc � __classcell__r r )rx r rt � s rt )N) Z samba.dcerpcr r r Z samba.netr Z samba.ndrr r5 r r r r2 Zsamba.dcerpc.drsuapir r r ry r r r" r) r r? rD rX rE rt r r r r �<module> s$ && W
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка