Fix SPC for all partitionned communications.

Signed-off-by: George Bosilca <[email protected]>

Author: bosilca

ompi/mpi/c/parrived.c

@@ -47,7 +47,7 @@ int MPI_Parrived(MPI_Request request, MPI_Count partition,  int *flag)
 {
     int rc;
 
-    SPC_RECORD(OMPI_SPC_ARRIVED, 1);
+    SPC_RECORD(OMPI_SPC_PARRIVED, 1);
 
     if (MPI_PARAM_CHECK) {
         rc = OMPI_SUCCESS;

ompi/mpi/c/precv_init.c

@@ -48,8 +48,6 @@ int MPI_Precv_init(void* buf, int partitions, MPI_Count count, MPI_Datatype data
 {
     int rc;
 
-    SPC_RECORD(OMPI_SPC_ARRIVED, 1);
-
     if (MPI_PARAM_CHECK) {
         rc = OMPI_SUCCESS;
 

ompi/mpi/c/psend_init.c

@@ -48,8 +48,6 @@ int MPI_Psend_init(const void* buf, int partitions, MPI_Count count, MPI_Datatyp
 {
     int rc;
 
-    SPC_RECORD(OMPI_SPC_ARRIVED, 1);
-
     if (MPI_PARAM_CHECK) {
         rc = OMPI_SUCCESS;
 

ompi/runtime/ompi_spc.c

@@ -166,9 +166,11 @@ static const ompi_spc_event_t ompi_spc_events_desc[OMPI_SPC_NUM_COUNTERS] = {
     SET_COUNTER_ARRAY(OMPI_SPC_MAX_UNEXPECTED_IN_QUEUE, "The maximum number of messages that the unexpected message queue(s) within an MPI process "
                                                     "contained at once since the last reset of this counter. Note: This counter is reset each time it is read.", true, false),
     SET_COUNTER_ARRAY(OMPI_SPC_MAX_OOS_IN_QUEUE, "The maximum number of messages that the out of sequence message queue(s) within an MPI process "
-                                             "contained at once since the last reset of this counter. Note: This counter is reset each time it is read.", true, false)
+                                             "contained at once since the last reset of this counter. Note: This counter is reset each time it is read.", true, false),
     SET_COUNTER_ARRAY(OMPI_SPC_ISENDRECV, "The number of times MPI_Isendrecv was called.", false, false),
     SET_COUNTER_ARRAY(OMPI_SPC_ISENDRECV_REPLACE, "The number of times MPI_Isendrecv_replace was called.", false, false),
+    SET_COUNTER_ARRAY(OMPI_SPC_PARRIVED, "The number of times MPI_Parrived was called.", false, false),
+    SET_COUNTER_ARRAY(OMPI_SPC_PREADY, "The number of times MPI_Pready (or similar functions) was called.", false, false),
 };
 
 /* An array of event structures to store the event data (value, attachments, flags) */

ompi/runtime/ompi_spc.h

@@ -154,6 +154,8 @@ typedef enum ompi_spc_counters {
     OMPI_SPC_MAX_OOS_IN_QUEUE,
     OMPI_SPC_ISENDRECV,
     OMPI_SPC_ISENDRECV_REPLACE,
+    OMPI_SPC_PARRIVED,
+    OMPI_SPC_PREADY,
     OMPI_SPC_NUM_COUNTERS /* This serves as the number of counters.  It must be last. */
 } ompi_spc_counters_t;