X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Firc%2FDccReceiver.java;h=abb018c7f78530c350380b1eb41d0ea7cbc156ef;hb=2a459ba5c365804cde3f7bd67d6f5aabbaa1b1d2;hp=e58fed3a2e5c285395ddbabefe7b479120b4fe89;hpb=f63869cc3b8dbe14f15def799d6fd4c997259d31;p=xudocci.git

diff --git a/src/main/java/net/pterodactylus/irc/DccReceiver.java b/src/main/java/net/pterodactylus/irc/DccReceiver.java
index e58fed3..abb018c 100644
--- a/src/main/java/net/pterodactylus/irc/DccReceiver.java
+++ b/src/main/java/net/pterodactylus/irc/DccReceiver.java
@@ -26,9 +26,12 @@ import java.util.concurrent.TimeUnit;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
+import net.pterodactylus.irc.event.DccDownloadFailed;
+import net.pterodactylus.irc.event.DccDownloadFinished;
 import net.pterodactylus.irc.event.DccSendReceived;
 import net.pterodactylus.xdcc.util.io.BandwidthCountingInputStream;
 
+import com.google.common.eventbus.EventBus;
 import com.google.common.io.Closeables;
 import com.google.common.util.concurrent.AbstractExecutionThreadService;
 
@@ -42,6 +45,9 @@ public class DccReceiver extends AbstractExecutionThreadService {
 	/** The logger. */
 	private static final Logger logger = Logger.getLogger(DccReceiver.class.getName());
 
+	/** The event bus. */
+	private final EventBus eventBus;
+
 	/** The address to connect to. */
 	private final InetAddress inetAddress;
 
@@ -78,10 +84,33 @@ public class DccReceiver extends AbstractExecutionThreadService {
 	 * @param outputStream
 	 * 		The output stream to write the file to
 	 */
-	public DccReceiver(InetAddress inetAddress, int port, String filename, long size, OutputStream outputStream) {
+	public DccReceiver(EventBus eventBus, InetAddress inetAddress, int port, String filename, long size, OutputStream outputStream) {
+		this(eventBus, inetAddress, port, filename, 0, size, outputStream);
+	}
+
+	/**
+	 * Creates a new DCC receiver.
+	 *
+	 * @param inetAddress
+	 * 		The address to connect to
+	 * @param port
+	 * 		The port number to connect to
+	 * @param filename
+	 * 		The name of the file being downloaded
+	 * @param startOffset
+	 * 		The offset at which the download starts in case of a resume
+	 * @param size
+	 * 		The size of the file being downloaded, or {@code -1} if the size is not
+	 * 		known
+	 * @param outputStream
+	 * 		The output stream to write the file to
+	 */
+	public DccReceiver(EventBus eventBus, InetAddress inetAddress, int port, String filename, long startOffset, long size, OutputStream outputStream) {
+		this.eventBus = eventBus;
 		this.inetAddress = inetAddress;
 		this.port = port;
 		this.filename = filename;
+		this.progress = startOffset;
 		this.size = size;
 		this.outputStream = outputStream;
 	}
@@ -126,7 +155,7 @@ public class DccReceiver extends AbstractExecutionThreadService {
 	 * @return The current rate of the download, in bytes/second
 	 */
 	public long currentRate() {
-		return inputStream.getCurrentRate();
+		return (inputStream != null) ? inputStream.getCurrentRate() : 0;
 	}
 
 	/**
@@ -135,7 +164,7 @@ public class DccReceiver extends AbstractExecutionThreadService {
 	 * @return The overall rate of the download, in bytes/second
 	 */
 	public long overallRate() {
-		return inputStream.getOverallRate();
+		return (inputStream != null) ? inputStream.getOverallRate() : 0;
 	}
 
 	//
@@ -147,6 +176,7 @@ public class DccReceiver extends AbstractExecutionThreadService {
 		Socket socket = null;
 		try {
 			socket = new Socket(inetAddress, port);
+			socket.setSoTimeout((int) TimeUnit.MINUTES.toMillis(3));
 			InputStream socketInputStream = socket.getInputStream();
 			inputStream = new BandwidthCountingInputStream(socketInputStream, 5, TimeUnit.SECONDS);
 			byte[] buffer = new byte[65536];
@@ -160,11 +190,19 @@ public class DccReceiver extends AbstractExecutionThreadService {
 				progress += r;
 			}
 			outputStream.flush();
+			if ((size == -1) || (progress == size)) {
+				eventBus.post(new DccDownloadFinished(this));
+			} else {
+				eventBus.post(new DccDownloadFailed(this, new IOException("Download aborted.")));
+			}
 		} catch (IOException ioe1) {
 			logger.log(Level.WARNING, "I/O error while receiving DCC!", ioe1);
+			eventBus.post(new DccDownloadFailed(this, ioe1));
 		} finally {
 			Closeables.close(inputStream, true);
-			socket.close();
+			if (socket != null) {
+				socket.close();
+			}
 		}
 	}