root/ompi/mca/vprotocol/base/vprotocol_base_request.c

DEFINITIONS

1. mca_vprotocol_base_request_parasite

   1 /* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil -*- */
   2 /*
   3  * Copyright (c) 2004-2007 The Trustees of the University of Tennessee.
   4  *                         All rights reserved.
   5  * Copyright (c) 2015      Los Alamos National Security, LLC. All rights
   6  *                         reserved.
   7  * $COPYRIGHT$
   8  *
   9  * Additional copyrights may follow
  10  *
  11  * $HEADER$
  12  */
  13 
  14 #include "ompi_config.h"
  15 #include "vprotocol_base_request.h"
  16 #include "ompi/mca/pml/v/pml_v_output.h"
  17 
  18 int mca_vprotocol_base_request_parasite(void)
  19 {
  20     int ret;
  21 
  22     if(mca_vprotocol.req_recv_class)
  23     {
  24         opal_free_list_t pml_fl_save = mca_pml_base_recv_requests;
  25         mca_pml_v.host_pml_req_recv_size =
  26             pml_fl_save.fl_frag_class->cls_sizeof;
  27         V_OUTPUT_VERBOSE(300, "req_rebuild: recv\tsize %lu+%lu\talignment=%lu", (unsigned long) mca_pml_v.host_pml_req_recv_size, (unsigned long) mca_vprotocol.req_recv_class->cls_sizeof, (unsigned long) pml_fl_save.fl_frag_alignment);
  28         mca_vprotocol.req_recv_class->cls_parent =
  29             pml_fl_save.fl_frag_class;
  30         mca_vprotocol.req_recv_class->cls_sizeof +=
  31             pml_fl_save.fl_frag_class->cls_sizeof;
  32         /* rebuild the requests free list with the right size */
  33         OBJ_DESTRUCT(&mca_pml_base_recv_requests);
  34         OBJ_CONSTRUCT(&mca_pml_base_recv_requests, opal_free_list_t);
  35         ret = opal_free_list_init (&mca_pml_base_recv_requests,
  36                                    mca_vprotocol.req_recv_class->cls_sizeof,
  37                                    pml_fl_save.fl_frag_alignment,
  38                                    mca_vprotocol.req_recv_class,
  39                                    pml_fl_save.fl_payload_buffer_size,
  40                                    pml_fl_save.fl_payload_buffer_alignment,
  41                                    pml_fl_save.fl_num_allocated,
  42                                    pml_fl_save.fl_max_to_alloc,
  43                                    pml_fl_save.fl_num_per_alloc,
  44                                    pml_fl_save.fl_mpool,
  45                                    pml_fl_save.fl_rcache_reg_flags,
  46                                    pml_fl_save.fl_rcache,
  47                                    pml_fl_save.item_init,
  48                                    pml_fl_save.ctx);
  49         if(OMPI_SUCCESS != ret) return ret;
  50     }
  51     if(mca_vprotocol.req_send_class)
  52     {
  53         opal_free_list_t pml_fl_save = mca_pml_base_send_requests;
  54         mca_pml_v.host_pml_req_send_size =
  55             pml_fl_save.fl_frag_class->cls_sizeof;
  56         V_OUTPUT_VERBOSE(300, "req_rebuild: send\tsize %lu+%lu\talignment=%lu", (unsigned long) mca_pml_v.host_pml_req_send_size, (unsigned long) mca_vprotocol.req_send_class->cls_sizeof, (unsigned long) pml_fl_save.fl_frag_alignment);
  57         mca_vprotocol.req_send_class->cls_parent =
  58             pml_fl_save.fl_frag_class;
  59         mca_vprotocol.req_send_class->cls_sizeof +=
  60             pml_fl_save.fl_frag_class->cls_sizeof;
  61         /* rebuild the requests free list with the right size */
  62         OBJ_DESTRUCT(&mca_pml_base_send_requests);
  63         OBJ_CONSTRUCT(&mca_pml_base_send_requests, opal_free_list_t);
  64         ret = opal_free_list_init (&mca_pml_base_send_requests,
  65                                    mca_vprotocol.req_send_class->cls_sizeof,
  66                                    pml_fl_save.fl_frag_alignment,
  67                                    mca_vprotocol.req_send_class,
  68                                    pml_fl_save.fl_payload_buffer_size,
  69                                    pml_fl_save.fl_payload_buffer_alignment,
  70                                    pml_fl_save.fl_num_allocated,
  71                                    pml_fl_save.fl_max_to_alloc,
  72                                    pml_fl_save.fl_num_per_alloc,
  73                                    pml_fl_save.fl_mpool,
  74                                    pml_fl_save.fl_rcache_reg_flags,
  75                                    pml_fl_save.fl_rcache,
  76                                    pml_fl_save.item_init,
  77                                    pml_fl_save.ctx);
  78         if(OMPI_SUCCESS != ret) return ret;
  79     }
  80     return OMPI_SUCCESS;
  81 
  82 }