transport/transport-tcp/src/main/java/org/opendaylight/netconf/transport/tcp/NioNettyImpl.java

   1 /*
   2  * Copyright (c) 2022 PANTHEON.tech, s.r.o. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.netconf.transport.tcp;
   9
  10 import io.netty.bootstrap.Bootstrap;
  11 import io.netty.bootstrap.ServerBootstrap;
  12 import io.netty.channel.ChannelOption;
  13 import io.netty.channel.EventLoopGroup;
  14 import io.netty.channel.nio.NioEventLoopGroup;
  15 import io.netty.channel.socket.nio.NioChannelOption;
  16 import io.netty.channel.socket.nio.NioServerSocketChannel;
  17 import io.netty.channel.socket.nio.NioSocketChannel;
  18 import java.util.Map;
  19 import java.util.concurrent.ThreadFactory;
  20 import jdk.net.ExtendedSocketOptions;
  21 import org.eclipse.jdt.annotation.NonNullByDefault;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.tcp.common.rev220524.tcp.common.grouping.Keepalives;
  23
  24 @NonNullByDefault
  25 final class NioNettyImpl extends AbstractNettyImpl {
  26     private static final ChannelOption<Integer> TCP_KEEPIDLE = NioChannelOption.of(ExtendedSocketOptions.TCP_KEEPIDLE);
  27     private static final ChannelOption<Integer> TCP_KEEPCNT = NioChannelOption.of(ExtendedSocketOptions.TCP_KEEPCOUNT);
  28     private static final ChannelOption<Integer> TCP_KEEPINTVL =
  29         NioChannelOption.of(ExtendedSocketOptions.TCP_KEEPINTERVAL);
  30
  31     private final boolean supportsKeepalives;
  32
  33     NioNettyImpl() {
  34         final var ch = new NioSocketChannel();
  35         try {
  36             supportsKeepalives = ch.config().setOptions(Map.of(
  37                 ChannelOption.SO_KEEPALIVE, Boolean.TRUE, TCP_KEEPIDLE, 7200, TCP_KEEPCNT, 3, TCP_KEEPINTVL, 5));
  38         } finally {
  39             ch.close();
  40         }
  41     }
  42
  43     @Override
  44     Class<NioSocketChannel> channelClass() {
  45         return NioSocketChannel.class;
  46     }
  47
  48     @Override
  49     Class<NioServerSocketChannel> serverChannelClass() {
  50         return NioServerSocketChannel.class;
  51     }
  52
  53     @Override
  54     EventLoopGroup newEventLoopGroup(final int numThreads, final ThreadFactory threadFactory) {
  55         return new NioEventLoopGroup(numThreads, threadFactory);
  56     }
  57
  58     @Override
  59     boolean supportsKeepalives() {
  60         return supportsKeepalives;
  61     }
  62
  63     @Override
  64     void configureKeepalives(final Bootstrap bootstrap, final Keepalives keepalives) {
  65         bootstrap
  66             .option(ChannelOption.SO_KEEPALIVE, Boolean.TRUE)
  67             .option(TCP_KEEPIDLE, keepalives.requireIdleTime().toJava())
  68             .option(TCP_KEEPCNT, keepalives.requireMaxProbes().toJava())
  69             .option(TCP_KEEPINTVL, keepalives.requireProbeInterval().toJava());
  70     }
  71
  72     @Override
  73     void configureKeepalives(final ServerBootstrap bootstrap, final Keepalives keepalives) {
  74         bootstrap
  75             .childOption(ChannelOption.SO_KEEPALIVE, Boolean.TRUE)
  76             .childOption(TCP_KEEPIDLE, keepalives.requireIdleTime().toJava())
  77             .childOption(TCP_KEEPCNT, keepalives.requireMaxProbes().toJava())
  78             .childOption(TCP_KEEPINTVL, keepalives.requireProbeInterval().toJava());
  79     }
  80
  81     @Override
  82     public String toString() {
  83         return "java.nio";
  84     }
  85 }