diff --git a/source/adios2/toolkit/sst/cp/ffs_marshal.c b/source/adios2/toolkit/sst/cp/ffs_marshal.c index 389ed31c64..d00642b5d6 100644 --- a/source/adios2/toolkit/sst/cp/ffs_marshal.c +++ b/source/adios2/toolkit/sst/cp/ffs_marshal.c @@ -900,6 +900,8 @@ static void IssueReadRequests(SstStream Stream, FFSArrayRequest Reqs) char tmpstr[256] = {0}; sprintf(tmpstr, "Request to rank %d, bytes", i); TAU_SAMPLE_COUNTER(tmpstr, (double)DataSize); + CP_verbose(Stream, "remote read request to node %d, buffer %p\n", i, + Info->WriterInfo[i].RawBuffer); Info->WriterInfo[i].ReadHandle = SstReadRemoteMemory( Stream, i, Stream->ReaderTimestep, 0, DataSize, Info->WriterInfo[i].RawBuffer, DP_TimestepInfo); @@ -1465,6 +1467,11 @@ extern SstStatusValue SstFFSPerformGets(SstStream Stream) if (Ret == SstSuccess) { + for (int i = 0; i < Stream->WriterCohortSize; i++) + { + CP_verbose(Stream, "Filling read requests node %d, buffer %p\n", i, + Info->WriterInfo[i].RawBuffer); + } FillReadRequests(Stream, Info->PendingVarRequests); } else @@ -1779,7 +1786,9 @@ extern void FFSClearTimestepData(SstStream Stream) for (int i = 0; i < Stream->WriterCohortSize; i++) { if (Info->WriterInfo[i].RawBuffer) - free(Info->WriterInfo[i].RawBuffer); + CP_verbose(Stream, "freeing rawbuffer node %d, buffer %p\n", i, + Info->WriterInfo[i].RawBuffer); + free(Info->WriterInfo[i].RawBuffer); } memset(Info->WriterInfo, 0, sizeof(Info->WriterInfo[0]) * Stream->WriterCohortSize); diff --git a/testing/adios2/engine/staging-common/run_test.py.gen.in b/testing/adios2/engine/staging-common/run_test.py.gen.in index 17538beb24..51042a1f6e 100755 --- a/testing/adios2/engine/staging-common/run_test.py.gen.in +++ b/testing/adios2/engine/staging-common/run_test.py.gen.in @@ -66,7 +66,7 @@ def do_simple_test(writer_cmd, reader_cmd, reader_delay, file_test): if writer_cmd is not None: if "--lock_geometry" in writer_cmd: - my_env["SstVerbose"] = "1" + my_env["SstCPVerbose"] = "1" print("TestDriver: Doing simple with file_test = " + str(file_test)) sys.stdout.flush() @@ -110,7 +110,7 @@ def do_simple_mpmd_test(writer_cmd, reader_cmd): if writer_cmd is not None: if "--lock_geometry" in writer_cmd: - my_env["SstVerbose"] = "1" + my_env["SstCPVerbose"] = "1" if '@MPIEXEC_EXTRA_FLAGS@': mpiexec_cmd.extend('@MPIEXEC_EXTRA_FLAGS@'.split(';'))