summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/openslx/filetransfer
diff options
context:
space:
mode:
authorBjörn Hagemeister2014-07-07 15:56:42 +0200
committerBjörn Hagemeister2014-07-07 15:56:42 +0200
commit0b48e7cc19578ed79a8b9b0dbaf7e54dc91cdef2 (patch)
tree89482ea1f5a557e36682030be3e785e2a97715d6 /src/main/java/org/openslx/filetransfer
parentChange the behavior of CRCFile (hopefully the last time) (diff)
downloadmaster-sync-shared-0b48e7cc19578ed79a8b9b0dbaf7e54dc91cdef2.tar.gz
master-sync-shared-0b48e7cc19578ed79a8b9b0dbaf7e54dc91cdef2.tar.xz
master-sync-shared-0b48e7cc19578ed79a8b9b0dbaf7e54dc91cdef2.zip
Used logger instead of system.out.println for system status.
Diffstat (limited to 'src/main/java/org/openslx/filetransfer')
-rw-r--r--src/main/java/org/openslx/filetransfer/Listener.java27
1 files changed, 20 insertions, 7 deletions
diff --git a/src/main/java/org/openslx/filetransfer/Listener.java b/src/main/java/org/openslx/filetransfer/Listener.java
index ec3372f..cd4a242 100644
--- a/src/main/java/org/openslx/filetransfer/Listener.java
+++ b/src/main/java/org/openslx/filetransfer/Listener.java
@@ -5,6 +5,10 @@ import javax.net.ssl.SSLServerSocket;
import javax.net.ssl.SSLServerSocketFactory;
import javax.net.ssl.SSLSocket;
+import org.apache.log4j.BasicConfigurator;
+import org.apache.log4j.Logger;
+import org.slf4j.LoggerFactory;
+
// TODO: (all files) apply formatting using strg+shift+f *after* importing scheme from ./extras/
public class Listener extends Thread
@@ -16,6 +20,17 @@ public class Listener extends Thread
*/
private SSLContext context;
private int port;
+ final private int U = 85; // hex - code 'U' = 85.
+ final private int D = 68; // hex - code 'D' = 68.
+
+ private static Logger log = Logger.getLogger( Listener.class );
+
+ static {
+ // This is a temporary workaround for this annoying log4j error msg.
+ // Initializing the logger before anything else is done.
+ BasicConfigurator.configure();
+ LoggerFactory.getLogger( "ROOT" );
+ }
/***********************************************************************/
/**
@@ -35,7 +50,6 @@ public class Listener extends Thread
* Method listen, should run from Master Server. Listen for incoming
* connection, and start Downloader or Uploader.
*
- * @throws Exception
*/
private void listen()
{
@@ -54,21 +68,20 @@ public class Listener extends Thread
System.out.println( length );
- // Ascii - Code: 'U' = 85 ; 'D' = 68. TODO: byte constant as class member
- if ( b[0] == 85 ) {
- System.out.println( "U erkannt --> Downloader starten" ); // TODO: Use Logger (see masterserver code for example)
+ if ( b[0] == U ) {
+ log.info( "recognized U --> starting Downloader" ); // TODO: Use Logger (see masterserver code for example)
// --> start Downloader(socket).
Downloader d = new Downloader( connectionSocket );
incomingEvent.incomingDownloader( d );
}
- else if ( b[0] == 68 ) {
- System.out.println( "D erkannt --> Uploader starten" );
+ else if ( b[0] == D ) {
+ log.info( "recognized D --> starting Uploader" );
// --> start Uploader(socket).
Uploader u = new Uploader( connectionSocket );
incomingEvent.incomingUploader( u );
}
else {
- System.out.println( "Müll empfangen" );
+ log.info( "Got invalid option ... close connection" );
connectionSocket.close();
}
}