w

vs.pu01/src/main/java/vs/Client.java

@@ -20,10 +20,11 @@ public class Client {
 
             socket.send(packetOut);
 
+            //? Got server IP
             DatagramPacket packetIn = new DatagramPacket(new byte[512], 512);
             socket.receive(packetIn);
 
-            System.out.println("Recieved!");
+            System.out.println("Recieved from " + packetIn.getSocketAddress());
 
             String syslogMessage = formatSyslogMessage(message);
             byte[] buffer2 = syslogMessage.getBytes();

vs.pu01/src/main/java/vs/DiscoveryServer.java

@@ -21,18 +21,22 @@ public class DiscoveryServer implements Runnable {
             discoverySocket.setReuseAddress(true);
             discoverySocket.setBroadcast(true);
 
-            byte[] buffer = new byte[256];
             while (true) {
-                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
-                discoverySocket.receive(packet);
+                byte[] buffer = new byte[256];
+                DatagramPacket packetIn = new DatagramPacket(buffer, buffer.length);
+                discoverySocket.receive(packetIn);
 
                 InetAddress clientAddress = packet.getAddress();
-                int clientPort = packet.getPort();
+                int clientPort = packetIn.getPort();
                 System.out.println("DISCOVERY from " + clientAddress.getHostAddress() + ":" + clientPort);
 
-                byte[] reply = new byte[0]; // leere Antwort
-                DatagramPacket response = new DatagramPacket(reply, reply.length, clientAddress, clientPort);
-                discoverySocket.send(response);
+
+                DatagramPacket packetOut = new DatagramPacket(new byte[256], 256);
+                packetOut.setSocketAddress(packetIn.getSocketAddress());
+                packetOut.setData(new byte[0]);
+                packetOut.setLength(0);
+
+                discoverySocket.send(packetOut);
             }
         } catch (Exception e) {
             e.printStackTrace();

vs.pu01/src/main/java/vs/SyslogUdpServer.java

@@ -26,6 +26,7 @@ public class SyslogUdpServer implements Runnable {
             while (true) {
                 DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                 syslogSocket.receive(packet); // UDP-Paket empfangen
+                System.out.println("SYSLOG from " + packet.getSocketAddress());
 
                 int len = packet.getLength();
                 InetAddress clientAddress = packet.getAddress();