root/ompi/mca/vprotocol/pessimist/vprotocol_pessimist_start.c

DEFINITIONS

1. mca_vprotocol_pessimist_start

   1 /*
   2  * Copyright (c) 2004-2007 The Trustees of the University of Tennessee.
   3  *                         All rights reserved.
   4  * $COPYRIGHT$
   5  *
   6  * Additional copyrights may follow
   7  *
   8  * $HEADER$
   9  */
  10 
  11 #include "ompi_config.h"
  12 #include "vprotocol_pessimist.h"
  13 
  14 OMPI_DECLSPEC int mca_vprotocol_pessimist_start(size_t count, ompi_request_t **requests)
  15 {
  16   int ret;
  17   size_t i;
  18 
  19   for(i = 0; i < count; i++)
  20   {
  21     mca_pml_base_request_t *pml_request = (mca_pml_base_request_t *) requests[i];
  22     if(NULL == pml_request) continue;
  23 
  24     switch(pml_request->req_type)
  25     {
  26       case MCA_PML_REQUEST_RECV :
  27         V_OUTPUT_VERBOSE(50, "pessimist:\tstart\trecv\t%"PRIpclock"\tfrom %d\ttag %d\tsize %lu", mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count);
  28         /* It's a persistent recv request, first, see if we have to enforce matching order */
  29         VPROTOCOL_PESSIMIST_MATCHING_REPLAY(pml_request->req_peer);
  30         break;
  31 
  32       case MCA_PML_REQUEST_SEND :
  33         V_OUTPUT_VERBOSE(50, "pessimist:\tstart\tsend\t%"PRIpclock"\tto %d\ttag %d\tsize %lu", mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count);
  34         /* It's a persistent send request, first, check if we are waiting ack
  35          * for some older events */
  36         break;
  37 
  38       default:
  39         V_OUTPUT_VERBOSE(50, "pessimist:\tstart\twrong %d\t%"PRIpclock"\tfrom %d\ttag %d\tsize %lu", pml_request->req_type, mca_vprotocol_pessimist.clock, pml_request->req_peer, pml_request->req_tag, (long) pml_request->req_count);
  40         return OMPI_ERR_REQUEST;
  41     }
  42   }
  43   ret = mca_pml_v.host_pml.pml_start(count, requests);
  44 
  45   /* restore requests status */
  46   return ret;
  47 }