summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/ReplicaManager.java
diff options
context:
space:
mode:
authorSam Anthony <sam@samanthony.xyz>2024-12-01 20:50:33 -0500
committerSam Anthony <sam@samanthony.xyz>2024-12-01 20:50:33 -0500
commit4382f9dcbe097b86c957ba028e2bcab6ca384f58 (patch)
tree618a7ec568bf406bc117a964f45f8e55cfb4795d /src/main/java/derms/ReplicaManager.java
parent90529cfd7ef1f38ddb25449ea85cceba036ecd57 (diff)
downloadsoen423-4382f9dcbe097b86c957ba028e2bcab6ca384f58.zip
pass NetworkInterface to TotalOrderMulticastReceiver
Diffstat (limited to 'src/main/java/derms/ReplicaManager.java')
-rw-r--r--src/main/java/derms/ReplicaManager.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/main/java/derms/ReplicaManager.java b/src/main/java/derms/ReplicaManager.java
index 81f8104..9e3a6cc 100644
--- a/src/main/java/derms/ReplicaManager.java
+++ b/src/main/java/derms/ReplicaManager.java
@@ -14,6 +14,7 @@ import derms.replica2.Replica2;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
+import java.net.NetworkInterface;
import java.net.Socket;
import java.io.ObjectOutputStream;
import java.io.ObjectInputStream;
@@ -58,7 +59,8 @@ public class ReplicaManager {
private void initMulticastReceiver() throws IOException {
InetSocketAddress group = Config.group;
InetAddress localAddress = InetAddress.getLocalHost(); // Your local address
- multicastReceiver = new TotalOrderMulticastReceiver<Request>(group, localAddress);
+ NetworkInterface netInterface = NetworkInterface.getByInetAddress(localAddress);
+ multicastReceiver = new TotalOrderMulticastReceiver<Request>(group, localAddress, netInterface);
new Thread(() -> {
while (true) {