From bed9f8b07a3f338f5cfc4e142133e4d00ab394df Mon Sep 17 00:00:00 2001 From: hba56 Date: Wed, 13 Sep 2017 12:19:33 +1200 Subject: [PATCH] send out to every client fix --- .../networkInterface/NetworkInterface.java | 21 +++++++++++-------- 1 file changed, 12 insertions(+), 9 deletions(-) diff --git a/matchBrowser/src/main/java/networkInterface/NetworkInterface.java b/matchBrowser/src/main/java/networkInterface/NetworkInterface.java index 431cdd84..62327081 100644 --- a/matchBrowser/src/main/java/networkInterface/NetworkInterface.java +++ b/matchBrowser/src/main/java/networkInterface/NetworkInterface.java @@ -66,14 +66,17 @@ public class NetworkInterface { if(game != null) { games.add(game); } - HostedGamesRequestEncoder encoder = new HostedGamesRequestEncoder(); - try { - byte[] message = encoder.encode(new HostGamesRequest(games)); - System.out.println(LocalDateTime.now() + ": Sending " + games.size() + " game/s"); - serverSocket.send(new DatagramPacket(message, message.length, groupAddress, groupPort)); - } catch (InvalidMessageException | IOException e) { - e.printStackTrace(); + } + + HostedGamesRequestEncoder encoder = new HostedGamesRequestEncoder(); + try { + byte[] message = encoder.encode(new HostGamesRequest(games)); + System.out.println(LocalDateTime.now() + ": Sending " + games.size() + " game/s"); + for(ClientAddress address: clientsAddresses) { + serverSocket.send(new DatagramPacket(message, message.length, InetAddress.getByName(address.getIp()), groupPort)); } + } catch (InvalidMessageException | IOException e) { + e.printStackTrace(); } } }, period, period); @@ -97,8 +100,8 @@ public class NetworkInterface { DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length); serverSocket.receive(receivePacket); - System.out.println(receivePacket.getAddress()); - System.out.println(this.clientsAddresses); +// System.out.println(receivePacket.getAddress()); +// System.out.println(this.clientsAddresses); BinaryMessageDecoder messageDecoder = new BinaryMessageDecoder(receivePacket.getData()); switch (MessageType.fromByte(messageDecoder.getHeaderMessageType())){