Guest User

Untitled

a guest
Jul 16th, 2018
77
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.23 KB | None | 0 0
  1. private class ServerListenThread implements Runnable {
  2. public ServerListenThread(ChatServer chatserver) {
  3. this.chatServer = chatserver;
  4. }
  5.  
  6. public void run() {
  7. try{
  8. int nbServers = ServerConfig.getNbServers();
  9. for(int i = 0; i<nbServers; i++){
  10. Socket socket = new Socket(ServerConfig.getRemoteServer(i),ServerConfig.getRemoteServerPort(i));
  11. ServerConnection con = new ServerConnection(socket,ChatServer.this);
  12. Sender sender = new Sender(con);
  13. sender.send(ProtocolDB.SERVERCONNECT_COMMAND, null);
  14. (new Thread(new Listener(con))).start();
  15.  
  16. }
  17. } catch (Exception e){
  18. }
  19. try {
  20.  
  21.  
  22. ServerSocket listenSocket = new ServerSocket(ServerConfig.getLocalServerPort());
  23. System.out.println("Listening for connecting servers on port " + ServerConfig.getLocalServerPort());
  24. int nbServers = ServerConfig.getNbOtherServers();
  25. //TODO
  26.  
  27.  
  28. for(int i = 0; i<nbServers; i++){
  29. ServerConfig.getRemoteServer(i);
  30. sendToServers(ProtocolDB.SERVERCONNECT_COMMAND, null);
  31. };
  32.  
  33. } catch (IllegalStateException e) {
  34. e.printStackTrace();
  35. } catch (IOException e) {
  36. e.printStackTrace();
  37. }
  38. }
  39.  
  40. private ChatServer chatServer;
  41. }
Add Comment
Please, Sign In to add comment