pml/ob1: add SPC instrumentation of sent fin messages

devreal · devreal · commit a9ed53aa6644 · 2020-09-28T15:19:29.000+02:00
Signed-off-by: Joseph Schuchart &lt;schuchart@icl.utk.edu&gt;
diff --git a/ompi/mca/pml/ob1/pml_ob1.c b/ompi/mca/pml/ob1/pml_ob1.c
@@ -47,6 +47,7 @@
 #include "ompi/mca/bml/base/base.h"
 #include "opal/mca/pmix/pmix-internal.h"
 #include "ompi/runtime/ompi_cr.h"
+#include "ompi/runtime/ompi_spc.h"
 
 #include "pml_ob1.h"
 #include "pml_ob1_component.h"
@@ -708,6 +709,7 @@ int mca_pml_ob1_send_fin( ompi_proc_t* proc,
         if( OPAL_LIKELY( 1 == rc ) ) {
             MCA_PML_OB1_PROGRESS_PENDING(bml_btl);
         }
+        SPC_RECORD(OMPI_SPC_BYTES_SENT_MPI, (ompi_spc_value_t)sizeof(mca_pml_ob1_fin_hdr_t));
         return OMPI_SUCCESS;
     }
     mca_bml_base_free(bml_btl, fin);

Original file line number	Diff line number	Diff line change
`@@ -47,6 +47,7 @@`
`47`	`47`	`#include "ompi/mca/bml/base/base.h"`
`48`	`48`	`#include "opal/mca/pmix/pmix-internal.h"`
`49`	`49`	`#include "ompi/runtime/ompi_cr.h"`
	`50`	`+#include "ompi/runtime/ompi_spc.h"`
`50`	`51`
`51`	`52`	`#include "pml_ob1.h"`
`52`	`53`	`#include "pml_ob1_component.h"`
`@@ -708,6 +709,7 @@ int mca_pml_ob1_send_fin( ompi_proc_t* proc,`
`708`	`709`	`if( OPAL_LIKELY( 1 == rc ) ) {`
`709`	`710`	`MCA_PML_OB1_PROGRESS_PENDING(bml_btl);`
`710`	`711`	`}`
	`712`	`+ SPC_RECORD(OMPI_SPC_BYTES_SENT_MPI, (ompi_spc_value_t)sizeof(mca_pml_ob1_fin_hdr_t));`
`711`	`713`	`return OMPI_SUCCESS;`
`712`	`714`	`}`
`713`	`715`	`mca_bml_base_free(bml_btl, fin);`