Ping(back) works on both client and server side.
This commit is contained in:
parent
146ff4ea82
commit
63a8e21f6c
@ -142,10 +142,9 @@ public class Client {
|
|||||||
socket = new Socket(hostname, 42069);
|
socket = new Socket(hostname, 42069);
|
||||||
Client client = new Client(socket, username);
|
Client client = new Client(socket, username);
|
||||||
client.chatListener();
|
client.chatListener();
|
||||||
client.sendMessage();
|
|
||||||
Thread cP = new Thread(client.clientPinger);
|
Thread cP = new Thread(client.clientPinger);
|
||||||
System.out.println("im here");
|
|
||||||
cP.start();
|
cP.start();
|
||||||
|
client.sendMessage(); //this one blocks.
|
||||||
} catch (UnknownHostException e) {
|
} catch (UnknownHostException e) {
|
||||||
System.out.println("Invalid host IP");
|
System.out.println("Invalid host IP");
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
|
|||||||
@ -20,11 +20,9 @@ public class JClientProtocolParser {
|
|||||||
switch (header) {
|
switch (header) {
|
||||||
case "SPING":
|
case "SPING":
|
||||||
c.sendMsgToServer("PINGB");
|
c.sendMsgToServer("PINGB");
|
||||||
System.out.println("got ping!"); //todo:delete
|
|
||||||
break;
|
break;
|
||||||
case "PINGB":
|
case "PINGB":
|
||||||
c.clientPinger.setGotPingBack(true);
|
c.clientPinger.setGotPingBack(true);
|
||||||
System.out.println("got pingback!"); //todo: delete
|
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
System.out.println("Received unknown command");
|
System.out.println("Received unknown command");
|
||||||
|
|||||||
@ -24,11 +24,9 @@ public class JServerProtocolParser {
|
|||||||
break;
|
break;
|
||||||
case "CPING":
|
case "CPING":
|
||||||
h.sendMsgToClient("PINGB");
|
h.sendMsgToClient("PINGB");
|
||||||
System.out.println("got ping!"); //todo:delete
|
|
||||||
break;
|
break;
|
||||||
case "PINGB":
|
case "PINGB":
|
||||||
h.serverPinger.setGotPingBack(true);
|
h.serverPinger.setGotPingBack(true);
|
||||||
System.out.println("got pingback!"); //todo: delete
|
|
||||||
break;
|
break;
|
||||||
case "QUITS":
|
case "QUITS":
|
||||||
h.closeEverything(h.getSocket(), h.getIn(), h.getOut());
|
h.closeEverything(h.getSocket(), h.getIn(), h.getOut());
|
||||||
|
|||||||
Reference in New Issue
Block a user