gpt4 book ai didi

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

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

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

ZooKeeperServer.getMinSessionTimeout介绍

暂无

代码示例

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

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

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

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

代码示例来源: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

int minSessionTimeout = getMinSessionTimeout();
if (sessionTimeout < minSessionTimeout) {
  sessionTimeout = minSessionTimeout;

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

int minSessionTimeout = getMinSessionTimeout();
if (sessionTimeout < minSessionTimeout) {
  sessionTimeout = minSessionTimeout;

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

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

代码示例来源: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

int minSessionTimeout = zk.getMinSessionTimeout();
if (sessionTimeout < minSessionTimeout) {
  sessionTimeout = minSessionTimeout;

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