From bae6e4a2098da08115d2f25f8bd0b37d733d8755 Mon Sep 17 00:00:00 2001 From: Rodrigo Arias Date: Fri, 10 Dec 2021 18:23:47 +0100 Subject: [PATCH] Add rank test with fake nosv tasks --- test/CMakeLists.txt | 6 +- test/mp-rank.c | 152 ++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 156 insertions(+), 2 deletions(-) create mode 100644 test/mp-rank.c diff --git a/test/CMakeLists.txt b/test/CMakeLists.txt index b459ff1..f74cdcc 100644 --- a/test/CMakeLists.txt +++ b/test/CMakeLists.txt @@ -18,10 +18,12 @@ set(OVNI_TEST_DIR "${CMAKE_SOURCE_DIR}/test") add_executable(flush flush.c) target_link_libraries(flush ovni) - add_test(NAME flush COMMAND "${OVNI_TEST_DIR}/driver.sh" flush) add_executable(mp-simple mp-simple.c) target_link_libraries(mp-simple ovni) - add_test(NAME mp-simple COMMAND "${OVNI_TEST_DIR}/mp-driver.sh" mp-simple) + +add_executable(mp-rank mp-rank.c) +target_link_libraries(mp-rank ovni) +add_test(NAME mp-rank COMMAND "${OVNI_TEST_DIR}/mp-driver.sh" mp-rank) diff --git a/test/mp-rank.c b/test/mp-rank.c new file mode 100644 index 0000000..9a3419b --- /dev/null +++ b/test/mp-rank.c @@ -0,0 +1,152 @@ +/* + * Copyright (c) 2021 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 +#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(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); + + memset(&ev, 0, sizeof(ev)); + + 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) +{ + int rank = atoi(getenv("OVNI_RANK")); + int nranks = atoi(getenv("OVNI_NRANKS")); + + instr_start(rank, nranks); + + /* Create some fake nosv tasks */ + for(int i=0; i<10; i++) + task(i + 1, 50 * 1000); + + instr_end(); + + return 0; +} +