Verbose on lock

Adhidarma Hadiwinoto
1 parent 668d5d29ef
Showing 1 changed file with 10 additions and 2 deletions Side-by-side Diff
lib/mutex.js
 '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	1	'use strict';
2	2
3	3	const locks = require('locks');
	4	+const logger = require('komodo-sdk/logger');
4	5
5	6	const mutexWaitForOK = locks.createMutex();
6	7	const mutexCommand = locks.createMutex();
...	...	@@ -8,8 +9,10 @@ const mutexCommand = locks.createMutex();
8	9	const mutexSubCommand = locks.createMutex();
9	10
10	11	function setLockWaitForOK() {
	12	+ logger.verbose('Entering MUTEX OK');
11	13	return new Promise((resolve) => {
12	14	mutexWaitForOK.lock(() => {
	15	+ logger.verbose('MUTEX OK entered');
13	16	resolve(true);
14	17	});
15	18	});
...	...	@@ -17,6 +20,7 @@ function setLockWaitForOK() {
17	20
18	21	function releaseLockWaitForOK() {
19	22	try {
	23	+ logger.verbose('Leaving MUTEX OK');
20	24	mutexWaitForOK.unlock();
21	25	} catch (e) {
22	26	//
...	...	@@ -24,8 +28,10 @@ function releaseLockWaitForOK() {
24	28	}
25	29
26	30	function setLockWaitForCommand() {
	31	+ logger.verbose('Entering MUTEX Command');
27	32	return new Promise((resolve) => {
28	33	mutexCommand.lock(() => {
	34	+ logger.verbose('MUTEX Command entered');
29	35	resolve(true);
30	36	});
31	37	});
...	...	@@ -38,6 +44,7 @@ function tryLockWaitForCommand() {
38	44
39	45	function releaseLockWaitForCommand() {
40	46	try {
	47	+ logger.verbose('Leaving MUTEX Command');
41	48	mutexCommand.unlock();
42	49	} catch (e) {
43	50	//
...	...	@@ -45,17 +52,18 @@ function releaseLockWaitForCommand() {
45	52	}
46	53
47	54	function setLockWaitForSubCommand() {
	55	+ logger.verbose('Entering MUTEX SUBCOMMAND');
48	56	return new Promise((resolve) => {
49	57	mutexSubCommand.lock(() => {
	58	+ logger.verbose('MUTEX SUBCOMMAND entered');
50	59	resolve(true);
51	60	});
52	61	});
53	62	}
54	63
55	64	function releaseLockWaitForSubCommand() {
56		- // mutexSubCommand.unlock();
57		-
58	65	try {
	66	+ logger.verbose('Leaving MUTEX SUBCOMMAND');
59	67	mutexSubCommand.unlock();
60	68	} catch (e) {
61	69	//