Skip to content

Commit 4e96e11

Browse files
committed
Fixed use of secondary criteria
1 parent 411dab6 commit 4e96e11

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/MongoDB.Driver/Core/Operations/RetryableWriteContext.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -67,17 +67,17 @@ public void Dispose()
6767
}
6868
}
6969

70-
public void AcquireOrReplaceChannel(OperationContext operationContext, IReadOnlyCollection<ServerDescription> deprioritizedServers, IMayUseSecondaryCriteria mayUseSecondaryCriteria = null)
70+
public void AcquireOrReplaceChannel(OperationContext operationContext, IReadOnlyCollection<ServerDescription> deprioritizedServers)
7171
{
7272
try
7373
{
7474
_errorDuringLastChannelAcquisition = false;
7575
_lastAcquiredServer = null;
7676
operationContext.ThrowIfTimedOutOrCanceled();
7777
//TODO The implementation of the two overloads is different, need to understand if it's an issue and we can just call the second overload from the first one.
78-
var writeChannelSource = mayUseSecondaryCriteria == null ?
78+
var writeChannelSource = _mayUseSecondaryCriteria == null ?
7979
Binding.GetWriteChannelSource(operationContext, deprioritizedServers)
80-
: Binding.GetWriteChannelSource(operationContext, deprioritizedServers, mayUseSecondaryCriteria);
80+
: Binding.GetWriteChannelSource(operationContext, deprioritizedServers, _mayUseSecondaryCriteria);
8181
ReplaceChannelSource(writeChannelSource);
8282
_lastAcquiredServer = ChannelSource.ServerDescription;
8383
ReplaceChannel(ChannelSource.GetChannel(operationContext));
@@ -93,17 +93,17 @@ public void AcquireOrReplaceChannel(OperationContext operationContext, IReadOnly
9393
}
9494
}
9595

96-
public async Task AcquireOrReplaceChannelAsync(OperationContext operationContext, IReadOnlyCollection<ServerDescription> deprioritizedServers, IMayUseSecondaryCriteria mayUseSecondaryCriteria = null)
96+
public async Task AcquireOrReplaceChannelAsync(OperationContext operationContext, IReadOnlyCollection<ServerDescription> deprioritizedServers)
9797
{
9898
try
9999
{
100100
_errorDuringLastChannelAcquisition = false;
101101
_lastAcquiredServer = null;
102102
operationContext.ThrowIfTimedOutOrCanceled();
103103
//TODO The implementation of the two overloads is different, need to understand if it's an issue and we can just call the second overload from the first one.
104-
var writeChannelSource = mayUseSecondaryCriteria == null ?
104+
var writeChannelSource = _mayUseSecondaryCriteria == null ?
105105
await Binding.GetWriteChannelSourceAsync(operationContext, deprioritizedServers).ConfigureAwait(false)
106-
: await Binding.GetWriteChannelSourceAsync(operationContext, deprioritizedServers, mayUseSecondaryCriteria).ConfigureAwait(false);
106+
: await Binding.GetWriteChannelSourceAsync(operationContext, deprioritizedServers, _mayUseSecondaryCriteria).ConfigureAwait(false);
107107
ReplaceChannelSource(writeChannelSource);
108108
_lastAcquiredServer = ChannelSource.ServerDescription;
109109
ReplaceChannel(await ChannelSource.GetChannelAsync(operationContext).ConfigureAwait(false));

0 commit comments

Comments
 (0)