Commit 11e2f42f authored by Ramon Nou's avatar Ramon Nou Committed by Ramon Nou
Browse files

Updated gkfs launch

parent 99cfd9be

src/scord/rpc_handlers.cpp

+13 −6
Original line number Diff line number Diff line
@@ -455,11 +455,13 @@ ADM_deploy_adhoc_storage(hg_handle_t h) { 
    /* Extract Job ID -> SLURM_JOB_ID */

        const std::string job_id = "SLURM_JOB_ID=42";



    /* Extract paths */

        const std::string mountpoint = "-m /tmp/mnt";

        const std::string rootdir = "-r /tmp/root";

    /* Number of nodes */

        const std::string nodes = "-n "+std::to_string(adhoc_storage->s_adhoc_ctx->c_resources->r_nodes->l_length);

        int nnodes = adhoc_storage->s_adhoc_ctx->c_resources->r_nodes->l_length;

        const std::string nodes = "-n "+std::to_string(nnodes);



    /* Walltime */

        int twalltime = adhoc_storage->s_adhoc_ctx->c_walltime;

        const std::string walltime = std::to_string(twalltime);



    /* Launch script */

        pid_t pid = fork();
@@ -467,9 +469,14 @@ ADM_deploy_adhoc_storage(hg_handle_t h) { 
            case 0: {

                std::vector<const char*> args;

                args.push_back("gkfs");

                args.push_back(mountpoint.c_str());

                args.push_back(rootdir.c_str());

                args.push_back("-c");

                args.push_back("gkfs.conf");

                args.push_back("-n");

                args.push_back(nodes.c_str());

                //args.push_back("-w");

                //args.push_back(walltime.c_str());

                args.push_back("--srun");

                args.push_back("start");

                args.push_back(NULL);

                std::vector<const char*> env;

                env.push_back(job_id.c_str());