QuorumPeer.java 文件源码

/** Maximum number of connections allowed from particular host (ip) */
public int getMaxClientCnxnsPerHost() {
    ServerCnxnFactory fac = getCnxnFactory();
    if (fac == null) {
        return -1;
    }
    return fac.getMaxClientCnxnsPerHost();
}