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

make recycles semantics and format consistent with cycles

Browse Source
This commit is contained in:
Jonathan Shook
2023-09-09 16:03:40 -05:00
parent 3aab634522
commit be396cceb2
12 changed files with 169 additions and 158 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
engine-core/src/main/java/io/nosqlbench/engine/core/fortesting/BlockingSegmentInput.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright (c) 2022 nosqlbench
* Copyright (c) 2022-2023 nosqlbench
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -30,7 +30,8 @@ import java.util.concurrent.atomic.AtomicLong;
public class BlockingSegmentInput implements Input {
private final AtomicLong cycle = new AtomicLong(0L);
private final InputInterval inputInterval = new InputInterval(0,Long.MAX_VALUE);
private final InputInterval inputInterval = new InputInterval(0L, 0L, Long.MAX_VALUE);
private CycleSegment segment;
@@ -38,14 +39,15 @@ public class BlockingSegmentInput implements Input {
public synchronized CycleSegment getInputSegment(int segmentLength) {
try {
this.wait();
} catch (InterruptedException ignored){}
} catch (InterruptedException ignored) {
}
CycleSegment toReturn = this.segment;
this.segment=null;
this.segment = null;
return toReturn;
}
public void publishSegment(long... cycleValues) {
this.segment = new CycleArray.ArraySegment(cycleValues);
this.segment = new CycleArray.ArraySegment(cycleValues, 0L);
synchronized (this) {
this.notify();
}