more verbosity

ornladios · May 31, 2020 · d8c86f1 · d8c86f1
1 parent 71e850d
commit d8c86f1
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 3 deletions.
diff --git 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
@@ -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(';'))