diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-12-01 13:08:59 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-12-01 13:08:59 -0500 |
| commit | 773c4b8a696dd49b3f0452783e1634350a82226a (patch) | |
| tree | ef12f77af9c8f6fd1ba80cd58bb2e811bbc2e978 /src/main/java/derms/net/tomulticast/TotalOrderMulticast.java | |
| parent | fc28d5d3607ac5056272e61b272a823c25dc9bc1 (diff) | |
| download | soen423-773c4b8a696dd49b3f0452783e1634350a82226a.zip | |
pass network interface name to sequencer explicitely
Diffstat (limited to 'src/main/java/derms/net/tomulticast/TotalOrderMulticast.java')
| -rw-r--r-- | src/main/java/derms/net/tomulticast/TotalOrderMulticast.java | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/main/java/derms/net/tomulticast/TotalOrderMulticast.java b/src/main/java/derms/net/tomulticast/TotalOrderMulticast.java index 0d8b690..1fb4348 100644 --- a/src/main/java/derms/net/tomulticast/TotalOrderMulticast.java +++ b/src/main/java/derms/net/tomulticast/TotalOrderMulticast.java @@ -6,6 +6,7 @@ import derms.net.rmulticast.ReliableMulticast; import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; +import java.net.NetworkInterface; import java.util.logging.Logger; /** @@ -29,6 +30,13 @@ public abstract class TotalOrderMulticast<T extends MessagePayload> { protected Long seq; // Sequence number. protected final Logger log; + protected TotalOrderMulticast(InetSocketAddress group, InetAddress laddr, NetworkInterface ifs) throws IOException { + this.sock = new ReliableMulticast<Message<T>>(group, laddr, ifs); + this.group = group; + this.seq = (long) 0; + this.log = Logger.getLogger(this.getClass().getName()); + } + protected TotalOrderMulticast(InetSocketAddress group, InetAddress laddr) throws IOException { this.sock = new ReliableMulticast<Message<T>>(group, laddr); this.group = group; |