in cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/pool/SessionPool.java [54:71]
public static void put(CassandraSessionImpl cassandraSes, Session driverSes) {
if (cassandraSes == null || driverSes == null) {
return;
}
SessionWrapper old;
synchronized (sessions) {
old = sessions.put(cassandraSes, new SessionWrapper(driverSes));
if (monitorSingleton == null || State.TERMINATED.equals(monitorSingleton.getState())) {
monitorSingleton = new SessionMonitor();
monitorSingleton.setDaemon(true);
monitorSingleton.setName("Cassandra-sessions-pool");
monitorSingleton.start();
}
}
if (old != null) {
old.release();
}
}