CORE-18981 Add configuration to disable session heartbeats

components/link-manager/src/integrationTest/kotlin/net/corda/p2p/linkmanager/integration/LinkManagerIntegrationTest.kt

@@ -12,6 +12,7 @@ import net.corda.data.p2p.crypto.protocol.RevocationCheckMode
 import net.corda.db.messagebus.testkit.DBSetup
 import net.corda.libs.configuration.SmartConfigFactory
 import net.corda.libs.configuration.schema.p2p.LinkManagerConfiguration
+import net.corda.libs.configuration.schema.p2p.LinkManagerConfiguration.Companion.HEARTBEAT_ENABLED_KEY
 import net.corda.libs.configuration.schema.p2p.LinkManagerConfiguration.Companion.HEARTBEAT_MESSAGE_PERIOD_KEY
 import net.corda.libs.configuration.schema.p2p.LinkManagerConfiguration.Companion.MAX_MESSAGE_SIZE_KEY
 import net.corda.libs.configuration.schema.p2p.LinkManagerConfiguration.Companion.MAX_REPLAYING_MESSAGES_PER_PEER
@@ -113,6 +114,7 @@ class LinkManagerIntegrationTest {
         return ConfigFactory.empty()
             .withValue(MAX_MESSAGE_SIZE_KEY, ConfigValueFactory.fromAnyRef(1000000))
             .withValue(MAX_REPLAYING_MESSAGES_PER_PEER, ConfigValueFactory.fromAnyRef(100))
+            .withValue(HEARTBEAT_ENABLED_KEY, ConfigValueFactory.fromAnyRef(true))
             .withValue(HEARTBEAT_MESSAGE_PERIOD_KEY, ConfigValueFactory.fromAnyRef(2000))
             .withValue(SESSION_TIMEOUT_KEY, ConfigValueFactory.fromAnyRef(10000))
             .withValue(SESSIONS_PER_PEER_KEY, ConfigValueFactory.fromAnyRef(null))

components/link-manager/src/main/kotlin/net/corda/p2p/linkmanager/metrics/MetricsHelpers.kt

@@ -86,4 +86,20 @@ private fun recordInboundMessagesMetric(source: String?, dest: String?, group: S
         builder.withTag(it.first, value)
     }
     builder.build().increment()
+}
+
+fun recordOutboundSessionTimeoutMetric(source: HoldingIdentity, destination: HoldingIdentity) {
+    CordaMetrics.Metric.OutboundSessionTimeoutCount.builder()
+        .withTag(CordaMetrics.Tag.SourceVirtualNode, source.x500Name.toString())
+        .withTag(CordaMetrics.Tag.DestinationVirtualNode, destination.x500Name.toString())
+        .withTag(CordaMetrics.Tag.MembershipGroup, source.groupId)
+        .build().increment()
+}
+
+fun recordInboundSessionTimeoutMetric(source: HoldingIdentity, destination: HoldingIdentity?) {
+    CordaMetrics.Metric.InboundSessionTimeoutCount.builder()
+        .withTag(CordaMetrics.Tag.SourceVirtualNode, source.x500Name.toString())
+        .withTag(CordaMetrics.Tag.DestinationVirtualNode, destination?.x500Name?.toString() ?: NOT_APPLICABLE_TAG_VALUE)
+        .withTag(CordaMetrics.Tag.MembershipGroup, source.groupId)
+        .build().increment()
 }