From c50a620009b9dab493fe409b79f21e7821982b6d Mon Sep 17 00:00:00 2001
From: Adhidarma Hadiwinoto <me@adhisimon.org>
Date: Fri, 2 Aug 2019 18:22:13 +0700
Subject: [PATCH] Verbose on lock
---
lib/mutex.js | 12 ++++++++++--
1 file changed, 10 insertions(+), 2 deletions(-)
diff --git a/lib/mutex.js b/lib/mutex.js
index d3e734f..41abf1a 100644
--- a/lib/mutex.js
+++ b/lib/mutex.js
@@ -1,6 +1,7 @@
'use strict';
const locks = require('locks');
+const logger = require('komodo-sdk/logger');
const mutexWaitForOK = locks.createMutex();
const mutexCommand = locks.createMutex();
@@ -8,8 +9,10 @@ const mutexCommand = locks.createMutex();
const mutexSubCommand = locks.createMutex();
function setLockWaitForOK() {
+ logger.verbose('Entering MUTEX OK');
return new Promise((resolve) => {
mutexWaitForOK.lock(() => {
+ logger.verbose('MUTEX OK entered');
resolve(true);
});
});
@@ -17,6 +20,7 @@ function setLockWaitForOK() {
function releaseLockWaitForOK() {
try {
+ logger.verbose('Leaving MUTEX OK');
mutexWaitForOK.unlock();
} catch (e) {
//
@@ -24,8 +28,10 @@ function releaseLockWaitForOK() {
}
function setLockWaitForCommand() {
+ logger.verbose('Entering MUTEX Command');
return new Promise((resolve) => {
mutexCommand.lock(() => {
+ logger.verbose('MUTEX Command entered');
resolve(true);
});
});
@@ -38,6 +44,7 @@ function tryLockWaitForCommand() {
function releaseLockWaitForCommand() {
try {
+ logger.verbose('Leaving MUTEX Command');
mutexCommand.unlock();
} catch (e) {
//
@@ -45,17 +52,18 @@ function releaseLockWaitForCommand() {
}
function setLockWaitForSubCommand() {
+ logger.verbose('Entering MUTEX SUBCOMMAND');
return new Promise((resolve) => {
mutexSubCommand.lock(() => {
+ logger.verbose('MUTEX SUBCOMMAND entered');
resolve(true);
});
});
}
function releaseLockWaitForSubCommand() {
- // mutexSubCommand.unlock();
-
try {
+ logger.verbose('Leaving MUTEX SUBCOMMAND');
mutexSubCommand.unlock();
} catch (e) {
//
--
1.9.0