bscpkgs/garlic/exp/creams/gran+node1.nix

{
  stdenv
, stdexp
, bsc
, targetMachine
, stages
}:

with stdenv.lib;

let
  # Initial variable configuration
  varConf = {
    input = [
      { nodes=1 ; nprocz=2 ; granul=256; time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul=128; time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul=64;  time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul=37;  time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul=32;  time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul=16;  time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul= 9;  time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul= 5;  time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul= 4;  time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul= 2;  time= "02:00:00"; }
      { nodes=1 ; nprocz=2 ; granul= 1;  time= "02:00:00"; }
    ];

    gitBranch = [
      "garlic/mpi+send+omp+fork"
      "garlic/mpi+send+omp+task"
      "garlic/mpi+send+oss+task"
      "garlic/mpi+isend+omp+task"
      "garlic/mpi+isend+oss+task"
      "garlic/tampi+isend+oss+task"
    ];
  };

  # Generate the complete configuration for each unit
  genConf = with bsc; c: targetMachine.config // rec {
    expName = "creams-gran-node1";
    inherit (targetMachine.config) hw;
    # Options for creams
    cc = icc;
    mpi = impi;
    inherit (c.input) granul time nodes;
    inherit (c) gitBranch;
    unitName = "${expName}-${toString nodes}-${gitBranch}";

    # Repeat the execution of each unit 10 times
    loops = 10;

    # Resources
    qos = "debug";
    ntasksPerNode = hw.socketsPerNode;
    cpusPerTask = hw.cpusPerSocket;
    jobName = unitName;
    
    nprocz = ntasksPerNode * nodes;
  };

  # Compute the array of configurations
  configs = stdexp.buildConfigs {
    inherit varConf genConf;
  };

  # Custom srun stage to copy the creams input dataset
  customSrun = {nextStage, conf, ...}:
    let
      input = bsc.garlic.apps.creamsInput.override {
        inherit (conf) gitBranch granul nprocz;
      };
    in
      stages.srun {
        # These are part of the stdndard srun stage:
        inherit (conf) nixPrefix;
        inherit nextStage;
        cpuBind = "cores,verbose";

        # Now we add some commands to execute before calling srun. These will
        # only run in one rank (the first in the list of allocated nodes)
        preSrun = ''
          cp -r ${input}/SodTubeBenchmark/* .
          chmod +w -R .
        '';
      };

  # Creams program
  creams = {nextStage, conf, ...}: with conf;
    let
      customPkgs = stdexp.replaceMpi conf.mpi;
    in
      customPkgs.apps.creams.override {
        inherit cc mpi gitBranch;
      };

  pipeline = stdexp.stdPipelineOverride {
    overrides = {
      # Replace the stdandard srun stage with our own
      srun = customSrun;
    };
  } ++ [ creams ];

in
 
  stdexp.genExperiment { inherit configs pipeline; }