- added the distributed lock in the documentation as well
- updated the log level to debug to refrain printing every iteration of
the scheduler
Issue-ID: CPS-2479
Change-Id: Ieeeff46168d70aca6f423e82bda15a12d6c405a5
Signed-off-by: mpriyank <priyank.maheshwari@est.tech>
*/
public void populateWorkQueueIfNeeded() {
if (moduleSyncWorkQueue.isEmpty() && cpsAndNcmpLock.tryLock(MODULE_SYNC_WORK_QUEUE_LOCK_NAME)) {
- log.info("Lock acquired by thread : {}", Thread.currentThread().getName());
+ log.debug("Lock acquired by thread : {}", Thread.currentThread().getName());
try {
populateWorkQueue();
if (moduleSyncWorkQueue.isEmpty()) {
}
} finally {
cpsAndNcmpLock.unlock(MODULE_SYNC_WORK_QUEUE_LOCK_NAME);
- log.info("Lock released by thread : {}", Thread.currentThread().getName());
+ log.debug("Lock released by thread : {}", Thread.currentThread().getName());
}
}
}
| cps-ncmp | moduleSetTagsBeingProcessed | Track module set tags which are processed to prevent |
| | | multiple threads working with same tag. |
+--------------+------------------------------------+-----------------------------------------------------------+
+| cps-ncmp | cpsAndNcmpLock | Cps and NCMP distributed lock for various use cases. |
++--------------+------------------------------------+-----------------------------------------------------------+
-Total number of caches : 7
+Total number of caches : 8