Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'org.eclipse.m2e.core/src/org/eclipse/m2e/core/internal/index/nexus/AsyncFetcher.java')
-rw-r--r--org.eclipse.m2e.core/src/org/eclipse/m2e/core/internal/index/nexus/AsyncFetcher.java18
1 files changed, 9 insertions, 9 deletions
diff --git a/org.eclipse.m2e.core/src/org/eclipse/m2e/core/internal/index/nexus/AsyncFetcher.java b/org.eclipse.m2e.core/src/org/eclipse/m2e/core/internal/index/nexus/AsyncFetcher.java
index 0c949b6f..b9a8ad50 100644
--- a/org.eclipse.m2e.core/src/org/eclipse/m2e/core/internal/index/nexus/AsyncFetcher.java
+++ b/org.eclipse.m2e.core/src/org/eclipse/m2e/core/internal/index/nexus/AsyncFetcher.java
@@ -38,7 +38,6 @@ import com.ning.http.client.simple.SimpleAHCTransferListener;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.core.runtime.NullProgressMonitor;
-import org.eclipse.core.runtime.Platform;
import org.eclipse.osgi.util.NLS;
import org.codehaus.plexus.util.FileUtils;
@@ -120,7 +119,7 @@ public class AsyncFetcher extends AbstractResourceFetcher {
private SimpleAsyncHttpClient createClient(String url) {
SimpleAsyncHttpClient.Builder sahcBuilder = new SimpleAsyncHttpClient.Builder();
-
+
sahcBuilder.setUserAgent(userAgent);
sahcBuilder.setConnectionTimeoutInMs(15 * 1000);
@@ -262,13 +261,13 @@ public class AsyncFetcher extends AbstractResourceFetcher {
}
private class MonitorListener implements SimpleAHCTransferListener {
-
+
private IProgressMonitor monitor;
-
+
public MonitorListener(IProgressMonitor monitor) {
this.monitor = monitor;
}
-
+
private void checkCancelled(String url) {
if(monitor.isCanceled()) {
cancel(url);
@@ -285,12 +284,12 @@ public class AsyncFetcher extends AbstractResourceFetcher {
public void onHeaders(String url, HeaderMap arg1) {
checkCancelled(url);
}
-
+
public void onBytesReceived(String url, long amount, long current, long total) {
checkCancelled(url);
monitor.subTask(NLS.bind(Messages.AsyncFetcher_task_fetching2, url, amount * 100 / total));
}
-
+
public void onBytesSent(String arg0, long arg1, long arg2, long arg3) {
// we only retrieve
}
@@ -298,11 +297,12 @@ public class AsyncFetcher extends AbstractResourceFetcher {
public void onCompleted(String arg0, int arg1, String arg2) {
monitor.subTask(""); //$NON-NLS-1$
}
-
+
}
private final class Streams {
PipedErrorInputStream in;
+
PipedOutputStream out;
public Streams(PipedErrorInputStream pis, PipedOutputStream pos) {
@@ -311,4 +311,4 @@ public class AsyncFetcher extends AbstractResourceFetcher {
}
}
-} \ No newline at end of file
+}

Back to the top