Silence spacc coverity warnings

mkurnosov · ggouaillardet · commit 2f0f47664246 · 2017-07-06T10:49:08.000+09:00
1. Add assert for opal_hibit return value: comm_size is always &gt; 1.
2. Modified verbose output (dead-code warning).

Signed-off-by: Mikhail Kurnosov &lt;mkurnosov@gmail.com&gt;
diff --git a/ompi/mca/coll/spacc/coll_spacc.h b/ompi/mca/coll/spacc/coll_spacc.h
@@ -17,8 +17,9 @@
 BEGIN_C_DECLS
 
 /* Globally exported variables */
-extern int ompi_coll_spacc_stream;
-extern int ompi_coll_spacc_priority;
+extern int mca_coll_spacc_stream;
+extern int mca_coll_spacc_priority;
+extern int mca_coll_spacc_verbose;
 
 /* API functions */
 
diff --git a/ompi/mca/coll/spacc/coll_spacc_allreduce.c b/ompi/mca/coll/spacc/coll_spacc_allreduce.c
@@ -87,18 +87,19 @@ int mca_coll_spacc_allreduce_intra_redscat_allgather(
     int comm_size = ompi_comm_size(comm);
     int rank = ompi_comm_rank(comm);
 
-    OPAL_OUTPUT((ompi_coll_spacc_stream,
-                "coll:spacc:allreduce_intra_redscat_allgather: rank %d/%d",
-                rank, comm_size));
+    opal_output_verbose(30, mca_coll_spacc_stream,
+                        "coll:spacc:allreduce_intra_redscat_allgather: rank %d/%d",
+                        rank, comm_size);
 
     /* Find nearest power-of-two less than or equal to comm_size */
     int nsteps = opal_hibit(comm_size, comm->c_cube_dim + 1);   /* ilog2(comm_size) */
+    assert(nsteps >= 0);
     int nprocs_pof2 = 1 << nsteps;                              /* flp2(comm_size) */
 
     if (count < nprocs_pof2 || !ompi_op_is_commute(op)) {
-        OPAL_OUTPUT((ompi_coll_spacc_stream,
-                    "coll:spacc:allreduce_intra_redscat_allgather: rank %d/%d count %d switching to base allreduce",
-                    rank, comm_size, count));
+        opal_output_verbose(20, mca_coll_spacc_stream, 
+                            "coll:spacc:allreduce_intra_redscat_allgather: rank %d/%d count %d switching to base allreduce",
+                            rank, comm_size, count);
         return ompi_coll_base_allreduce_intra_basic_linear(sbuf, rbuf, count, dtype,
                                                            op, comm, module);
     }
diff --git a/ompi/mca/coll/spacc/coll_spacc_component.c b/ompi/mca/coll/spacc/coll_spacc_component.c
@@ -21,8 +21,9 @@ const char *ompi_coll_spacc_component_version_string =
 /*
  * Global variable
  */
-int ompi_coll_spacc_priority = 5;
-int ompi_coll_spacc_stream = -1;
+int mca_coll_spacc_priority = 5;
+int mca_coll_spacc_stream = -1;
+int mca_coll_spacc_verbose = 0;
 
 /*
  * Local function
@@ -67,38 +68,33 @@ mca_coll_spacc_component_t mca_coll_spacc_component = {
 static int spacc_register(void)
 {
     /* Use a low priority, but allow other components to be lower */
-    ompi_coll_spacc_priority = 5;
+    mca_coll_spacc_priority = 5;
     (void)mca_base_component_var_register(&mca_coll_spacc_component.super.collm_version,
                                           "priority", "Priority of the spacc coll component",
                                           MCA_BASE_VAR_TYPE_INT, NULL, 0, 0,
-                                          OPAL_INFO_LVL_6,
+                                          OPAL_INFO_LVL_9,
                                           MCA_BASE_VAR_SCOPE_READONLY,
-                                          &ompi_coll_spacc_priority);
+                                          &mca_coll_spacc_priority);
+
+    (void)mca_base_component_var_register(&mca_coll_spacc_component.super.collm_version,
+                                          "verbose", "Verbose level of the spacc coll component",
+                                          MCA_BASE_VAR_TYPE_INT, NULL, 0, 0,
+                                          OPAL_INFO_LVL_9,
+                                          MCA_BASE_VAR_SCOPE_READONLY,
+                                          &mca_coll_spacc_verbose);
     return OMPI_SUCCESS;
 }
 
 static int spacc_open(void)
 {
-#if OPAL_ENABLE_DEBUG
-    {
-        int param;
-
-        param = mca_base_var_find("ompi", "coll", "base", "verbose");
-        if (param >= 0) {
-            const int *verbose = NULL;
-            mca_base_var_get_value(param, &verbose, NULL, NULL);
-            if (verbose && verbose[0] > 0) {
-                ompi_coll_spacc_stream = opal_output_open(NULL);
-            }
-        }
-    }
-#endif  /* OPAL_ENABLE_DEBUG */
-    OPAL_OUTPUT((ompi_coll_spacc_stream, "coll:spacc:component_open: done"));
+    mca_coll_spacc_stream = opal_output_open(NULL);
+    opal_output_set_verbosity(mca_coll_spacc_stream, mca_coll_spacc_verbose);
+    opal_output_verbose(30, mca_coll_spacc_stream, "coll:spacc:component_open: done");
     return OMPI_SUCCESS;
 }
 
 static int spacc_close(void)
 {
-    OPAL_OUTPUT((ompi_coll_spacc_stream, "coll:spacc:component_close: done"));
+    opal_output_verbose(30, mca_coll_spacc_stream, "coll:spacc:component_close: done");
     return OMPI_SUCCESS;
 }
diff --git a/ompi/mca/coll/spacc/coll_spacc_module.c b/ompi/mca/coll/spacc/coll_spacc_module.c
@@ -37,9 +37,11 @@ mca_coll_base_module_t *ompi_coll_spacc_comm_query(
 {
     mca_coll_spacc_module_t *spacc_module;
 
-    OPAL_OUTPUT((ompi_coll_spacc_stream, "coll:spacc:module_spacc query called"));
+    opal_output_verbose(30, mca_coll_spacc_stream, "coll:spacc:module_comm_query called");
 
     if (OMPI_COMM_IS_INTER(comm)) {
+        opal_output_verbose(20, mca_coll_spacc_stream,
+                            "coll:spacc:module_comm_query: spacc does not support inter-communicators");
         *priority = 0;
         return NULL;
     }
@@ -53,7 +55,7 @@ mca_coll_base_module_t *ompi_coll_spacc_comm_query(
     if (NULL == spacc_module)
         return NULL;
 
-    *priority = ompi_coll_spacc_priority;
+    *priority = mca_coll_spacc_priority;
 
     spacc_module->super.coll_module_enable = spacc_module_enable;
     spacc_module->super.ft_event = NULL;
@@ -84,7 +86,7 @@ mca_coll_base_module_t *ompi_coll_spacc_comm_query(
 static int spacc_module_enable(mca_coll_base_module_t *module,
                                struct ompi_communicator_t *comm)
 {
-    OPAL_OUTPUT((ompi_coll_spacc_stream, "coll:spacc:module_enable called."));
+    opal_output_verbose(30, mca_coll_spacc_stream, "coll:spacc:module_enable called");
     return OMPI_SUCCESS;
 }
 
diff --git a/ompi/mca/coll/spacc/coll_spacc_reduce.c b/ompi/mca/coll/spacc/coll_spacc_reduce.c
@@ -89,18 +89,19 @@ int mca_coll_spacc_reduce_intra_redscat_gather(
     int comm_size = ompi_comm_size(comm);
     int rank = ompi_comm_rank(comm);
 
-    OPAL_OUTPUT((ompi_coll_spacc_stream,
-                "coll:spacc:reduce_intra_redscat_gather: rank %d/%d, root %d",
-                rank, comm_size, root));
+    opal_output_verbose(30, mca_coll_spacc_stream,
+                        "coll:spacc:reduce_intra_redscat_gather: rank %d/%d, root %d",
+                        rank, comm_size, root);
 
     /* Find nearest power-of-two less than or equal to comm_size */
     int nsteps = opal_hibit(comm_size, comm->c_cube_dim + 1);   /* ilog2(comm_size) */
+    assert(nsteps >= 0);
     int nprocs_pof2 = 1 << nsteps;                              /* flp2(comm_size) */
 
     if (count < nprocs_pof2 || !ompi_op_is_commute(op)) {
-        OPAL_OUTPUT((ompi_coll_spacc_stream,
-                    "coll:spacc:reduce_intra_redscat_gather: rank %d/%d count %d switching to base reduce",
-                    rank, comm_size, count));
+        opal_output_verbose(20, mca_coll_spacc_stream,
+                            "coll:spacc:reduce_intra_redscat_gather: rank %d/%d count %d switching to base reduce",
+                            rank, comm_size, count);
         return ompi_coll_base_reduce_intra_basic_linear(sbuf, rbuf, count, dtype,
                                                         op, root, comm, module);
     }

Original file line number	Diff line number	Diff line change
`@@ -37,9 +37,11 @@ mca_coll_base_module_t *ompi_coll_spacc_comm_query(`
`37`	`37`	`{`
`38`	`38`	`mca_coll_spacc_module_t *spacc_module;`
`39`	`39`
`40`		`- OPAL_OUTPUT((ompi_coll_spacc_stream, "coll:spacc:module_spacc query called"));`
	`40`	`+ opal_output_verbose(30, mca_coll_spacc_stream, "coll:spacc:module_comm_query called");`
`41`	`41`
`42`	`42`	`if (OMPI_COMM_IS_INTER(comm)) {`
	`43`	`+ opal_output_verbose(20, mca_coll_spacc_stream,`
	`44`	`+ "coll:spacc:module_comm_query: spacc does not support inter-communicators");`
`43`	`45`	`*priority = 0;`
`44`	`46`	`return NULL;`
`45`	`47`	`}`
`@@ -53,7 +55,7 @@ mca_coll_base_module_t *ompi_coll_spacc_comm_query(`
`53`	`55`	`if (NULL == spacc_module)`
`54`	`56`	`return NULL;`
`55`	`57`
`56`		`- *priority = ompi_coll_spacc_priority;`
	`58`	`+ *priority = mca_coll_spacc_priority;`
`57`	`59`
`58`	`60`	`spacc_module->super.coll_module_enable = spacc_module_enable;`
`59`	`61`	`spacc_module->super.ft_event = NULL;`
`@@ -84,7 +86,7 @@ mca_coll_base_module_t *ompi_coll_spacc_comm_query(`
`84`	`86`	`static int spacc_module_enable(mca_coll_base_module_t *module,`
`85`	`87`	`struct ompi_communicator_t *comm)`
`86`	`88`	`{`
`87`		`- OPAL_OUTPUT((ompi_coll_spacc_stream, "coll:spacc:module_enable called."));`
	`89`	`+ opal_output_verbose(30, mca_coll_spacc_stream, "coll:spacc:module_enable called");`
`88`	`90`	`return OMPI_SUCCESS;`
`89`	`91`	`}`
`90`	`92`