0.0.7

pom.xml

@@ -5,7 +5,7 @@
 
 	<groupId>com.github.immueggpain</groupId>
 	<artifactId>simple-streaming</artifactId>
-	<version>0.0.6</version>
+	<version>0.0.7</version>
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/java/com/github/immueggpain/simplestreaming/Launcher.java

@@ -11,7 +11,7 @@
 		subcommands = { HelpCommand.class, StreamUpload.class, StreamServer.class, Serve.class })
 public class Launcher implements Callable<Void> {
 
-	public static final String VERSTR = "0.0.6";
+	public static final String VERSTR = "0.0.7";
 	public static final int LOCAL_PORT = 2233;
 	public static final int LOCAL_OVPN_PORT = 1194;
 	public static final int BUFLEN = 1024 * 16;

src/main/java/com/github/immueggpain/simplestreaming/StreamServer.java

@@ -125,20 +125,23 @@ private void upload_thread(Socket socket) {
 			InputStream is = socket.getInputStream();
 			byte[] buf = new byte[Launcher.BUFLEN];
 
-			int len = is.read(buf);
-			if (len == -1)
-				return;
-
-			synchronized (activeDownloaders) {
-				for (Downloader downloader : activeDownloaders.values()) {
-					if (downloader.buflen == 0) {
-						System.arraycopy(buf, 0, downloader.buf, 0, len);
-						downloader.buflen = len;
+			while (true) {
+				int len = is.read(buf);
+				if (len == -1)
+					return;
+
+				synchronized (activeDownloaders) {
+					for (Downloader downloader : activeDownloaders.values()) {
+						if (downloader.buflen == 0) {
+							System.arraycopy(buf, 0, downloader.buf, 0, len);
+							downloader.buflen = len;
+							System.out.println("copied");
+						} else {
+							System.out.println("skiped");
+						}
 					}
 				}
 			}
-
-			socket.close();
 		} catch (Exception e) {
 			e.printStackTrace();
 		}

src/main/java/com/github/immueggpain/simplestreaming/StreamUpload.java

@@ -57,6 +57,7 @@ private static long copyLarge(final RandomAccessFile input, final OutputStream o
 		int n;
 		while (-1 != (n = input.read(buffer))) {
 			output.write(buffer, 0, n);
+			System.out.println("sent " + n);
 		}
 		return input.getFilePointer();
 	}