diff --git a/src/server/FifoPipe.java b/src/server/FifoPipe.java index b8c0c40..abf6370 100644 --- a/src/server/FifoPipe.java +++ b/src/server/FifoPipe.java @@ -23,8 +23,8 @@ package server; */ public class FifoPipe { - private PipeElement firstElement; - private PipeElement lastElement; + PipeElement firstElement; + PipeElement lastElement; /** * Diese Funktion dient zum Einreihen von Elementen in die FIFO-Pipe diff --git a/src/server/ServerHandelClientsThread.java b/src/server/ServerHandelClientsThread.java index 76e5f6f..92c566c 100644 --- a/src/server/ServerHandelClientsThread.java +++ b/src/server/ServerHandelClientsThread.java @@ -7,6 +7,8 @@ package server; import java.io.*; import java.net.*; +import java.util.logging.Level; +import java.util.logging.Logger; /** * @@ -18,9 +20,16 @@ public class ServerHandelClientsThread extends Thread { private ClientMessageDistributorThread messageDistributor = null; public void run() { - PrintWriter pr = new PrintWriter(clientSocket.getOutputStream(), true); - InputStreamReader in = new InputStreamReader(clientSocket.getInputStream()); - BufferedReader bf = new BufferedReader(in); + PrintWriter pr = null; + try { + pr = new PrintWriter(clientSocket.getOutputStream(), true); + InputStreamReader in = new InputStreamReader(clientSocket.getInputStream()); + BufferedReader bf = new BufferedReader(in); + } catch (IOException ex) { + Logger.getLogger(ServerHandelClientsThread.class.getName()).log(Level.SEVERE, null, ex); + } finally { + pr.close(); + } } public ServerHandelClientsThread(Socket socket, ClientMessageDistributorThread distributor) {