IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

Initial commit

Browse Source
This commit is contained in:
sahankj2000 2024-03-22 11:34:06 +05:30
parent 88318c7215
commit 89422ee23e
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
engine-core/src/main/java/io/nosqlbench/engine/api/scenarios/NBCLIScenarioPreprocessor.java
View File

@ -170,7 +170,7 @@ public class NBCLIScenarioPreprocessor {
// here, we should actually parse the command using argv rules
cmd = userParamsInterp.apply(cmd);
LinkedHashMap<String, SCNamedParam> parsedStep = parseStep(cmd);
LinkedHashMap<String, SCNamedParam> parsedStep = parseStep(cmd, stepName, scenarioName);
LinkedHashMap<String, String> usersCopy = new LinkedHashMap<>(userProvidedParams);
LinkedHashMap<String, String> buildingCmd = new LinkedHashMap<>();
@ -252,7 +252,7 @@ public class NBCLIScenarioPreprocessor {
private static final Pattern WordAndMaybeAssignment = Pattern.compile("(?<name>\\w[-_\\d\\w.]+)((?<oper>=+)(?<val>.+))?");
private static LinkedHashMap<String, SCNamedParam> parseStep(String cmd) {
private static LinkedHashMap<String, SCNamedParam> parseStep(String cmd, String stepName, String scenarioName) {
LinkedHashMap<String, SCNamedParam> parsedStep = new LinkedHashMap<>();
String[] namedStepPieces = cmd.split(" +");
@ -270,6 +270,10 @@ public class NBCLIScenarioPreprocessor {
String commandName = matcher.group("name");
String assignmentOp = matcher.group("oper");
String assignedValue = matcher.group("val");
if (parsedStep.containsKey(commandName)) {
String errorMessage = String.format("Duplicate occurrence of parameter \"%s\" on step \"%s\" of scenario \"%s\", step command: \"%s\"", commandName, stepName, scenarioName, cmd);
throw new BasicError(errorMessage);
}
parsedStep.put(commandName, new SCNamedParam(commandName, assignmentOp, assignedValue));
}
return parsedStep;

3
engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/session/CmdParser.java
View File

@ -72,6 +72,9 @@ public class CmdParser {
Map<String,CmdArg> params = new LinkedHashMap<>();
while (cmdstructs.peekFirst() instanceof parameter param) {
cmdstructs.removeFirst();
if (params.containsKey(param.name())) {
throw new BasicError("Duplicate occurrence of option: " + param.name());
}
params.put(param.name(),CmdArg.of(cmd.name(),param.name(),param.op(),param.value()));
}
cmds.add(new Cmd(cmd.name(),params));