farina/COO-farina-vincent
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

bugfixes TCP (6)

Browse source
This commit is contained in:
Louis Farina 2021-01-12 19:29:43 +01:00
parent 52b6850af3
commit 899be6991c
1 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/chat/NetworkClient.java
View file

@ -191,7 +191,8 @@ class ConnectionListenerThread extends Thread {
} }
if(accepted) if(accepted)
{ {
Socket s = (new ServerSocket(1237+(known_users.size()))).accept(); portNumber++;
Socket s = (new ServerSocket(portNumber)).accept();
(new ReceiveThread(user, s, displayArea, known_users, knownUsersPanel, dest_sockets)).start(); (new ReceiveThread(user, s, displayArea, known_users, knownUsersPanel, dest_sockets)).start();
dest_sockets.add(s); dest_sockets.add(s);
@ -207,7 +208,6 @@ class ConnectionListenerThread extends Thread {
{ {
knownUsersPanel.append(" " + a.getName() + " \n"); knownUsersPanel.append(" " + a.getName() + " \n");
} }
portNumber++;
} }
} }
catch(SocketTimeoutException e) {} catch(SocketTimeoutException e) {}
@ -305,10 +305,11 @@ public class NetworkClient {
userListSocket.receive(responsePacket); userListSocket.receive(responsePacket);
System.out.println("Received a reply from " + responsePacket.getAddress().getHostAddress()); System.out.println("Received a reply from " + responsePacket.getAddress().getHostAddress());
String[] response = new String(responsePacket.getData()).split(";"); String[] response = new String(responsePacket.getData()).trim().split(";");
String[] usernameList = response[0].split(" "); String[] usernameList = response[0].split(" ");
String[] addressList = response[1].split(" "); String[] addressList = response[1].split(" ");
System.out.println (response[2].length());
portNumber = Integer.parseInt(response[2]); portNumber = Integer.parseInt(response[2]);
@ -345,17 +346,17 @@ public class NetworkClient {
} }
catch (SocketException e2) catch (SocketException e2)
{ {
e2.printStackTrace(); e2.printStackTrace();
} }
catch (Exception e3) catch (Exception e3)
{ {
System.out.println(e3.getMessage()); e3.printStackTrace();
} }
if(connected) if(connected)
{ {
(new ConnectionListenerThread(user, known_users, dest_sockets, chatText, knownUsersPanel, 1234)).start(); (new ConnectionListenerThread(user, known_users, dest_sockets, chatText, knownUsersPanel, portNumber)).start();
try try
{ {