root/ompi/mca/vprotocol/example/vprotocol_example_recv.c

DEFINITIONS

1. mca_vprotocol_example_irecv_init
2. mca_vprotocol_example_irecv
3. mca_vprotocol_example_recv

   1 /*
   2  * Copyright (c) 2004-2007 The Trustees of the University of Tennessee.
   3  *                         All rights reserved.
   4  * Copyright (c) 2010      The University of Tennessee and The University
   5  *                         of Tennessee Research Foundation.  All rights
   6  *                         reserved.
   7  * $COPYRIGHT$
   8  *
   9  * Additional copyrights may follow
  10  *
  11  * $HEADER$
  12  */
  13 
  14 #include "ompi_config.h"
  15 #include "../pml_v.h"
  16 #include "vprotocol_example.h"
  17 
  18 int mca_vprotocol_example_irecv_init(void *addr,
  19                       size_t count,
  20                       struct ompi_datatype_t *datatype,
  21                       int src,
  22                       int tag,
  23                       struct ompi_communicator_t* comm,
  24                       struct ompi_request_t **request )
  25 {
  26   int ret;
  27 
  28   ret = mca_pml_v.host_pml.pml_irecv_init(addr, count, datatype, src, tag, comm, request);
  29   V_OUTPUT_VERBOSE(50, "posted\tirecv_init %ld\tcomm %d\tfrom %d\ttag %d\tsize %ld", ((mca_pml_base_request_t *)*request)->req_sequence, comm->c_contextid, src, tag, (long) count);
  30   return ret;
  31 }
  32 
  33 int mca_vprotocol_example_irecv(void *addr,
  34                      size_t count,
  35                      ompi_datatype_t * datatype,
  36                      int src,
  37                      int tag,
  38                      struct ompi_communicator_t *comm,
  39                      struct ompi_request_t **request)
  40 {
  41   int ret;
  42 
  43   ret = mca_pml_v.host_pml.pml_irecv(addr, count, datatype, src, tag, comm, request);
  44   V_OUTPUT_VERBOSE(50, "posted\tirecv %ld\tcomm %d\tfrom %d\ttag %d\tsize %ld", ((mca_pml_base_request_t *)*request)->req_sequence, comm->c_contextid, src, tag, (long) count);
  45   return ret;
  46 }
  47 
  48 int mca_vprotocol_example_recv(void *addr,
  49                       size_t count,
  50                       ompi_datatype_t * datatype,
  51                       int src,
  52                       int tag,
  53                       struct ompi_communicator_t *comm,
  54                       ompi_status_public_t * status )
  55 {
  56   int ret;
  57   V_OUTPUT_VERBOSE(50, "posted\trecv \tcomm %d\tfrom %d\ttag %d\tsize %ld", comm->c_contextid, src, tag, (long) count);
  58   ret = mca_pml_v.host_pml.pml_recv(addr, count, datatype, src, tag, comm, status);
  59 # ifdef OPAL_ENABLE_DEBUG
  60     if(status)
  61       V_OUTPUT_VERBOSE(75, "deliver\trecv \tcomm %d\tfrom %d(%d)\ttag %d(%d)\tsize %ld(%ld)\tstatus %d", comm->c_contextid, src, status->MPI_SOURCE, tag, status->MPI_TAG, (long) count, (long) status->_ucount, status->MPI_ERROR);
  62     else
  63       V_OUTPUT_VERBOSE(75, "deliver\trecv \tcomm %d\tfrom %d\ttag %d\tsize %ld", comm->c_contextid, src, tag, (long) count);
  64 # endif
  65   return ret;
  66 }