From 507611b3b3de3492d7dc3ba9fc0f6b4c34e8b262 Mon Sep 17 00:00:00 2001 From: Simon Rettberg Date: Wed, 2 Jul 2014 22:09:45 +0200 Subject: Added TODOs --- src/main/java/org/openslx/filetransfer/Listener.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) (limited to 'src/main/java/org/openslx/filetransfer/Listener.java') diff --git a/src/main/java/org/openslx/filetransfer/Listener.java b/src/main/java/org/openslx/filetransfer/Listener.java index afd4126..eaa8d4b 100644 --- a/src/main/java/org/openslx/filetransfer/Listener.java +++ b/src/main/java/org/openslx/filetransfer/Listener.java @@ -5,6 +5,8 @@ import javax.net.ssl.SSLServerSocket; import javax.net.ssl.SSLServerSocketFactory; import javax.net.ssl.SSLSocket; +// TODO: (all files) apply formatting using strg+shift+f *after* importing scheme from ./extras/ + public class Listener extends Thread { private IncomingEvent incomingEvent; /* @@ -41,22 +43,24 @@ public class Listener extends Thread { * connection, and start Downloader or Uploader. * @throws Exception */ - private void listen() throws Exception { + private void listen() throws Exception { // TODO: Handle exceptions in function to keep going SSLServerSocketFactory sslServerSocketFactory = context.getServerSocketFactory(); SSLServerSocket welcomeSocket = (SSLServerSocket) sslServerSocketFactory.createServerSocket(this.port); while (!isInterrupted()) { SSLSocket connectionSocket = (SSLSocket) welcomeSocket.accept(); + connectionSocket.setSoTimeout(2000); // 2 second timeout enough? Maybe even use a small thread pool for handling accepted connections + // TODO: Handle SocketTimeoutException for all reads and writes in Downloader and Uploader byte[] b = new byte[1]; int length = connectionSocket.getInputStream().read(b); System.out.println(length); - // Ascii - Code: 'U' = 85 ; 'D' = 68. + // Ascii - Code: 'U' = 85 ; 'D' = 68. TODO: byte constant as class member if (b[0] == 85) { - System.out.println("U erkannt --> Downloader starten"); + System.out.println("U erkannt --> Downloader starten"); // TODO: Use Logger (see masterserver code for example) // --> start Downloader(socket). Downloader d = new Downloader(connectionSocket); incomingEvent.incomingDownloader(d); -- cgit v1.2.3-55-g7522