Class TrackerServer

src/main/java/org/traccar/TrackerServer.java:35–135

import java.net.InetSocketAddress;

public abstract class TrackerServer implements TrackerConnector {

    private final boolean datagram;
    private final boolean secure;

    @SuppressWarnings("rawtypes")
    private final AbstractBootstrap bootstrap;

    private final int port;
    private final String address;

    private final ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    @Override
    public boolean isDatagram() {
        return datagram;
    }

    @Override
    public boolean isSecure() {
        return secure;
    }

    public TrackerServer(Config config, String protocol, boolean datagram) {
        secure = config.getBoolean(Keys.PROTOCOL_SSL.withPrefix(protocol));
        address = config.getString(Keys.PROTOCOL_ADDRESS.withPrefix(protocol));
        port = config.getInteger(Keys.PROTOCOL_PORT.withPrefix(protocol));

        BasePipelineFactory pipelineFactory = new BasePipelineFactory(this, config, protocol) {
            @Override
            protected void addTransportHandlers(PipelineBuilder pipeline) {
                try {
                    if (isSecure()) {
                        SSLEngine engine = SSLContext.getDefault().createSSLEngine();
                        pipeline.addLast(new SslHandler(engine));
                    }
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }

            @Override
            protected void addProtocolHandlers(PipelineBuilder pipeline) {
                TrackerServer.this.addProtocolHandlers(pipeline, config);
            }
        };

        this.datagram = datagram;
        var eventLoopGroupFactory = Main.getInjector().getInstance(EventLoopGroupFactory.class);
        if (datagram) {
            bootstrap = new Bootstrap()
                    .group(eventLoopGroupFactory.getWorkerGroup())
                    .channel(NioDatagramChannel.class)
                    .handler(pipelineFactory);
        } else {
            bootstrap = new ServerBootstrap()
                    .group(eventLoopGroupFactory.getBossGroup(), eventLoopGroupFactory.getWorkerGroup())
                    .channel(NioServerSocketChannel.class)