You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2019/08/22 16:42:26 UTC
[airavata-mft] 20/22: TCP transport implementation
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata-mft.git
commit 1635fe53bf1c5263c76ca2259e787d0fe394f80a
Author: isururanawaka <ir...@gmail.com>
AuthorDate: Thu Aug 22 11:14:57 2019 +0530
TCP transport implementation
---
.../apache/airavata/mft/transport/tcp/RemoteResourceIdentifier.java | 3 ---
.../org/apache/airavata/mft/transport/tcp/server/FileServer.java | 5 -----
2 files changed, 8 deletions(-)
diff --git a/transport/tcp-transport/src/main/java/org/apache/airavata/mft/transport/tcp/RemoteResourceIdentifier.java b/transport/tcp-transport/src/main/java/org/apache/airavata/mft/transport/tcp/RemoteResourceIdentifier.java
index 7877a66..7fddfaf 100644
--- a/transport/tcp-transport/src/main/java/org/apache/airavata/mft/transport/tcp/RemoteResourceIdentifier.java
+++ b/transport/tcp-transport/src/main/java/org/apache/airavata/mft/transport/tcp/RemoteResourceIdentifier.java
@@ -28,13 +28,11 @@ public class RemoteResourceIdentifier {
private String host;
private int port;
-
private InetSocketAddress inetSocketAddress;
public RemoteResourceIdentifier(String host, int port) {
this.host = host;
this.port = port;
-
inetSocketAddress = new InetSocketAddress(host, port);
}
@@ -56,7 +54,6 @@ public class RemoteResourceIdentifier {
/**
* provides the InetSocketAddress of given host and port
- *
* @return InetSocketAddress
*/
public InetSocketAddress getAddress() {
diff --git a/transport/tcp-transport/src/main/java/org/apache/airavata/mft/transport/tcp/server/FileServer.java b/transport/tcp-transport/src/main/java/org/apache/airavata/mft/transport/tcp/server/FileServer.java
index f41f673..e1f7bcb 100644
--- a/transport/tcp-transport/src/main/java/org/apache/airavata/mft/transport/tcp/server/FileServer.java
+++ b/transport/tcp-transport/src/main/java/org/apache/airavata/mft/transport/tcp/server/FileServer.java
@@ -35,7 +35,6 @@ public class FileServer {
private ConcurrentHashMap<String, FileServerConnector> remoteHostToConnectorMap =
new ConcurrentHashMap<>(Constants.MAX_NUM_OF_HOSTS);
-
private volatile boolean runServer = true;
/**
@@ -65,8 +64,6 @@ public class FileServer {
}
fileServerConnector.addChannel(channel);
-
-
}
}
} catch (Exception ex) {
@@ -76,7 +73,6 @@ public class FileServer {
/**
* Server is shutdown and stops accepting incoming connections
- *
* @return
*/
public void stop() {
@@ -86,7 +82,6 @@ public class FileServer {
/**
* Get connector bound to remote client. If remote host is not known keep it null.
- *
* @param host
* @return
*/