@@ -64,13 +64,9 @@ async function getESClient () {
64
64
const tId = _ . get ( params . query , 'transactionId' )
65
65
params . query = _ . omit ( params . query , 'transactionId' )
66
66
if ( ! tId || tId !== transactionId ) {
67
- logger . info ( `${ transactionId } is trying to acquire the mutex` )
68
67
const release = await esClientMutex . acquire ( )
69
- logger . info ( `${ transactionId } has acquired the mutex` )
70
68
mutexReleaseMap [ tId || 'noTransaction' ] = release
71
69
transactionId = tId
72
- } else {
73
- logger . info ( `${ transactionId } did not acquire any mutex` )
74
70
}
75
71
try {
76
72
return await esClient . transport . originalRequest ( params )
@@ -80,12 +76,8 @@ async function getESClient () {
80
76
delete mutexReleaseMap [ tId || 'noTransaction' ]
81
77
transactionId = undefined
82
78
if ( release ) {
83
- logger . info ( `${ transactionId } is now releasing the mutex` )
84
79
release ( )
85
- logger . info ( `${ transactionId } has released the mutex` )
86
80
}
87
- } else {
88
- logger . info ( `${ transactionId } did not release the mutex` )
89
81
}
90
82
}
91
83
}
@@ -195,11 +187,7 @@ function checkEsMutexRelease (tId) {
195
187
delete mutexReleaseMap [ tId ]
196
188
transactionId = undefined
197
189
if ( release ) {
198
- logger . info ( `${ tId } is releasing the mutex` )
199
190
release ( )
200
- logger . info ( `${ tId } has released the mutex` )
201
- } else {
202
- logger . info ( `${ tId } has no mutex to release` )
203
191
}
204
192
}
205
193
}
0 commit comments