HHH-6186 Upgraded to latest Infinispan 5.0 CR

This commit is contained in:
Galder Zamarreño 2011-05-17 13:55:44 +02:00
parent fc94dd07eb
commit f01505591d
7 changed files with 19 additions and 11 deletions

View File

@ -5,7 +5,7 @@ configurations {
}
dependencies {
infinispanVersion = '4.2.1.CR1'
infinispanVersion = '5.0.0.CR2'
jnpVersion = '5.0.3.GA'
compile(project(':hibernate-core'))

View File

@ -268,7 +268,7 @@ public abstract class BaseRegion implements Region {
protected boolean handleEvictAllModification(CacheEntryModifiedEvent event) {
if (!event.isPre() && (replication || event.isOriginLocal()) && CacheHelper.isEvictAllNotification(event.getKey(), event.getValue())) {
if (log.isTraceEnabled()) log.trace("Set invalid state because marker cache entry was put: {0}", event);
if (log.isTraceEnabled()) log.tracef("Set invalid state because marker cache entry was put: {0}", event);
invalidateState.set(InvalidateState.INVALID);
return true;
}
@ -277,13 +277,13 @@ public abstract class BaseRegion implements Region {
@CacheEntryInvalidated
public void entryInvalidated(CacheEntryInvalidatedEvent event) {
if (log.isTraceEnabled()) log.trace("Cache entry invalidated: {0}", event);
if (log.isTraceEnabled()) log.tracef("Cache entry invalidated: {0}", event);
handleEvictAllInvalidation(event);
}
protected boolean handleEvictAllInvalidation(CacheEntryInvalidatedEvent event) {
if (!event.isPre() && CacheHelper.isEvictAllNotification(event.getKey())) {
if (log.isTraceEnabled()) log.trace("Set invalid state because marker cache entry was invalidated: {0}", event);
if (log.isTraceEnabled()) log.tracef("Set invalid state because marker cache entry was invalidated: {0}", event);
invalidateState.set(InvalidateState.INVALID);
return true;
}

View File

@ -39,7 +39,11 @@ public class AddressAdapterImpl implements AddressAdapter, Externalizable {
private Address address;
private AddressAdapterImpl(Address address) {
// Required by Java Externalizable
public AddressAdapterImpl() {
}
public AddressAdapterImpl(Address address) {
this.address = address;
}

View File

@ -69,10 +69,14 @@ public class CacheHelper {
return key instanceof EvictAll && value == Internal.EVICT;
}
private static class EvictAll implements Externalizable {
public static class EvictAll implements Externalizable {
AddressAdapter member;
EvictAll(AddressAdapter member) {
// Required by Java Externalizable
public EvictAll() {
}
public EvictAll(AddressAdapter member) {
this.member = member;
}

View File

@ -175,7 +175,7 @@ public class ConcurrentWriteTest extends SingleNodeTestCase {
assertEquals( customerSlcs.getElementCountInMemory(), 1 );
assertEquals( customerSlcs.getEntries().size(), 1 );
log.info( "Add contact to customer {0}", customerId );
log.infof( "Add contact to customer {0}", customerId );
SecondLevelCacheStatistics contactsCollectionSlcs = sessionFactory()
.getStatistics()
.getSecondLevelCacheStatistics( Customer.class.getName() + ".contacts" );
@ -478,7 +478,7 @@ public class ConcurrentWriteTest extends SingleNodeTestCase {
thinkRandomTime();
++completedIterations;
if ( log.isTraceEnabled() ) {
log.trace( "Iteration completed {0}", completedIterations );
log.tracef( "Iteration completed {0}", completedIterations );
}
}
}

View File

@ -263,7 +263,7 @@ public class DualNodeJtaTransactionImpl implements Transaction {
if (prepareResult != XAResource.XA_RDONLY)
xaResource.commit(xid, b);
else
log.trace("Not committing {0} due to readonly.", xid);
log.tracef("Not committing {0} due to readonly.", xid);
}
@Override

View File

@ -265,7 +265,7 @@ public class XaTransactionImpl implements Transaction {
if (prepareResult != XAResource.XA_RDONLY)
xaResource.commit(xid, b);
else
log.trace("Not committing {0} due to readonly.", xid);
log.tracef("Not committing {0} due to readonly.", xid);
}
@Override