ASAN fixes

CTestConfig.cmake

@@ -14,15 +14,4 @@ set(MEMORYCHECK_SUPPRESSIONS_FILE ${CMAKE_SOURCE_DIR}/scripts/dashboard/nightly/
 
 # Ignore tests that are currently failing, remove tests here as they are fixed
 list(APPEND CTEST_CUSTOM_MEMCHECK_IGNORE 
-Remote.BPWriteReadADIOS2stdio.GetRemote
-Remote.BPWriteMemorySelectionRead.GetRemote
-Remote.BPWriteMemorySelectionRead.FileRemote
-remoteServerCleanup
-Engine.SST.SstWriteFails.InvalidBeginStep.Serial
-Staging.1x1.Local2.CommMin.BP5.SST
-Staging.1x1Struct.CommMin.BP5.SST
-Staging.WriteMemorySelectionRead.1x1.CommMin.BP5.SST
-Staging.1x1.Local2.CommMin.BP.SST
-Staging.WriteMemorySelectionRead.1x1.CommMin.BP.SST
-Staging.1x1Struct.BP5
 )

scripts/ci/cmake/adios-asan.supp

@@ -1,2 +1,4 @@
 leak:ps_make_timer_name_
-leak:ibv_get_device_list
+leak:ibv_get_device_list
+leak:add_transport_to_cm
+leak:INT_CMadd_delayed_task

source/adios2/toolkit/format/bp5/BP5Deserializer.cpp

@@ -1986,6 +1986,10 @@ BP5Deserializer::~BP5Deserializer()
         free(VarRec.second->VarName);
         if (VarRec.second->Operator)
             free(VarRec.second->Operator);
+        if (VarRec.second->Def)
+            delete VarRec.second->Def;
+        //        if (VarRec.second->ReaderDef)
+        //            delete VarRec.second->ReaderDef;
         delete VarRec.second;
     }
     if (m_FreeableMBA)

source/adios2/toolkit/format/bp5/BP5Serializer.cpp

@@ -37,6 +37,8 @@ namespace format
 BP5Serializer::BP5Serializer() { Init(); }
 BP5Serializer::~BP5Serializer()
 {
+    if (CurDataBuffer)
+        delete CurDataBuffer;
     if (!Info.RecNameMap.empty())
     {
         for (auto &rec : Info.RecNameMap)
@@ -553,6 +555,8 @@ BP5Serializer::BP5WriterRec BP5Serializer::CreateWriterRec(void *Variable, const
         struct_list[0].struct_size = (int)SD->StructSize();
 
         FMFormat Format = register_data_format(Info.LocalFMContext, &struct_list[0]);
+        free_FMfield_list(List);
+        free((void *)struct_list[0].format_name);
 
         int IDLength;
         char *ServerID = get_server_ID_FMformat(Format, &IDLength);
@@ -639,6 +643,8 @@ BP5Serializer::BP5WriterRec BP5Serializer::CreateWriterRec(void *Variable, const
         // Changing the formats renders these invalid
         Info.MetaFormat = NULL;
     }
+    if (TextStructID)
+        free((void *)TextStructID);
     Info.RecCount++;
     return Rec;
 }

source/adios2/toolkit/remote/Remote.cpp

@@ -15,6 +15,12 @@ namespace adios2
 Remote::Remote() {}
 
 #ifdef ADIOS2_HAVE_SST
+Remote::~Remote()
+{
+    if (m_conn)
+        CMConnection_close(m_conn);
+}
+
 void OpenResponseHandler(CManager cm, CMConnection conn, void *vevent, void *client_data,
                          attr_list attrs)
 {
@@ -86,9 +92,10 @@ void Remote::Open(const std::string hostname, const int32_t port, const std::str
     atom_t CM_IP_HOSTNAME = -1;
     CM_IP_HOSTNAME = attr_atom_from_string("IP_HOST");
     CM_IP_PORT = attr_atom_from_string("IP_PORT");
-    add_attr(contact_list, CM_IP_HOSTNAME, Attr_String, (attr_value)hostname.c_str());
+    add_attr(contact_list, CM_IP_HOSTNAME, Attr_String, (attr_value)strdup(hostname.c_str()));
     add_attr(contact_list, CM_IP_PORT, Attr_Int4, (attr_value)port);
     m_conn = CMinitiate_conn(ev_state.cm, contact_list);
+    free_attr_list(contact_list);
     if (!m_conn)
         return;
 
@@ -124,9 +131,10 @@ void Remote::OpenSimpleFile(const std::string hostname, const int32_t port,
     atom_t CM_IP_HOSTNAME = -1;
     CM_IP_HOSTNAME = attr_atom_from_string("IP_HOST");
     CM_IP_PORT = attr_atom_from_string("IP_PORT");
-    add_attr(contact_list, CM_IP_HOSTNAME, Attr_String, (attr_value)hostname.c_str());
+    add_attr(contact_list, CM_IP_HOSTNAME, Attr_String, (attr_value)strdup(hostname.c_str()));
     add_attr(contact_list, CM_IP_PORT, Attr_Int4, (attr_value)port);
     m_conn = CMinitiate_conn(ev_state.cm, contact_list);
+    free_attr_list(contact_list);
     if (!m_conn)
         return;
 
@@ -193,5 +201,6 @@ Remote::GetHandle Remote::Read(size_t Start, size_t Size, void *Dest)
 {
     return static_cast<GetHandle>(0);
 };
+Remote::~Remote() {}
 #endif
 } // end namespace adios2

source/adios2/toolkit/remote/Remote.h

@@ -32,6 +32,7 @@ class Remote
      * @param comm passed to m_Comm
      */
     Remote();
+    ~Remote();
 
     explicit operator bool() const { return m_Active; }
 
@@ -55,7 +56,7 @@ class Remote
 #ifdef ADIOS2_HAVE_SST
     void InitCMData();
     RemoteCommon::Remote_evpath_state ev_state;
-    CMConnection m_conn;
+    CMConnection m_conn = NULL;
     std::mutex m_CMInitMutex;
 #endif
     bool m_Active = false;

source/adios2/toolkit/remote/remote_common.h

@@ -95,6 +95,7 @@ typedef struct _CloseFileMsg
 typedef struct _KillServerMsg
 {
     int KillResponseCondition;
+    size_t unused; // small messages call stack addressing issues?
 } *KillServerMsg;
 
 typedef struct _KillResponseMsg

source/adios2/toolkit/sst/cp/cp_reader.c

@@ -1221,6 +1221,7 @@ static void waitForMetadataWithTimeout(SstStream Stream, float timeout_secs)
         if (timercmp(&now, &end, >))
         {
             CP_verbose(Stream, PerRankVerbose, "Returning from wait after timing out\n");
+            free(TimeoutTask);
             return;
         }
         /* wait until we get the timestep metadata or something else changes */