Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed negative data and throughput values in an output of class RawErasureCoderBenchmark

This commit is contained in:
FuzzingTeam 2022-10-11 18:14:07 +05:30
parent 03d600fa82
commit 3c249dcb6b
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/erasurecode/rawcoder/RawErasureCoderBenchmark.java
View File

@ -320,6 +320,7 @@ public final class RawErasureCoderBenchmark {
private ByteBuffer[] decodeInputs = new ByteBuffer[NUM_ALL_UNITS]; private ByteBuffer[] decodeInputs = new ByteBuffer[NUM_ALL_UNITS];
public static void configure(int dataSizeMB, int chunkSizeKB) { public static void configure(int dataSizeMB, int chunkSizeKB) {
Preconditions.checkArgument(dataSizeMB > 0);
chunkSize = chunkSizeKB * 1024; chunkSize = chunkSizeKB * 1024;
// buffer size needs to be a multiple of (numDataUnits * chunkSize) // buffer size needs to be a multiple of (numDataUnits * chunkSize)
int round = (int) Math.round( int round = (int) Math.round(

9
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/erasurecode/rawcoder/TestRawErasureCoderBenchmark.java
View File

@ -18,6 +18,7 @@
package org.apache.hadoop.io.erasurecode.rawcoder; package org.apache.hadoop.io.erasurecode.rawcoder;
import org.apache.hadoop.io.erasurecode.ErasureCodeNative; import org.apache.hadoop.io.erasurecode.ErasureCodeNative;
import org.junit.Assert;
import org.junit.Assume; import org.junit.Assume;
import org.junit.Test; import org.junit.Test;
@ -33,6 +34,14 @@ public class TestRawErasureCoderBenchmark {
RawErasureCoderBenchmark.CODER.DUMMY_CODER, 2, 100, 1024); RawErasureCoderBenchmark.CODER.DUMMY_CODER, 2, 100, 1024);
RawErasureCoderBenchmark.performBench("decode", RawErasureCoderBenchmark.performBench("decode",
RawErasureCoderBenchmark.CODER.DUMMY_CODER, 5, 150, 100); RawErasureCoderBenchmark.CODER.DUMMY_CODER, 5, 150, 100);
try {
RawErasureCoderBenchmark.performBench("decode",
RawErasureCoderBenchmark.CODER.DUMMY_CODER, 5, -150, 100);
Assert.fail("should have thrown an IllegalArgumentException");
} catch (IllegalArgumentException e) {
// intentionally swallow exception
}
} }
@Test @Test