This source file includes following definitions.
- mca_pml_monitoring_start
   1 
   2 
   3 
   4 
   5 
   6 
   7 
   8 
   9 
  10 
  11 
  12 
  13 #include <ompi_config.h>
  14 #include "pml_monitoring.h"
  15 #include <ompi/mca/pml/base/pml_base_request.h>
  16 
  17 
  18 int mca_pml_monitoring_start(size_t count,
  19                              ompi_request_t** requests)
  20 {
  21     size_t i;
  22 
  23     for( i = 0; i < count; i++ ) {
  24         mca_pml_base_request_t *pml_request = (mca_pml_base_request_t*)requests[i];
  25         int world_rank;
  26 
  27         if(NULL == pml_request) {
  28             continue;
  29         }
  30         if(OMPI_REQUEST_PML != requests[i]->req_type) {
  31             continue;
  32         }
  33         if(MCA_PML_REQUEST_SEND != pml_request->req_type) {
  34             continue;
  35         }
  36 
  37         
  38 
  39 
  40         if(OPAL_SUCCESS == mca_common_monitoring_get_world_rank(pml_request->req_peer,
  41                                                                 pml_request->req_comm->c_remote_group,
  42                                                                 &world_rank)) {
  43             size_t type_size, data_size;
  44             ompi_datatype_type_size(pml_request->req_datatype, &type_size);
  45             data_size = pml_request->req_count * type_size;
  46             mca_common_monitoring_record_pml(world_rank, data_size, 1);
  47         }
  48     }
  49     return pml_selected_module.pml_start(count, requests);
  50 }
  51