Skip to content
Snippets Groups Projects
Commit 8036b859 authored by Jan Kožusznik's avatar Jan Kožusznik
Browse files

FIX: reason og auth fail inspection

parent c2e52e6e
No related branches found
No related tags found
1 merge request!14Iss1026
......@@ -19,6 +19,7 @@ import org.slf4j.LoggerFactory;
import cz.it4i.fiji.haas.JobManager.JobManager4Job;
import cz.it4i.fiji.haas.JobManager.JobSynchronizableFile;
import cz.it4i.fiji.haas_java_client.DummyProgressNotifier;
import cz.it4i.fiji.haas_java_client.HaaSClient;
import cz.it4i.fiji.haas_java_client.HaaSClient.UploadingFile;
import cz.it4i.fiji.haas_java_client.HaaSFileTransfer;
......
package cz.it4i.fiji.haas;
import cz.it4i.fiji.haas_java_client.ProgressNotifier;
package cz.it4i.fiji.haas_java_client;
public class DummyProgressNotifier implements ProgressNotifier {
......
......@@ -246,6 +246,8 @@ public class HaaSClient {
public HaaSFileTransfer startFileTransfer(long jobId, ProgressNotifier notifier) {
try {
//TODO it may be usefull reuse fileTransfer for concurrent transfers
//- count using is needed
FileTransferMethodExt ft = getFileTransfer().getFileTransferMethod(jobId, getSessionID());
return new HaaSFileTransferImp(ft, getSessionID(), jobId, getFileTransfer(), getScpClient(ft), notifier);
} catch (RemoteException | ServiceException | UnsupportedEncodingException | JSchException e) {
......
package cz.it4i.fiji.haas_java_client;
import java.io.IOException;
import java.util.Arrays;
import javax.xml.rpc.ServiceException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class TestHaaSJavaClient2 {
private static Logger log = LoggerFactory.getLogger(cz.it4i.fiji.haas_java_client.TestHaaSJavaClient2.class);
public static void main(String[] args) throws ServiceException, IOException {
HaaSClient client = new HaaSClient(TestingConstants.getSettings(1l, 600, 7l, "OPEN-12-20"));
HaaSFileTransfer tr1 = client.startFileTransfer(250, new DummyProgressNotifier());
HaaSFileTransfer tr2 = client.startFileTransfer(250, new DummyProgressNotifier());
log.info("config.yaml - size:" + tr1.obtainSize(Arrays.asList("config.yaml")));
log.info("config.yaml - size:" + tr2.obtainSize(Arrays.asList("config.yaml")));
tr1.close();
tr2.close();
}
}
......@@ -19,6 +19,7 @@ import cz.it4i.fiji.haas_spim_benchmark.core.TaskComputation;
import cz.it4i.fiji.haas_spim_benchmark.core.TaskComputation.Log;
import javafx.beans.value.ObservableValue;
import javafx.beans.value.ObservableValueBase;
//TASK: fix occasional auth fails with ssh
//TASK: improve performance
public class TaskComputationAdapter implements Closeable {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment