digital-asset/daml
1
1
Fork 0
mirror of https://github.com/digital-asset/daml.git synced 2024-09-20 01:07:18 +03:00
Code Issues Projects Releases Wiki Activity

Introduce CLI option for input buffer size (#6211)

Browse Source 
* Introduce CLI option for input buffer size

Also improves CLI help text for other back-pressure related options.

changelog_begin
[Sandbox] Allow to configure --input-buffer-size, which allows to tune the number of commands waiting to be submitted before the Sandbox applies back-pressure, run daml sandbox --help for more info.
changelog_end

* Update ledger/sandbox/src/main/scala/com/digitalasset/platform/sandbox/cli/Cli.scala

Co-authored-by: Samir Talwar <samir.talwar@digitalasset.com>

Co-authored-by: Samir Talwar <samir.talwar@digitalasset.com>
This commit is contained in:
Stefano Baghino 2020-06-04 08:50:50 +02:00 committed by GitHub
parent b993339844
commit 003549ecbf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
ledger/sandbox/src/main/scala/com/digitalasset/platform/sandbox/cli/Cli.scala
View File

@ -266,14 +266,19 @@ object Cli {
.optional()
.action((value, config) =>
config.copy(commandConfig = config.commandConfig.copy(maxCommandsInFlight = value)))
.text("The maximum number of unconfirmed commands in flight in CommandService.")
.text("Maximum number of submitted commands waiting for completion for each party (only applied when using the CommandService). Overflowing this threshold will cause back-pressure, signaled by a RESOURCE_EXHAUSTED error code. Default is 256.")
opt[Int]("max-parallel-submissions")
.optional()
.action((value, config) =>
config.copy(commandConfig = config.commandConfig.copy(maxParallelSubmissions = value)))
.text(
"The maximum number of parallel command submissions. Only applicable to sandbox-classic.")
.text("Maximum number of successfully interpreted commands waiting to be sequenced (applied only when running sandbox-classic). The threshold is shared across all parties. Overflowing it will cause back-pressure, signaled by a RESOURCE_EXHAUSTED error code. Default is 512.")
opt[Int]("input-buffer-size")
.optional()
.action((value, config) =>
config.copy(commandConfig = config.commandConfig.copy(inputBufferSize = value)))
.text("The maximum number of commands waiting to be submitted for each party. Overflowing this threshold will cause back-pressure, signaled by a RESOURCE_EXHAUSTED error code. Default is 512.")
opt[Long]("max-lf-value-translation-cache-entries")
.optional()