本文整理了Java中org.apache.accumulo.fate.zookeeper.ZooSession.sessionKey()
方法的一些代码示例,展示了ZooSession.sessionKey()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooSession.sessionKey()
方法的具体详情如下:
包路径:org.apache.accumulo.fate.zookeeper.ZooSession
类名称:ZooSession
方法名:sessionKey
暂无
代码示例来源:origin: apache/accumulo
public static synchronized ZooKeeper getSession(String zooKeepers, int timeout, String scheme,
byte[] auth) {
if (sessions == null)
throw new ZooSessionShutdownException(
"The Accumulo singleton that that tracks zookeeper session is disabled. This is likely "
+ "caused by all AccumuloClients being closed or garbage collected.");
String sessionKey = sessionKey(zooKeepers, timeout, scheme, auth);
// a read-only session can use a session with authorizations, so cache a copy for it w/out auths
String readOnlySessionKey = sessionKey(zooKeepers, timeout, null, null);
ZooSessionInfo zsi = sessions.get(sessionKey);
if (zsi != null && zsi.zooKeeper.getState() == States.CLOSED) {
log.debug("Removing closed ZooKeeper session to {}", zooKeepers);
if (auth != null && sessions.get(readOnlySessionKey) == zsi)
sessions.remove(readOnlySessionKey);
zsi = null;
sessions.remove(sessionKey);
}
if (zsi == null) {
ZooWatcher watcher = new ZooWatcher();
log.debug("Connecting to {} with timeout {} with auth", zooKeepers, timeout);
zsi = new ZooSessionInfo(connect(zooKeepers, timeout, scheme, auth, watcher));
sessions.put(sessionKey, zsi);
if (auth != null && !sessions.containsKey(readOnlySessionKey))
sessions.put(readOnlySessionKey, zsi);
}
return zsi.zooKeeper;
}
代码示例来源:origin: org.apache.accumulo/accumulo-fate
public static synchronized ZooKeeper getSession(String zooKeepers, int timeout, String scheme,
byte[] auth) {
if (sessions == null)
throw new ZooSessionShutdownException();
String sessionKey = sessionKey(zooKeepers, timeout, scheme, auth);
// a read-only session can use a session with authorizations, so cache a copy for it w/out auths
String readOnlySessionKey = sessionKey(zooKeepers, timeout, null, null);
ZooSessionInfo zsi = sessions.get(sessionKey);
if (zsi != null && zsi.zooKeeper.getState() == States.CLOSED) {
log.debug("Removing closed ZooKeeper session to " + zooKeepers);
if (auth != null && sessions.get(readOnlySessionKey) == zsi)
sessions.remove(readOnlySessionKey);
zsi = null;
sessions.remove(sessionKey);
}
if (zsi == null) {
ZooWatcher watcher = new ZooWatcher();
log.debug("Connecting to " + zooKeepers + " with timeout " + timeout + " with auth");
zsi = new ZooSessionInfo(connect(zooKeepers, timeout, scheme, auth, watcher), watcher);
sessions.put(sessionKey, zsi);
if (auth != null && !sessions.containsKey(readOnlySessionKey))
sessions.put(readOnlySessionKey, zsi);
}
return zsi.zooKeeper;
}
内容来源于网络,如有侵权,请联系作者删除!