Skip to content

Commit

Permalink
Revert discovery hack
Browse files Browse the repository at this point in the history
  • Loading branch information
Nashatyrev committed Nov 1, 2024
1 parent 926a29b commit c65239b
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ public DiscV5Service(
discoConfig.areSiteLocalAddressesEnabled()
? AddressAccessPolicy.ALLOW_ALL
: address -> !address.getAddress().isSiteLocalAddress())
.discoveryServer(new FakeNettyDiscoveryServer(new InetSocketAddress(listenAddress, listenUdpPort)))
// .discoveryServer(new FakeNettyDiscoveryServer(new InetSocketAddress(listenAddress, listenUdpPort)))
.build();
this.kvStore = kvStore;
metricsSystem.createIntegerGauge(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ private CompletableFuture<NioDatagramChannel> startServer(final NioEventLoopGrou
public void initChannel(NioDatagramChannel ch) {
final ChannelPipeline pipeline = ch.pipeline();
pipeline
.addFirst(new LoggingHandler(LogLevel.TRACE))
.addFirst(new LoggingHandler(LogLevel.DEBUG))
.addLast(new DatagramToEnvelope())
.addLast(new IncomingMessageSink(incomingSink));

Expand All @@ -79,7 +79,8 @@ public void initChannel(NioDatagramChannel ch) {
}
});

final ChannelFuture bindFuture = b.connect("127.0.0.1", 37777);
// final ChannelFuture bindFuture = b.connect("127.0.0.1", 37777);
final ChannelFuture bindFuture = b.bind(listenAddress);
bindFuture.addListener(
result -> {
if (!result.isSuccess()) {
Expand Down

0 comments on commit c65239b

Please sign in to comment.