Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private class ServerListenThread implements Runnable {
- public ServerListenThread(ChatServer chatserver) {
- this.chatServer = chatserver;
- }
- public void run() {
- try{
- int nbServers = ServerConfig.getNbServers();
- for(int i = 0; i<nbServers; i++){
- Socket socket = new Socket(ServerConfig.getRemoteServer(i),ServerConfig.getRemoteServerPort(i));
- ServerConnection con = new ServerConnection(socket,ChatServer.this);
- Sender sender = new Sender(con);
- sender.send(ProtocolDB.SERVERCONNECT_COMMAND, null);
- (new Thread(new Listener(con))).start();
- }
- } catch (Exception e){
- }
- try {
- ServerSocket listenSocket = new ServerSocket(ServerConfig.getLocalServerPort());
- System.out.println("Listening for connecting servers on port " + ServerConfig.getLocalServerPort());
- int nbServers = ServerConfig.getNbOtherServers();
- //TODO
- for(int i = 0; i<nbServers; i++){
- ServerConfig.getRemoteServer(i);
- sendToServers(ProtocolDB.SERVERCONNECT_COMMAND, null);
- };
- } catch (IllegalStateException e) {
- e.printStackTrace();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- private ChatServer chatServer;
- }
Add Comment
Please, Sign In to add comment