private TServer getTServer()

in dubbo-rpc-extensions/dubbo-rpc-native-thrift/src/main/java/org/apache/dubbo/rpc/protocol/nativethrift/ThriftProtocol.java [137:195]
45 lines of code
6 McCabe index (conditional complexity)

    private <T> TServer getTServer(T impl, Class<T> type, URL url) {

        TThreadedSelectorServer.Args tArgs = null;
        String typeName = type.getName();

        TServer tserver;
        if (typeName.endsWith(THRIFT_IFACE)) {
            String processorClsName = typeName.substring(0, typeName.indexOf(THRIFT_IFACE)) + THRIFT_PROCESSOR;
            try {
                Class<?> clazz = Class.forName(processorClsName);
                Constructor constructor = clazz.getConstructor(type);

                TProcessor tprocessor = (TProcessor) constructor.newInstance(impl);
                processor.registerProcessor(typeName, tprocessor);

                tserver = SERVER_MAP.get(url.getAddress());
                if (tserver == null) {

                    /**Solve the problem of only 50 of the default number of concurrent connections*/
                    TNonblockingServerSocket.NonblockingAbstractServerSocketArgs args = new TNonblockingServerSocket.NonblockingAbstractServerSocketArgs();
                    /**1000 connections*/
                    args.backlog(1000);
                    String bindIp = url.getParameter(Constants.BIND_IP_KEY, url.getHost());
                    if (url.getParameter(ANYHOST_KEY, false)) {
                        bindIp = ANYHOST_VALUE;
                    }
                    int bindPort = url.getParameter(Constants.BIND_PORT_KEY, url.getPort());
                    args.bindAddr(new InetSocketAddress(bindIp, bindPort));
                    /**timeout: 10s */
                    args.clientTimeout(10000);

                    TNonblockingServerSocket transport = new TNonblockingServerSocket(args);

                    tArgs = new TThreadedSelectorServer.Args(transport);
                    tArgs.workerThreads(200);
                    tArgs.selectorThreads(4);
                    tArgs.acceptQueueSizePerThread(256);
                    tArgs.processor(processor);
                    tArgs.transportFactory(new TFramedTransport.Factory());
                    tArgs.protocolFactory(new TCompactProtocol.Factory());
                } else {
                    // if server is starting, return and do nothing here
                    return null;
                }

            } catch (Exception e) {
                logger.error(e.getMessage(), e);
                throw new RpcException("Fail to create nativethrift server(" + url + ") : " + e.getMessage(), e);
            }
        }

        if (tArgs == null) {
            logger.error("Fail to create native thrift server(" + url + ") due to null args");
            throw new RpcException("Fail to create nativethrift server(" + url + ") due to null args");
        }
        tserver = new TThreadedSelectorServer(tArgs);
        return tserver;

    }