rarias/ovni
rarias/ovni
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Add switch-same-type emu test for Nanos6

Browse Source
This commit is contained in:
Rodrigo Arias 2023-02-24 16:54:40 +01:00 committed by Rodrigo Arias Mallo
parent aab6808f4e
commit c57bef14a3
2 changed files with 60 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
test/emu/nanos6/CMakeLists.txt
View File

@ -9,3 +9,4 @@ ovni_test(blocking.c MP)
ovni_test(ss-mismatch.c SHOULD_FAIL
REGEX "thread [0-9]\\+ ended with 1 stacked nanos6 subsystems")
ovni_test(delayed-connect-ss.c)
ovni_test(switch-same-type.c)

59
test/emu/nanos6/switch-same-type.c Normal file
View File

@ -0,0 +1,59 @@
/* Copyright (c) 2023 Barcelona Supercomputing Center (BSC)
* SPDX-License-Identifier: GPL-3.0-or-later */
#include "instr_nanos6.h"
#include "emu_prv.h"
int
main(void)
{
/* Tests that switching to a nested task of the same type produces
* duplicated events in the Paraver trace with the task type and task
* rank. */
instr_start(0, 1);
uint32_t typeid = 100;
uint32_t gid = instr_nanos6_type_create(typeid);
/* Create two tasks of the same type */
instr_nanos6_task_create(1, typeid);
instr_nanos6_task_create(2, typeid);
/* Change subsystem to prevent duplicates */
instr_nanos6_task_body_enter();
instr_nanos6_task_execute(1);
instr_nanos6_submit_task_enter();
instr_nanos6_task_body_enter();
instr_nanos6_task_execute(2);
/* Match the PRV line in the trace */
FILE *f = fopen("match.sh", "w");
if (f == NULL)
die("fopen failed:");
/* Check the task type */
int prvtype = PRV_NANOS6_TYPE;
int64_t t = get_delta();
fprintf(f, "grep ':%ld:%d:%d$' ovni/thread.prv\n", t, prvtype, gid);
fprintf(f, "grep ':%ld:%d:%d$' ovni/cpu.prv\n", t, prvtype, gid);
/* Check the rank */
prvtype = PRV_NANOS6_RANK;
int rank = 0 + 1; /* Starts at one */
fprintf(f, "grep ':%ld:%d:%d$' ovni/thread.prv\n", t, prvtype, rank);
fprintf(f, "grep ':%ld:%d:%d$' ovni/cpu.prv\n", t, prvtype, rank);
fclose(f);
/* Exit from tasks and subsystem */
instr_nanos6_task_end(2);
instr_nanos6_task_body_exit();
instr_nanos6_submit_task_exit();
instr_nanos6_task_end(1);
instr_nanos6_task_body_exit();
instr_end();
return 0;
}