File tree Expand file tree Collapse file tree 1 file changed +13
-12
lines changed
core/server/master/src/main/java/alluxio/master/metastore/caching Expand file tree Collapse file tree 1 file changed +13
-12
lines changed Original file line number Diff line number Diff line change @@ -176,21 +176,22 @@ private Optional<V> getSkipCache(K key) {
176
176
* @param value the value
177
177
*/
178
178
public void put (K key , V value ) {
179
- mMap .compute (key , (k , entry ) -> {
180
- onPut (key , value );
181
- if (entry == null && cacheIsFull ()) {
182
- writeToBackingStore (key , value );
183
- return null ;
184
- }
185
- if (entry == null || entry .mValue == null ) {
186
- onCacheUpdate (key , value );
187
- return new Entry (key , value );
188
- }
179
+ onPut (key , value );
180
+ Entry entry = mMap .get (key );
181
+ if (entry == null && cacheIsFull ()) {
182
+ writeToBackingStore (key , value );
183
+ return ;
184
+ }
185
+
186
+ if (entry == null || entry .mValue == null ) {
187
+ onCacheUpdate (key , value );
188
+ entry = new Entry (key , value );
189
+ } else {
189
190
entry .mValue = value ;
190
191
entry .mReferenced = true ;
191
192
entry .mDirty = true ;
192
- return entry ;
193
- } );
193
+ }
194
+ mMap . put ( key , entry );
194
195
wakeEvictionThreadIfNecessary ();
195
196
}
196
197
You can’t perform that action at this time.
0 commit comments