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:28 UTC
[airavata-mft] 22/22: Merge pull request #1 from
isururanawaka/nioImpl
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 c2f432e9d299fb95c1715d5666d34968deb69b0e
Merge: ce2e3ad e331ff7
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Thu Aug 22 12:42:01 2019 -0400
Merge pull request #1 from isururanawaka/nioImpl
NIO based file transport implementation
LICENSE | 0
README | 0
core/pom.xml | 12 +++
.../airavata/mft/core/api/CompletionCallback.java | 41 ++++++++
.../apache/airavata/mft/core/api/Connector.java | 43 +++++++++
.../airavata/mft/core/api/ConnectorChannel.java | 64 +++++++++++++
.../org/apache/airavata/mft/core/api/Mediator.java | 39 ++++++++
.../airavata/mft/core/api/SinkConnector.java | 37 +++++++
.../airavata/mft/core/api/SourceConnector.java | 31 ++++++
.../airavata/mft/core/api/StreamedReceiver.java | 0
.../airavata/mft/core/api/StreamedSender.java | 0
.../airavata/mft/core/api/TransportOperator.java | 0
.../mft/core/bufferedImpl/ConnectorException.java | 37 +++++++
.../airavata/mft/core/bufferedImpl/Constants.java | 29 ++++++
.../core/bufferedImpl/channel/AbstractChannel.java | 54 +++++++++++
.../bufferedImpl/channel/AbstractConnector.java | 50 ++++++++++
.../core/bufferedImpl/channel/ChannelUtils.java | 92 ++++++++++++++++++
.../mft/core/bufferedImpl/channel/InChannel.java | 69 ++++++++++++++
.../mft/core/bufferedImpl/channel/OutChannel.java | 67 +++++++++++++
.../mediation/PassthroughMediator.java | 84 ++++++++++++++++
.../core/streaming/DoubleByteArrayInputStream.java | 0
.../streaming/DoubleByteArrayOutputStream.java | 0
.../mft/core/streaming/TransportMetadata.java | 0
.../mft/core/streaming/TransportStream.java | 0
pom.xml | 0
transport/local-transport/pom.xml | 41 ++++++++
.../mft/transport/local/FileConstants.java | 29 ++++++
.../airavata/mft/transport/local/FileUtils.java | 52 ++++++++++
.../mft/transport/local/ResourceIdentifier.java | 37 +++++++
.../mft/transport/local/SinkFileConnector.java | 60 ++++++++++++
.../mft/transport/local/SourceFileConnector.java | 50 ++++++++++
transport/pom.xml | 2 +
transport/s3-transport/pom.xml | 12 +++
.../org/apache/airavata/mft/transport/s3/Main.java | 86 +++++++++++++++++
.../airavata/mft/transport/s3/S3Constants.java | 30 ++++++
.../airavata/mft/transport/s3/S3Receiver.java | 0
.../mft/transport/s3/S3ResourceIdentifier.java | 0
.../apache/airavata/mft/transport/s3/S3Sender.java | 0
.../airavata/mft/transport/s3/S3SinkConnector.java | 87 +++++++++++++++++
.../mft/transport/s3/S3SourceConnector.java | 61 ++++++++++++
.../mft/transport/s3/S3TransportOperator.java | 0
.../airavata/mft/transport/s3/S3TransportUtil.java | 0
transport/scp-transport/pom.xml | 0
.../apache/airavata/mft/transport/scp/Main.java | 0
.../airavata/mft/transport/scp/SCPReceiver.java | 0
.../airavata/mft/transport/scp/SCPSender.java | 0
.../mft/transport/scp/SCPTransportOperator.java | 0
.../mft/transport/scp/SCPTransportUtil.java | 0
.../mft/transport/scp/SSHResourceIdentifier.java | 0
transport/tcp-transport/pom.xml | 41 ++++++++
.../airavata/mft/transport/tcp/Constants.java | 30 ++++++
.../transport/tcp/RemoteResourceIdentifier.java | 62 ++++++++++++
.../tcp/client/RemoteFileServerConnector.java | 54 +++++++++++
.../mft/transport/tcp/server/FileServer.java | 106 +++++++++++++++++++++
.../transport/tcp/server/FileServerConnector.java | 51 ++++++++++
55 files changed, 1640 insertions(+)