honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Tests: tone down random compression tests 

Closes #7314
This commit is contained in:
Robert Muir 2014-08-18 10:37:45 -04:00
parent 639692943f
commit ae326c4232
2 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/test/java/org/elasticsearch/common/compress/CompressedStreamTests.java
View File

@ -48,8 +48,8 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
public void testRandom() throws IOException { public void testRandom() throws IOException {
Random r = getRandom(); Random r = getRandom();
for (int i = 0; i < 100; i++) { for (int i = 0; i < 10; i++) {
byte bytes[] = new byte[TestUtil.nextInt(r, 1, 4000000)]; byte bytes[] = new byte[TestUtil.nextInt(r, 1, 400000)];
r.nextBytes(bytes); r.nextBytes(bytes);
doTest(bytes); doTest(bytes);
} }
@ -68,7 +68,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
try { try {
Random r = new Random(seed); Random r = new Random(seed);
startingGun.await(); startingGun.await();
for (int i = 0; i < 100; i++) { for (int i = 0; i < 10; i++) {
byte bytes[] = new byte[TestUtil.nextInt(r, 1, 100000)]; byte bytes[] = new byte[TestUtil.nextInt(r, 1, 100000)];
r.nextBytes(bytes); r.nextBytes(bytes);
doTest(bytes); doTest(bytes);
@ -89,7 +89,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
public void testLineDocs() throws IOException { public void testLineDocs() throws IOException {
Random r = getRandom(); Random r = getRandom();
LineFileDocs lineFileDocs = new LineFileDocs(r); LineFileDocs lineFileDocs = new LineFileDocs(r);
for (int i = 0; i < 100; i++) { for (int i = 0; i < 10; i++) {
int numDocs = TestUtil.nextInt(r, 1, 200); int numDocs = TestUtil.nextInt(r, 1, 200);
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
for (int j = 0; j < numDocs; j++) { for (int j = 0; j < numDocs; j++) {
@ -115,7 +115,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
Random r = new Random(seed); Random r = new Random(seed);
startingGun.await(); startingGun.await();
LineFileDocs lineFileDocs = new LineFileDocs(r); LineFileDocs lineFileDocs = new LineFileDocs(r);
for (int i = 0; i < 100; i++) { for (int i = 0; i < 10; i++) {
int numDocs = TestUtil.nextInt(r, 1, 200); int numDocs = TestUtil.nextInt(r, 1, 200);
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
for (int j = 0; j < numDocs; j++) { for (int j = 0; j < numDocs; j++) {
@ -140,7 +140,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
public void testRepetitionsL() throws IOException { public void testRepetitionsL() throws IOException {
Random r = getRandom(); Random r = getRandom();
for (int i = 0; i < 200; i++) { for (int i = 0; i < 10; i++) {
int numLongs = TestUtil.nextInt(r, 1, 10000); int numLongs = TestUtil.nextInt(r, 1, 10000);
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
long theValue = r.nextLong(); long theValue = r.nextLong();
@ -174,7 +174,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
try { try {
Random r = new Random(seed); Random r = new Random(seed);
startingGun.await(); startingGun.await();
for (int i = 0; i < 200; i++) { for (int i = 0; i < 10; i++) {
int numLongs = TestUtil.nextInt(r, 1, 10000); int numLongs = TestUtil.nextInt(r, 1, 10000);
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
long theValue = r.nextLong(); long theValue = r.nextLong();
@ -208,7 +208,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
public void testRepetitionsI() throws IOException { public void testRepetitionsI() throws IOException {
Random r = getRandom(); Random r = getRandom();
for (int i = 0; i < 200; i++) { for (int i = 0; i < 10; i++) {
int numInts = TestUtil.nextInt(r, 1, 20000); int numInts = TestUtil.nextInt(r, 1, 20000);
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
int theValue = r.nextInt(); int theValue = r.nextInt();
@ -238,7 +238,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
try { try {
Random r = new Random(seed); Random r = new Random(seed);
startingGun.await(); startingGun.await();
for (int i = 0; i < 200; i++) { for (int i = 0; i < 10; i++) {
int numInts = TestUtil.nextInt(r, 1, 20000); int numInts = TestUtil.nextInt(r, 1, 20000);
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
int theValue = r.nextInt(); int theValue = r.nextInt();
@ -268,7 +268,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
public void testRepetitionsS() throws IOException { public void testRepetitionsS() throws IOException {
Random r = getRandom(); Random r = getRandom();
for (int i = 0; i < 200; i++) { for (int i = 0; i < 10; i++) {
int numShorts = TestUtil.nextInt(r, 1, 40000); int numShorts = TestUtil.nextInt(r, 1, 40000);
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
short theValue = (short) r.nextInt(65535); short theValue = (short) r.nextInt(65535);
@ -286,11 +286,11 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
public void testMixed() throws IOException { public void testMixed() throws IOException {
Random r = getRandom(); Random r = getRandom();
LineFileDocs lineFileDocs = new LineFileDocs(r); LineFileDocs lineFileDocs = new LineFileDocs(r);
for (int i = 0; i < 100; ++i) { for (int i = 0; i < 2; ++i) {
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
int prevInt = r.nextInt(); int prevInt = r.nextInt();
long prevLong = r.nextLong(); long prevLong = r.nextLong();
while (bos.size() < 4000000) { while (bos.size() < 400000) {
switch (r.nextInt(4)) { switch (r.nextInt(4)) {
case 0: case 0:
addInt(r, prevInt, bos); addInt(r, prevInt, bos);
@ -362,7 +362,7 @@ public class CompressedStreamTests extends ElasticsearchTestCase {
try { try {
Random r = new Random(seed); Random r = new Random(seed);
startingGun.await(); startingGun.await();
for (int i = 0; i < 200; i++) { for (int i = 0; i < 10; i++) {
int numShorts = TestUtil.nextInt(r, 1, 40000); int numShorts = TestUtil.nextInt(r, 1, 40000);
ByteArrayOutputStream bos = new ByteArrayOutputStream(); ByteArrayOutputStream bos = new ByteArrayOutputStream();
short theValue = (short) r.nextInt(65535); short theValue = (short) r.nextInt(65535);

2
src/test/java/org/elasticsearch/common/compress/CompressedStringTests.java
View File

@ -58,7 +58,7 @@ public class CompressedStringTests extends ElasticsearchTestCase {
String compressor = "lzf"; String compressor = "lzf";
CompressorFactory.configure(ImmutableSettings.settingsBuilder().put("compress.default.type", compressor).build()); CompressorFactory.configure(ImmutableSettings.settingsBuilder().put("compress.default.type", compressor).build());
Random r = getRandom(); Random r = getRandom();
for (int i = 0; i < 2000; i++) { for (int i = 0; i < 1000; i++) {
String string = TestUtil.randomUnicodeString(r, 10000); String string = TestUtil.randomUnicodeString(r, 10000);
CompressedString compressedString = new CompressedString(string); CompressedString compressedString = new CompressedString(string);
assertThat(compressedString.string(), equalTo(string)); assertThat(compressedString.string(), equalTo(string));