Nu aber!

assignments/src/MV3500Cohort2019JulySeptember/homework2/Brennenstuhl/BRE_KNO_MCC/BRE_KNO_MCC_PC2_Controller.java

@@ -37,7 +37,6 @@ public class BRE_KNO_MCC_PC2_Controller
         pc2_pc3_sender = new BRE_KNO_MCC_PC2_PC3_UNICAST_PduSender();
         pc2_pc3_sender.setNetworkSettinigs(ipPC3, portPC3);
         pc2_pc3_sender.setKeepRunning(true);
-
         
         pc2_pc3_receiver = new BRE_KNO_MCC_PC2_PC3_UNICAST_PduReceiver();
         pc2_pc3_receiver.setNetworkSettings(2344);
@@ -58,7 +57,7 @@ public class BRE_KNO_MCC_PC2_Controller
                 if (!pc2_pc3_receiver.isAlive())
                 {
                     pc2_pc3_receiver.start();        
-                }
+                }                
             }
             
             else

assignments/src/MV3500Cohort2019JulySeptember/homework2/Brennenstuhl/BRE_KNO_MCC/BRE_KNO_MCC_PC2_PC1_MCAST_PduReceiver.java

@@ -148,13 +148,13 @@ public class BRE_KNO_MCC_PC2_PC1_MCAST_PduReceiver extends Thread
         {
             mutex.acquire();
             temp = new ArrayList(mcastMessagesToSend);
+            mcastMessagesToSend.clear();                    
             mutex.release();
         }
         catch (InterruptedException ex)
         {
             Logger.getLogger(BRE_KNO_MCC_PC2_PC1_MCAST_PduReceiver.class.getName()).log(Level.SEVERE, null, ex);
         }
-
         return temp;
     }
 }

assignments/src/MV3500Cohort2019JulySeptember/homework2/Brennenstuhl/BRE_KNO_MCC/BRE_KNO_MCC_PC3_PC2_UNICAST_PduReceiver.java

@@ -33,7 +33,6 @@ public class BRE_KNO_MCC_PC3_PC2_UNICAST_PduReceiver
         }
 
         run();
-
     }
 
     public static void run()
@@ -43,9 +42,9 @@ public class BRE_KNO_MCC_PC3_PC2_UNICAST_PduReceiver
 
         try
         {
-            DatagramSocket clientSocket = new DatagramSocket(portPC3);            
+            DatagramSocket clientSocket = new DatagramSocket(portPC3);
             socket = new DatagramSocket(2344);
-            
+
             while (keepRunning)
             {
                 DatagramPacket datagramPacket = new DatagramPacket(buffer, 0, buffer.length);
@@ -77,7 +76,8 @@ public class BRE_KNO_MCC_PC3_PC2_UNICAST_PduReceiver
 
                     System.out.println(message);
 
-                    sendAnswer(tempPdu.getTimestamp());
+                    sendAnswerUNICASTtoPC2(tempPdu.getTimestamp());
+                    sendMCASTOver3000(tempPdu);
 
                 }
                 catch (IOException ex)
@@ -102,7 +102,7 @@ public class BRE_KNO_MCC_PC3_PC2_UNICAST_PduReceiver
         keepRunning = k;
     }
 
-    static void sendAnswer(int internID)
+    static void sendAnswerUNICASTtoPC2(int internID)
     {
         //Sending via UNICAST
 
@@ -117,4 +117,51 @@ public class BRE_KNO_MCC_PC3_PC2_UNICAST_PduReceiver
             Logger.getLogger(BRE_KNO_MCC_PC2_PC3_UNICAST_PduSender.class.getName()).log(Level.SEVERE, null, ex);
         }
     }
+
+    static void sendMCASTOver3000(Pdu tempPdu)
+    {
+        InetAddress localMulticastAddress = null;
+        try
+        {
+            localMulticastAddress = InetAddress.getByName("239.1.2.3");
+        }
+        catch (UnknownHostException ex)
+        {
+            Logger.getLogger(BRE_KNO_MCC_PC3_PC2_UNICAST_PduReceiver.class.getName()).log(Level.SEVERE, null, ex);
+        }
+             
+        ByteArrayOutputStream baos = new ByteArrayOutputStream();
+        DataOutputStream dos = new DataOutputStream(baos);
+        byte[] buffer;
+
+        try
+        {
+            tempPdu.marshal(dos);
+        }
+        catch (Exception ex)
+        {
+            Logger.getLogger(BRE_KNO_MCC_PC1_MCAST_PduSender.class.getName()).log(Level.SEVERE, null, ex);
+        }
+
+        buffer = baos.toByteArray();
+        DatagramPacket packet = new DatagramPacket(buffer, buffer.length, localMulticastAddress, 3000);
+        MulticastSocket socket;
+        try
+        {
+            socket = new MulticastSocket(3000);
+            socket.joinGroup(localMulticastAddress);
+            socket.send(packet);
+        }
+        catch (IOException ex)
+        {
+            Logger.getLogger(BRE_KNO_MCC_PC3_PC2_UNICAST_PduReceiver.class.getName()).log(Level.SEVERE, null, ex);
+        } 
+        try
+        {
+            Thread.sleep(100L);
+        }
+        catch (InterruptedException ex)
+        {
+        }
+    }
 }