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

bugfixes TCP (5)

Browse source
This commit is contained in:
Louis Farina 2021-01-12 19:12:25 +01:00
parent 3c3a1fb0a9
commit 52b6850af3
1 changed files with 20 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
src/chat/NetworkClient.java
View file

@ -165,6 +165,25 @@ class ConnectionListenerThread extends Thread {
InetAddress clientAddress= request.getAddress(); InetAddress clientAddress= request.getAddress();
System.out.println("Received a request from " + username + "@" + clientAddress.getHostAddress()); System.out.println("Received a request from " + username + "@" + clientAddress.getHostAddress());
response = "";
for(User u:known_users)
{
response += u.getName() + " ";
}
response = response.trim();
response += ";";
for(Socket s:dest_sockets)
{
response += s.getInetAddress().getHostAddress() + " ";
}
response = response.trim();
response += ";" + (portNumber+1);
System.out.println("Response :" + response);
responseBytes = response.getBytes();
responsePacket = new DatagramPacket(responseBytes, responseBytes.length, clientAddress, 1337);
responseSocket.send(responsePacket);
accepted = true; accepted = true;
for(User a:known_users) for(User a:known_users)
{ {
@ -190,25 +209,6 @@ class ConnectionListenerThread extends Thread {
} }
portNumber++; portNumber++;
} }
response = "";
for(User u:known_users)
{
response += u.getName() + " ";
}
response = response.trim();
response += ";";
for(Socket s:dest_sockets)
{
response += s.getInetAddress().getHostAddress() + " ";
}
response = response.trim();
response += ";" + portNumber;
System.out.println("Response :" + response);
responseBytes = response.getBytes();
responsePacket = new DatagramPacket(responseBytes, responseBytes.length, clientAddress, 1337);
responseSocket.send(responsePacket);
} }
catch(SocketTimeoutException e) {} catch(SocketTimeoutException e) {}
} }
@ -355,7 +355,7 @@ public class NetworkClient {
if(connected) if(connected)
{ {
(new ConnectionListenerThread(user, known_users, dest_sockets, chatText, knownUsersPanel, portNumber)).start(); (new ConnectionListenerThread(user, known_users, dest_sockets, chatText, knownUsersPanel, 1234)).start();
try try
{ {