/*
* JBoss, Home of Professional Open Source
* Copyright 2012 Red Hat Inc. and/or its affiliates and other contributors
* as indicated by the @author tags. All rights reserved.
* See the copyright.txt in the distribution for a
* full listing of individual contributors.
*
* This copyrighted material is made available to anyone wishing to use,
* modify, copy, or redistribute it subject to the terms and conditions
* of the GNU Lesser General Public License, v. 2.1.
* This program is distributed in the hope that it will be useful, but WITHOUT A
* WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
* PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
* You should have received a copy of the GNU Lesser General Public License,
* v.2.1 along with this distribution; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
* MA 02110-1301, USA.
*/
package org.infinispan.cli.interpreter.session;
import javax.transaction.TransactionManager;
import org.infinispan.AdvancedCache;
import org.infinispan.Cache;
import org.infinispan.CacheException;
import org.infinispan.api.BasicCacheContainer;
import org.infinispan.commands.CommandsFactory;
import org.infinispan.commands.CreateCacheCommand;
import org.infinispan.configuration.cache.Configuration;
import org.infinispan.configuration.cache.ConfigurationBuilder;
import org.infinispan.manager.EmbeddedCacheManager;
import org.infinispan.remoting.rpc.RpcManager;
public class SessionImpl implements Session {
private final EmbeddedCacheManager cacheManager;
private final String id;
private Cache<?, ?> cache = null;
private String cacheName = null;
private long timestamp;
public SessionImpl(final EmbeddedCacheManager cacheManager, final String id) {
this.cacheManager = cacheManager;
this.id = id;
timestamp = System.nanoTime();
}
@Override
public EmbeddedCacheManager getCacheManager() {
return cacheManager;
}
@Override
public String getId() {
return id;
}
@Override
public <K, V> Cache<K, V> getCurrentCache() {
return (Cache<K, V>) cache;
}
@Override
public String getCurrentCacheName() {
return cacheName;
}
@Override
public <K, V> Cache<K, V> getCache(final String cacheName) {
Cache<K, V> c;
if (cacheName != null) {
c = cacheManager.getCache(cacheName, false);
} else {
c = getCurrentCache();
}
if (c == null) {
throw new IllegalArgumentException("No cache named " + cacheName);
}
return c;
}
@Override
public void setCurrentCache(final String cacheName) {
cache = getCache(cacheName);
this.cacheName = cacheName;
}
@Override
public void createCache(String cacheName, String baseCacheName) {
Configuration configuration;
if (baseCacheName != null) {
configuration = cacheManager.getCacheConfiguration(baseCacheName);
if (configuration == null) {
throw new IllegalArgumentException("A cache named " + baseCacheName + " doesn't exist");
}
} else {
configuration = cacheManager.getDefaultCacheConfiguration();
baseCacheName = BasicCacheContainer.DEFAULT_CACHE_NAME;
}
if (cacheManager.cacheExists(cacheName)) {
throw new IllegalArgumentException("A cache named " + cacheName + " already exists");
}
if (configuration.clustering().cacheMode().isClustered()) {
AdvancedCache<?, ?> clusteredCache = cacheManager.getCache(baseCacheName).getAdvancedCache();
RpcManager rpc = clusteredCache.getRpcManager();
CommandsFactory factory = clusteredCache.getComponentRegistry().getComponent(CommandsFactory.class);
CreateCacheCommand ccc = factory.buildCreateCacheCommand(cacheName, baseCacheName);
try {
rpc.invokeRemotely(null, ccc, true, false);
ccc.init(cacheManager);
ccc.perform(null);
} catch (Throwable e) {
throw new CacheException("Could not create cache on all clustered nodes", e);
}
} else {
ConfigurationBuilder b = new ConfigurationBuilder();
b.read(configuration);
cacheManager.defineConfiguration(cacheName, b.build());
cacheManager.getCache(cacheName);
}
}
@Override
public void reset() {
resetCache(cacheManager.getCache());
for (String cacheName : cacheManager.getCacheNames()) {
resetCache(cacheManager.getCache(cacheName));
}
timestamp = System.nanoTime();
}
private void resetCache(final Cache<Object, Object> cache) {
if (cache.getCacheConfiguration().invocationBatching().enabled()) {
cache.endBatch(false);
}
TransactionManager tm = cache.getAdvancedCache().getTransactionManager();
try {
if (tm.getTransaction() != null) {
tm.rollback();
}
} catch (Exception e) {
}
}
@Override
public long getTimestamp() {
return timestamp;
}
}