Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
11 changed files
with
700 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,80 @@ | ||
| { pkgs | ||
| , lib | ||
| , stateDir | ||
| , basePort | ||
| , node-services | ||
| , generator-service | ||
| ## Last-moment overrides: | ||
| , extraSupervisorConfig | ||
| }: | ||
|
|
||
| with lib; | ||
|
|
||
| let | ||
| ## | ||
| ## supervisorConf :: SupervisorConf | ||
| ## | ||
| ## Refer to: http://supervisord.org/configuration.html | ||
| ## | ||
| supervisorConf = | ||
| { | ||
| supervisord = { | ||
| logfile = "${stateDir}/supervisor/supervisord.log"; | ||
| pidfile = "${stateDir}/supervisor/supervisord.pid"; | ||
| strip_ansi = true; | ||
| }; | ||
| supervisorctl = {}; | ||
| inet_http_server = { | ||
| port = "127.0.0.1:9001"; | ||
| }; | ||
| "rpcinterface:supervisor" = { | ||
| "supervisor.rpcinterface_factory" = "supervisor.rpcinterface:make_main_rpcinterface"; | ||
| }; | ||
| } | ||
| // | ||
| listToAttrs | ||
| (mapAttrsToList (_: nodeSvcSupervisorProgram) node-services) | ||
| // | ||
| { | ||
| "program:generator" = { | ||
| directory = "${stateDir}/generator"; | ||
| command = "sh start.sh"; | ||
| stdout_logfile = "${stateDir}/generator/stdout"; | ||
| stderr_logfile = "${stateDir}/generator/stderr"; | ||
| autostart = false; | ||
| startretries = 0; | ||
| }; | ||
| } | ||
| // | ||
| { | ||
| "program:tracer" = { | ||
| directory = "${stateDir}/tracer"; | ||
| command = "sh start.sh"; | ||
| stdout_logfile = "${stateDir}/tracer/stdout"; | ||
| stderr_logfile = "${stateDir}/tracer/stderr"; | ||
| autostart = false; | ||
| startretries = 0; | ||
| }; | ||
| } | ||
| // | ||
| extraSupervisorConfig; | ||
|
|
||
| ## | ||
| ## nodeSvcSupervisorProgram :: NodeService -> SupervisorConfSection | ||
| ## | ||
| ## Refer to: http://supervisord.org/configuration.html#program-x-section-settings | ||
| ## | ||
| nodeSvcSupervisorProgram = { nodeSpec, service, ... }: | ||
| nameValuePair "program:${nodeSpec.value.name}" { | ||
| directory = "${service.value.stateDir}"; | ||
| command = "sh start.sh"; | ||
| stdout_logfile = "${service.value.stateDir}/stdout"; | ||
| stderr_logfile = "${service.value.stateDir}/stderr"; | ||
| startretries = 0; | ||
| autostart = false; | ||
| autorestart = false; | ||
| }; | ||
|
|
||
| in | ||
| pkgs.writeText "supervisor.conf" | ||
| (generators.toINI {} supervisorConf) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,157 @@ | ||
| let | ||
| batchNameDefault = "plain"; | ||
| profileNameDefault = "default-bage"; | ||
| in | ||
|
|
||
| { pkgs | ||
| , cardanoNodePackages | ||
| , docker-workbench | ||
| ## | ||
| , profileName ? profileNameDefault | ||
| , batchName ? batchNameDefault | ||
| ## | ||
| , workbenchDevMode ? false | ||
| , cardano-node-rev ? "0000000000000000000000000000000000000000" | ||
| }: | ||
|
|
||
| let | ||
| inherit (docker-workbench) workbench backend cacheDir stateDir basePort; | ||
|
|
||
| with-docker-profile = | ||
| { envArgsOverride ? {} }: | ||
| workbench.with-profile | ||
| { inherit backend profileName; | ||
| envArgs = docker-workbench.env-args-base // envArgsOverride; | ||
| }; | ||
|
|
||
| inherit | ||
| (with-docker-profile {}) | ||
| profileNix profile topology genesis; | ||
| in | ||
|
|
||
| let | ||
|
|
||
| inherit (profile.value) era composition monetary; | ||
|
|
||
| path = pkgs.lib.makeBinPath path'; | ||
| path' = | ||
| [ cardanoNodePackages.bech32 pkgs.jq pkgs.gnused pkgs.coreutils pkgs.bash pkgs.moreutils | ||
| ] | ||
| ## In dev mode, call the script directly: | ||
| ++ pkgs.lib.optionals (!workbenchDevMode) | ||
| [ workbench.workbench ]; | ||
|
|
||
| interactive-start = pkgs.writeScriptBin "start-cluster" '' | ||
| set -euo pipefail | ||
| export PATH=$PATH:${path} | ||
| wb start \ | ||
| --batch-name ${batchName} \ | ||
| --profile-name ${profileName} \ | ||
| --profile ${profile} \ | ||
| --cache-dir ${cacheDir} \ | ||
| --base-port ${toString basePort} \ | ||
| ''${WB_MODE_CABAL:+--cabal} \ | ||
| "$@" | ||
| ''; | ||
|
|
||
| interactive-stop = pkgs.writeScriptBin "stop-cluster" '' | ||
| set -euo pipefail | ||
| wb finish "$@" | ||
| ''; | ||
|
|
||
| interactive-restart = pkgs.writeScriptBin "restart-cluster" '' | ||
| set -euo pipefail | ||
| wb run restart "$@" && \ | ||
| echo "workbench: alternate command for this action: wb run restart" >&2 | ||
| ''; | ||
|
|
||
| nodeBuildProduct = | ||
| name: | ||
| "report ${name}-log $out ${name}/stdout"; | ||
|
|
||
| profile-run = | ||
| { trace ? false }: | ||
| let | ||
| inherit | ||
| (with-docker-profile | ||
| { envArgsOverride = { cacheDir = "./cache"; stateDir = "./"; }; }) | ||
| profileNix profile topology genesis; | ||
|
|
||
| run = pkgs.runCommand "workbench-run-docker-${profileName}" | ||
| { requiredSystemFeatures = [ "benchmark" ]; | ||
| nativeBuildInputs = with cardanoNodePackages; with pkgs; [ | ||
| bash | ||
| bech32 | ||
| coreutils | ||
| gnused | ||
| jq | ||
| moreutils | ||
| nixWrapped | ||
| pstree | ||
| python3Packages.docker | ||
| workbench.workbench | ||
| zstd | ||
| ]; | ||
| } | ||
| '' | ||
| mkdir -p $out/{cache,nix-support} | ||
| cd $out | ||
| export HOME=$out | ||
| export WB_BACKEND=docker | ||
| export CARDANO_NODE_SOCKET_PATH=$(wb backend get-node-socket-path ${stateDir} node-0) | ||
| cmd=( | ||
| wb | ||
| ${pkgs.lib.optionalString trace "--trace"} | ||
| start | ||
| --profile-name ${profileName} | ||
| --profile ${profile} | ||
| --topology ${topology} | ||
| --genesis-cache-entry ${genesis} | ||
| --batch-name smoke-test | ||
| --base-port ${toString basePort} | ||
| --node-source ${cardanoNodePackages.cardano-node.src.origSrc} | ||
| --node-rev ${cardano-node-rev} | ||
| --cache-dir ./cache | ||
| ) | ||
| echo "''${cmd[*]}" > $out/wb-start.sh | ||
| time "''${cmd[@]}" 2>&1 | | ||
| tee $out/wb-start.log | ||
| ## Convert structure from $out/run/RUN-ID/* to $out/*: | ||
| rm -rf cache | ||
| rm -f run/{current,-current} | ||
| find $out -type s | xargs rm -f | ||
| tag=$(cd run; ls) | ||
| (cd run; tar c $tag --zstd) > archive.tar.zst | ||
| mv run/$tag/* . | ||
| rmdir run/$tag run | ||
| cat > $out/nix-support/hydra-build-products <<EOF | ||
| report workbench-log $out wb-start.log | ||
| report meta $out meta.json | ||
| ${pkgs.lib.concatStringsSep "\n" | ||
| (map nodeBuildProduct (__attrNames profileNix.node-specs.value))} | ||
| report archive-tar-zst $out archive.tar.zst | ||
| EOF | ||
| echo "workbench-test: completed run $tag" | ||
| ''; | ||
| in | ||
| run // { | ||
| analysis = workbench.run-analysis { inherit pkgs workbench profileNix run; }; | ||
| }; | ||
| in | ||
| { | ||
| inherit stateDir; | ||
| inherit workbench docker-workbench; | ||
| inherit profileNix profile topology genesis; | ||
| inherit interactive-start interactive-stop interactive-restart; | ||
| inherit profile-run; | ||
| } |
Oops, something went wrong.