JAVA-2976: Protocol v5 error codes CAS_WRITE_UNKNOWN, CDC_WRITE_FAILURE not supported (3.x) (#1585)

Author: absurdfarce

driver-core/src/main/java/com/datastax/driver/core/ExceptionCode.java

@@ -36,6 +36,8 @@ enum ExceptionCode {
   READ_FAILURE(0x1300),
   FUNCTION_FAILURE(0x1400),
   WRITE_FAILURE(0x1500),
+  CDC_WRITE_FAILURE(0x1600),
+  CAS_WRITE_UNKNOWN(0x1700),
 
   // 2xx: problem validating the request
   SYNTAX_ERROR(0x2000),

driver-core/src/main/java/com/datastax/driver/core/Responses.java

@@ -24,6 +24,8 @@
 import com.datastax.driver.core.exceptions.AlreadyExistsException;
 import com.datastax.driver.core.exceptions.AuthenticationException;
 import com.datastax.driver.core.exceptions.BootstrappingException;
+import com.datastax.driver.core.exceptions.CASWriteUnknownException;
+import com.datastax.driver.core.exceptions.CDCWriteException;
 import com.datastax.driver.core.exceptions.DriverException;
 import com.datastax.driver.core.exceptions.DriverInternalError;
 import com.datastax.driver.core.exceptions.FunctionExecutionException;
@@ -119,6 +121,12 @@ public Error decode(ByteBuf body, ProtocolVersion version, CodecRegistry codecRe
                           clt, received, blockFor, failures, failuresMap, dataPresent != 0);
                 }
                 break;
+              case CAS_WRITE_UNKNOWN:
+                clt = CBUtil.readConsistencyLevel(body);
+                received = body.readInt();
+                blockFor = body.readInt();
+                infos = new CASWriteUnknownException(clt, received, blockFor);
+                break;
               case UNPREPARED:
                 infos = MD5Digest.wrap(CBUtil.readBytes(body));
                 break;
@@ -173,6 +181,10 @@ DriverException asException(EndPoint endPoint) {
           return ((ReadFailureException) infos).copy(endPoint);
         case FUNCTION_FAILURE:
           return new FunctionExecutionException(endPoint, message);
+        case CDC_WRITE_FAILURE:
+          return new CDCWriteException(endPoint, message);
+        case CAS_WRITE_UNKNOWN:
+          return ((CASWriteUnknownException) infos).copy(endPoint);
         case SYNTAX_ERROR:
           return new SyntaxError(endPoint, message);
         case UNAUTHORIZED:

driver-core/src/main/java/com/datastax/driver/core/exceptions/CASWriteUnknownException.java

@@ -0,0 +1,91 @@
+/*
+ * Copyright DataStax, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.datastax.driver.core.exceptions;
+
+import com.datastax.driver.core.ConsistencyLevel;
+import com.datastax.driver.core.EndPoint;
+
+public class CASWriteUnknownException extends QueryConsistencyException {
+
+  private static final long serialVersionUID = 0;
+
+  /**
+   * This constructor should only be used internally by the driver when decoding error responses.
+   */
+  public CASWriteUnknownException(ConsistencyLevel consistency, int received, int required) {
+    this(null, consistency, received, required);
+  }
+
+  public CASWriteUnknownException(
+      EndPoint endPoint, ConsistencyLevel consistency, int received, int required) {
+    super(
+        endPoint,
+        String.format(
+            "CAS operation result is unknown - proposal was not accepted by a quorum. (%d / %d)",
+            received, required),
+        consistency,
+        received,
+        required);
+  }
+
+  private CASWriteUnknownException(
+      EndPoint endPoint,
+      String msg,
+      Throwable cause,
+      ConsistencyLevel consistency,
+      int received,
+      int required) {
+    super(endPoint, msg, cause, consistency, received, required);
+  }
+
+  @Override
+  public CASWriteUnknownException copy() {
+    return new CASWriteUnknownException(
+        getEndPoint(),
+        getMessage(),
+        this,
+        getConsistencyLevel(),
+        getReceivedAcknowledgements(),
+        getRequiredAcknowledgements());
+  }
+
+  /**
+   * Create a copy of this exception with a nicer stack trace, and including the coordinator address
+   * that caused this exception to be raised.
+   *
+   * <p>This method is mainly intended for internal use by the driver and exists mainly because:
+   *
+   * <ol>
+   *   <li>the original exception was decoded from a response frame and at that time, the
+   *       coordinator address was not available; and
+   *   <li>the newly-created exception will refer to the current thread in its stack trace, which
+   *       generally yields a more user-friendly stack trace that the original one.
+   * </ol>
+   *
+   * @param endPoint The full address of the host that caused this exception to be thrown.
+   * @return a copy/clone of this exception, but with the given host address instead of the original
+   *     one.
+   */
+  public CASWriteUnknownException copy(EndPoint endPoint) {
+    return new CASWriteUnknownException(
+        endPoint,
+        getMessage(),
+        this,
+        getConsistencyLevel(),
+        getReceivedAcknowledgements(),
+        getRequiredAcknowledgements());
+  }
+}

driver-core/src/main/java/com/datastax/driver/core/exceptions/CDCWriteException.java

@@ -0,0 +1,61 @@
+/*
+ * Copyright DataStax, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.datastax.driver.core.exceptions;
+
+import com.datastax.driver.core.EndPoint;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+
+/** An error occurred when trying to write a CDC mutation to the commitlog * */
+public class CDCWriteException extends QueryExecutionException implements CoordinatorException {
+
+  private static final long serialVersionUID = 0;
+
+  private final EndPoint endPoint;
+
+  public CDCWriteException(EndPoint endPoint, String message) {
+    super(message);
+    this.endPoint = endPoint;
+  }
+
+  /** Private constructor used solely when copying exceptions. */
+  private CDCWriteException(EndPoint endPoint, String message, CDCWriteException cause) {
+    super(message, cause);
+    this.endPoint = endPoint;
+  }
+
+  @Override
+  public EndPoint getEndPoint() {
+    return endPoint;
+  }
+
+  @Override
+  @Deprecated
+  public InetSocketAddress getAddress() {
+    return (endPoint == null) ? null : endPoint.resolve();
+  }
+
+  @Override
+  @Deprecated
+  public InetAddress getHost() {
+    return (endPoint == null) ? null : endPoint.resolve().getAddress();
+  }
+
+  @Override
+  public CDCWriteException copy() {
+    return new CDCWriteException(endPoint, getMessage(), this);
+  }
+}