提交 93bc507b 编写于 作者: A andrew

Merge

...@@ -29,11 +29,13 @@ ...@@ -29,11 +29,13 @@
* @run main MultiThreadedReadTest * @run main MultiThreadedReadTest
*/ */
import java.io.BufferedOutputStream;
import java.io.File; import java.io.File;
import java.io.FileOutputStream; import java.io.FileOutputStream;
import java.io.InputStream; import java.io.InputStream;
import java.nio.file.Paths; import java.nio.file.Paths;
import java.util.Random; import java.util.Random;
import java.util.zip.CRC32;
import java.util.zip.ZipEntry; import java.util.zip.ZipEntry;
import java.util.zip.ZipFile; import java.util.zip.ZipFile;
import java.util.zip.ZipOutputStream; import java.util.zip.ZipOutputStream;
...@@ -42,7 +44,8 @@ import jdk.testlibrary.FileUtils; ...@@ -42,7 +44,8 @@ import jdk.testlibrary.FileUtils;
public class MultiThreadedReadTest extends Thread { public class MultiThreadedReadTest extends Thread {
private static final int NUM_THREADS = 10; private static final int NUM_THREADS = 10;
private static final String ZIPFILE_NAME = "large.zip"; private static final String ZIPFILE_NAME =
System.currentTimeMillis() + "-bug8038491-tmp.large.zip";
private static final String ZIPENTRY_NAME = "random.txt"; private static final String ZIPENTRY_NAME = "random.txt";
private static InputStream is = null; private static InputStream is = null;
...@@ -61,23 +64,34 @@ public class MultiThreadedReadTest extends Thread { ...@@ -61,23 +64,34 @@ public class MultiThreadedReadTest extends Thread {
threadArray[i].join(); threadArray[i].join();
} }
} finally { } finally {
long t = System.currentTimeMillis();
FileUtils.deleteFileIfExistsWithRetry(Paths.get(ZIPFILE_NAME)); FileUtils.deleteFileIfExistsWithRetry(Paths.get(ZIPFILE_NAME));
System.out.println("Deleting zip file took:" +
(System.currentTimeMillis() - t) + "ms");
} }
} }
private static void createZipFile() throws Exception { private static void createZipFile() throws Exception {
try (ZipOutputStream zos = CRC32 crc32 = new CRC32();
new ZipOutputStream(new FileOutputStream(ZIPFILE_NAME))) { long t = System.currentTimeMillis();
File zipFile = new File(ZIPFILE_NAME);
zos.putNextEntry(new ZipEntry(ZIPENTRY_NAME)); try (FileOutputStream fos = new FileOutputStream(zipFile);
StringBuilder sb = new StringBuilder(); BufferedOutputStream bos = new BufferedOutputStream(fos);
Random rnd = new Random(); ZipOutputStream zos = new ZipOutputStream(bos)) {
for(int i = 0; i < 1000; i++) { ZipEntry e = new ZipEntry(ZIPENTRY_NAME);
// append some random string for ZipEntry e.setMethod(ZipEntry.STORED);
sb.append(Long.toString(rnd.nextLong())); StringBuilder blahBuilder = new StringBuilder();
for (int i = 0; i < 10_000; i++) {
blahBuilder.append("BLAH");
} }
byte[] b = sb.toString().getBytes(); byte[] toWrite = blahBuilder.toString().getBytes();
zos.write(b, 0, b.length); e.setTime(t);
e.setSize(toWrite.length);
crc32.reset();
crc32.update(toWrite);
e.setCrc(crc32.getValue());
zos.putNextEntry(e);
zos.write(toWrite);
} }
} }
...@@ -86,6 +100,7 @@ public class MultiThreadedReadTest extends Thread { ...@@ -86,6 +100,7 @@ public class MultiThreadedReadTest extends Thread {
try { try {
while (is.read() != -1) { } while (is.read() != -1) { }
} catch (Exception e) { } catch (Exception e) {
System.out.println("read exception:" + e);
// Swallow any Exceptions (which are expected) - we're only interested in the crash // Swallow any Exceptions (which are expected) - we're only interested in the crash
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册