|
|
@ -39,6 +39,7 @@ const TIMEOUT_ERROR = 2; |
|
|
const NOT_FOUND_ERROR = 3; |
|
|
const NOT_FOUND_ERROR = 3; |
|
|
|
|
|
|
|
|
const statFrequency = Number(config.get('script.stat_print_frequency')); |
|
|
const statFrequency = Number(config.get('script.stat_print_frequency')); |
|
|
|
|
|
const memoryUsageTraceFrequency = Number(config.get('script.memory_usage_trace_frequency')); |
|
|
const scriptBodyTraceFrequency = Number(config.get('script.script_body_trace_frequency')); |
|
|
const scriptBodyTraceFrequency = Number(config.get('script.script_body_trace_frequency')); |
|
|
const useSandbox = config.get('script.use_sandbox') === 'true'; |
|
|
const useSandbox = config.get('script.use_sandbox') === 'true'; |
|
|
const maxActiveScripts = Number(config.get('script.max_active_scripts')); |
|
|
const maxActiveScripts = Number(config.get('script.max_active_scripts')); |
|
|
@ -167,6 +168,10 @@ export class JsInvokeMessageProcessor { |
|
|
if (this.executedScriptsCounter % scriptBodyTraceFrequency == 0) { |
|
|
if (this.executedScriptsCounter % scriptBodyTraceFrequency == 0) { |
|
|
this.logger.info('[%s] Executing script body: [%s]', scriptId, invokeRequest.scriptBody); |
|
|
this.logger.info('[%s] Executing script body: [%s]', scriptId, invokeRequest.scriptBody); |
|
|
} |
|
|
} |
|
|
|
|
|
if (this.executedScriptsCounter % memoryUsageTraceFrequency == 0) { |
|
|
|
|
|
this.logger.info('Current memory usage: [%s]', process.memoryUsage()); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
this.getOrCompileScript(scriptId, invokeRequest.scriptBody).then( |
|
|
this.getOrCompileScript(scriptId, invokeRequest.scriptBody).then( |
|
|
(script) => { |
|
|
(script) => { |
|
|
this.executor.executeScript(script, invokeRequest.args, invokeRequest.timeout).then( |
|
|
this.executor.executeScript(script, invokeRequest.args, invokeRequest.timeout).then( |
|
|
|