This is an automated email from the ASF dual-hosted git repository.

marcuse pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/cassandra-in-jvm-dtest-api.git


The following commit(s) were added to refs/heads/master by this push:
     new 39ec22a  Default to 3 datadirs in in-jvm dtests (#13)
39ec22a is described below

commit 39ec22a3c813ee6bf663c85d8c1053abda59575e
Author: Marcus Eriksson <[email protected]>
AuthorDate: Tue Sep 8 13:10:39 2020 +0200

    Default to 3 datadirs in in-jvm dtests (#13)
    
    Patch by marcuse; reviewed by David Capwell for CASSANDRA-15386
---
 .../cassandra/distributed/shared/AbstractBuilder.java      | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git 
a/src/main/java/org/apache/cassandra/distributed/shared/AbstractBuilder.java 
b/src/main/java/org/apache/cassandra/distributed/shared/AbstractBuilder.java
index d601cda..63ceca3 100644
--- a/src/main/java/org/apache/cassandra/distributed/shared/AbstractBuilder.java
+++ b/src/main/java/org/apache/cassandra/distributed/shared/AbstractBuilder.java
@@ -54,6 +54,7 @@ public abstract class AbstractBuilder<I extends IInstance, C 
extends ICluster, B
     private ClassLoader sharedClassLoader = 
Thread.currentThread().getContextClassLoader();
     private int broadcastPort = 7012;
     private BiConsumer<ClassLoader, Integer> instanceInitializer = (cl, id) -> 
{};
+    private int datadirCount = 3;
 
     public AbstractBuilder(Factory<I, C, B> factory)
     {
@@ -101,6 +102,11 @@ public abstract class AbstractBuilder<I extends IInstance, 
C extends ICluster, B
         return instanceInitializer;
     }
 
+    public int getDatadirCount()
+    {
+        return datadirCount;
+    }
+
     public C start() throws IOException
     {
         C cluster = createWithoutStarting();
@@ -268,6 +274,14 @@ public abstract class AbstractBuilder<I extends IInstance, 
C extends ICluster, B
         return (B) this;
     }
 
+    public B withDataDirCount(int datadirCount)
+    {
+        assert datadirCount > 0 : "data dir count requires a positive number 
but given " + datadirCount;
+        this.datadirCount = datadirCount;
+        return (B) this;
+    }
+
+
     static String dcName(int index)
     {
         return "datacenter" + index;


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to