diff --git a/ledger/participant-integration-api/src/main/scala/platform/apiserver/ApiServices.scala b/ledger/participant-integration-api/src/main/scala/platform/apiserver/ApiServices.scala index c8baf2e0b5d2..53e03a598e85 100644 --- a/ledger/participant-integration-api/src/main/scala/platform/apiserver/ApiServices.scala +++ b/ledger/participant-integration-api/src/main/scala/platform/apiserver/ApiServices.scala @@ -240,7 +240,6 @@ private[daml] object ApiServices { ledgerId, commandConfig.inputBufferSize, commandConfig.maxCommandsInFlight, - commandConfig.limitMaxCommandsInFlight, commandConfig.retentionPeriod, ), // Using local services skips the gRPC layer, improving performance. diff --git a/ledger/participant-integration-api/src/main/scala/platform/apiserver/services/ApiCommandService.scala b/ledger/participant-integration-api/src/main/scala/platform/apiserver/services/ApiCommandService.scala index 3c66cd17965e..23571e85ccd8 100644 --- a/ledger/participant-integration-api/src/main/scala/platform/apiserver/services/ApiCommandService.scala +++ b/ledger/participant-integration-api/src/main/scala/platform/apiserver/services/ApiCommandService.scala @@ -139,15 +139,11 @@ private[apiserver] final class ApiCommandService private ( ledgerEnd, () => ledgerConfig.maxDeduplicationTime, ) - val trackingFlow = - if (configuration.limitMaxCommandsInFlight) - MaxInFlight( - configuration.maxCommandsInFlight, - capacityCounter = metrics.daml.commands.maxInFlightCapacity(metricsPrefixFirstParty), - lengthCounter = metrics.daml.commands.maxInFlightLength(metricsPrefixFirstParty), - ).joinMat(tracker)(Keep.right) - else - tracker + val trackingFlow = MaxInFlight( + configuration.maxCommandsInFlight, + capacityCounter = metrics.daml.commands.maxInFlightCapacity(metricsPrefixFirstParty), + lengthCounter = metrics.daml.commands.maxInFlightLength(metricsPrefixFirstParty), + ).joinMat(tracker)(Keep.right) TrackerImpl( trackingFlow, configuration.inputBufferSize, @@ -247,7 +243,6 @@ private[apiserver] object ApiCommandService { ledgerId: LedgerId, inputBufferSize: Int, maxCommandsInFlight: Int, - limitMaxCommandsInFlight: Boolean, retentionPeriod: FiniteDuration, ) diff --git a/ledger/participant-integration-api/src/main/scala/platform/configuration/CommandConfiguration.scala b/ledger/participant-integration-api/src/main/scala/platform/configuration/CommandConfiguration.scala index 0591a6f65946..fe8a913fda3e 100644 --- a/ledger/participant-integration-api/src/main/scala/platform/configuration/CommandConfiguration.scala +++ b/ledger/participant-integration-api/src/main/scala/platform/configuration/CommandConfiguration.scala @@ -19,8 +19,6 @@ import scala.concurrent.duration.{DurationInt, FiniteDuration} * transaction has been shipped via the WriteService. * @param maxCommandsInFlight * Maximum number of submitted commands waiting to be completed for each party. - * @param limitMaxCommandsInFlight - * Whether [[maxCommandsInFlight]] should be honored or not. * @param retentionPeriod * For how long the command service will keep an active command tracker for a given party. * A longer retention period allows to not instantiate a new tracker for a party that seldom acts. @@ -30,7 +28,6 @@ final case class CommandConfiguration( inputBufferSize: Int, maxParallelSubmissions: Int, maxCommandsInFlight: Int, - limitMaxCommandsInFlight: Boolean, retentionPeriod: FiniteDuration, ) @@ -42,7 +39,6 @@ object CommandConfiguration { inputBufferSize = 512, maxParallelSubmissions = 512, maxCommandsInFlight = 256, - limitMaxCommandsInFlight = true, retentionPeriod = DefaultTrackerRetentionPeriod, ) }