move setting of the component used to managed buffer sends out of the

pmls, and into ompi_mpi_init.  This is the first of several steps to pull
buffered send management out of the pmls.

This commit was SVN r15451.

ompi/mca/pml/cm/pml_cm_component.c

@@ -148,12 +148,6 @@ mca_pml_cm_component_init(int* priority,
     ompi_pml_cm.super.pml_max_contextid = ompi_mtl->mtl_max_contextid;
     ompi_pml_cm.super.pml_max_tag = ompi_mtl->mtl_max_tag;
     
-    /* initialize buffered send code */
-    if(OMPI_SUCCESS != mca_pml_base_bsend_init(enable_mpi_threads)) {
-        opal_output(0, "mca_pml_cm_component_init: mca_pml_bsend_init failed\n");
-        return NULL;
-    }
-
     return &ompi_pml_cm.super;
 }
 

ompi/mca/pml/dr/pml_dr_component.c

@@ -143,13 +143,6 @@ mca_pml_base_module_t* mca_pml_dr_component_init(int* priority,
     }
     *priority = mca_pml_dr.priority;
        
-    /* buffered send */
-    if(OMPI_SUCCESS != mca_pml_base_bsend_init(enable_mpi_threads)) {
-        opal_output(0, "mca_pml_dr_component_init: mca_pml_bsend_init failed\n");
-        return NULL;
-    }
-    
-    
     if(OMPI_SUCCESS != mca_bml_base_init( enable_progress_threads, 
                                           enable_mpi_threads )) {
         return NULL; 

ompi/mca/pml/ob1/pml_ob1_component.c

@@ -177,13 +177,6 @@ mca_pml_ob1_component_init( int* priority,
     }
     *priority = mca_pml_ob1.priority;
 
-    /* buffered send */
-    if(OMPI_SUCCESS != mca_pml_base_bsend_init(enable_mpi_threads)) {
-        opal_output(0, "mca_pml_ob1_component_init: mca_pml_bsend_init failed\n");
-        return NULL;
-    }
-
-    
     if(OMPI_SUCCESS != mca_bml_base_init( enable_progress_threads, 
                                           enable_mpi_threads)) {
         return NULL;

ompi/runtime/ompi_mpi_init.c

@@ -423,6 +423,13 @@ int ompi_mpi_init(int argc, char **argv, int requested, int *provided)
         goto error;
     }
 
+    /* select buffered send allocator component to be used */
+    ret=mca_pml_base_bsend_init(OMPI_ENABLE_MPI_THREADS);
+    if( OMPI_SUCCESS != ret ) {
+        error = "mca_pml_base_bsend_init() failed";
+        goto error;
+    }
+
     if (OMPI_SUCCESS != 
         (ret = mca_coll_base_find_available(OMPI_ENABLE_PROGRESS_THREADS,
                                             OMPI_ENABLE_MPI_THREADS))) {