Add 2 new MCA parameters to set the size of the expected and unexpected

queues.

This commit was SVN r15206.

ompi/mca/mtl/portals/mtl_portals.c

@@ -83,13 +83,13 @@ ompi_mtl_portals_add_procs(struct mca_mtl_base_module_t *mtl,
 
         /* initialize the event queues */
         ret = PtlEQAlloc(ompi_mtl_portals.ptl_ni_h,
-                        1024, /* BWB - fix me */
+                         ompi_mtl_portals.ptl_expected_queue_size,
                          PTL_EQ_HANDLER_NONE,
                          &(ompi_mtl_portals.ptl_eq_h));
         assert(ret == PTL_OK);
 
         ret = PtlEQAlloc(ompi_mtl_portals.ptl_ni_h,
-                         1024, /* BWB - fix me */
+                         ompi_mtl_portals.ptl_unexpected_queue_size,
                          PTL_EQ_HANDLER_NONE,
                          &(ompi_mtl_portals.ptl_unexpected_recv_eq_h));
         assert(ret == PTL_OK);

ompi/mca/mtl/portals/mtl_portals.h

@@ -58,6 +58,9 @@ struct mca_mtl_portals_module_t {
     
     opal_list_t ptl_recv_short_blocks;
     opal_list_t unexpected_messages;
+
+    int ptl_expected_queue_size;
+    int ptl_unexpected_queue_size;
 };
 typedef struct mca_mtl_portals_module_t mca_mtl_portals_module_t;
 

ompi/mca/mtl/portals/mtl_portals_component.c

@@ -100,6 +100,22 @@ ompi_mtl_portals_component_open(void)
 
     ompi_mtl_portals.ptl_ni_h = PTL_INVALID_HANDLE;
 
+    mca_base_param_reg_int(&mca_mtl_portals_component.mtl_version,
+                           "expected_queue_size",
+                           "Size of the expected receive queue in bytes",
+                           false,
+                           false,
+                           1024,
+                           &ompi_mtl_portals.ptl_expected_queue_size);
+
+    mca_base_param_reg_int(&mca_mtl_portals_component.mtl_version,
+                           "unexpected_queue_size",
+                           "Size of the unexpected receive queue in bytes",
+                           false,
+                           false,
+                           1024,
+                           &ompi_mtl_portals.ptl_unexpected_queue_size);
+
     return OMPI_SUCCESS;
 }