gpt4 book ai didi

org.apache.zookeeper.server.ZooKeeperServer.getMaxSessionTimeout()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-17 03:28:40 28 4
gpt4 key购买 nike

本文整理了Java中org.apache.zookeeper.server.ZooKeeperServer.getMaxSessionTimeout()方法的一些代码示例,展示了ZooKeeperServer.getMaxSessionTimeout()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperServer.getMaxSessionTimeout()方法的具体详情如下:
包路径:org.apache.zookeeper.server.ZooKeeperServer
类名称:ZooKeeperServer
方法名:getMaxSessionTimeout

ZooKeeperServer.getMaxSessionTimeout介绍

暂无

代码示例

代码示例来源:origin: apache/zookeeper

public int getMaxSessionTimeout() {
  return zks.getMaxSessionTimeout();
}

代码示例来源:origin: org.apache.zookeeper/zookeeper

public int getMaxSessionTimeout() {
  return zks.getMaxSessionTimeout();
}

代码示例来源:origin: apache/zookeeper

public void dumpConf(PrintWriter pwriter) {
  pwriter.print("clientPort=");
  pwriter.println(getClientPort());
  pwriter.print("secureClientPort=");
  pwriter.println(getSecureClientPort());
  pwriter.print("dataDir=");
  pwriter.println(zkDb.snapLog.getSnapDir().getAbsolutePath());
  pwriter.print("dataDirSize=");
  pwriter.println(getDataDirSize());
  pwriter.print("dataLogDir=");
  pwriter.println(zkDb.snapLog.getDataDir().getAbsolutePath());
  pwriter.print("dataLogSize=");
  pwriter.println(getLogDirSize());
  pwriter.print("tickTime=");
  pwriter.println(getTickTime());
  pwriter.print("maxClientCnxns=");
  pwriter.println(getMaxClientCnxnsPerHost());
  pwriter.print("minSessionTimeout=");
  pwriter.println(getMinSessionTimeout());
  pwriter.print("maxSessionTimeout=");
  pwriter.println(getMaxSessionTimeout());
  pwriter.print("serverId=");
  pwriter.println(getServerId());
}

代码示例来源:origin: org.apache.zookeeper/zookeeper

public void dumpConf(PrintWriter pwriter) {
  pwriter.print("clientPort=");
  pwriter.println(getClientPort());
  pwriter.print("dataDir=");
  pwriter.println(zkDb.snapLog.getSnapDir().getAbsolutePath());
  pwriter.print("dataLogDir=");
  pwriter.println(zkDb.snapLog.getDataDir().getAbsolutePath());
  pwriter.print("tickTime=");
  pwriter.println(getTickTime());
  pwriter.print("maxClientCnxns=");
  pwriter.println(serverCnxnFactory.getMaxClientCnxnsPerHost());
  pwriter.print("minSessionTimeout=");
  pwriter.println(getMinSessionTimeout());
  pwriter.print("maxSessionTimeout=");
  pwriter.println(getMaxSessionTimeout());
  pwriter.print("serverId=");
  pwriter.println(getServerId());
}

代码示例来源:origin: apache/zookeeper

public ZooKeeperServerConf getConf() {
  return new ZooKeeperServerConf
    (getClientPort(),
     zkDb.snapLog.getSnapDir().getAbsolutePath(),
     zkDb.snapLog.getDataDir().getAbsolutePath(),
     getTickTime(),
     serverCnxnFactory.getMaxClientCnxnsPerHost(),
     getMinSessionTimeout(),
     getMaxSessionTimeout(),
     getServerId());
}

代码示例来源:origin: org.apache.zookeeper/zookeeper

/**
 * Creates a ZooKeeperServer instance. It sets everything up, but doesn't
 * actually start listening for clients until run() is invoked.
 * 
 * @param dataDir the directory to put the data
 */
public ZooKeeperServer(FileTxnSnapLog txnLogFactory, int tickTime,
    int minSessionTimeout, int maxSessionTimeout,
    DataTreeBuilder treeBuilder, ZKDatabase zkDb) {
  serverStats = new ServerStats(this);
  this.txnLogFactory = txnLogFactory;
  this.txnLogFactory.setServerStats(this.serverStats);
  this.zkDb = zkDb;
  this.tickTime = tickTime;
  this.minSessionTimeout = minSessionTimeout;
  this.maxSessionTimeout = maxSessionTimeout;
  listener = new ZooKeeperServerListenerImpl(this);
  LOG.info("Created server with tickTime " + tickTime
      + " minSessionTimeout " + getMinSessionTimeout()
      + " maxSessionTimeout " + getMaxSessionTimeout()
      + " datadir " + txnLogFactory.getDataDir()
      + " snapdir " + txnLogFactory.getSnapDir());
}

代码示例来源:origin: apache/zookeeper

/**
 * Creates a ZooKeeperServer instance. It sets everything up, but doesn't
 * actually start listening for clients until run() is invoked.
 *
 * @param dataDir the directory to put the data
 */
public ZooKeeperServer(FileTxnSnapLog txnLogFactory, int tickTime,
    int minSessionTimeout, int maxSessionTimeout, ZKDatabase zkDb) {
  serverStats = new ServerStats(this);
  this.txnLogFactory = txnLogFactory;
  this.txnLogFactory.setServerStats(this.serverStats);
  this.zkDb = zkDb;
  this.tickTime = tickTime;
  setMinSessionTimeout(minSessionTimeout);
  setMaxSessionTimeout(maxSessionTimeout);
  listener = new ZooKeeperServerListenerImpl(this);
  readResponseCache = new ResponseCache();
  connThrottle = new BlueThrottle();
  LOG.info("Created server with tickTime " + tickTime
      + " minSessionTimeout " + getMinSessionTimeout()
      + " maxSessionTimeout " + getMaxSessionTimeout()
      + " datadir " + txnLogFactory.getDataDir()
      + " snapdir " + txnLogFactory.getSnapDir());
}

代码示例来源:origin: apache/zookeeper

sessionTimeout = minSessionTimeout;
int maxSessionTimeout = getMaxSessionTimeout();
if (sessionTimeout > maxSessionTimeout) {
  sessionTimeout = maxSessionTimeout;

代码示例来源:origin: org.apache.zookeeper/zookeeper

sessionTimeout = minSessionTimeout;
int maxSessionTimeout = getMaxSessionTimeout();
if (sessionTimeout > maxSessionTimeout) {
  sessionTimeout = maxSessionTimeout;

代码示例来源:origin: org.apache.hadoop/zookeeper

public int getMaxSessionTimeout() {
  return zks.getMaxSessionTimeout();
}

代码示例来源:origin: org.apache.hadoop/zookeeper

public void dumpConf(PrintWriter pwriter) {
  pwriter.print("clientPort=");
  pwriter.println(getClientPort());
  pwriter.print("dataDir=");
  pwriter.println(zkDb.snapLog.getSnapDir().getAbsolutePath());
  pwriter.print("dataLogDir=");
  pwriter.println(zkDb.snapLog.getDataDir().getAbsolutePath());
  pwriter.print("tickTime=");
  pwriter.println(getTickTime());
  pwriter.print("maxClientCnxns=");
  pwriter.println(serverCnxnFactory.getMaxClientCnxns());
  pwriter.print("minSessionTimeout=");
  pwriter.println(getMinSessionTimeout());
  pwriter.print("maxSessionTimeout=");
  pwriter.println(getMaxSessionTimeout());
  pwriter.print("serverId=");
  pwriter.println(getServerId());
}

代码示例来源:origin: org.apache.hadoop/zookeeper

/**
 * Creates a ZooKeeperServer instance. It sets everything up, but doesn't
 * actually start listening for clients until run() is invoked.
 * 
 * @param dataDir the directory to put the data
 * @throws IOException
 */
public ZooKeeperServer(FileTxnSnapLog txnLogFactory, int tickTime,
    int minSessionTimeout, int maxSessionTimeout,
    DataTreeBuilder treeBuilder, ZKDatabase zkDb) throws IOException {
  serverStats = new ServerStats(this);
  this.txnLogFactory = txnLogFactory;
  this.zkDb = zkDb;
  this.tickTime = tickTime;
  this.minSessionTimeout = minSessionTimeout;
  this.maxSessionTimeout = maxSessionTimeout;
  
  LOG.info("Created server with tickTime " + tickTime
      + " minSessionTimeout " + getMinSessionTimeout()
      + " maxSessionTimeout " + getMaxSessionTimeout()
      + " datadir " + txnLogFactory.getDataDir()
      + " snapdir " + txnLogFactory.getSnapDir());
}

代码示例来源:origin: org.apache.hadoop/zookeeper

sessionTimeout = minSessionTimeout;
int maxSessionTimeout = zk.getMaxSessionTimeout();
if (sessionTimeout > maxSessionTimeout) {
  sessionTimeout = maxSessionTimeout;

28 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com