|
|
@@ -1,6 +1,7 @@
|
|
|
const logger = require('@overleaf/logger')
|
|
|
const Errors = require('./Errors')
|
|
|
const RequestParser = require('./RequestParser')
|
|
|
+const Metrics = require('@overleaf/metrics')
|
|
|
|
|
|
// The lock timeout should be higher than the maximum end-to-end compile time.
|
|
|
// Here, we use the maximum compile timeout plus 2 minutes.
|
|
|
@@ -19,6 +20,8 @@ function acquire(key) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ Metrics.gauge('concurrent_compile_requests', LOCKS.size)
|
|
|
+
|
|
|
const lock = new Lock(key)
|
|
|
LOCKS.set(key, lock)
|
|
|
return lock
|
|
|
@@ -39,6 +42,9 @@ class Lock {
|
|
|
if (!lockWasActive) {
|
|
|
logger.error({ key: this.key }, 'Lock was released twice')
|
|
|
}
|
|
|
+ if (this.isExpired()) {
|
|
|
+ Metrics.inc('compile_lock_expired_before_release')
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|