diff --git a/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/dstore/universal/miners/UniversalFileSystemMiner.java b/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/dstore/universal/miners/UniversalFileSystemMiner.java index c46623e951e..afc57091a99 100644 --- a/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/dstore/universal/miners/UniversalFileSystemMiner.java +++ b/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/dstore/universal/miners/UniversalFileSystemMiner.java @@ -449,7 +449,10 @@ public class UniversalFileSystemMiner extends Miner { updateCancellableThreads(status.getParent(), queryThread); } - private void updateCancellableThreads(DataElement command, ICancellableHandler thread) + /** + * @since 3.2 + */ + public void updateCancellableThreads(DataElement command, ICancellableHandler thread) { //First Check to make sure that there are no "zombie" threads Iterator iter = _cancellableThreads.keySet().iterator(); diff --git a/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/internal/dstore/universal/miners/filesystem/UniversalDownloadHandler.java b/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/internal/dstore/universal/miners/filesystem/UniversalDownloadHandler.java index b4d5c98bc65..6137b814a6c 100644 --- a/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/internal/dstore/universal/miners/filesystem/UniversalDownloadHandler.java +++ b/rse/plugins/org.eclipse.rse.services.dstore/miners/org/eclipse/rse/internal/dstore/universal/miners/filesystem/UniversalDownloadHandler.java @@ -70,23 +70,7 @@ public class UniversalDownloadHandler extends SecuredThread implements ICancella } private void removeFromCancellableList(){ - Class clazz = _miner.getClass(); - - try { - Method[] methods = clazz.getDeclaredMethods(); - for (int i = 0; i < methods.length; i++){ - Method method = methods[i]; - if (method.getName().equals("updateCancellableThreads")){ //$NON-NLS-1$ - method.setAccessible(true); - Object[] args = { _status.getParent(), this }; - method.invoke(_miner, args); - return; - } - } - - } catch (Exception e) { - _dataStore.trace(e); - } + _miner.updateCancellableThreads(_status.getParent(), this); } public boolean isDone()