Skip to content

Commit

Permalink
Working!!
Browse files Browse the repository at this point in the history
  • Loading branch information
Thomas Applencourt committed Jul 24, 2024
1 parent 62231c9 commit 98e04fd
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions xprof/sync_daemon_mpi.c
Original file line number Diff line number Diff line change
Expand Up @@ -37,10 +37,11 @@ int MPIX_Init_Session(MPI_Session *lib_shandle, MPI_Comm *lib_comm) {
/*
* check we got thread support level foo library needs
*/
/*

/* Intel MPI doesn't support MPI_Info_get_string
CHECK_MPI(MPI_Session_get_info(*lib_shandle, &tinfo));
{
char out_value[100]; //
char out_value[100];
int valuelen = sizeof(out_value);
int flag;
CHECK_MPI(MPI_Info_get_string(tinfo, mt_key, &valuelen, out_value, &flag));
Expand All @@ -50,7 +51,8 @@ int MPIX_Init_Session(MPI_Session *lib_shandle, MPI_Comm *lib_comm) {
fprintf(stderr, "THAPI_SYNC_DAEMON_MPI Warning: Did not get MPI_THREAD_SINGLE, got %s\n",
out_value);
}
*/
*/

/*
* create a group from the WORLD process set
*/
Expand Down Expand Up @@ -145,16 +147,12 @@ int main(int argc, char **argv) {
ret = signal_loop(parent_pid, MPI_COMM_WORLD_THAPI, MPI_COMM_NODE);

fn_exit:
printf("MPI_Comm_free: MPI_COMM_NODE\n");
if (MPI_COMM_NODE != MPI_COMM_NULL)
MPI_Comm_free(&MPI_COMM_NODE);
printf("MPI_Comm_free: MPI_COMM_WORLD_THAPI\n");
if (MPI_COMM_WORLD_THAPI != MPI_COMM_NULL)
MPI_Comm_free(&MPI_COMM_WORLD_THAPI);
printf("MPI_Session_finalize\n");
if (lib_shandle != MPI_SESSION_NULL)
MPI_Session_finalize(&lib_shandle);
printf("Signal RT_SIGNAL_READY \n");
if (parent_pid != 0)
kill(parent_pid, RT_SIGNAL_READY);
return ret;
Expand Down

0 comments on commit 98e04fd

Please sign in to comment.