diff --git a/dhfs-parent/dhfs-fuse/src/test/java/com/usatiuk/dhfsfuse/integration/LazyFsIT.java b/dhfs-parent/dhfs-fuse/src/test/java/com/usatiuk/dhfsfuse/integration/LazyFsIT.java index ce8a742b..e0537aa2 100644 --- a/dhfs-parent/dhfs-fuse/src/test/java/com/usatiuk/dhfsfuse/integration/LazyFsIT.java +++ b/dhfs-parent/dhfs-fuse/src/test/java/com/usatiuk/dhfsfuse/integration/LazyFsIT.java @@ -12,12 +12,10 @@ import org.testcontainers.containers.GenericContainer; import org.testcontainers.containers.Network; import org.testcontainers.containers.output.Slf4jLogConsumer; import org.testcontainers.containers.output.WaitingConsumer; -import org.testcontainers.containers.wait.strategy.Wait; import java.io.File; import java.io.IOException; import java.nio.file.Files; -import java.time.Duration; import java.util.Objects; import java.util.UUID; import java.util.concurrent.*; @@ -125,7 +123,7 @@ public class LazyFsIT { } private void checkConsistency(String testName) { - await().atMost(45, TimeUnit.SECONDS).until(() -> { + await().atMost(120, TimeUnit.SECONDS).until(() -> { var ls1 = container1.execInContainer("/bin/sh", "-c", "ls /dhfs_test/fuse"); var cat1 = container1.execInContainer("/bin/sh", "-c", "cat /dhfs_test/fuse/*"); var ls2 = container2.execInContainer("/bin/sh", "-c", "ls /dhfs_test/fuse"); diff --git a/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/peersync/api/PeerSyncApiClientDynamic.java b/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/peersync/api/PeerSyncApiClientDynamic.java index 5ac3cd98..50e3e43e 100644 --- a/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/peersync/api/PeerSyncApiClientDynamic.java +++ b/dhfs-parent/sync-base/src/main/java/com/usatiuk/dhfs/peersync/api/PeerSyncApiClientDynamic.java @@ -4,6 +4,7 @@ import com.usatiuk.dhfs.peerdiscovery.IpPeerAddress; import com.usatiuk.dhfs.peerdiscovery.PeerAddress; import io.quarkus.rest.client.reactive.QuarkusRestClientBuilder; import jakarta.enterprise.context.ApplicationScoped; +import org.eclipse.microprofile.config.inject.ConfigProperty; import java.net.URI; import java.util.concurrent.TimeUnit; @@ -13,6 +14,10 @@ import java.util.concurrent.TimeUnit; */ @ApplicationScoped public class PeerSyncApiClientDynamic { + + @ConfigProperty(name = "dhfs.objects.sync.peer-sync-api.timeout", defaultValue = "5") + int timeout; + /** * Queries peer about its information. * @@ -29,8 +34,8 @@ public class PeerSyncApiClientDynamic { private ApiPeerInfo getSelfInfo(String address, int port) { var client = QuarkusRestClientBuilder.newBuilder() .baseUri(URI.create("http://" + address + ":" + port)) - .connectTimeout(1, TimeUnit.SECONDS) - .readTimeout(1, TimeUnit.SECONDS) + .connectTimeout(timeout, TimeUnit.SECONDS) + .readTimeout(timeout, TimeUnit.SECONDS) .build(PeerSyncApiClient.class); return client.getSelfInfo(); }