in cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/pool/SessionPool.java [93:119]
public static void release() {
Collection<SessionWrapper> wrappers;
synchronized (sessions) {
try {
if (sessions.size() == 0) {
return;
}
wrappers = new LinkedList<>();
for (SessionWrapper wrapper : sessions.values()) {
wrappers.add(wrapper);
}
sessions.clear();
}
finally {
if (!(Thread.currentThread() instanceof SessionMonitor) && monitorSingleton != null) {
try {
monitorSingleton.interrupt();
}
catch (Throwable ignored) {
}
}
}
}
for (SessionWrapper wrapper : wrappers) {
wrapper.release();
}
}