diff --git a/test/CMakeLists.txt b/test/CMakeLists.txt index 8e0b214..86d8779 100644 --- a/test/CMakeLists.txt +++ b/test/CMakeLists.txt @@ -31,3 +31,4 @@ ovni_test("flush" "driver.sh") ovni_test("flush-overhead" "driver.sh") ovni_test("mp-simple" "mp-driver.sh") ovni_test("mp-rank" "mp-driver.sh") +ovni_test("nosv-nested-tasks" "driver.sh") diff --git a/test/nosv-nested-tasks.c b/test/nosv-nested-tasks.c new file mode 100644 index 0000000..83fb3da --- /dev/null +++ b/test/nosv-nested-tasks.c @@ -0,0 +1,166 @@ +/* + * Copyright (c) 2021-2022 Barcelona Supercomputing Center (BSC) + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . + */ + +#define _GNU_SOURCE + +#include "ovni.h" +#include "compat.h" + +#include +#include +#include +#include +#include +#include +#include +#include + +static void +fail(const char *msg) +{ + fprintf(stderr, "%s\n", msg); + abort(); +} + +static inline void +emit_ev(char *mcv) +{ + struct ovni_ev ev = { 0 }; + + ovni_ev_set_mcv(&ev, mcv); + ovni_ev_set_clock(&ev, ovni_clock_now()); + ovni_ev_emit(&ev); +} + +#define INSTR_3ARG(name, mcv, ta, a, tb, b, tc, c) \ + static inline void name(ta a, tb b, tc c) \ + { \ + struct ovni_ev ev = {0}; \ + ovni_ev_set_mcv(&ev, mcv); \ + ovni_ev_set_clock(&ev, ovni_clock_now()); \ + ovni_payload_add(&ev, (uint8_t *)&a, sizeof(a)); \ + ovni_payload_add(&ev, (uint8_t *)&b, sizeof(b)); \ + ovni_payload_add(&ev, (uint8_t *)&c, sizeof(c)); \ + ovni_ev_emit(&ev); \ + } + +INSTR_3ARG(instr_thread_execute, "OHx", int32_t, cpu, int32_t, creator_tid, uint64_t, tag) + +static inline void +instr_thread_end(void) +{ + struct ovni_ev ev = {0}; + + ovni_ev_set_mcv(&ev, "OHe"); + ovni_ev_set_clock(&ev, ovni_clock_now()); + ovni_ev_emit(&ev); + + /* Flush the events to disk before killing the thread */ + ovni_flush(); +} + +static inline void +instr_start(int rank, int nranks) +{ + char hostname[HOST_NAME_MAX]; + + if(gethostname(hostname, HOST_NAME_MAX) != 0) + fail("gethostname failed"); + + ovni_proc_init(1, hostname, getpid()); + + ovni_proc_set_rank(rank, nranks); + + ovni_thread_init(gettid()); + + /* Only the rank 0 inform about all CPUs */ + if(rank == 0) + { + /* Fake nranks cpus */ + for(int i=0; i < nranks; i++) + ovni_add_cpu(i, i); + } + + int curcpu = rank; + + fprintf(stderr, "thread %d has cpu %d (ncpus=%d)\n", + gettid(), curcpu, nranks); + + instr_thread_execute(curcpu, -1, 0); +} + +static inline void +instr_end(void) +{ + instr_thread_end(); + ovni_thread_free(); + ovni_proc_fini(); +} + +static void +task_begin(int32_t id, int us) +{ + int32_t typeid = 1; + struct ovni_ev ev = {0}; + + ovni_ev_set_mcv(&ev, "VTc"); + ovni_ev_set_clock(&ev, ovni_clock_now()); + ovni_payload_add(&ev, (uint8_t *) &id, sizeof(id)); + ovni_payload_add(&ev, (uint8_t *) &typeid, sizeof(id)); + ovni_ev_emit(&ev); + + memset(&ev, 0, sizeof(ev)); + + ovni_ev_set_mcv(&ev, "VTx"); + ovni_ev_set_clock(&ev, ovni_clock_now()); + ovni_payload_add(&ev, (uint8_t *) &id, sizeof(id)); + ovni_ev_emit(&ev); + + usleep(us); +} + +static void +task_end(int32_t id) +{ + struct ovni_ev ev = {0}; + + ovni_ev_set_mcv(&ev, "VTe"); + ovni_ev_set_clock(&ev, ovni_clock_now()); + ovni_payload_add(&ev, (uint8_t *) &id, sizeof(id)); + ovni_ev_emit(&ev); +} + +int +main(void) +{ + instr_start(0, 1); + + int ntasks = 100; + + /* Create and run the tasks, one nested into another */ + for(int i=0; i=0; i--) + task_end(i + 1); + + instr_end(); + + return 0; +} +