Skip to content

Commit

Permalink
[Grid] Enabling IPv6, fixes #7541
Browse files Browse the repository at this point in the history
Also enabling `--detect-drivers` for nodes
  • Loading branch information
diemol committed Feb 17, 2020
1 parent d69ee97 commit 55aaf10
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -46,10 +46,12 @@ class BoundZmqEventBus implements EventBus {
LOG.info(String.format("XPUB binding to %s, XSUB binding to %s", xpubAddr, xsubAddr));

xpub = context.createSocket(SocketType.XPUB);
xpub.setIPv6(true);
xpub.setImmediate(true);
xpub.bind(xpubAddr.bindTo);

xsub = context.createSocket(SocketType.XSUB);
xsub.setIPv6(true);
xsub.setImmediate(true);
xsub.bind(xsubAddr.bindTo);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,10 +64,12 @@ class UnboundZmqEventBus implements EventBus {
LOG.info(String.format("Connecting to %s and %s", publishConnection, subscribeConnection));

sub = context.createSocket(SocketType.SUB);
sub.setIPv6(true);
sub.connect(publishConnection);
sub.subscribe(new byte[0]);

pub = context.createSocket(SocketType.PUB);
pub.setIPv6(true);
pub.connect(subscribeConnection);

ZMQ.Poller poller = context.createPoller(1);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,5 +27,5 @@ class NodeFlags {
names = {"--detect-drivers"},
description = "Autodetect which drivers are available on the current system, and add them to the node.")
@ConfigValue(section = "node", name = "detect-drivers")
public boolean autoconfigure;
public boolean autoconfigure = true;
}

0 comments on commit 55aaf10

Please sign in to comment.