This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/master by this push:
new 10cdbb0 JAMES-3586 Use LOCAL_ONE for optimistic consistency downgrades
10cdbb0 is described below
commit 10cdbb0033e814dc18e8613b5f600fc0186742dd
Author: Benoit Tellier <[email protected]>
AuthorDate: Wed May 19 19:42:53 2021 +0700
JAMES-3586 Use LOCAL_ONE for optimistic consistency downgrades
This makes this more viable in a multi-DC setup
while not affecting the single DC use case.
---
.../java/org/apache/james/blob/cassandra/CassandraBucketDAO.java | 6 +++---
.../org/apache/james/blob/cassandra/CassandraDefaultBucketDAO.java | 6 +++---
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBucketDAO.java
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBucketDAO.java
index 809d4c3..8a86ebf 100644
---
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBucketDAO.java
+++
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBucketDAO.java
@@ -19,7 +19,7 @@
package org.apache.james.blob.cassandra;
-import static com.datastax.driver.core.ConsistencyLevel.ONE;
+import static com.datastax.driver.core.ConsistencyLevel.LOCAL_ONE;
import static com.datastax.driver.core.querybuilder.QueryBuilder.bindMarker;
import static com.datastax.driver.core.querybuilder.QueryBuilder.delete;
import static com.datastax.driver.core.querybuilder.QueryBuilder.eq;
@@ -151,7 +151,7 @@ public class CassandraBucketDAO {
select.bind()
.setString(BUCKET, bucketName.asString())
.setString(ID, blobId.asString())
- .setConsistencyLevel(ONE))
+ .setConsistencyLevel(LOCAL_ONE))
.map(row -> row.getInt(NUMBER_OF_CHUNK));
}
@@ -170,7 +170,7 @@ public class CassandraBucketDAO {
.setString(BucketBlobParts.BUCKET, bucketName.asString())
.setString(BucketBlobParts.ID, blobId.asString())
.setInt(BucketBlobParts.CHUNK_NUMBER, position)
- .setConsistencyLevel(ONE))
+ .setConsistencyLevel(LOCAL_ONE))
.map(this::rowToData);
}
diff --git
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraDefaultBucketDAO.java
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraDefaultBucketDAO.java
index 0866491..eec7461 100644
---
a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraDefaultBucketDAO.java
+++
b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraDefaultBucketDAO.java
@@ -19,7 +19,7 @@
package org.apache.james.blob.cassandra;
-import static com.datastax.driver.core.ConsistencyLevel.ONE;
+import static com.datastax.driver.core.ConsistencyLevel.LOCAL_ONE;
import static com.datastax.driver.core.querybuilder.QueryBuilder.bindMarker;
import static com.datastax.driver.core.querybuilder.QueryBuilder.delete;
import static com.datastax.driver.core.querybuilder.QueryBuilder.eq;
@@ -128,7 +128,7 @@ public class CassandraDefaultBucketDAO {
return cassandraAsyncExecutor.executeSingleRow(
select.bind()
.setString(ID, blobId.asString())
- .setConsistencyLevel(ONE))
+ .setConsistencyLevel(LOCAL_ONE))
.map(row -> row.getInt(NUMBER_OF_CHUNK));
}
@@ -145,7 +145,7 @@ public class CassandraDefaultBucketDAO {
selectPart.bind()
.setString(DefaultBucketBlobParts.ID, blobId.asString())
.setInt(DefaultBucketBlobParts.CHUNK_NUMBER, position)
- .setConsistencyLevel(ONE))
+ .setConsistencyLevel(LOCAL_ONE))
.map(this::rowToData);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
