Commit 5633e72b authored by Ramon Nou's avatar Ramon Nou Committed by Ramon Nou
Browse files

Execute external script

parent 03a981c5

src/scord/rpc_handlers.cpp

+37 −5
Original line number Diff line number Diff line
@@ -31,6 +31,9 @@ 
#include "job_manager.hpp"

#include "adhoc_storage_manager.hpp"



// Process running

#include <unistd.h>



struct remote_procedure {

    static std::uint64_t

    new_id() {
@@ -448,15 +451,44 @@ ADM_deploy_adhoc_storage(hg_handle_t h) { 


    /* Look inside adhoc_storage and launch gkfs script */



    if (adhoc_storage->s_type == ADM_STORAGE_GEKKOFS)

    {

    if (adhoc_storage->s_type == ADM_STORAGE_GEKKOFS) {

    /* 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";



    /* Launch script */



        pid_t pid = fork();

        switch (pid) {

            case 0: {

                std::vector<const char*> args;

                args.push_back("/usr/bin/echo");

                args.push_back(mountpoint.c_str());

                args.push_back(rootdir.c_str());

                args.push_back(NULL);

                std::vector<const char*> env;

                env.push_back(job_id.c_str());

                env.push_back(NULL);

                

                execve("/usr/bin/echo", const_cast<char* const*>(args.data()), 

                const_cast<char* const*>(env.data())); 

                LOGGER_INFO("ADM_deploy_adhoc_storage() script didn't execute");

                exit(0);

                break;

            }            

            case -1: {

                out.retval = -1;

                LOGGER_ERROR("ADM_deploy_adhoc_storage() didn't fork");

                break;

            }

            default: {

                LOGGER_INFO("ADM_deploy_adhoc_storage() executed");

                out.retval = 0;

                break;

            }

        }

    }



    ret = margo_respond(h, &out);