swamirishi commented on code in PR #6024:
URL: https://github.com/apache/ozone/pull/6024#discussion_r1536049089
##########
hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/snapshot/SnapshotCache.java:
##########
@@ -221,11 +213,24 @@ public void release(OmSnapshot omSnapshot) {
release(snapshotTableKey);
}
+ /**
+ * Callback method used to enqueue or dequeue ReferenceCounted from
+ * pendingEvictionList.
+ * @param referenceCounted ReferenceCounted object
+ */
+ @Override
+ public void callback(ReferenceCounted referenceCounted) {
+ if (referenceCounted.getTotalRefCount() == 0L) {
+ // Reference count reaches zero, add to pendingEvictionList
+ pendingEvictionQueue.add((String) referenceCounted.getParentKey());
+ }
+ }
+
/**
* Wrapper for cleanupInternal() that is synchronized to prevent multiple
* threads from interleaving into the cleanup method.
*/
- private synchronized void cleanup() {
+ public synchronized void cleanup() {
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
