diff options
author | Harald Musum <musum@oath.com> | 2017-12-12 12:32:01 +0100 |
---|---|---|
committer | Harald Musum <musum@oath.com> | 2017-12-12 12:32:01 +0100 |
commit | 5124bc3a959a399483db3e52e721e789ba426338 (patch) | |
tree | 2d0f5585e4beadc61a9e73bc1fe551446d1a9b08 /filedistribution/src/test | |
parent | 245823f083f130ffbc9847ab79df9974b023d7c2 (diff) |
Make sure to use a tmp directory on same partition as download directory
Diffstat (limited to 'filedistribution/src/test')
-rw-r--r-- | filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java | 8 | ||||
-rw-r--r-- | filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileReceiverTest.java | 19 |
2 files changed, 22 insertions, 5 deletions
diff --git a/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java b/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java index 4618b229de1..60478550084 100644 --- a/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java +++ b/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileDownloaderTest.java @@ -36,13 +36,15 @@ public class FileDownloaderTest { private MockConnection connection; private FileDownloader fileDownloader; private File downloadDir; + private File tempDir; @Before public void setup() { try { downloadDir = Files.createTempDirectory("filedistribution").toFile(); + tempDir = Files.createTempDirectory("download").toFile(); connection = new MockConnection(); - fileDownloader = new FileDownloader(connection, downloadDir, Duration.ofMillis(2000)); + fileDownloader = new FileDownloader(connection, downloadDir, tempDir, Duration.ofMillis(2000)); } catch (IOException e) { e.printStackTrace(); fail(e.getMessage()); @@ -147,7 +149,7 @@ public class FileDownloaderTest { @Test public void getFileWhenConnectionError() throws IOException { - fileDownloader = new FileDownloader(connection, downloadDir, Duration.ofMillis(3000)); + fileDownloader = new FileDownloader(connection, downloadDir, tempDir, Duration.ofMillis(3000)); File downloadDir = fileDownloader.downloadDirectory(); int timesToFail = 2; @@ -183,7 +185,7 @@ public class FileDownloaderTest { File downloadDir = Files.createTempDirectory("filedistribution").toFile(); MockConnection connectionPool = new MockConnection(); connectionPool.setResponseHandler(new MockConnection.WaitResponseHandler(timeout.plus(Duration.ofMillis(1000)))); - FileDownloader fileDownloader = new FileDownloader(connectionPool, downloadDir, timeout); + FileDownloader fileDownloader = new FileDownloader(connectionPool, downloadDir, tempDir, timeout); FileReference foo = new FileReference("foo"); FileReference bar = new FileReference("bar"); List<FileReference> fileReferences = Arrays.asList(foo, bar); diff --git a/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileReceiverTest.java b/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileReceiverTest.java index 5edd1151cb1..34ce53ad4c8 100644 --- a/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileReceiverTest.java +++ b/filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileReceiverTest.java @@ -4,7 +4,11 @@ import com.yahoo.config.FileReference; import com.yahoo.text.Utf8; import net.jpountz.xxhash.XXHash64; import net.jpountz.xxhash.XXHashFactory; +import org.junit.Before; +import org.junit.Rule; import org.junit.Test; +import org.junit.rules.TemporaryFolder; + import static org.junit.Assert.assertEquals; @@ -14,8 +18,19 @@ import java.nio.ByteBuffer; import java.nio.file.Files; public class FileReceiverTest { - private final File root = new File("."); + private File root; + private File tempDir; private final XXHash64 hasher = XXHashFactory.fastestInstance().hash64(); + + @Rule + public TemporaryFolder temporaryFolder = new TemporaryFolder(); + + @Before + public void setup() throws IOException { + root = temporaryFolder.newFolder("root"); + tempDir = temporaryFolder.newFolder("tmp"); + } + @Test public void receiveMultiPartFile() throws IOException{ @@ -40,7 +55,7 @@ public class FileReceiverTest { private String transferParts(FileReference ref, String fileName, String all, int numParts) throws IOException { byte [] allContent = Utf8.toBytes(all); - FileReceiver.Session session = new FileReceiver.Session(root, 1, ref, + FileReceiver.Session session = new FileReceiver.Session(root, tempDir, 1, ref, FileReferenceData.Type.file, fileName, allContent.length); int partSize = (allContent.length+(numParts-1))/numParts; ByteBuffer bb = ByteBuffer.wrap(allContent); |