Skip to content

Commit 302aca6

Browse files
committed
Refactoring: remove unused binding parameters from MixedBulkWriteOperation
JAVA-5956, JAVA-6117, JAVA-6113, JAVA-6119, JAVA-6141
1 parent c5941ef commit 302aca6

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

driver-core/src/main/com/mongodb/internal/operation/MixedBulkWriteOperation.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ public BulkWriteResult execute(final WriteBinding binding, final OperationContex
215215
bypassDocumentValidation, retryWrites, writeRequests, operationContextWithMinRTT, comment, variables),
216216
timeoutContextWithMinRtt);
217217
}
218-
return executeBulkWriteBatch(retryState, writeConcern, binding, operationContextWithMinRTT, connection);
218+
return executeBulkWriteBatch(retryState, writeConcern, operationContextWithMinRTT, connection);
219219
}, operationContext)
220220
);
221221
try {
@@ -261,7 +261,7 @@ && handleMongoWriteConcernWithResponseExceptionAsync(retryState, releasingCallba
261261
releasingCallback.onResult(null, t);
262262
return;
263263
}
264-
executeBulkWriteBatchAsync(retryState, writeConcern, binding, operationContextWithMinRtt, connection, releasingCallback);
264+
executeBulkWriteBatchAsync(retryState, writeConcern, operationContextWithMinRtt, connection, releasingCallback);
265265
})
266266
).whenComplete(binding::release);
267267
retryingBulkWrite.get(exceptionTransformingCallback(errorHandlingCallback(callback, LOGGER)));
@@ -270,7 +270,6 @@ && handleMongoWriteConcernWithResponseExceptionAsync(retryState, releasingCallba
270270
private BulkWriteResult executeBulkWriteBatch(
271271
final RetryState retryState,
272272
final WriteConcern effectiveWriteConcern,
273-
final WriteBinding binding,
274273
final OperationContext operationContext,
275274
final Connection connection) {
276275
BulkWriteTracker currentBulkWriteTracker = retryState.attachment(AttachmentKeys.bulkWriteTracker())
@@ -318,7 +317,6 @@ private BulkWriteResult executeBulkWriteBatch(
318317
private void executeBulkWriteBatchAsync(
319318
final RetryState retryState,
320319
final WriteConcern effectiveWriteConcern,
321-
final AsyncWriteBinding binding,
322320
final OperationContext operationContext,
323321
final AsyncConnection connection,
324322
final SingleResultCallback<BulkWriteResult> callback) {

0 commit comments

Comments
 (0)