fix thread_enabled name

Author: Mamzi Bayatpour [email protected] ()

ompi/mca/osc/ucx/osc_ucx.h

@@ -165,10 +165,10 @@ typedef struct ompi_osc_ucx_lock {
 #define OSC_UCX_GET_EP(_module, rank_) (mca_osc_ucx_component.endpoints[_module->comm_world_ranks[rank_]])
 #define OSC_UCX_GET_DISP(module_, rank_) ((module_->disp_unit < 0) ? module_->disp_units[rank_] : module_->disp_unit)
 
-extern bool thread_enabled;
+extern bool opal_common_ucx_thread_enabled;
 
 #define OSC_UCX_GET_DEFAULT_EP(_ep_ptr, _module, _target)                   \
-    if (thread_enabled) {                  \
+    if (opal_common_ucx_thread_enabled) {                  \
         _ep_ptr = NULL;                                                     \
     } else {                                                                \
         _ep_ptr = (ucp_ep_h *)&(OSC_UCX_GET_EP(_module, _target));          \

ompi/mca/osc/ucx/osc_ucx_component.c

@@ -175,7 +175,7 @@ static int component_register(void) {
                                            MCA_BASE_VAR_SCOPE_GROUP, &mca_osc_ucx_component.no_locks);
     free(description_str);
 
-    thread_enabled = opal_using_threads();
+    opal_common_ucx_thread_enabled = opal_using_threads();
     mca_osc_ucx_component.acc_single_intrinsic = false;
 
     opal_asprintf(&description_str, "Enable optimizations for MPI_Fetch_and_op, MPI_Accumulate, etc for codes "
@@ -193,10 +193,10 @@ static int component_register(void) {
 
     opal_asprintf(&description_str, "Enable optimizations for multi-threaded applications by allocating a separate worker "
                                     "for each thread and a separate endpoint for each window  (default: %s)",
-                                         thread_enabled  ? "true" : "false");
+                                         opal_common_ucx_thread_enabled  ? "true" : "false");
     (void) mca_base_component_var_register(&mca_osc_ucx_component.super.osc_version, "enable_wpool_thread_multiple",
                                            description_str, MCA_BASE_VAR_TYPE_BOOL, NULL, 0, 0, OPAL_INFO_LVL_5,
-                                           MCA_BASE_VAR_SCOPE_GROUP, &thread_enabled);
+                                           MCA_BASE_VAR_SCOPE_GROUP, &opal_common_ucx_thread_enabled);
 
     opal_asprintf(&description_str, "Threshold on number of nonblocking accumulate calls on which there is a  periodical "
                                         "flush (default: %d)", ompi_osc_ucx_outstanding_ops_flush_threshold);
@@ -309,7 +309,7 @@ static int component_init(bool enable_progress_threads, bool enable_mpi_threads)
 }
 
 static int component_finalize(void) {
-    if (!thread_enabled) {
+    if (!opal_common_ucx_thread_enabled) {
         int i;
         for (i = 0; i < mca_osc_ucx_component.comm_world_size; i++) {
             ucp_ep_h ep = mca_osc_ucx_component.endpoints[i];
@@ -519,7 +519,7 @@ static int component_select(struct ompi_win_t *win, void **base, size_t size, in
             OSC_UCX_VERBOSE(1, "opal_common_ucx_wpool_init failed: %d", ret);
             goto select_unlock;
         }
-        if (!thread_enabled) {
+        if (!opal_common_ucx_thread_enabled) {
             mca_osc_ucx_component.comm_world_size = ompi_proc_world_size();
             mca_osc_ucx_component.endpoints = calloc(mca_osc_ucx_component.comm_world_size, sizeof(ucp_ep_h));
         }

opal/mca/common/ucx/common_ucx_wpool.c

@@ -31,7 +31,7 @@ __thread FILE *tls_pf = NULL;
 __thread int initialized = 0;
 #endif
 
-bool thread_enabled;
+bool opal_common_ucx_thread_enabled;
 
 static _ctx_record_t *_tlocal_add_ctx_rec(opal_common_ucx_ctx_t *ctx);
 static inline _ctx_record_t *_tlocal_get_ctx_rec(opal_tsd_tracked_key_t tls_key);
@@ -50,7 +50,7 @@ static opal_common_ucx_winfo_t *_winfo_create(opal_common_ucx_wpool_t *wpool)
     ucs_status_t status;
     opal_common_ucx_winfo_t *winfo = NULL;
 
-    if (thread_enabled || wpool->dflt_winfo == NULL) {
+    if (opal_common_ucx_thread_enabled || wpool->dflt_winfo == NULL) {
         memset(&worker_params, 0, sizeof(worker_params));
         worker_params.field_mask = UCP_WORKER_PARAM_FIELD_THREAD_MODE;
         worker_params.thread_mode = UCS_THREAD_MODE_SINGLE;
@@ -98,7 +98,7 @@ static void _winfo_destructor(opal_common_ucx_winfo_t *winfo)
 
     if (winfo->comm_size != 0) {
         size_t i;
-        if (thread_enabled) {
+        if (opal_common_ucx_thread_enabled) {
             for (i = 0; i < winfo->comm_size; i++) {
                 if (NULL != winfo->endpoints[i]) {
                     ucp_ep_destroy(winfo->endpoints[i]);
@@ -113,7 +113,7 @@ static void _winfo_destructor(opal_common_ucx_winfo_t *winfo)
     winfo->comm_size = 0;
 
     OBJ_DESTRUCT(&winfo->mutex);
-    if (thread_enabled || winfo->is_dflt_winfo) {
+    if (opal_common_ucx_thread_enabled || winfo->is_dflt_winfo) {
         ucp_worker_destroy(winfo->worker);
     }
 
@@ -730,13 +730,13 @@ OPAL_DECLSPEC int opal_common_ucx_tlocal_fetch_spath(opal_common_ucx_wpmem_t *me
 
     /* Obtain the endpoint */
     if (OPAL_UNLIKELY(NULL == winfo->endpoints[target])) {
-        if (thread_enabled || (dflt_ep == NULL) ||
+        if (opal_common_ucx_thread_enabled || (dflt_ep == NULL) ||
                 (*dflt_ep == NULL)) {
             rc = _tlocal_ctx_connect(ctx_rec, target);
             if (rc != OPAL_SUCCESS) {
                 return rc;
             }
-            if (!thread_enabled && (dflt_ep != NULL) &&
+            if (!opal_common_ucx_thread_enabled && (dflt_ep != NULL) &&
                     (*dflt_ep == NULL)) {
                 /* set the proc ep */
                 *dflt_ep = winfo->endpoints[target];