17
17
import org .hibernate .cache .spi .access .SoftLock ;
18
18
import org .hibernate .engine .spi .SharedSessionContractImplementor ;
19
19
20
- import org .jboss .logging .Logger ;
21
20
22
21
import static org .hibernate .cache .spi .SecondLevelCacheLogger .L2CACHE_LOGGER ;
23
22
24
23
/**
25
24
* @author Steve Ebersole
26
25
*/
27
26
public abstract class AbstractReadWriteAccess extends AbstractCachedDomainDataAccess {
28
- private static final Logger log = Logger .getLogger ( AbstractReadWriteAccess .class );
29
27
30
28
private final UUID uuid = UUID .randomUUID ();
31
29
private final AtomicLong nextLockId = new AtomicLong ();
@@ -63,31 +61,35 @@ protected Lock writeLock() {
63
61
*/
64
62
@ Override
65
63
public Object get (SharedSessionContractImplementor session , Object key ) {
66
- final boolean traceEnabled = log .isTraceEnabled ();
64
+ final boolean traceEnabled = L2CACHE_LOGGER .isTraceEnabled ();
67
65
if ( traceEnabled ) {
68
- log .tracef ( "Getting cached data from region [`%s` (%s)] by key [%s]" , getRegion ().getName (), getAccessType (), key );
66
+ L2CACHE_LOGGER .tracef ( "Getting cached data from region ['%s' (%s)] by key [%s]" ,
67
+ getRegion ().getName (), getAccessType (), key );
69
68
}
70
69
try {
71
70
readLock .lock ();
72
71
final Lockable item = (Lockable ) getStorageAccess ().getFromCache ( key , session );
73
72
74
73
if ( item == null ) {
75
74
if ( traceEnabled ) {
76
- log .tracef ( "Cache miss : region = `%s`, key = `%s`" , getRegion ().getName (), key );
75
+ L2CACHE_LOGGER .tracef ( "Cache miss: region = '%s', key = '%s'" ,
76
+ getRegion ().getName (), key );
77
77
}
78
78
return null ;
79
79
}
80
80
81
81
final boolean readable = item .isReadable ( session .getCacheTransactionSynchronization ().getCachingTimestamp () );
82
82
if ( readable ) {
83
83
if ( traceEnabled ) {
84
- log .tracef ( "Cache hit : region = `%s`, key = `%s`" , getRegion ().getName (), key );
84
+ L2CACHE_LOGGER .tracef ( "Cache hit: region = '%s', key = '%s'" ,
85
+ getRegion ().getName (), key );
85
86
}
86
87
return item .getValue ();
87
88
}
88
89
else {
89
90
if ( traceEnabled ) {
90
- log .tracef ( "Cache hit, but item is unreadable/invalid : region = `%s`, key = `%s`" , getRegion ().getName (), key );
91
+ L2CACHE_LOGGER .tracef ( "Cache hit, but item is unreadable/invalid: region = '%s', key = '%s'" ,
92
+ getRegion ().getName (), key );
91
93
}
92
94
return null ;
93
95
}
@@ -104,9 +106,10 @@ public boolean putFromLoad(
104
106
Object value ,
105
107
Object version ) {
106
108
try {
107
- final boolean traceEnabled = log .isTraceEnabled ();
109
+ final boolean traceEnabled = L2CACHE_LOGGER .isTraceEnabled ();
108
110
if ( traceEnabled ) {
109
- log .tracef ( "Caching data from load [region='%s' (%s)] : key[%s] -> value[%s]" , getRegion ().getName (), getAccessType (), key , value );
111
+ L2CACHE_LOGGER .tracef ( "Caching data from load [region='%s' (%s)] : key[%s] -> value[%s]" ,
112
+ getRegion ().getName (), getAccessType (), key , value );
110
113
}
111
114
writeLock .lock ();
112
115
Lockable item = (Lockable ) getStorageAccess ().getFromCache ( key , session );
@@ -122,8 +125,8 @@ public boolean putFromLoad(
122
125
}
123
126
else {
124
127
if ( traceEnabled ) {
125
- log .tracef (
126
- "Cache put-from-load [region=`%s` (%s), key=`%s` , value=`%s` ] failed due to being non-writable" ,
128
+ L2CACHE_LOGGER .tracef (
129
+ "Cache put-from-load [region='%s' (%s), key='%s' , value='%s' ] failed due to being non-writable" ,
127
130
getAccessType (),
128
131
getRegion ().getName (),
129
132
key ,
@@ -156,8 +159,9 @@ public SoftLock lockItem(SharedSessionContractImplementor session, Object key, O
156
159
writeLock .lock ();
157
160
158
161
long timeout = getRegion ().getRegionFactory ().nextTimestamp () + getRegion ().getRegionFactory ().getTimeout ();
159
- if ( log .isTraceEnabled () ) {
160
- log .tracef ( "Locking cache item [region=`%s` (%s)] : `%s` (timeout=%s, version=%s)" , getRegion ().getName (), getAccessType (), key , timeout , version );
162
+ if ( L2CACHE_LOGGER .isTraceEnabled () ) {
163
+ L2CACHE_LOGGER .tracef ( "Locking cache item [region='%s' (%s)] : '%s' (timeout=%s, version=%s)" ,
164
+ getRegion ().getName (), getAccessType (), key , timeout , version );
161
165
}
162
166
163
167
Lockable item = (Lockable ) getStorageAccess ().getFromCache ( key , session );
@@ -175,18 +179,14 @@ public SoftLock lockItem(SharedSessionContractImplementor session, Object key, O
175
179
@ Override
176
180
public void unlockItem (SharedSessionContractImplementor session , Object key , SoftLock lock ) {
177
181
try {
178
- if ( log .isTraceEnabled () ) {
179
- log .tracef (
180
- "Unlocking cache item [region=`%s` (%s)] : %s" ,
181
- getRegion ().getName (),
182
- getAccessType (),
183
- key
184
- );
182
+ if ( L2CACHE_LOGGER .isTraceEnabled () ) {
183
+ L2CACHE_LOGGER .tracef ( "Unlocking cache item [region='%s' (%s)] : %s" ,
184
+ getRegion ().getName (), getAccessType (), key );
185
185
}
186
186
writeLock .lock ();
187
187
Lockable item = (Lockable ) getStorageAccess ().getFromCache ( key , session );
188
188
189
- if ( ( item != null ) && item .isUnlockable ( lock ) ) {
189
+ if ( item != null && item .isUnlockable ( lock ) ) {
190
190
decrementLock ( session , key , (SoftLockImpl ) item );
191
191
}
192
192
else {
@@ -205,7 +205,7 @@ protected void decrementLock(SharedSessionContractImplementor session, Object ke
205
205
206
206
protected void handleLockExpiry (SharedSessionContractImplementor session , Object key , Lockable lock ) {
207
207
L2CACHE_LOGGER .softLockedCacheExpired ( getRegion ().getName (), key );
208
- log .tracef ( "Cached entry expired: %s" , key );
208
+ L2CACHE_LOGGER .tracef ( "Cached entry expired: %s" , key );
209
209
final RegionFactory regionFactory = getRegion ().getRegionFactory ();
210
210
211
211
// create new lock that times out immediately
@@ -219,7 +219,9 @@ protected void handleLockExpiry(SharedSessionContractImplementor session, Object
219
219
@ Override
220
220
public void remove (SharedSessionContractImplementor session , Object key ) {
221
221
if ( getStorageAccess ().getFromCache ( key , session ) instanceof SoftLock ) {
222
- log .debugf ( "Skipping #remove call in read-write access to maintain SoftLock: %s" , key );
222
+ if ( L2CACHE_LOGGER .isDebugEnabled () ) {
223
+ L2CACHE_LOGGER .debugf ( "Skipping remove call in read-write access to maintain SoftLock: " , key );
224
+ }
223
225
// don't do anything... we want the SoftLock to remain in place
224
226
}
225
227
else {
@@ -285,9 +287,9 @@ public final static class Item implements Serializable, Lockable {
285
287
286
288
@ Override
287
289
public boolean isReadable (long txTimestamp ) {
288
- if ( log .isTraceEnabled () ) {
289
- log .tracef (
290
- "Checking readability of read-write cache item [timestamp=`%s` , version=`%s` ] : txTimestamp=`%s` " ,
290
+ if ( L2CACHE_LOGGER .isTraceEnabled () ) {
291
+ L2CACHE_LOGGER .tracef (
292
+ "Checking readability of read-write cache item [timestamp='%s' , version='%s' ] : txTimestamp='%s' " ,
291
293
(Object ) timestamp ,
292
294
version ,
293
295
txTimestamp
@@ -299,9 +301,9 @@ public boolean isReadable(long txTimestamp) {
299
301
300
302
@ Override
301
303
public boolean isWriteable (long txTimestamp , Object newVersion , Comparator versionComparator ) {
302
- if ( log .isTraceEnabled () ) {
303
- log .tracef (
304
- "Checking writeability of read-write cache item [timestamp=`%s` , version=`%s` ] : txTimestamp=`%s` , newVersion=`%s` " ,
304
+ if ( L2CACHE_LOGGER .isTraceEnabled () ) {
305
+ L2CACHE_LOGGER .tracef (
306
+ "Checking writeability of read-write cache item [timestamp='%s' , version='%s' ] : txTimestamp='%s' , newVersion='%s' " ,
305
307
timestamp ,
306
308
version ,
307
309
txTimestamp ,
@@ -372,9 +374,9 @@ public boolean isReadable(long txTimestamp) {
372
374
373
375
@ Override
374
376
public boolean isWriteable (long txTimestamp , Object newVersion , Comparator versionComparator ) {
375
- if ( log .isTraceEnabled () ) {
376
- log .tracef (
377
- "Checking writeability of read-write cache lock [timeout=`%s` , lockId=`%s` , version=`%s` , sourceUuid=%s, multiplicity=`%s` , unlockTimestamp=`%s` ] : txTimestamp=`%s` , newVersion=`%s` " ,
377
+ if ( L2CACHE_LOGGER .isTraceEnabled () ) {
378
+ L2CACHE_LOGGER .tracef (
379
+ "Checking writeability of read-write cache lock [timeout='%s' , lockId='%s' , version='%s' , sourceUuid=%s, multiplicity='%s' , unlockTimestamp='%s' ] : txTimestamp='%s' , newVersion='%s' " ,
378
380
timeout ,
379
381
lockId ,
380
382
version ,
0 commit comments