[infinispan-commits] Infinispan SVN: r255 - in trunk: core/src/main/java/org/infinispan and 1 other directory.
infinispan-commits at lists.jboss.org
infinispan-commits at lists.jboss.org
Tue May 12 05:43:17 EDT 2009
Author: manik.surtani at jboss.com
Date: 2009-05-12 05:43:17 -0400 (Tue, 12 May 2009)
New Revision: 255
Modified:
trunk/cachestore/bdbje/src/main/java/org/infinispan/loaders/bdbje/BdbjeCacheStore.java
trunk/cachestore/bdbje/src/main/java/org/infinispan/loaders/bdbje/BdbjeResourceFactory.java
trunk/core/src/main/java/org/infinispan/CacheDelegate.java
Log:
Fixed compile warnings
Modified: trunk/cachestore/bdbje/src/main/java/org/infinispan/loaders/bdbje/BdbjeCacheStore.java
===================================================================
--- trunk/cachestore/bdbje/src/main/java/org/infinispan/loaders/bdbje/BdbjeCacheStore.java 2009-05-12 09:13:12 UTC (rev 254)
+++ trunk/cachestore/bdbje/src/main/java/org/infinispan/loaders/bdbje/BdbjeCacheStore.java 2009-05-12 09:43:17 UTC (rev 255)
@@ -399,7 +399,7 @@
*/
public Set<InternalCacheEntry> loadAll() throws CacheLoaderException {
try {
- return new HashSet(cacheMap.values());
+ return new HashSet<InternalCacheEntry>(cacheMap.values());
} catch (RuntimeException caught) {
throw convertToCacheLoaderException("error loading all entries", caught);
}
Modified: trunk/cachestore/bdbje/src/main/java/org/infinispan/loaders/bdbje/BdbjeResourceFactory.java
===================================================================
--- trunk/cachestore/bdbje/src/main/java/org/infinispan/loaders/bdbje/BdbjeResourceFactory.java 2009-05-12 09:13:12 UTC (rev 254)
+++ trunk/cachestore/bdbje/src/main/java/org/infinispan/loaders/bdbje/BdbjeResourceFactory.java 2009-05-12 09:43:17 UTC (rev 255)
@@ -96,11 +96,9 @@
* @throws com.sleepycat.je.DatabaseException
* if the StoredMap cannot be opened.
*/
- public StoredMap createStoredMapViewOfDatabase(Database database, StoredClassCatalog classCatalog, Marshaller m) throws DatabaseException {
+ public StoredMap<Object, InternalCacheEntry> createStoredMapViewOfDatabase(Database database, StoredClassCatalog classCatalog, Marshaller m) throws DatabaseException {
EntryBinding<Object> storedEntryKeyBinding =
new SerialBinding<Object>(classCatalog, Object.class);
-// EntryBinding storedEntryValueBinding =
-// new SerialBinding(classCatalog, InternalCacheEntry.class);
EntryBinding<InternalCacheEntry> storedEntryValueBinding = new InternalCacheEntryBinding(m);
try {
return new StoredMap<Object, InternalCacheEntry>(database,
Modified: trunk/core/src/main/java/org/infinispan/CacheDelegate.java
===================================================================
--- trunk/core/src/main/java/org/infinispan/CacheDelegate.java 2009-05-12 09:13:12 UTC (rev 254)
+++ trunk/core/src/main/java/org/infinispan/CacheDelegate.java 2009-05-12 09:43:17 UTC (rev 255)
@@ -61,7 +61,6 @@
import javax.transaction.Transaction;
import javax.transaction.TransactionManager;
-
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
@@ -211,7 +210,7 @@
}
public void putForExternalRead(K key, V value) {
- putForExternalRead(key, value, null);
+ putForExternalRead(key, value, (Flag[]) null);
}
public void evict(K key) {
@@ -268,7 +267,7 @@
LockControlCommand command = commandsFactory.buildLockControlCommand(keys, false);
invoker.invoke(getInvocationContext(), command);
}
-
+
public void start() {
componentRegistry.start();
defaultLifespan = config.getExpirationLifespan();
@@ -313,7 +312,7 @@
public void putForExternalRead(K key, V value, Flag... flags) {
InvocationContext invocationContext = getInvocationContext();
- invocationContext.setFlags(flags);
+ if (flags != null) invocationContext.setFlags(flags);
Transaction ongoingTransaction = null;
try {
if (transactionManager != null && (ongoingTransaction = transactionManager.getTransaction()) != null) {
More information about the infinispan-commits
mailing list