aboutsummaryrefslogtreecommitdiffstats
path: root/filedistribution/src/test
diff options
context:
space:
mode:
authorHarald Musum <musum@oath.com>2017-12-12 12:32:01 +0100
committerHarald Musum <musum@oath.com>2017-12-12 12:32:01 +0100
commit5124bc3a959a399483db3e52e721e789ba426338 (patch)
tree2d0f5585e4beadc61a9e73bc1fe551446d1a9b08 /filedistribution/src/test
parent245823f083f130ffbc9847ab79df9974b023d7c2 (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.java8
-rw-r--r--filedistribution/src/test/java/com/yahoo/vespa/filedistribution/FileReceiverTest.java19
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);