From a9763bb6a48c31b4593e2598ffdf2880506eaef9 Mon Sep 17 00:00:00 2001 From: a10zn8 Date: Mon, 5 Dec 2022 13:41:27 +0400 Subject: [PATCH] more metrics for grpc executor - only if extended enabled --- .../io/emeraldpay/dshackle/GrpcServer.kt | 18 +++++++++++------- 1 file changed, 11 insertions(+), 7 deletions(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt b/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt index d7cdfc4a..702a220e 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt @@ -67,14 +67,18 @@ open class GrpcServer( serverBuilder.addService(it) } - serverBuilder.executor( - ExecutorServiceMetrics.monitor( - Metrics.globalRegistry, - Executors.newFixedThreadPool(20, ThreadFactoryBuilder().setNameFormat("fixed-grpc-%d").build()), - "fixed-grpc-executor", - "grpc_" - ) + val pool = Executors.newFixedThreadPool(20, ThreadFactoryBuilder().setNameFormat("fixed-grpc-%d").build()) + serverBuilder.executor( + if (mainConfig.monitoring.enableExtended) + ExecutorServiceMetrics.monitor( + Metrics.globalRegistry, + pool, + "fixed-grpc-executor", + "grpc_" + ) + else + pool ) val server = serverBuilder.build()