Merge pull request #334 from XN137/remove-junit4-dependency

Remove junit4 dependency
This commit is contained in:
Jonathan Shook
2021-06-17 09:54:49 -05:00
committed by GitHub
225 changed files with 479 additions and 469 deletions

View File

@@ -1,7 +1,7 @@
package io.nosqlbench.docsys.core; package io.nosqlbench.docsys.core;
import io.nosqlbench.docsys.endpoints.DocsysMarkdownEndpoint; import io.nosqlbench.docsys.endpoints.DocsysMarkdownEndpoint;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class DocsysMarkdownLoaderEndpointTest { public class DocsysMarkdownLoaderEndpointTest {

View File

@@ -2,14 +2,14 @@ package io.nosqlbench.activitytype.cockroachdb;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.engine.api.activityimpl.ParameterMap; import io.nosqlbench.engine.api.activityimpl.ParameterMap;
import org.junit.Test; import org.junit.jupiter.api.Test;
import org.postgresql.util.PSQLException; import org.postgresql.util.PSQLException;
import org.postgresql.util.PSQLState; import org.postgresql.util.PSQLState;
import java.net.SocketTimeoutException; import java.net.SocketTimeoutException;
import java.sql.SQLException; import java.sql.SQLException;
import static org.junit.Assert.*; import static org.junit.jupiter.api.Assertions.assertEquals;
public class CockroachActivityTest { public class CockroachActivityTest {
@Test @Test

View File

@@ -3,13 +3,13 @@ package com.datastax.ebdrivers.cql;
import io.nosqlbench.activitytype.cql.core.CqlAction; import io.nosqlbench.activitytype.cql.core.CqlAction;
import io.nosqlbench.activitytype.cql.core.CqlActivity; import io.nosqlbench.activitytype.cql.core.CqlActivity;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class CqlActionTest { public class CqlActionTest {
@Test @Test
@Ignore @Disabled
public void testCqlAction() { public void testCqlAction() {
ActivityDef ad = ActivityDef.parseActivityDef("driver=ebdrivers;alias=foo;yaml=write-telemetry.yaml;"); ActivityDef ad = ActivityDef.parseActivityDef("driver=ebdrivers;alias=foo;yaml=write-telemetry.yaml;");
CqlActivity cac = new CqlActivity(ad); CqlActivity cac = new CqlActivity(ad);

View File

@@ -1,7 +1,7 @@
package com.datastax.ebdrivers.cql.statements; package com.datastax.ebdrivers.cql.statements;
import io.nosqlbench.activitytype.cql.statements.core.CQLStatementDefParser; import io.nosqlbench.activitytype.cql.statements.core.CQLStatementDefParser;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;

View File

@@ -8,7 +8,7 @@ import com.datastax.driver.core.policies.ReconnectionPolicy;
import com.datastax.driver.core.policies.RetryPolicy; import com.datastax.driver.core.policies.RetryPolicy;
import com.datastax.driver.core.policies.SpeculativeExecutionPolicy; import com.datastax.driver.core.policies.SpeculativeExecutionPolicy;
import io.nosqlbench.activitytype.cql.core.CQLOptions; import io.nosqlbench.activitytype.cql.core.CQLOptions;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.activitytype.cql.core; package io.nosqlbench.activitytype.cql.core;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -3,7 +3,7 @@ package io.nosqlbench.activitytype.cql.datamappers.functions.double_to_cqldurati
import com.datastax.driver.core.Duration; import com.datastax.driver.core.Duration;
import io.nosqlbench.activitytype.cql.datamappers.functions.long_to_cqlduration.CqlDurationFunctions; import io.nosqlbench.activitytype.cql.datamappers.functions.long_to_cqlduration.CqlDurationFunctions;
import io.nosqlbench.activitytype.cql.datamappers.functions.long_to_cqlduration.ToCqlDurationNanos; import io.nosqlbench.activitytype.cql.datamappers.functions.long_to_cqlduration.ToCqlDurationNanos;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.function.LongToIntFunction; import java.util.function.LongToIntFunction;
import java.util.function.LongUnaryOperator; import java.util.function.LongUnaryOperator;

View File

@@ -1,7 +1,7 @@
package io.nosqlbench.activitytype.cql.datamappers.functions.long_localdate; package io.nosqlbench.activitytype.cql.datamappers.functions.long_localdate;
import org.joda.time.DateTime; import org.joda.time.DateTime;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.time.Instant; import java.time.Instant;
import java.time.LocalDate; import java.time.LocalDate;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.activitytype.cql.datamappers.functions.to_daterange; package io.nosqlbench.activitytype.cql.datamappers.functions.to_daterange;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.function.Function; import java.util.function.Function;
import java.util.function.LongFunction; import java.util.function.LongFunction;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.generators.cql.lang; package io.nosqlbench.generators.cql.lang;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.io.IOException; import java.io.IOException;
import java.net.URL; import java.net.URL;

View File

@@ -3,13 +3,13 @@ package com.datastax.ebdrivers.cql;
import io.nosqlbench.activitytype.cql.core.CqlAction; import io.nosqlbench.activitytype.cql.core.CqlAction;
import io.nosqlbench.activitytype.cql.core.CqlActivity; import io.nosqlbench.activitytype.cql.core.CqlActivity;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class CqlActionTest { public class CqlActionTest {
@Test @Test
@Ignore @Disabled
public void testCqlAction() { public void testCqlAction() {
ActivityDef ad = ActivityDef.parseActivityDef("driver=ebdrivers;alias=foo;yaml=write-telemetry.yaml;"); ActivityDef ad = ActivityDef.parseActivityDef("driver=ebdrivers;alias=foo;yaml=write-telemetry.yaml;");
CqlActivity cac = new CqlActivity(ad); CqlActivity cac = new CqlActivity(ad);

View File

@@ -1,7 +1,7 @@
package com.datastax.ebdrivers.cql.statements; package com.datastax.ebdrivers.cql.statements;
import io.nosqlbench.activitytype.cql.statements.core.CQLStatementDefParser; import io.nosqlbench.activitytype.cql.statements.core.CQLStatementDefParser;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;

View File

@@ -8,7 +8,7 @@ import com.datastax.driver.core.policies.ReconnectionPolicy;
import com.datastax.driver.core.policies.RetryPolicy; import com.datastax.driver.core.policies.RetryPolicy;
import com.datastax.driver.core.policies.SpeculativeExecutionPolicy; import com.datastax.driver.core.policies.SpeculativeExecutionPolicy;
import io.nosqlbench.activitytype.cql.core.CQLOptions; import io.nosqlbench.activitytype.cql.core.CQLOptions;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.activitytype.cql.core; package io.nosqlbench.activitytype.cql.core;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.generators.cql.lang; package io.nosqlbench.generators.cql.lang;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.io.IOException; import java.io.IOException;
import java.net.URL; import java.net.URL;

View File

@@ -4,7 +4,7 @@ import io.nosqlbench.engine.api.activityapi.core.Action;
import io.nosqlbench.engine.api.activityapi.core.ActionDispenser; import io.nosqlbench.engine.api.activityapi.core.ActionDispenser;
import io.nosqlbench.engine.api.activityapi.core.SyncAction; import io.nosqlbench.engine.api.activityapi.core.SyncAction;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.junit.Test; import org.junit.jupiter.api.Test;
/* /*
* Copyright 2016 jshook * Copyright 2016 jshook

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.activitytype.diag; package io.nosqlbench.activitytype.diag;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.io.PrintStream; import java.io.PrintStream;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.activitytype.cmds; package io.nosqlbench.activitytype.cmds;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.Map; import java.util.Map;

View File

@@ -3,7 +3,7 @@ package io.nosqlbench.activitytype.cmds;
import io.nosqlbench.engine.api.activityconfig.StatementsLoader; import io.nosqlbench.engine.api.activityconfig.StatementsLoader;
import io.nosqlbench.engine.api.activityconfig.yaml.OpTemplate; import io.nosqlbench.engine.api.activityconfig.yaml.OpTemplate;
import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDocList; import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDocList;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.net.http.HttpRequest; import java.net.http.HttpRequest;
import java.util.Map; import java.util.Map;

View File

@@ -3,7 +3,7 @@ package io.nosqlbench.activitytype.http;
import io.nosqlbench.engine.api.activityapi.core.Action; import io.nosqlbench.engine.api.activityapi.core.Action;
import io.nosqlbench.engine.api.activityapi.core.ActionDispenser; import io.nosqlbench.engine.api.activityapi.core.ActionDispenser;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class HttpActivityTypeTest { public class HttpActivityTypeTest {
@Test @Test

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.driver.jmx; package io.nosqlbench.driver.jmx;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -1,7 +1,7 @@
package io.nosqlbench.driver.mongodb; package io.nosqlbench.driver.mongodb;
import org.junit.Before; import org.junit.jupiter.api.BeforeEach;
import org.junit.Test; import org.junit.jupiter.api.Test;
import io.nosqlbench.engine.api.activityapi.planning.OpSequence; import io.nosqlbench.engine.api.activityapi.planning.OpSequence;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
@@ -12,7 +12,7 @@ public class MongoActivityTest {
private ActivityDef activityDef; private ActivityDef activityDef;
@Before @BeforeEach
public void setup() { public void setup() {
String[] params = { String[] params = {
"yaml=activities/mongodb-basic.yaml", "yaml=activities/mongodb-basic.yaml",

View File

@@ -10,8 +10,8 @@ import io.nosqlbench.virtdata.core.templates.BindPoint;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.bson.conversions.Bson; import org.bson.conversions.Bson;
import org.junit.Before; import org.junit.jupiter.api.BeforeEach;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;
import java.util.Objects; import java.util.Objects;
@@ -25,7 +25,7 @@ public class ReadyMongoStatementTest {
private ActivityDef activityDef; private ActivityDef activityDef;
private StmtsDocList stmtsDocList; private StmtsDocList stmtsDocList;
@Before @BeforeEach
public void setup() { public void setup() {
String[] params = { String[] params = {
"yaml=activities/mongodb-basic.yaml", "yaml=activities/mongodb-basic.yaml",

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.activitytype.stdout; package io.nosqlbench.activitytype.stdout;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.Arrays; import java.util.Arrays;

View File

@@ -20,7 +20,7 @@ package io.nosqlbench.activitytype.stdout;
import io.nosqlbench.engine.api.activityapi.core.Action; import io.nosqlbench.engine.api.activityapi.core.Action;
import io.nosqlbench.engine.api.activityapi.core.ActionDispenser; import io.nosqlbench.engine.api.activityapi.core.ActionDispenser;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.junit.Test; import org.junit.jupiter.api.Test;
/** /**
* Created by sebastianestevez on 5/5/17. * Created by sebastianestevez on 5/5/17.

View File

@@ -1,8 +1,8 @@
package io.nosqlbench.driver.webdriver; package io.nosqlbench.driver.webdriver;
import io.nosqlbench.nb.api.testutils.Perf; import io.nosqlbench.nb.api.testutils.Perf;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import org.openqa.selenium.WebDriver; import org.openqa.selenium.WebDriver;
import org.openqa.selenium.chrome.ChromeDriver; import org.openqa.selenium.chrome.ChromeDriver;
import org.openqa.selenium.htmlunit.HtmlUnitDriver; import org.openqa.selenium.htmlunit.HtmlUnitDriver;
@@ -18,7 +18,7 @@ import org.openqa.selenium.htmlunit.HtmlUnitDriver;
public class ExampleWebScript { public class ExampleWebScript {
@Test @Test
@Ignore @Disabled
public void getDocsSiteChromeDriver() { public void getDocsSiteChromeDriver() {
System.setProperty("webdriver.http.factory", "okhttp"); System.setProperty("webdriver.http.factory", "okhttp");
WebDriver driver = new ChromeDriver(); WebDriver driver = new ChromeDriver();
@@ -39,7 +39,7 @@ public class ExampleWebScript {
} }
@Test @Test
@Ignore @Disabled
public void getDocSiteWebHtml() { public void getDocSiteWebHtml() {
// System.setProperty("webdriver.http.factory", "okhttp"); // System.setProperty("webdriver.http.factory", "okhttp");
WebDriver driver = new HtmlUnitDriver(false); WebDriver driver = new HtmlUnitDriver(false);

View File

@@ -19,11 +19,12 @@
package io.nosqlbench.engine.api.activityapi; package io.nosqlbench.engine.api.activityapi;
import io.nosqlbench.engine.api.activityimpl.ParameterMap; import io.nosqlbench.engine.api.activityimpl.ParameterMap;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.Optional; import java.util.Optional;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
public class ParameterMapTest { public class ParameterMapTest {
@@ -85,11 +86,12 @@ public class ParameterMapTest {
assertThat(multiNames.get().getOptionalString("delta","gamma").orElse("missing")).isEqualTo("blue"); assertThat(multiNames.get().getOptionalString("delta","gamma").orElse("missing")).isEqualTo("blue");
} }
@Test(expected = RuntimeException.class) @Test
public void testAmbiguousMultiValueThrowsException() { public void testAmbiguousMultiValueThrowsException() {
Optional<ParameterMap> multiNames = ParameterMap.parseParams("alpha=blue;beta=red;delta=blue"); Optional<ParameterMap> multiNames = ParameterMap.parseParams("alpha=blue;beta=red;delta=blue");
assertThat(multiNames).isPresent(); assertThat(multiNames).isPresent();
assertThat(multiNames.get().getOptionalString("alpha","delta").orElse("missing")).isEqualTo("blue"); assertThatExceptionOfType(RuntimeException.class)
.isThrownBy(() -> multiNames.get().getOptionalString("alpha","delta"));
} }
@Test @Test

View File

@@ -6,7 +6,7 @@ import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.SucceededOp
import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.EventedOpImpl; import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.EventedOpImpl;
import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.StartedOp; import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.StartedOp;
import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.TrackedOp; import io.nosqlbench.engine.api.activityapi.core.ops.fluent.opfacets.TrackedOp;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class OpTrackerImplTest { public class OpTrackerImplTest {

View File

@@ -20,7 +20,7 @@ package io.nosqlbench.engine.api.activityapi.cyclelog;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultSegmentBuffer; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultSegmentBuffer;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.stream.StreamSupport; import java.util.stream.StreamSupport;

View File

@@ -21,7 +21,7 @@ import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle.CycleResultsRLEBufferReadable; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle.CycleResultsRLEBufferReadable;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle.CycleResultsRLEBufferTarget; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle.CycleResultsRLEBufferTarget;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.util.ArrayList; import java.util.ArrayList;

View File

@@ -20,7 +20,7 @@ package io.nosqlbench.engine.api.activityapi.cyclelog.buffers;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle.CycleResultsRLEBufferReadable; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle.CycleResultsRLEBufferReadable;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle.CycleResultsRLEBufferTarget; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results_rle.CycleResultsRLEBufferTarget;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Iterator; import java.util.Iterator;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results; package io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.stream.StreamSupport; import java.util.stream.StreamSupport;

View File

@@ -18,7 +18,7 @@
package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate; package io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.ResultReadable; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.ResultReadable;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -19,8 +19,8 @@ package io.nosqlbench.engine.api.activityapi.cyclelog.inputs.cyclelog;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment;
import io.nosqlbench.engine.api.activityapi.cyclelog.outputs.cyclelog.CycleLogOutput; import io.nosqlbench.engine.api.activityapi.cyclelog.outputs.cyclelog.CycleLogOutput;
import org.junit.BeforeClass; import org.junit.jupiter.api.BeforeAll;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.io.File; import java.io.File;
@@ -31,7 +31,7 @@ public class CycleLogInputTest {
private final static String filepath="cycle-log-reader-test"; private final static String filepath="cycle-log-reader-test";
private static File cyclefile; private static File cyclefile;
@BeforeClass @BeforeAll
public static void createTempFile() { public static void createTempFile() {
try { try {
cyclefile = File.createTempFile(filepath, "cyclelog"); cyclefile = File.createTempFile(filepath, "cyclelog");

View File

@@ -22,7 +22,7 @@ import io.nosqlbench.engine.api.activityapi.cyclelog.filters.CoreResultValueFilt
import io.nosqlbench.engine.api.activityapi.cyclelog.filters.ResultFilterDispenser; import io.nosqlbench.engine.api.activityapi.cyclelog.filters.ResultFilterDispenser;
import io.nosqlbench.engine.api.activityapi.cyclelog.filters.ResultValueFilterType; import io.nosqlbench.engine.api.activityapi.cyclelog.filters.ResultValueFilterType;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.MutableCycleResult; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.MutableCycleResult;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.function.Predicate; import java.util.function.Predicate;

View File

@@ -22,7 +22,7 @@ import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.ResultReada
import io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate.ResultFilteringSieve; import io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate.ResultFilteringSieve;
import io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate.TristateFilter; import io.nosqlbench.engine.api.activityapi.cyclelog.filters.tristate.TristateFilter;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.MutableCycleResult; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.MutableCycleResult;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;

View File

@@ -17,8 +17,8 @@
package io.nosqlbench.engine.api.activityapi.errorhandling; package io.nosqlbench.engine.api.activityapi.errorhandling;
import org.junit.Before; import org.junit.jupiter.api.BeforeEach;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.security.InvalidParameterException; import java.security.InvalidParameterException;
import java.util.ArrayList; import java.util.ArrayList;
@@ -26,19 +26,22 @@ import java.util.List;
import java.util.Set; import java.util.Set;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
public class HashedErrorHandlerTest { public class HashedErrorHandlerTest {
HashedErrorHandler<Throwable, Boolean> handler; HashedErrorHandler<Throwable, Boolean> handler;
@Before @BeforeEach
public void beforeTest() { public void beforeTest() {
handler = new HashedErrorHandler<Throwable,Boolean>(); handler = new HashedErrorHandler<Throwable,Boolean>();
} }
@Test(expected= RuntimeException.class) @Test
public void testDefaultHandlerThrowsException() { public void testDefaultHandlerThrowsException() {
assertThatExceptionOfType(RuntimeException.class).isThrownBy(() -> {
handler.handleError(1L, new InvalidParameterException("this is an invalid exception, actually")); handler.handleError(1L, new InvalidParameterException("this is an invalid exception, actually"));
});
} }
@Test @Test
@@ -91,7 +94,7 @@ public class HashedErrorHandlerTest {
assertThat(result).isFalse(); assertThat(result).isFalse();
} }
@Test(expected = RuntimeException.class) @Test
public void testNamedGroup() { public void testNamedGroup() {
handler.setGroup("test1",IndexOutOfBoundsException.class,ArrayIndexOutOfBoundsException.class); handler.setGroup("test1",IndexOutOfBoundsException.class,ArrayIndexOutOfBoundsException.class);
handler.setGroup("types",InvalidParameterException.class); handler.setGroup("types",InvalidParameterException.class);
@@ -99,36 +102,41 @@ public class HashedErrorHandlerTest {
assertThat(handler.getGroupNames()).hasSize(2); assertThat(handler.getGroupNames()).hasSize(2);
assertThat(handler.getGroupNames()).contains("test1"); assertThat(handler.getGroupNames()).contains("test1");
assertThat(handler.getGroupNames()).contains("types"); assertThat(handler.getGroupNames()).contains("types");
handler.handleError(5L,new InvalidParameterException("this is an error")); assertThatExceptionOfType(RuntimeException.class).isThrownBy(() ->
handler.handleError(5L,new InvalidParameterException("this is an error")));
} }
@Test(expected = RuntimeException.class) @Test
public void testFindVagueSingleSubmatchException() { public void testFindVagueSingleSubmatchException() {
handler.setGroup("index", IndexOutOfBoundsException.class, ArrayIndexOutOfBoundsException.class); handler.setGroup("index", IndexOutOfBoundsException.class, ArrayIndexOutOfBoundsException.class);
handler.setHandlerForPattern("Index", CycleErrorHandlers.rethrow("12345 678910 11 12")); assertThatExceptionOfType(RuntimeException.class).isThrownBy(() ->
handler.setHandlerForPattern("Index", CycleErrorHandlers.rethrow("12345 678910 11 12")));
} }
@Test(expected = RuntimeException.class) @Test
public void testFindMultipleRegex() { public void testFindMultipleRegex() {
handler.setGroup("index", IndexOutOfBoundsException.class, ArrayIndexOutOfBoundsException.class); handler.setGroup("index", IndexOutOfBoundsException.class, ArrayIndexOutOfBoundsException.class);
handler.setHandlerForPattern(".*Index.*", CycleErrorHandlers.rethrow("Journey through the klein bottle.")); handler.setHandlerForPattern(".*Index.*", CycleErrorHandlers.rethrow("Journey through the klein bottle."));
Boolean result = handler.handleError(9L, new IndexOutOfBoundsException("9L was out of bounds")); assertThatExceptionOfType(RuntimeException.class).isThrownBy(() ->
handler.handleError(9L, new IndexOutOfBoundsException("9L was out of bounds")));
} }
@Test(expected = RuntimeException.class) @Test
public void testNonMatchingSubstringException() { public void testNonMatchingSubstringException() {
handler.setGroup("index", IndexOutOfBoundsException.class, ArrayIndexOutOfBoundsException.class); handler.setGroup("index", IndexOutOfBoundsException.class, ArrayIndexOutOfBoundsException.class);
Set<Class<? extends Throwable>> groups = handler.getGroup("index"); Set<Class<? extends Throwable>> groups = handler.getGroup("index");
assertThat(groups).isNotNull(); assertThat(groups).isNotNull();
assertThat(groups).hasSize(2); assertThat(groups).hasSize(2);
assertThat(groups.contains(IndexOutOfBoundsException.class)).isTrue(); assertThat(groups.contains(IndexOutOfBoundsException.class)).isTrue();
handler.setHandlerForPattern("Dyahwemo", CycleErrorHandlers.rethrow("Journey through the klein bottle.")); assertThatExceptionOfType(RuntimeException.class).isThrownBy(() ->
handler.setHandlerForPattern("Dyahwemo", CycleErrorHandlers.rethrow("Journey through the klein bottle.")));
} }
@Test(expected=RuntimeException.class) @Test
public void testSetHandlerForMissingGroupException() { public void testSetHandlerForMissingGroupException() {
handler.setGroup("index", IndexOutOfBoundsException.class, ArrayIndexOutOfBoundsException.class); handler.setGroup("index", IndexOutOfBoundsException.class, ArrayIndexOutOfBoundsException.class);
handler.setHandlerForGroup("outdex", CycleErrorHandlers.rethrow("Journey through the klein bottle.")); assertThatExceptionOfType(RuntimeException.class).isThrownBy(() ->
handler.setHandlerForGroup("outdex", CycleErrorHandlers.rethrow("Journey through the klein bottle.")));
} }
@Test @Test

View File

@@ -6,22 +6,23 @@ import com.codahale.metrics.Meter;
import com.codahale.metrics.Timer; import com.codahale.metrics.Timer;
import io.nosqlbench.engine.api.activityapi.errorhandling.ErrorMetrics; import io.nosqlbench.engine.api.activityapi.errorhandling.ErrorMetrics;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
public class NBErrorHandlerTest { public class NBErrorHandlerTest {
private final RuntimeException runtimeException = new RuntimeException("test exception"); private final RuntimeException runtimeException = new RuntimeException("test exception");
@Test
@Test(expected = RuntimeException.class)
public void testNullConfig() { public void testNullConfig() {
ErrorMetrics errorMetrics = new ErrorMetrics(ActivityDef.parseActivityDef("alias=testalias_stop")); ErrorMetrics errorMetrics = new ErrorMetrics(ActivityDef.parseActivityDef("alias=testalias_stop"));
NBErrorHandler errhandler = new NBErrorHandler(() -> "stop", () -> errorMetrics); NBErrorHandler errhandler = new NBErrorHandler(() -> "stop", () -> errorMetrics);
ErrorDetail detail = errhandler.handleError(runtimeException, 1, 2); assertThatExceptionOfType(RuntimeException.class)
.isThrownBy(() -> errhandler.handleError(runtimeException, 1, 2));
} }
@Test @Test
@@ -90,6 +91,4 @@ public class NBErrorHandlerTest {
assertThat(detail.isRetryable()).isFalse(); assertThat(detail.isRetryable()).isFalse();
assertThat(detail.resultCode).isEqualTo(42); assertThat(detail.resultCode).isEqualTo(42);
} }
} }

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.engine.api.activityapi.planning; package io.nosqlbench.engine.api.activityapi.planning;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.activityapi.planning; package io.nosqlbench.engine.api.activityapi.planning;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.activityapi.planning; package io.nosqlbench.engine.api.activityapi.planning;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.activityapi.ratelimits; package io.nosqlbench.engine.api.activityapi.ratelimits;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -20,8 +20,8 @@ package io.nosqlbench.engine.api.activityapi.ratelimits;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.nb.api.testutils.Perf; import io.nosqlbench.nb.api.testutils.Perf;
import io.nosqlbench.nb.api.testutils.Result; import io.nosqlbench.nb.api.testutils.Result;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.function.Function; import java.util.function.Function;
@@ -32,77 +32,77 @@ public class TestHybridRateLimiterPerf {
private RateLimiterPerfTestMethods methods = new RateLimiterPerfTestMethods(); private RateLimiterPerfTestMethods methods = new RateLimiterPerfTestMethods();
@Test @Test
@Ignore @Disabled
public void testPerf1e9() { public void testPerf1e9() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E9, 1.1),10_000_000,0.01d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E9, 1.1),10_000_000,0.01d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e8() { public void testPerf1e8() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E8, 1.1),50_000_000,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E8, 1.1),50_000_000,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e7() { public void testPerf1e7() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E7, 1.1),5_000_000,0.01d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E7, 1.1),5_000_000,0.01d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e6() { public void testPerf1e6() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E6, 1.1),500_000,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E6, 1.1),500_000,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e5() { public void testPerf1e5() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E5, 1.1),50_000,0.01d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E5, 1.1),50_000,0.01d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e4() { public void testPerf1e4() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E4, 1.1),5_000,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E4, 1.1),5_000,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e3() { public void testPerf1e3() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E3, 1.1),500,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E3, 1.1),500,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e2() { public void testPerf1e2() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E2, 1.1),50,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E2, 1.1),50,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e1() { public void testPerf1e1() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E1, 1.1),5,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E1, 1.1),5,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e0() { public void testPerf1e0() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E0, 1.1),2,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E0, 1.1),2,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testePerf1eN1() { public void testePerf1eN1() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E-1, 1.1),1,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E-1, 1.1),1,0.005d);
System.out.println(result); System.out.println(result);
@@ -110,14 +110,14 @@ public class TestHybridRateLimiterPerf {
} }
@Test @Test
@Ignore @Disabled
public void test100Mops_160threads() { public void test100Mops_160threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,160); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,160);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
} }
@Test @Test
@Ignore @Disabled
public void test100Mops_80threads() { public void test100Mops_80threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,80); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,80);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -130,7 +130,7 @@ public class TestHybridRateLimiterPerf {
// JVM 11.0.1 // JVM 11.0.1
// 400000000_ops 33.622751_S 11896706.363_ops_s, 84_ns_op // 400000000_ops 33.622751_S 11896706.363_ops_s, 84_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_40threads() { public void test100Mops_40threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,40); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,40);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -150,7 +150,7 @@ public class TestHybridRateLimiterPerf {
// 200000000_ops 17.691698_S 11304737.461_ops_s, 88_ns_op // 200000000_ops 17.691698_S 11304737.461_ops_s, 88_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_20threads() { public void test100Mops_20threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,20); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,20);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -163,7 +163,7 @@ public class TestHybridRateLimiterPerf {
// 200000000_ops 17.474475_S 11445264.894_ops_s, 87_ns_op // 200000000_ops 17.474475_S 11445264.894_ops_s, 87_ns_op
// 200000000_ops 14.089247_S 14195222.897_ops_s, 70_ns_op // 200000000_ops 14.089247_S 14195222.897_ops_s, 70_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_10threads() { public void test100Mops_10threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,10); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 10_000_000,10);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -177,7 +177,7 @@ public class TestHybridRateLimiterPerf {
// JVM 11.0.1 // JVM 11.0.1
// 200000000_ops 11.839666_S 16892368.438_ops_s, 59_ns_op // 200000000_ops 11.839666_S 16892368.438_ops_s, 59_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_5threads() { public void test100Mops_5threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 40_000_000,5); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 40_000_000,5);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());

View File

@@ -19,8 +19,8 @@ package io.nosqlbench.engine.api.activityapi.ratelimits;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.nb.api.testutils.Perf; import io.nosqlbench.nb.api.testutils.Perf;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.function.Function; import java.util.function.Function;
@@ -40,7 +40,7 @@ public class TestRateLimiterPerf1E7 {
// JVM 11.0.1 // JVM 11.0.1
// 160000000_ops 18.122886_S 8828615.971_ops_s, 113_ns_op // 160000000_ops 18.122886_S 8828615.971_ops_s, 113_ns_op
@Test @Test
@Ignore @Disabled
public void test10Mops_160threads() { public void test10Mops_160threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,160); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,160);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -50,7 +50,7 @@ public class TestRateLimiterPerf1E7 {
// JVM 11.0.1 // JVM 11.0.1
// 80000000_ops 8.354648_S 9575507.945_ops_s, 104_ns_op // 80000000_ops 8.354648_S 9575507.945_ops_s, 104_ns_op
@Test @Test
@Ignore @Disabled
public void test10Mops_80threads() { public void test10Mops_80threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,80); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,80);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -60,7 +60,7 @@ public class TestRateLimiterPerf1E7 {
// JVM 11.0.1 // JVM 11.0.1
// 40000000_ops 4.001661_S 9995849.116_ops_s, 100_ns_op // 40000000_ops 4.001661_S 9995849.116_ops_s, 100_ns_op
@Test @Test
@Ignore @Disabled
public void test10Mops_40threads() { public void test10Mops_40threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,40); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,40);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -70,7 +70,7 @@ public class TestRateLimiterPerf1E7 {
// JVM 11.0.1 // JVM 11.0.1
// 20000000_ops 1.914366_S 10447323.063_ops_s, 96_ns_op // 20000000_ops 1.914366_S 10447323.063_ops_s, 96_ns_op
@Test @Test
@Ignore @Disabled
public void test10Mops_20threads() { public void test10Mops_20threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 10), 20_000_000,20); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 10), 20_000_000,20);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -84,7 +84,7 @@ public class TestRateLimiterPerf1E7 {
// 100000000_ops 10.123873_S 9877642.338_ops_s, 101_ns_op // 100000000_ops 10.123873_S 9877642.338_ops_s, 101_ns_op
// 100000000_ops 10.078673_S 9921941.517_ops_s, 101_ns_op // 100000000_ops 10.078673_S 9921941.517_ops_s, 101_ns_op
@Test @Test
@Ignore @Disabled
public void test10Mops_10threads() { public void test10Mops_10threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,10); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,10);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -99,7 +99,7 @@ public class TestRateLimiterPerf1E7 {
// 200000000_ops 19.761154_S 10120866.172_ops_s, 99_ns_op // 200000000_ops 19.761154_S 10120866.172_ops_s, 99_ns_op
// 200000000_ops 19.928625_S 10035815.505_ops_s, 100_ns_op // 200000000_ops 19.928625_S 10035815.505_ops_s, 100_ns_op
@Test @Test
@Ignore @Disabled
public void test10Mops_5threads() { public void test10Mops_5threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,5); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E7, 1.1), 20_000_000,5);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());

View File

@@ -19,8 +19,8 @@ package io.nosqlbench.engine.api.activityapi.ratelimits;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.nb.api.testutils.Perf; import io.nosqlbench.nb.api.testutils.Perf;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.function.Function; import java.util.function.Function;
@@ -44,7 +44,7 @@ public class TestRateLimiterPerf1E8 {
// 1600000000_ops 158.224286_S 10_112_227.620_ops_s, 99_ns_op // 1600000000_ops 158.224286_S 10_112_227.620_ops_s, 99_ns_op
// //
@Test @Test
@Ignore @Disabled
public void test100Mops_160threads() { public void test100Mops_160threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,160); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,160);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -55,7 +55,7 @@ public class TestRateLimiterPerf1E8 {
// 800000000_ops 74.104295_S 10795595.534_ops_s, 93_ns_op // 800000000_ops 74.104295_S 10795595.534_ops_s, 93_ns_op
// 800000000_ops 74.155495_S 10788141.933_ops_s, 93_ns_op // 800000000_ops 74.155495_S 10788141.933_ops_s, 93_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_80threads() { public void test100Mops_80threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,80); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,80);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -68,7 +68,7 @@ public class TestRateLimiterPerf1E8 {
// JVM 11.0.1, Intel(R) Core(TM) i7-4790 CPU @ 3.60GHz // JVM 11.0.1, Intel(R) Core(TM) i7-4790 CPU @ 3.60GHz
// 400000000_ops 33.622751_S 11896706.363_ops_s, 84_ns_op // 400000000_ops 33.622751_S 11896706.363_ops_s, 84_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_40threads() { public void test100Mops_40threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,40); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,40);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -88,7 +88,7 @@ public class TestRateLimiterPerf1E8 {
// 200000000_ops 17.691698_S 11304737.461_ops_s, 88_ns_op // 200000000_ops 17.691698_S 11304737.461_ops_s, 88_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_20threads() { public void test100Mops_20threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,20); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,20);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -104,7 +104,7 @@ public class TestRateLimiterPerf1E8 {
// 100000000_ops 7.751758_S 12900299.587_ops_s, 78_ns_op // 100000000_ops 7.751758_S 12900299.587_ops_s, 78_ns_op
// 100000000_ops 7.864851_S 12714799.657_ops_s, 79_ns_op // 100000000_ops 7.864851_S 12714799.657_ops_s, 79_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_10threads() { public void test100Mops_10threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,10); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,10);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());
@@ -121,7 +121,7 @@ public class TestRateLimiterPerf1E8 {
// 100000000_ops 6.317008_S 15830279.182_ops_s, 63_ns_op // 100000000_ops 6.317008_S 15830279.182_ops_s, 63_ns_op
// 200000000_ops 13.551712_S 14758282.931_ops_s, 68_ns_op // 200000000_ops 13.551712_S 14758282.931_ops_s, 68_ns_op
@Test @Test
@Ignore @Disabled
public void test100Mops_5threads() { public void test100Mops_5threads() {
Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,5); Perf perf = methods.testRateLimiterMultiThreadedContention(rlFunction, new RateSpec(1E8, 1.1), 100_000_000,5);
System.out.println(perf.getLastResult()); System.out.println(perf.getLastResult());

View File

@@ -19,8 +19,8 @@ package io.nosqlbench.engine.api.activityapi.ratelimits;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.nb.api.testutils.Result; import io.nosqlbench.nb.api.testutils.Result;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.function.Function; import java.util.function.Function;
@@ -37,77 +37,77 @@ public class TestRateLimiterPerfSingle {
private RateLimiterPerfTestMethods methods = new RateLimiterPerfTestMethods(); private RateLimiterPerfTestMethods methods = new RateLimiterPerfTestMethods();
@Test @Test
@Ignore @Disabled
public void testPerf1e9() { public void testPerf1e9() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E9, 1.1),10_000_000,0.01d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E9, 1.1),10_000_000,0.01d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e8() { public void testPerf1e8() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E8, 1.1),50_000_000,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E8, 1.1),50_000_000,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e7() { public void testPerf1e7() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E7, 1.1),5_000_000,0.01d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E7, 1.1),5_000_000,0.01d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e6() { public void testPerf1e6() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E6, 1.1),500_000,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E6, 1.1),500_000,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e5() { public void testPerf1e5() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E5, 1.1),50_000,0.01d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E5, 1.1),50_000,0.01d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e4() { public void testPerf1e4() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E4, 1.1),5_000,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E4, 1.1),5_000,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e3() { public void testPerf1e3() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E3, 1.1),500,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E3, 1.1),500,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e2() { public void testPerf1e2() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E2, 1.1),50,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E2, 1.1),50,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e1() { public void testPerf1e1() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E1, 1.1),5,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E1, 1.1),5,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testPerf1e0() { public void testPerf1e0() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E0, 1.1),2,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E0, 1.1),2,0.005d);
System.out.println(result); System.out.println(result);
} }
@Test @Test
@Ignore @Disabled
public void testePerf1eN1() { public void testePerf1eN1() {
Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E-1, 1.1),1,0.005d); Result result = methods.rateLimiterSingleThreadedConvergence(rlFunction,new RateSpec(1E-1, 1.1),1,0.005d);
System.out.println(result); System.out.println(result);

View File

@@ -19,7 +19,7 @@ package io.nosqlbench.engine.api.activityapi.ratelimits;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.engine.api.activityimpl.ParameterMap; import io.nosqlbench.engine.api.activityimpl.ParameterMap;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -17,13 +17,13 @@
package io.nosqlbench.engine.api.activityapi.sysperf; package io.nosqlbench.engine.api.activityapi.sysperf;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class SysPerfBaselinerTest { public class SysPerfBaselinerTest {
@Test @Test
@Ignore @Disabled
public void testSysOpsNanoTime() { public void testSysOpsNanoTime() {
SysPerfBaseliner sbo = new SysPerfBaseliner(); SysPerfBaseliner sbo = new SysPerfBaseliner();
SysPerfData perfdata = sbo.getSysPerfData(); SysPerfData perfdata = sbo.getSysPerfData();

View File

@@ -17,8 +17,8 @@
package io.nosqlbench.engine.api.activityapi.sysperf; package io.nosqlbench.engine.api.activityapi.sysperf;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.nio.file.attribute.FileTime; import java.nio.file.attribute.FileTime;
import java.util.Optional; import java.util.Optional;
@@ -28,7 +28,7 @@ import static org.assertj.core.api.Assertions.assertThat;
public class SysPerfTest { public class SysPerfTest {
@Test @Test
@Ignore @Disabled
public void testForcedBench() { public void testForcedBench() {
// SysPerf.get().reset(); // SysPerf.get().reset();

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.activityconfig; package io.nosqlbench.engine.api.activityconfig;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;

View File

@@ -21,7 +21,7 @@ import io.nosqlbench.virtdata.core.bindings.DataMapper;
import io.nosqlbench.virtdata.core.bindings.VirtData; import io.nosqlbench.virtdata.core.bindings.VirtData;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -22,7 +22,7 @@ import io.nosqlbench.engine.api.activityconfig.yaml.OpTemplate;
import io.nosqlbench.engine.api.activityconfig.yaml.StmtsBlock; import io.nosqlbench.engine.api.activityconfig.yaml.StmtsBlock;
import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDoc; import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDoc;
import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDocList; import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDocList;
import org.junit.Test; import org.junit.jupiter.api.Test;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;

View File

@@ -19,7 +19,7 @@ package io.nosqlbench.engine.api.activityconfig.rawyaml;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;

View File

@@ -19,10 +19,10 @@ package io.nosqlbench.engine.api.activityconfig.rawyaml;
import io.nosqlbench.engine.api.activityconfig.StatementsLoader; import io.nosqlbench.engine.api.activityconfig.StatementsLoader;
import io.nosqlbench.engine.api.activityconfig.yaml.*; import io.nosqlbench.engine.api.activityconfig.yaml.*;
import org.junit.BeforeClass; import org.junit.jupiter.api.BeforeAll;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;
@@ -33,7 +33,7 @@ public class StmtEscapingTest {
private final static Logger logger = LogManager.getLogger(StmtEscapingTest.class); private final static Logger logger = LogManager.getLogger(StmtEscapingTest.class);
private static List<OpTemplate> defs; private static List<OpTemplate> defs;
@BeforeClass @BeforeAll
public static void testLayering() { public static void testLayering() {
StmtsDocList all = StatementsLoader.loadPath(logger, "testdocs/escaped_stmts.yaml"); StmtsDocList all = StatementsLoader.loadPath(logger, "testdocs/escaped_stmts.yaml");

View File

@@ -19,7 +19,7 @@ package io.nosqlbench.engine.api.activityconfig.rawyaml;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;

View File

@@ -19,10 +19,10 @@ package io.nosqlbench.engine.api.activityconfig.yaml;
import io.nosqlbench.engine.api.activityconfig.StatementsLoader; import io.nosqlbench.engine.api.activityconfig.StatementsLoader;
import io.nosqlbench.engine.api.activityconfig.ParsedStmt; import io.nosqlbench.engine.api.activityconfig.ParsedStmt;
import org.junit.BeforeClass; import org.junit.jupiter.api.BeforeAll;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
@@ -30,7 +30,7 @@ public class ParsedStmtTest {
private static final Logger logger = LogManager.getLogger(ParsedStmtTest.class); private static final Logger logger = LogManager.getLogger(ParsedStmtTest.class);
private static StmtsDocList doclist; private static StmtsDocList doclist;
@BeforeClass @BeforeAll
public static void testLoadYaml() { public static void testLoadYaml() {
doclist = StatementsLoader.loadPath(logger, "testdocs/bindings.yaml"); doclist = StatementsLoader.loadPath(logger, "testdocs/bindings.yaml");
} }

View File

@@ -20,7 +20,7 @@ package io.nosqlbench.engine.api.activityconfig.yaml;
import io.nosqlbench.engine.api.activityconfig.StatementsLoader; import io.nosqlbench.engine.api.activityconfig.StatementsLoader;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;

View File

@@ -19,10 +19,10 @@ package io.nosqlbench.engine.api.activityconfig.yaml;
import io.nosqlbench.engine.api.activityconfig.StatementsLoader; import io.nosqlbench.engine.api.activityconfig.StatementsLoader;
import org.assertj.core.data.MapEntry; import org.assertj.core.data.MapEntry;
import org.junit.BeforeClass; import org.junit.jupiter.api.BeforeAll;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.LinkedHashMap; import java.util.LinkedHashMap;
import java.util.List; import java.util.List;
@@ -49,7 +49,7 @@ public class StmtsDocListTest {
}}; }};
@BeforeClass @BeforeAll
public static void testLoadYaml() { public static void testLoadYaml() {
doclist = StatementsLoader.loadPath(logger, "testdocs/docs_blocks_stmts.yaml"); doclist = StatementsLoader.loadPath(logger, "testdocs/docs_blocks_stmts.yaml");
} }

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.activityimpl; package io.nosqlbench.engine.api.activityimpl;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.activityimpl; package io.nosqlbench.engine.api.activityimpl;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.Optional; import java.util.Optional;

View File

@@ -19,7 +19,7 @@ package io.nosqlbench.engine.api.activityimpl.input;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -19,7 +19,7 @@ package io.nosqlbench.engine.api.activityimpl.input;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleArray; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleArray;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -19,7 +19,7 @@ package io.nosqlbench.engine.api.activityimpl.input;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleArray; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleArray;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -18,7 +18,7 @@
package io.nosqlbench.engine.api.activityimpl.input; package io.nosqlbench.engine.api.activityimpl.input;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleSegment;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -19,7 +19,7 @@ package io.nosqlbench.engine.api.activityimpl.marker;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.activityimpl.marker; package io.nosqlbench.engine.api.activityimpl.marker;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class CoreOutputAtticTest { public class CoreOutputAtticTest {

View File

@@ -21,7 +21,7 @@ import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResult
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultSegmentBuffer; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultSegmentBuffer;
import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment; import io.nosqlbench.engine.api.activityapi.cyclelog.buffers.results.CycleResultsSegment;
import io.nosqlbench.engine.api.activityapi.output.Output; import io.nosqlbench.engine.api.activityapi.output.Output;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;

View File

@@ -2,8 +2,8 @@ package io.nosqlbench.engine.api.activityimpl.tracking;
import io.nosqlbench.engine.api.activityimpl.marker.longheap.LongTreeTracker; import io.nosqlbench.engine.api.activityimpl.marker.longheap.LongTreeTracker;
import io.nosqlbench.engine.api.activityimpl.marker.longheap.LongTreeTrackerAtomic; import io.nosqlbench.engine.api.activityimpl.marker.longheap.LongTreeTrackerAtomic;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
@@ -139,7 +139,7 @@ public class LongTreeTrackerTest2 {
*/ */
@Test @Test
@Ignore @Disabled
public void speedcheckThreadLocal() { public void speedcheckThreadLocal() {
long t1=System.nanoTime(); long t1=System.nanoTime();
LongTreeTracker t = new LongTreeTracker(); LongTreeTracker t = new LongTreeTracker();
@@ -159,7 +159,7 @@ public class LongTreeTrackerTest2 {
} }
@Test @Test
@Ignore @Disabled
public void speedcheckConcurrentLocal() { public void speedcheckConcurrentLocal() {
long t1=System.nanoTime(); long t1=System.nanoTime();
LongTreeTracker t = new LongTreeTrackerAtomic(); LongTreeTracker t = new LongTreeTrackerAtomic();

View File

@@ -1,7 +1,7 @@
package io.nosqlbench.engine.api.activityimpl.tracking; package io.nosqlbench.engine.api.activityimpl.tracking;
import io.nosqlbench.engine.api.activityimpl.marker.longheap.TreeTracker1024; import io.nosqlbench.engine.api.activityimpl.marker.longheap.TreeTracker1024;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.engine.api.clireader; package io.nosqlbench.engine.api.clireader;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -19,7 +19,7 @@ package io.nosqlbench.engine.api.metrics;
import com.codahale.metrics.Metric; import com.codahale.metrics.Metric;
import com.codahale.metrics.MetricRegistry; import com.codahale.metrics.MetricRegistry;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.Map; import java.util.Map;

View File

@@ -1,7 +1,7 @@
package io.nosqlbench.engine.api.metrics; package io.nosqlbench.engine.api.metrics;
import com.codahale.metrics.Snapshot; import com.codahale.metrics.Snapshot;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class DeltaHdrHistogramReservoirTest { public class DeltaHdrHistogramReservoirTest {

View File

@@ -20,7 +20,7 @@ package io.nosqlbench.engine.api.metrics;
import org.HdrHistogram.EncodableHistogram; import org.HdrHistogram.EncodableHistogram;
import org.HdrHistogram.Histogram; import org.HdrHistogram.Histogram;
import org.HdrHistogram.HistogramLogReader; import org.HdrHistogram.HistogramLogReader;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.metrics; package io.nosqlbench.engine.api.metrics;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -2,13 +2,13 @@ package io.nosqlbench.engine.api.metrics;
import com.codahale.metrics.ExponentiallyDecayingReservoir; import com.codahale.metrics.ExponentiallyDecayingReservoir;
import com.codahale.metrics.Snapshot; import com.codahale.metrics.Snapshot;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class TestHistoTypes { public class TestHistoTypes {
@Test @Test
@Ignore @Disabled
public void compareHistos() { public void compareHistos() {
Clock c = new Clock(); Clock c = new Clock();

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.scripting; package io.nosqlbench.engine.api.scripting;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.Date; import java.util.Date;

View File

@@ -3,7 +3,7 @@ package io.nosqlbench.engine.api.templating;
import io.nosqlbench.engine.api.activityconfig.StatementsLoader; import io.nosqlbench.engine.api.activityconfig.StatementsLoader;
import io.nosqlbench.engine.api.activityconfig.yaml.OpTemplate; import io.nosqlbench.engine.api.activityconfig.yaml.OpTemplate;
import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDocList; import io.nosqlbench.engine.api.activityconfig.yaml.StmtsDocList;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.templating; package io.nosqlbench.engine.api.templating;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.*; import java.util.*;

View File

@@ -18,7 +18,7 @@
package io.nosqlbench.engine.api.util; package io.nosqlbench.engine.api.util;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.io.FileNotFoundException; import java.io.FileNotFoundException;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.util; package io.nosqlbench.engine.api.util;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.api.util; package io.nosqlbench.engine.api.util;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;

View File

@@ -18,7 +18,7 @@
package io.nosqlbench.engine.api.util; package io.nosqlbench.engine.api.util;
import org.assertj.core.data.Offset; import org.assertj.core.data.Offset;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -1,10 +1,11 @@
package io.nosqlbench.engine.cli; package io.nosqlbench.engine.cli;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
public class BasicScriptBufferTest { public class BasicScriptBufferTest {
@@ -62,14 +63,9 @@ public class BasicScriptBufferTest {
assertThat(script).matches("(?s).*a single line.*"); assertThat(script).matches("(?s).*a single line.*");
} }
@Test(expected = NumberFormatException.class) @Test
public void shouldThrowErrorForInvalidWaitMillisOperand() { public void shouldThrowErrorForInvalidWaitMillisOperand() {
NBCLIOptions opts = new NBCLIOptions(new String[]{ "waitmillis", "noway" }); assertThatExceptionOfType(NumberFormatException.class)
BasicScriptBuffer b = new BasicScriptBuffer(); .isThrownBy(() -> new NBCLIOptions(new String[]{ "waitmillis", "noway" }));
b.add(opts.getCommands().toArray(new Cmd[0]));
String s = b.getParsedScript();
} }
} }

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.engine.cli; package io.nosqlbench.engine.cli;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.engine.cli; package io.nosqlbench.engine.cli;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.io.IOException; import java.io.IOException;
import java.nio.file.Files; import java.nio.file.Files;
@@ -10,6 +10,7 @@ import java.util.LinkedList;
import java.util.List; import java.util.List;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
public class NBCLIArgsFileTest { public class NBCLIArgsFileTest {
@@ -30,11 +31,11 @@ public class NBCLIArgsFileTest {
System.out.println(result); System.out.println(result);
} }
@Test(expected = RuntimeException.class) @Test
public void testLoadingMissingRequiredFails() { public void testLoadingMissingRequiredFails() {
LinkedList<String> result;
NBCLIArgsFile argsFile = new NBCLIArgsFile(); NBCLIArgsFile argsFile = new NBCLIArgsFile();
result = argsFile.process("--argsfile-required", "src/test/resources/argsfiles/nonextant.cli"); assertThatExceptionOfType(RuntimeException.class)
.isThrownBy(() -> argsFile.process("--argsfile-required", "src/test/resources/argsfiles/nonextant.cli"));
} }
@Test @Test

View File

@@ -2,11 +2,12 @@ package io.nosqlbench.engine.cli;
import io.nosqlbench.engine.api.scenarios.NBCLIScenarioParser; import io.nosqlbench.engine.api.scenarios.NBCLIScenarioParser;
import io.nosqlbench.nb.api.errors.BasicError; import io.nosqlbench.nb.api.errors.BasicError;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
public class NBCLIScenarioParserTest { public class NBCLIScenarioParserTest {
@@ -49,15 +50,16 @@ public class NBCLIScenarioParserTest {
assertThat(cmds.get(0).getArg("driver")).isEqualTo("stdout"); assertThat(cmds.get(0).getArg("driver")).isEqualTo("stdout");
} }
@Test(expected = BasicError.class) @Test
public void testThatVerboseFinalParameterThrowsError() { public void testThatVerboseFinalParameterThrowsError() {
NBCLIOptions opts = new NBCLIOptions(new String[]{ "scenario-test", "yaml=canttouchthis"}); assertThatExceptionOfType(BasicError.class)
List<Cmd> cmds = opts.getCommands(); .isThrownBy(() -> new NBCLIOptions(new String[]{ "scenario-test", "yaml=canttouchthis"}));
} }
@Test(expected = BasicError.class) @Test
public void testThatMissingScenarioNameThrowsError() { public void testThatMissingScenarioNameThrowsError() {
NBCLIOptions opts = new NBCLIOptions(new String[]{ "scenario-test", "missing-scenario"}); assertThatExceptionOfType(BasicError.class)
.isThrownBy(() -> new NBCLIOptions(new String[]{ "scenario-test", "missing-scenario"}));
} }
@Test @Test

View File

@@ -17,7 +17,7 @@
package io.nosqlbench.engine.cli; package io.nosqlbench.engine.cli;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -2,7 +2,7 @@ package io.nosqlbench.engine.cli;
import io.nosqlbench.docsys.core.PathWalker; import io.nosqlbench.docsys.core.PathWalker;
import io.nosqlbench.nb.api.content.NBIO; import io.nosqlbench.nb.api.content.NBIO;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.net.URL; import java.net.URL;
import java.nio.file.Path; import java.nio.file.Path;
@@ -11,6 +11,7 @@ import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
public class TestNBCLIOptions { public class TestNBCLIOptions {
@@ -87,9 +88,10 @@ public class TestNBCLIOptions {
assertThat(opts.wantsTopicalHelp()).isFalse(); assertThat(opts.wantsTopicalHelp()).isFalse();
} }
@Test(expected = IllegalArgumentException.class) @Test
public void shouldErrorSanelyWhenNoMatch() { public void shouldErrorSanelyWhenNoMatch() {
NBCLIOptions opts = new NBCLIOptions(new String[]{"unrecognizable command"}); assertThatExceptionOfType(IllegalArgumentException.class)
.isThrownBy(() -> new NBCLIOptions(new String[]{"unrecognizable command"}));
} }
@Test @Test
@@ -102,14 +104,16 @@ public class TestNBCLIOptions {
assertThat(cmd.getParams().get("param1")).isEqualTo("value1"); assertThat(cmd.getParams().get("param1")).isEqualTo("value1");
} }
@Test(expected = InvalidParameterException.class) @Test
public void testShouldErrorSanelyWhenScriptNameSkipped() { public void testShouldErrorSanelyWhenScriptNameSkipped() {
NBCLIOptions opts = new NBCLIOptions(new String[]{"script", "param1=value1"}); assertThatExceptionOfType(InvalidParameterException.class)
.isThrownBy(() -> new NBCLIOptions(new String[]{"script", "param1=value1"}));
} }
@Test(expected = InvalidParameterException.class) @Test
public void testShouldErrorForMissingScriptName() { public void testShouldErrorForMissingScriptName() {
NBCLIOptions opts = new NBCLIOptions(new String[]{"script"}); assertThatExceptionOfType(InvalidParameterException.class)
.isThrownBy(() -> new NBCLIOptions(new String[]{"script"}));
} }
@Test @Test
@@ -140,10 +144,10 @@ public class TestNBCLIOptions {
} }
@Test(expected = InvalidParameterException.class) @Test
public void shouldThrowErrorForInvalidStopActivity() { public void shouldThrowErrorForInvalidStopActivity() {
NBCLIOptions opts = new NBCLIOptions(new String[]{ "stop", "woah=woah" }); assertThatExceptionOfType(InvalidParameterException.class)
List<Cmd> cmds = opts.getCommands(); .isThrownBy(() -> new NBCLIOptions(new String[]{ "stop", "woah=woah" }));
} }
@Test @Test
@@ -155,11 +159,10 @@ public class TestNBCLIOptions {
} }
@Test(expected = InvalidParameterException.class) @Test
public void shouldThrowErrorForInvalidAwaitActivity() { public void shouldThrowErrorForInvalidAwaitActivity() {
NBCLIOptions opts = new NBCLIOptions(new String[]{ "await", "awaitme=notvalid" }); assertThatExceptionOfType(InvalidParameterException.class)
List<Cmd> cmds = opts.getCommands(); .isThrownBy(() -> new NBCLIOptions(new String[]{ "await", "awaitme=notvalid" }));
} }
@Test @Test

View File

@@ -1,7 +1,7 @@
package io.nosqlbench.engine.clients.grafana; package io.nosqlbench.engine.clients.grafana;
import org.assertj.core.data.Offset; import org.assertj.core.data.Offset;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -1,8 +1,8 @@
package io.nosqlbench.engine.clients.grafana; package io.nosqlbench.engine.clients.grafana;
import io.nosqlbench.engine.clients.grafana.transfer.GAnnotation; import io.nosqlbench.engine.clients.grafana.transfer.GAnnotation;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.List; import java.util.List;
@@ -10,7 +10,7 @@ public class GrafanaClientTest {
private static final String testurl = "http://localhost:3000/"; private static final String testurl = "http://localhost:3000/";
@Test @Test
@Ignore @Disabled
public void testCreateAnnotation() { public void testCreateAnnotation() {
GrafanaClient client = new GrafanaClient(testurl); GrafanaClient client = new GrafanaClient(testurl);
client.getConfig().basicAuth("admin", "admin"); client.getConfig().basicAuth("admin", "admin");
@@ -22,7 +22,7 @@ public class GrafanaClientTest {
} }
@Test @Test
@Ignore @Disabled
public void testFindAnnotations() { public void testFindAnnotations() {
GrafanaClient client = new GrafanaClient(testurl); GrafanaClient client = new GrafanaClient(testurl);
client.getConfig().basicAuth("admin", "admin"); client.getConfig().basicAuth("admin", "admin");
@@ -31,7 +31,7 @@ public class GrafanaClientTest {
} }
@Test @Test
@Ignore @Disabled
public void testGetApiToken() { public void testGetApiToken() {
GrafanaClient client = new GrafanaClient(testurl); GrafanaClient client = new GrafanaClient(testurl);
client.getConfig().basicAuth("admin", "admin"); client.getConfig().basicAuth("admin", "admin");

View File

@@ -1,13 +1,13 @@
package io.nosqlbench.engine.clients.grafana.analyzer; package io.nosqlbench.engine.clients.grafana.analyzer;
import io.nosqlbench.engine.clients.grafana.transfer.GDashboard; import io.nosqlbench.engine.clients.grafana.transfer.GDashboard;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class GrafanaRegionAnalyzerTest { public class GrafanaRegionAnalyzerTest {
@Test @Test
@Ignore @Disabled
public void testGetQueries() { public void testGetQueries() {
GrafanaRegionAnalyzer gra = new GrafanaRegionAnalyzer(); GrafanaRegionAnalyzer gra = new GrafanaRegionAnalyzer();
gra.setBaseUrl("http://44.242.139.57:3000/"); gra.setBaseUrl("http://44.242.139.57:3000/");

View File

@@ -4,8 +4,8 @@ import com.google.gson.Gson;
import com.google.gson.GsonBuilder; import com.google.gson.GsonBuilder;
import com.google.gson.reflect.TypeToken; import com.google.gson.reflect.TypeToken;
import io.nosqlbench.nb.api.content.NBIO; import io.nosqlbench.nb.api.content.NBIO;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.lang.reflect.Type; import java.lang.reflect.Type;
@@ -14,7 +14,7 @@ import static org.assertj.core.api.Assertions.assertThat;
public class PMatrixElemTest { public class PMatrixElemTest {
@Test @Test
@Ignore @Disabled
public void testMatrixElem() { public void testMatrixElem() {
Gson gson = new GsonBuilder().create(); Gson gson = new GsonBuilder().create();
String json = NBIO.classpath().name("test.json").one().asString(); String json = NBIO.classpath().name("test.json").one().asString();

View File

@@ -15,7 +15,7 @@ import io.nosqlbench.engine.api.activityimpl.motor.CoreMotorDispenser;
import io.nosqlbench.engine.core.lifecycle.ActivityExecutor; import io.nosqlbench.engine.core.lifecycle.ActivityExecutor;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.Optional; import java.util.Optional;

View File

@@ -5,7 +5,7 @@ import io.nosqlbench.engine.core.fortesting.BlockingSegmentInput;
import io.nosqlbench.engine.api.activityimpl.ActivityDef; import io.nosqlbench.engine.api.activityimpl.ActivityDef;
import io.nosqlbench.engine.api.activityimpl.SimpleActivity; import io.nosqlbench.engine.api.activityimpl.SimpleActivity;
import io.nosqlbench.engine.api.activityimpl.motor.CoreMotor; import io.nosqlbench.engine.api.activityimpl.motor.CoreMotor;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicLongArray; import java.util.concurrent.atomic.AtomicLongArray;

View File

@@ -2,7 +2,7 @@ package io.nosqlbench.engine.core;
import io.nosqlbench.engine.api.scripting.ScriptEnvBuffer; import io.nosqlbench.engine.api.scripting.ScriptEnvBuffer;
import io.nosqlbench.engine.core.script.Scenario; import io.nosqlbench.engine.core.script.Scenario;
import org.junit.Test; import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;

View File

@@ -1,6 +1,6 @@
package io.nosqlbench.engine.core.experimental; package io.nosqlbench.engine.core.experimental;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage; import java.util.concurrent.CompletionStage;

View File

@@ -2,7 +2,7 @@ package io.nosqlbench.engine.core.metrics;
import com.codahale.metrics.Timer; import com.codahale.metrics.Timer;
import io.nosqlbench.engine.api.metrics.DeltaHdrHistogramReservoir; import io.nosqlbench.engine.api.metrics.DeltaHdrHistogramReservoir;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;

View File

@@ -1,7 +1,7 @@
package io.nosqlbench.engine.core.script; package io.nosqlbench.engine.core.script;
import io.nosqlbench.engine.api.scripting.ScriptEnvBuffer; import io.nosqlbench.engine.api.scripting.ScriptEnvBuffer;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.io.IOException; import java.io.IOException;

View File

@@ -18,13 +18,13 @@
package io.nosqlbench.engine.core.script; package io.nosqlbench.engine.core.script;
import io.nosqlbench.engine.core.lifecycle.ScenariosResults; import io.nosqlbench.engine.core.lifecycle.ScenariosResults;
import org.junit.Ignore; import org.junit.jupiter.api.Disabled;
import org.junit.Test; import org.junit.jupiter.api.Test;
public class ScenariosExecutorTest { public class ScenariosExecutorTest {
@Test @Test
@Ignore @Disabled
public void testAwaitOnTime() { public void testAwaitOnTime() {
ScenariosExecutor e = new ScenariosExecutor(ScenariosExecutorTest.class.getSimpleName(), 1); ScenariosExecutor e = new ScenariosExecutor(ScenariosExecutorTest.class.getSimpleName(), 1);
Scenario s = new Scenario("testing", Scenario.Engine.Graalvm,"stdout:3000"); Scenario s = new Scenario("testing", Scenario.Engine.Graalvm,"stdout:3000");

View File

@@ -1,23 +1,25 @@
package io.nosqlbench.engine.core.script; package io.nosqlbench.engine.core.script;
import io.nosqlbench.nb.api.errors.BasicError; import io.nosqlbench.nb.api.errors.BasicError;
import org.junit.Test; import org.junit.jupiter.api.Test;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
public class ScriptParamsTest { public class ScriptParamsTest {
@Test(expected = BasicError.class) @Test
public void testThatNullOverridesKeyThrowsBasicError() { public void testThatNullOverridesKeyThrowsBasicError() {
ScriptParams p = new ScriptParams(); ScriptParams p = new ScriptParams();
p.putAll(Map.of("a","b")); p.putAll(Map.of("a","b"));
p.withDefaults(Map.of("c","d")); p.withDefaults(Map.of("c","d"));
HashMap<String, String> overrides = new HashMap<>(); HashMap<String, String> overrides = new HashMap<>();
overrides.put(null,"test"); overrides.put(null,"test");
p.withOverrides(overrides); assertThatExceptionOfType(BasicError.class)
.isThrownBy(() -> p.withOverrides(overrides));
} }
} }

Some files were not shown because too many files have changed in this diff Show More