Swiftdiff options
| author | Alex Clayton <alex.clayton@isode.com> | 2016-01-27 16:36:15 (GMT) |
|---|---|---|
| committer | Alex Clayton <alex.clayton@isode.com> | 2016-01-28 12:25:43 (GMT) |
| commit | ceb4798aa0739ebd7177632c3f508babacb2f8d7 (patch) | |
| tree | 7e5a2c1852261c8f0e4d8ed3262a32cced037378 | |
| parent | 93eb4ab62a08da883cab4a3743a3a86c198eb0b4 (diff) | |
| download | stroke-ceb4798aa0739ebd7177632c3f508babacb2f8d7.zip stroke-ceb4798aa0739ebd7177632c3f508babacb2f8d7.tar.bz2 | |
Changes to FileTransfer to be inline with current Swiften code
There has been some changes to the file transfer clases in Swiften since Tarun's
patch was written. This patch updates the java classes to bring them in line
with the swiften one.
In details
IBBSendSession - added code to clean up onResponse connection when not needed.
In Swiften this was done by keeping reference to current session using boost
bindings to remove binding. In java we have to keep a reference to the current
onResponse connection and disconnect it when not neeeded.
IncomingFileTransferManager - Remove redundant IQRouter field.
LocalJingeTransportCandidateGenerator - Do not advertise link-local IPv6
addresses in FT candidates
OutgoingSIFileTransfer - File deleted
SOCKS5BytestreamProxiesManager and SOCKS5BytestreamProxyFinder - Search for all
proxies instead of just one.
Test-information:
Ran make and make test to check everything built ok and that the unit tests
still passed.
Change-Id: I696444e5074fe20625243693a44c836306b3a41e
7 files changed, 141 insertions, 233 deletions
diff --git a/src/com/isode/stroke/filetransfer/FileTransferManagerImpl.java b/src/com/isode/stroke/filetransfer/FileTransferManagerImpl.java index 58ea74e..da5e120 100644 --- a/src/com/isode/stroke/filetransfer/FileTransferManagerImpl.java +++ b/src/com/isode/stroke/filetransfer/FileTransferManagerImpl.java @@ -90,4 +90,3 @@ public class FileTransferManagerImpl extends FileTransferManager { incomingFTManager = new IncomingFileTransferManager( - jingleSessionManager, - iqRouter, + jingleSessionManager, transporterFactory, diff --git a/src/com/isode/stroke/filetransfer/IBBSendSession.java b/src/com/isode/stroke/filetransfer/IBBSendSession.java index 5a812ff..bb44006 100644 --- a/src/com/isode/stroke/filetransfer/IBBSendSession.java +++ b/src/com/isode/stroke/filetransfer/IBBSendSession.java @@ -1,3 +1,3 @@ /* - * Copyright (c) 2010-2013 Isode Limited. + * Copyright (c) 2010-2015 Isode Limited. * All rights reserved. @@ -14,2 +14,3 @@ package com.isode.stroke.filetransfer; import com.isode.stroke.signals.Signal1; +import com.isode.stroke.signals.SignalConnection; import com.isode.stroke.signals.Slot2; @@ -33,4 +34,5 @@ public class IBBSendSession { private boolean waitingForData; + private SignalConnection currentRequestOnResponseConnection; - public IBBSendSession(final String id, final JID from, final JID to, ReadBytestream bytestream, IQRouter router) { + public IBBSendSession(final String id, final JID from, final JID to, ReadBytestream bytestream, IQRouter router) { this.id = id; @@ -54,3 +56,3 @@ public class IBBSendSession { IBBRequest request = IBBRequest.create(from, to, IBB.createIBBOpen(id, (int)(blockSize)), router); - request.onResponse.connect(new Slot2<IBB, ErrorPayload>() { + currentRequestOnResponseConnection = request.onResponse.connect(new Slot2<IBB, ErrorPayload>() { @Override @@ -68,2 +70,6 @@ public class IBBSendSession { } + if (currentRequestOnResponseConnection != null) { + currentRequestOnResponseConnection.disconnect(); + currentRequestOnResponseConnection = null; + } finish(null); @@ -85,4 +91,7 @@ public class IBBSendSession { public final Signal1<Integer> onBytesSent = new Signal1<Integer>(); - - private void handleIBBResponse(IBB ibb, ErrorPayload error) { + private void handleIBBResponse(IBB ibb, ErrorPayload error) { + if (currentRequestOnResponseConnection != null) { + currentRequestOnResponseConnection.disconnect(); + currentRequestOnResponseConnection = null; + } if (error == null && active) { diff --git a/src/com/isode/stroke/filetransfer/IncomingFileTransferManager.java b/src/com/isode/stroke/filetransfer/IncomingFileTransferManager.java index ffdf86e..7166d67 100644 --- a/src/com/isode/stroke/filetransfer/IncomingFileTransferManager.java +++ b/src/com/isode/stroke/filetransfer/IncomingFileTransferManager.java @@ -32,3 +32,2 @@ public class IncomingFileTransferManager implements IncomingJingleSessionHandler private JingleSessionManager jingleSessionManager; - private IQRouter router; private FileTransferTransporterFactory transporterFactory; @@ -39,4 +38,3 @@ public class IncomingFileTransferManager implements IncomingJingleSessionHandler public IncomingFileTransferManager( - JingleSessionManager jingleSessionManager, - IQRouter router, + JingleSessionManager jingleSessionManager, FileTransferTransporterFactory transporterFactory, @@ -45,3 +43,2 @@ public class IncomingFileTransferManager implements IncomingJingleSessionHandler this.jingleSessionManager = jingleSessionManager; - this.router = router; this.transporterFactory = transporterFactory; diff --git a/src/com/isode/stroke/filetransfer/LocalJingleTransportCandidateGenerator.java b/src/com/isode/stroke/filetransfer/LocalJingleTransportCandidateGenerator.java index 3839b26..a4c4623 100644 --- a/src/com/isode/stroke/filetransfer/LocalJingleTransportCandidateGenerator.java +++ b/src/com/isode/stroke/filetransfer/LocalJingleTransportCandidateGenerator.java @@ -24,4 +24,7 @@ import com.isode.stroke.signals.Slot; import com.isode.stroke.signals.Signal1; + +import java.net.Inet6Address; import java.util.Vector; import java.util.logging.Logger; + import com.isode.stroke.network.HostAddressPort; @@ -174,3 +177,7 @@ public class LocalJingleTransportCandidateGenerator { for(HostAddressPort addressPort : directCandidates) { - JingleS5BTransportPayload.Candidate candidate = new JingleS5BTransportPayload.Candidate(); + if (addressPort.getAddress().getInetAddress() instanceof Inet6Address + && addressPort.getAddress().getInetAddress().isLinkLocalAddress()) { + continue; + } + JingleS5BTransportPayload.Candidate candidate = new JingleS5BTransportPayload.Candidate(); candidate.type = JingleS5BTransportPayload.Candidate.Type.DirectType; diff --git a/src/com/isode/stroke/filetransfer/OutgoingSIFileTransfer.java b/src/com/isode/stroke/filetransfer/OutgoingSIFileTransfer.java deleted file mode 100644 index 4ba17de..0000000 --- a/src/com/isode/stroke/filetransfer/OutgoingSIFileTransfer.java +++ /dev/null @@ -1,149 +0,0 @@ -/* - * Copyright (c) 2010-2015 Isode Limited. - * All rights reserved. - * See the COPYING file for more information. - */ -/* - * Copyright (c) 2015 Tarun Gupta. - * Licensed under the simplified BSD license. - * See Documentation/Licenses/BSD-simplified.txt for more information. - */ - -package com.isode.stroke.filetransfer; - -import com.isode.stroke.jid.JID; -import com.isode.stroke.queries.IQRouter; -import com.isode.stroke.signals.Signal1; -import com.isode.stroke.elements.ErrorPayload; -import com.isode.stroke.elements.StreamInitiation; -import com.isode.stroke.elements.Bytestreams; - -public class OutgoingSIFileTransfer implements OutgoingFileTransfer { - - private long fileSizeInBytes = 0; //FileTransferVariables - private String filename = ""; //FileTransferVariables - - /** - * FileTransferMethod. - */ - @Override - public String getFileName() { - return filename; - } - - /** - * FileTransferMethod. - */ - @Override - public long getFileSizeInBytes() { - return fileSizeInBytes; - } - - /** - * FileTransferMethod. - */ - @Override - public void setFileInfo(final String name, long size) { - this.filename = name; - this.fileSizeInBytes = size; - } - - private String id = ""; - private JID from; - private JID to; - private String name = ""; - private long size; - private String description = ""; - private ReadBytestream bytestream; - private IQRouter iqRouter; - private SOCKS5BytestreamServer socksServer; - private IBBSendSession ibbSession; - - public OutgoingSIFileTransfer(final String id, final JID from, final JID to, final String name, long size, final String description, ReadBytestream bytestream, IQRouter iqRouter, SOCKS5BytestreamServer socksServer) { - this.id = id; - this.from = from; - this.to = to; - this.name = name; - this.size = size; - this.description = description; - this.bytestream = bytestream; - this.iqRouter = iqRouter; - this.socksServer = socksServer; - this.ibbSession = ibbSession; - } - - /** - * OutgoingFileTransferMethod. - */ - @Override - public void start() { - /* - StreamInitiation::ref streamInitiation(new StreamInitiation()); - streamInitiation.setID(id); - streamInitiation.setFileInfo(StreamInitiationFileInfo(name, description, size)); - //streamInitiation.addProvidedMethod("http://jabber.org/protocol/bytestreams"); - streamInitiation.addProvidedMethod("http://jabber.org/protocol/ibb"); - StreamInitiationRequest::ref request = StreamInitiationRequest::create(to, streamInitiation, iqRouter); - request.onResponse.connect(boost::bind(&OutgoingSIFileTransfer::handleStreamInitiationRequestResponse, this, _1, _2)); - request.send(); - */ - } - - public void stop() { - } - - public final Signal1<FileTransferError> onFinished = new Signal1<FileTransferError>(); - - private void handleStreamInitiationRequestResponse(StreamInitiation stream, ErrorPayload error) { - /* - if (error) { - finish(FileTransferError()); - } - else { - if (response->getRequestedMethod() == "http://jabber.org/protocol/bytestreams") { - socksServer->addReadBytestream(id, from, to, bytestream); - Bytestreams::ref bytestreams(new Bytestreams()); - bytestreams->setStreamID(id); - HostAddressPort addressPort = socksServer->getAddressPort(); - bytestreams->addStreamHost(Bytestreams::StreamHost(addressPort.getAddress().toString(), from, addressPort.getPort())); - BytestreamsRequest::ref request = BytestreamsRequest::create(to, bytestreams, iqRouter); - request->onResponse.connect(boost::bind(&OutgoingSIFileTransfer::handleBytestreamsRequestResponse, this, _1, _2)); - request->send(); - } - else if (response->getRequestedMethod() == "http://jabber.org/protocol/ibb") { - ibbSession = boost::make_shared<IBBSendSession>(id, from, to, bytestream, iqRouter); - ibbSession->onFinished.connect(boost::bind(&OutgoingSIFileTransfer::handleIBBSessionFinished, this, _1)); - ibbSession->start(); - } - } - */ - } - - private void handleBytestreamsRequestResponse(Bytestreams stream, ErrorPayload error) { - /* - if (error) { - finish(FileTransferError()); - } - */ - //socksServer->onTransferFinished.connect(); - } - - private void finish(FileTransferError error) { - /* - if (ibbSession) { - ibbSession->onFinished.disconnect(boost::bind(&OutgoingSIFileTransfer::handleIBBSessionFinished, this, _1)); - ibbSession.reset(); - } - socksServer->removeReadBytestream(id, from, to); - onFinished(error); - */ - } - - private void handleIBBSessionFinished(FileTransferError error) { - //finish(error); - } - - public void cancel() { - - } -}
\ No newline at end of file diff --git a/src/com/isode/stroke/filetransfer/SOCKS5BytestreamProxiesManager.java b/src/com/isode/stroke/filetransfer/SOCKS5BytestreamProxiesManager.java index eab3031..f541222 100644 --- a/src/com/isode/stroke/filetransfer/SOCKS5BytestreamProxiesManager.java +++ b/src/com/isode/stroke/filetransfer/SOCKS5BytestreamProxiesManager.java @@ -18,25 +18,25 @@ package com.isode.stroke.filetransfer; +import java.util.Collection; +import java.util.HashMap; +import java.util.Iterator; +import java.util.List; +import java.util.Map; +import java.util.Vector; +import java.util.logging.Logger; + +import com.isode.stroke.elements.S5BProxyRequest; +import com.isode.stroke.jid.JID; import com.isode.stroke.network.Connection; import com.isode.stroke.network.ConnectionFactory; -import com.isode.stroke.network.DomainNameResolver; -import com.isode.stroke.network.TimerFactory; -import com.isode.stroke.network.HostAddressPort; -import com.isode.stroke.network.DomainNameResolveError; import com.isode.stroke.network.DomainNameAddressQuery; +import com.isode.stroke.network.DomainNameResolveError; +import com.isode.stroke.network.DomainNameResolver; import com.isode.stroke.network.HostAddress; +import com.isode.stroke.network.HostAddressPort; +import com.isode.stroke.network.TimerFactory; import com.isode.stroke.queries.IQRouter; -import com.isode.stroke.session.Session; -import com.isode.stroke.signals.Slot1; -import com.isode.stroke.signals.Slot2; import com.isode.stroke.signals.Signal; import com.isode.stroke.signals.SignalConnection; -import com.isode.stroke.elements.S5BProxyRequest; -import com.isode.stroke.jid.JID; - -import java.util.Iterator; -import java.util.Vector; -import java.util.Collection; -import java.util.Map; -import java.util.HashMap; -import java.util.logging.Logger; +import com.isode.stroke.signals.Slot1; +import com.isode.stroke.signals.Slot2; @@ -55,4 +55,2 @@ public class SOCKS5BytestreamProxiesManager { - // TODO plonk this into the pair or not - // TODO think what this is trying to do? private static class Pair { @@ -66,3 +64,4 @@ public class SOCKS5BytestreamProxiesManager { - /** + private SignalConnection onProxiesFoundConnection; + /** * Map between {@link SOCKS5BytestreamClientSession} and a {@link SignalConnection} to their @@ -185,27 +184,33 @@ public class SOCKS5BytestreamProxiesManager { public final Signal onDiscoveredProxiesChanged = new Signal(); - - private void handleProxyFound(final S5BProxyRequest proxy) { - if (proxy != null) { - if (new HostAddress(proxy.getStreamHost().host).isValid()) { - addS5BProxy(proxy); - onDiscoveredProxiesChanged.emit(); - } - else { - DomainNameAddressQuery resolveRequest = resolver_.createAddressQuery(proxy.getStreamHost().host); - resolveRequest.onResult.connect(new Slot2<Collection<HostAddress>, DomainNameResolveError>() { - @Override - public void call(Collection<HostAddress> c, DomainNameResolveError d) { - handleNameLookupResult(c, d, proxy); - } - }); - resolveRequest.run(); - } - } - else { - onDiscoveredProxiesChanged.emit(); - } - proxyFinder_.stop(); - proxyFinder_ = null; + + private void handleProxiesFound(Collection<? extends S5BProxyRequest> proxyHosts) { + if (onProxiesFoundConnection != null) { + onProxiesFoundConnection.disconnect(); + onProxiesFoundConnection = null; + } + for (final S5BProxyRequest proxy : proxyHosts) { + if (proxy != null) { + if (new HostAddress(proxy.getStreamHost().host).isValid()) { + addS5BProxy(proxy); + onDiscoveredProxiesChanged.emit(); + } + else { + DomainNameAddressQuery resolveRequest = resolver_.createAddressQuery(proxy.getStreamHost().host); + resolveRequest.onResult.connect(new Slot2<Collection<HostAddress>, DomainNameResolveError>() { + @Override + public void call(Collection<HostAddress> c, DomainNameResolveError d) { + handleNameLookupResult(c, d, proxy); + } + }); + resolveRequest.run(); + } + } + } + proxyFinder_.stop(); + proxyFinder_ = null; + if (proxyHosts.isEmpty()) { + onDiscoveredProxiesChanged.emit(); + } } - + private void handleNameLookupResult(final Collection<HostAddress> addresses, DomainNameResolveError error, S5BProxyRequest proxy) { @@ -217,3 +222,2 @@ public class SOCKS5BytestreamProxiesManager { logger_.warning("S5B proxy hostname does not resolve.\n"); - onDiscoveredProxiesChanged.emit(); } @@ -228,4 +232,4 @@ public class SOCKS5BytestreamProxiesManager { } - onDiscoveredProxiesChanged.emit(); } + onDiscoveredProxiesChanged.emit(); } @@ -235,7 +239,6 @@ public class SOCKS5BytestreamProxiesManager { proxyFinder_ = new SOCKS5BytestreamProxyFinder(serviceRoot_, iqRouter_); - - proxyFinder_.onProxyFound.connect(new Slot1<S5BProxyRequest>() { + onProxiesFoundConnection = proxyFinder_.onProxiesFound.connect(new Slot1<List<S5BProxyRequest>>() { @Override - public void call(S5BProxyRequest s) { - handleProxyFound(s); + public void call(List<S5BProxyRequest> s) { + handleProxiesFound(s); } diff --git a/src/com/isode/stroke/filetransfer/SOCKS5BytestreamProxyFinder.java b/src/com/isode/stroke/filetransfer/SOCKS5BytestreamProxyFinder.java index d856a2f..e880bfb 100644 --- a/src/com/isode/stroke/filetransfer/SOCKS5BytestreamProxyFinder.java +++ b/src/com/isode/stroke/filetransfer/SOCKS5BytestreamProxyFinder.java @@ -18,16 +18,22 @@ package com.isode.stroke.filetransfer; -import com.isode.stroke.network.HostAddressPort; -import com.isode.stroke.elements.S5BProxyRequest; -import com.isode.stroke.elements.ErrorPayload; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Set; +import java.util.logging.Logger; + +import com.isode.stroke.disco.DiscoServiceWalker; import com.isode.stroke.elements.DiscoInfo; +import com.isode.stroke.elements.ErrorPayload; import com.isode.stroke.elements.IQ; -import com.isode.stroke.disco.DiscoServiceWalker; -import com.isode.stroke.queries.IQRouter; +import com.isode.stroke.elements.S5BProxyRequest; +import com.isode.stroke.jid.JID; import com.isode.stroke.queries.GenericRequest; +import com.isode.stroke.queries.IQRouter; import com.isode.stroke.signals.Signal1; import com.isode.stroke.signals.SignalConnection; +import com.isode.stroke.signals.Slot; import com.isode.stroke.signals.Slot2; -import com.isode.stroke.jid.JID; -import java.util.Vector; -import java.util.logging.Logger; @@ -38,3 +44,3 @@ import java.util.logging.Logger; public class SOCKS5BytestreamProxyFinder { - + private JID service; @@ -42,4 +48,11 @@ public class SOCKS5BytestreamProxyFinder { private DiscoServiceWalker serviceWalker; - private Vector<GenericRequest<S5BProxyRequest> > requests = new Vector<GenericRequest<S5BProxyRequest>>(); + private final List<S5BProxyRequest> proxyHosts = new ArrayList<S5BProxyRequest>(); + private final Set<GenericRequest<S5BProxyRequest>> pendingRequests = new HashSet<GenericRequest<S5BProxyRequest>>(); + private SignalConnection onServiceFoundConnection; + private SignalConnection onWalkCompleteConnection; + private final Map<GenericRequest<S5BProxyRequest>,SignalConnection> requestOnResponseConnections + = new HashMap<GenericRequest<S5BProxyRequest>,SignalConnection>(); + + private Logger logger_ = Logger.getLogger(this.getClass().getName()); @@ -59,2 +72,10 @@ public class SOCKS5BytestreamProxyFinder { }); + onWalkCompleteConnection = serviceWalker.onWalkComplete.connect(new Slot() { + + @Override + public void call() { + handleWalkEnded(); + } + + }); serviceWalker.beginWalk(); @@ -63,8 +84,13 @@ public class SOCKS5BytestreamProxyFinder { public void stop() { - serviceWalker.endWalk(); + for (SignalConnection onResponseConnection : requestOnResponseConnections.values()) { + onResponseConnection.disconnect(); + } + requestOnResponseConnections.clear(); + serviceWalker.endWalk(); onServiceFoundConnection.disconnect(); + onWalkCompleteConnection.disconnect(); serviceWalker = null; } - - public final Signal1<S5BProxyRequest> onProxyFound = new Signal1<S5BProxyRequest>(); + + public final Signal1<List<S5BProxyRequest>> onProxiesFound = new Signal1<List<S5BProxyRequest>>(); @@ -72,10 +98,12 @@ public class SOCKS5BytestreamProxyFinder { S5BProxyRequest proxyRequest = new S5BProxyRequest(); - GenericRequest<S5BProxyRequest> request = new GenericRequest<S5BProxyRequest>(IQ.Type.Get, jid, proxyRequest, iqRouter); - request.onResponse.connect(new Slot2<S5BProxyRequest, ErrorPayload>() { + final GenericRequest<S5BProxyRequest> requester = new GenericRequest<S5BProxyRequest>(IQ.Type.Get, jid, proxyRequest, iqRouter); + SignalConnection requestOnResponseConnection = requester.onResponse.connect(new Slot2<S5BProxyRequest, ErrorPayload>() { @Override public void call(S5BProxyRequest s, ErrorPayload e) { - handleProxyResponse(s, e); + handleProxyResponse(requester,s,e); } }); - request.send(); + pendingRequests.add(requester); + requestOnResponseConnections.put(requester, requestOnResponseConnection); + requester.send(); } @@ -87,4 +115,16 @@ public class SOCKS5BytestreamProxyFinder { } - private void handleProxyResponse(S5BProxyRequest request, ErrorPayload error) { - if (error != null) { + + private void handleWalkEnded() { + if (pendingRequests.isEmpty()) { + onProxiesFound.emit(proxyHosts); + } + } + + private void handleProxyResponse(GenericRequest<S5BProxyRequest> requester,S5BProxyRequest request, ErrorPayload error) { + SignalConnection requestOnResponseConnection = requestOnResponseConnections.remove(request); + if (requestOnResponseConnection != null) { + requestOnResponseConnection.disconnect(); + } + pendingRequests.remove(requester); + if (error != null) { logger_.fine("ERROR\n"); @@ -92,7 +132,9 @@ public class SOCKS5BytestreamProxyFinder { if (request != null) { - onProxyFound.emit(request); - } else { - //assert(false); - } + logger_.fine("add request\n"); + proxyHosts.add(request); + } } + if (pendingRequests.isEmpty() && !serviceWalker.isActive()) { + onProxiesFound.emit(proxyHosts); + } } |