diff options
Diffstat (limited to 'src/main/java/derms/ReplicaManager.java')
| -rw-r--r-- | src/main/java/derms/ReplicaManager.java | 4 |
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) { |