6 public class HandleClient extends Thread {
11 @SuppressWarnings("static-access")
12 public HandleClient(Socket s) {
15 in = new ObjectInputStream(s.getInputStream());
16 ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream());
17 name = s.getInetAddress().getLocalHost().getHostName();
18 Register.Instance().getNodeOfName(name).setOutputStream(out);
19 } catch (Exception e) {
20 System.err.println("error in HandleClient Constructor: " + e);
21 e.printStackTrace(System.out);
25 public HandleClient(Socket s, int type) {
28 in = new ObjectInputStream(s.getInputStream());
29 } catch (Exception e) {
30 System.out.println("error in HandleClient Constructor: " + e);
31 e.printStackTrace(System.out);
39 while (s.isConnected()
40 && LocalHost.Instance().getStartedThreads() == true) {
41 Object x = in.readObject();
42 if (x instanceof Message) {
45 // msg=(Message)in.readObject();
46 if (msg.getTimeStep() == JaceSession.Instance()
47 .getTaskObject().timeStep)
48 // System.out.println("recieved message from "+msg.getSender().getHostName()+" tag="+msg.getSrc_tag()+" iter= "+msg.getSrc_iteration()+" "+j);
49 MsgQueue.Instance().add(msg);
56 } catch (Exception e) {
57 // System.out.println("error in HandleClient run method :"+e);
61 Register.Instance().getNodeOfName(name).getOutputStream()
63 Register.Instance().getNodeOfName(name).setOutputStream(null);
65 } catch (Exception e1) {
66 // System.out.println("unable to close socket in HandleClient run method :"+e);