Partager via


4.1.10.6.1 ProcessGetNCChangesReply

 procedure ProcessGetNCChangesReply(
   hDrs: DRS_HANDLE,
   rf: RepsFrom,
   msgIn: DRS_MSG_GETCHGREQ_V10,
   dwOutVersion: ULONG,
   msgOut: DRS_MSG_GETCHGREPLY) : ULONG

Informative summary of behavior: The ProcessGetNCChangesReply procedure is invoked when an IDL_DRSGetNCChanges response is received over RPC or SMTP, as specified in [MS-SRPL]. Processing of a given response can be separated into five distinct phases: decompression, attribute value decryption, processing object updates, processing link value updates, and updating the "watermark" information.

The arguments to this procedure are as follows:

  • hDrs: The DRS_HANDLE derived by sending IDL_DRSBind to the server.

  • rf: RepsFrom for the server.

  • msgIn: IDL_DRSGetNCChanges request message sent to the server.

  • dwOutVersion: Version of response message received from the server.

  • msgOut: Response message received from the server.

     msgReplyNative: DRS_MSG_GETCHGREPLY_NATIVE
     replEntinfList: REPLENTINFLIST
     continueProcessing: boolean
     writableReplica: boolean
     sourcePrefixTable: PrefixTable
     attributesAndStamps: set of AttributeAndStamp
     linkValueCount: DWORD
     clientSchemaSignature: sequence of BYTE
     serverSchemaSignature: sequence of BYTE
     fServerSchemaMoreRecent: boolean
     lastElement: DWORD
     ulResult : ULONG
      
     /* Decompress and/or translate the response to a Native response,
      * as necessary. */
     if (dwOutVersion = 0x2) or (dwOutVersion = 0x7) then
       msgReplyNative := DecompressReplyMessage(msgOut, dwOutVersion)
     else
       msgReplyNative := GetNCChangesNativeReply(msgOut, dwOutVersion)
     endif
      
     ulResult := msgReplyNative.dwDRSError
      
     if (ulResult = 0) then
      
       sourcePrefixTable :=   
           AbstractPTFromConcretePT(msgReplyNative.PrefixTableSrc)
      
       /* Check whether the schema on client and server match. */ 
       lastElement := sourcePrefixTable.length - 1
       serverSchemaSignature :=
          copy sourcePrefixTable[lastElement].prefix.length bytes of data 
          from sourcePrefixTable[lastElement].prefix.elements
       clientSchemaSignature := SchemaInfo()
       if clientSchemaSignature ≠ serverSchemaSignature and 
          msgReplyNative.pNC^ ≠ SchemaNC())
       then
         return ERROR_DS_DRA_SCHEMA_MISMATCH
       endif
       Remove sourcePrefixTable[lastElement] from sourcePrefixTable
      
     else
       return ulResult
     endif
      
     /* If the source has the Recycle Bin optional feature enabled, then it must
      * be enabled locally, unless the Schema partition is being updating.
      */
     if  msgReplyNative.pNC^ ≠ SchemaNC() and
        ServerExtensions(hDrs).RB and not IsRecycleBinEnabled()
     then
        EnableRecycleBin()
        return ERROR_DS_DRS_EXTENSIONS_CHANGED
     endif
      
     /* If the source has the Privileged Access Management optional feature enabled,
      * then it must be enabled locally unless the Schema partition is being updated.
      */
     if  msgReplyNative.pNC^ ≠ SchemaNC() and
        ServerExtensions(hDrs).GR9 and not IsPrivilegedAccessManagementEnabled()
     then
        EnablePrivilegedAccessManagement()
        return ERROR_DS_DRS_EXTENSIONS_CHANGED
     endif
      
     /* Process object updates. */
     replEntinfList := msgReplyNative.pObjects^
     while (ulResult = 0) and (not replEntinfList = null)
       /* Decrypt any encrypted attribute values. */
       ulResult := DecryptValuesIfNecessary (
                     hDrs,
                     sourcePrefixTable,
                     replEntinfList.Entinf.AttrBlock)
      
       if (ulResult = 0) then
         attributesAndStamps := GetStampsForUpdate(
                              replEntinfList,
                              sourcePrefixTable)
         /* Process objects that are moved across an NC. */
         continueProcessing := PrepareCrossNCMove(
                                 replEntinfList, 
                                 sourcePrefixTable)
       endif
       if continueProcessing and (ulResult = 0) then
         if (DRS_WRIT_REP in msgIn.ulFlags) then
           writableReplica  := true
         else
           writableReplica  := false
         endif
         continueProcessing := AdjustInstanceTypeAttrVal(
                                 msgReplyNative.pNC^,
                                 writableReplica , 
                                 replEntinfList, 
                                 prefixTable)
       endif
       if continueProcessing and (ulResult = 0) then
         if (not ObjExists(replEntinfList.Entinf.pName^)) then
           ulResult := AddObject(
                         replEntinfList, 
                         sourcePrefixTable,
                         attributesAndStamps)
         else
           ulResult := UpdateObject(
                         replEntinfList, 
                         sourcePrefixTable,
                         attributesAndStamps)
         endif
       endif
       replEntinfList := replEntinfList.pNextEntInf^
     endwhile
      
     /* Enable link value updates for outbound replication
      * if inbound link value updates are detected from source. */
     if (msgReplyNative.cNumValues > 0) then
       dc.fLinkValueStampEnabled = true
     endif
      
     /* Process link value updates. */
     linkValueCount := 0
     while (ulResult = 0) and (linkValueCount < msgReplyNative.cNumValues)
       ulResult := ProcessLinkValue(
                     msgReplyNative.rgValues[linkValueCount],
                     msgReplyNative.pNC^,
                     prefixTable,
                     msgIn.ulFlags,
                     msgIn.ulMoreFlags)
       linkValueCount := linkValueCount + 1
     endwhile
      
     if (ulResult = ERROR_DS_DRA_MISSING_PARENT) then
       Send IDL_DRSGetNCChanges message again with the same input 
       parameters specified in msgIn but this time with msgIn.ulFlags 
       containing DRS_GET_ANC field set. It is an error for this 
       condition to occur if (DRS_GET_ANC in msgIn.ulFlags) is true
     else if (ulResult = ERROR_DS_DRA_RECYCLED_TARGET) then
       Send IDL_DRSGetNCChanges message again with the same input 
       parameters specified in the msgIn but this time with msgIn.ulMoreFlags 
       containing DRS_GET_TGT field set. 
     else if (msgIn.ulExtendedOp = 0) then
       /* Not an extended operation. Update "watermark" information. */
       UpdateRepsFrom(
         rf,
         msgReplyNative, 
         dsaServer,
         ulResult)
       
       if (ulResult = 0) and (msgReplyNative.fMoreData = false) then
         UpdateUTDandPAS(
           msgReplyNative,
           msgIn.partialAttrSetEx^)
       endif
     endif
      
     return ulResult