diff --git a/packages/runtime/container-runtime/src/containerRuntime.ts b/packages/runtime/container-runtime/src/containerRuntime.ts index 2d3a8a76ec54..9ff5ef278ec4 100644 --- a/packages/runtime/container-runtime/src/containerRuntime.ts +++ b/packages/runtime/container-runtime/src/containerRuntime.ts @@ -1318,6 +1318,7 @@ export class ContainerRuntime private dirtyContainer: boolean; private emitDirtyDocumentEvent = true; private readonly disableAttachReorder: boolean | undefined; + private readonly useDeltaManagerOpsProxy: boolean; private readonly closeSummarizerDelayMs: number; private readonly defaultTelemetrySignalSampleCount = 100; private readonly _signalTracking: IPerfSignalReport = { @@ -1622,8 +1623,8 @@ export class ContainerRuntime ); let outerDeltaManager: IDeltaManager; - const useDeltaManagerOpsProxy = - this.mc.config.getBoolean("Fluid.ContainerRuntime.DeltaManagerOpsProxy") !== false; + this.useDeltaManagerOpsProxy = + this.mc.config.getBoolean("Fluid.ContainerRuntime.DeltaManagerOpsProxy") === true; // The summarizerDeltaManager Proxy is used to lie to the summarizer to convince it is in the right state as a summarizer client. const summarizerDeltaManagerProxy = new DeltaManagerSummarizerProxy( this.innerDeltaManager, @@ -1632,7 +1633,7 @@ export class ContainerRuntime // The DeltaManagerPendingOpsProxy is used to control the minimum sequence number // It allows us to lie to the layers below so that they can maintain enough local state for rebasing ops. - if (useDeltaManagerOpsProxy) { + if (this.useDeltaManagerOpsProxy) { const pendingOpsDeltaManagerProxy = new DeltaManagerPendingOpsProxy( summarizerDeltaManagerProxy, this.pendingStateManager, @@ -2909,7 +2910,10 @@ export class ContainerRuntime const { local, message, savedOp, localOpMetadata } = messageWithContext; // Set the minimum sequence number to the containerRuntime's understanding of minimum sequence number. - if (this.deltaManager.minimumSequenceNumber < message.minimumSequenceNumber) { + if ( + this.useDeltaManagerOpsProxy && + this.deltaManager.minimumSequenceNumber < message.minimumSequenceNumber + ) { message.minimumSequenceNumber = this.deltaManager.minimumSequenceNumber; }