Change CommandMessage.requireOpMsgResponse such that it accounts for ordered/unordered bulk writes

Author: stIncMale

driver-core/src/main/com/mongodb/internal/connection/CommandMessage.java

@@ -253,7 +253,7 @@ private boolean requireOpMsgResponse() {
         if (responseExpected) {
             return true;
         } else {
-            return payload != null && payload.hasAnotherSplit();
+            return payload != null && payload.isOrdered() && payload.hasAnotherSplit();
         }
     }
 

driver-core/src/main/com/mongodb/internal/connection/SplittablePayload.java

@@ -57,6 +57,7 @@ public final class SplittablePayload {
     private final WriteRequestEncoder writeRequestEncoder = new WriteRequestEncoder();
     private final Type payloadType;
     private final List<WriteRequestWithIndex> writeRequestWithIndexes;
+    private final boolean ordered;
     private final Map<Integer, BsonValue> insertedIds = new HashMap<>();
     private int position = 0;
 
@@ -91,9 +92,10 @@ public enum Type {
      * @param payloadType the payload type
      * @param writeRequestWithIndexes the writeRequests
      */
-    public SplittablePayload(final Type payloadType, final List<WriteRequestWithIndex> writeRequestWithIndexes) {
+    public SplittablePayload(final Type payloadType, final List<WriteRequestWithIndex> writeRequestWithIndexes, final boolean ordered) {
         this.payloadType = notNull("batchType", payloadType);
         this.writeRequestWithIndexes = notNull("writeRequests", writeRequestWithIndexes);
+        this.ordered = ordered;
     }
 
     /**
@@ -159,13 +161,17 @@ public boolean hasAnotherSplit() {
         return writeRequestWithIndexes.size() > position;
     }
 
+    boolean isOrdered() {
+        return ordered;
+    }
+
     /**
      * @return a new SplittablePayload containing only the values after the current position.
      */
     public SplittablePayload getNextSplit() {
         isTrue("hasAnotherSplit", hasAnotherSplit());
         List<WriteRequestWithIndex> nextPayLoad = writeRequestWithIndexes.subList(position, writeRequestWithIndexes.size());
-        return new SplittablePayload(payloadType, nextPayLoad);
+        return new SplittablePayload(payloadType, nextPayLoad, ordered);
     }
 
     /**

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

@@ -154,7 +154,7 @@ private BulkWriteBatch(final MongoNamespace namespace, final ConnectionDescripti
 
         this.indexMap = indexMap;
         this.unprocessed = unprocessedItems;
-        this.payload = new SplittablePayload(getPayloadType(batchType), payloadItems);
+        this.payload = new SplittablePayload(getPayloadType(batchType), payloadItems, ordered);
         this.operationContext = operationContext;
         this.comment = comment;
         this.variables = variables;