TestCommit
This commit is contained in:
parent
39b03fdf61
commit
318abd4930
2 changed files with 14 additions and 5 deletions
|
@ -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
|
||||
|
|
|
@ -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) {
|
||||
|
|
Loading…
Reference in a new issue