Prevent subcomms from being freed before user's comm

Signed-off-by: Matthew Whitlock <[email protected]>

Author: Matthew-Whitlock

ompi/mca/coll/han/coll_han_subcomms.c

@@ -46,6 +46,15 @@
         (COMM)->c_coll->coll_##COLL##_module = (FALLBACKS).COLL.module;      \
     } while (0)
 
+#define HAN_SUBCOM_EXTRA_RETAIN(COMM)                                        \
+    do                                                                       \
+    {                                                                        \
+        if(!OMPI_COMM_IS_EXTRA_RETAIN(COMM)){                                \
+            OMPI_COMM_SET_EXTRA_RETAIN(COMM);                                \
+            OBJ_RETAIN(COMM);                                                \
+        }                                                                    \
+    } while (0)
+
 /*
  * Routine that creates the local hierarchical sub-communicators
  * Called each time a collective is called.
@@ -206,6 +215,11 @@ int mca_coll_han_comm_create_new(struct ompi_communicator_t *comm,
     HAN_SUBCOM_RESTORE_COLLECTIVE(fallbacks, comm, han_module, scatterv);
 
     OBJ_DESTRUCT(&comm_info);
+   
+    /* Ensure these communicators aren't released before the parent comm */
+    HAN_SUBCOM_EXTRA_RETAIN(*low_comm);
+    HAN_SUBCOM_EXTRA_RETAIN(*up_comm);
+
     return OMPI_SUCCESS;
 
 return_with_error:
@@ -376,6 +390,12 @@ int mca_coll_han_comm_create(struct ompi_communicator_t *comm,
     han_module->cached_up_comms = up_comms;
     han_module->cached_vranks = vranks;
 
+    /* Ensure these communicators aren't released before the parent comm */
+    HAN_SUBCOM_EXTRA_RETAIN(low_comms[0]);
+    HAN_SUBCOM_EXTRA_RETAIN(low_comms[1]);
+    HAN_SUBCOM_EXTRA_RETAIN( up_comms[0]);
+    HAN_SUBCOM_EXTRA_RETAIN( up_comms[1]);
+
     /* Reset the saved collectives to point back to HAN */
     HAN_SUBCOM_RESTORE_COLLECTIVE(fallbacks, comm, han_module, alltoall);
     HAN_SUBCOM_RESTORE_COLLECTIVE(fallbacks, comm, han_module, alltoallv);