mtl/portals4: Some little patches

PDeveze · PDeveze · commit d48865e691d2 · 2016-07-12T15:07:57.000+02:00
diff --git a/ompi/mca/mtl/portals4/mtl_portals4.h b/ompi/mca/mtl/portals4/mtl_portals4.h
@@ -54,11 +54,11 @@ struct mca_mtl_portals4_module_t {
     /** Size of short message blocks */
     unsigned long long recv_short_size;
     /** Number of short message blocks which should be created during startup */
-    int recv_short_num;
+    uint32_t recv_short_num;
     /** Length of the send event queues */
-    int send_queue_size;
+    uint32_t send_queue_size;
     /** Length of the receive event queues */
-    int recv_queue_size;
+    uint32_t recv_queue_size;
     /** Protocol for long message transfer */
     enum { eager, rndv } protocol;
 
diff --git a/ompi/mca/mtl/portals4/mtl_portals4_component.c b/ompi/mca/mtl/portals4/mtl_portals4_component.c
@@ -224,7 +224,7 @@ ompi_mtl_portals4_component_open(void)
     ompi_mtl_portals4.send_eq_h = PTL_INVALID_HANDLE;
     ompi_mtl_portals4.recv_eq_h = PTL_INVALID_HANDLE;
     ompi_mtl_portals4.zero_md_h = PTL_INVALID_HANDLE;
-
+    ompi_mtl_portals4.send_md_h = PTL_INVALID_HANDLE;
     ompi_mtl_portals4.long_overflow_me_h = PTL_INVALID_HANDLE;
     ompi_mtl_portals4.recv_idx = (ptl_pt_index_t) ~0UL;
     ompi_mtl_portals4.read_idx = (ptl_pt_index_t) ~0UL;
@@ -364,6 +364,7 @@ ompi_mtl_portals4_component_init(bool enable_progress_threads,
                          "My nid,pid = %x,%x",
                          id.phys.nid, id.phys.pid));
 
+    ompi_mtl_portals4.base.mtl_max_tag = MTL_PORTALS4_MAX_TAG;
     return &ompi_mtl_portals4.base;
 
  error:
diff --git a/ompi/mca/mtl/portals4/mtl_portals4_recv.c b/ompi/mca/mtl/portals4/mtl_portals4_recv.c
@@ -91,6 +91,7 @@ ompi_mtl_portals4_recv_progress(ptl_event_t *ev,
             opal_output_verbose(1, ompi_mtl_base_framework.framework_output,
                                 "%s:%d: PTL_EVENT_PUT with ni_fail_type: %d",
                                 __FILE__, __LINE__, ev->ni_fail_type);
+            ret = PTL_FAIL;
             goto callback_error;
         }
 
@@ -118,7 +119,7 @@ ompi_mtl_portals4_recv_progress(ptl_event_t *ev,
                to pull the second part of the message. */
             ret = read_msg((char*) ptl_request->delivery_ptr + ompi_mtl_portals4.eager_limit,
                            ((msg_length > ptl_request->delivery_len) ?
-                            ptl_request->delivery_len : msg_length) - ompi_mtl_portals4.eager_limit,
+                           ptl_request->delivery_len : msg_length) - ompi_mtl_portals4.eager_limit,
                            ev->initiator,
                            ev->hdr_data,
                            ompi_mtl_portals4.eager_limit,
@@ -159,6 +160,7 @@ ompi_mtl_portals4_recv_progress(ptl_event_t *ev,
             opal_output_verbose(1, ompi_mtl_base_framework.framework_output,
                                 "%s:%d: PTL_EVENT_REPLY with ni_fail_type: %d",
                                 __FILE__, __LINE__, ev->ni_fail_type);
+            ret = PTL_FAIL;
             goto callback_error;
         }
 
@@ -204,6 +206,7 @@ ompi_mtl_portals4_recv_progress(ptl_event_t *ev,
             opal_output_verbose(1, ompi_mtl_base_framework.framework_output,
                                 "%s:%d: PTL_EVENT_PUT_OVERFLOW with ni_fail_type: %d",
                                 __FILE__, __LINE__, ev->ni_fail_type);
+            ret = PTL_FAIL;
             goto callback_error;
         }
 
@@ -285,7 +288,7 @@ ompi_mtl_portals4_recv_progress(ptl_event_t *ev,
 
             ret = read_msg((char*) ptl_request->delivery_ptr + ev->mlength,
                            ((msg_length > ptl_request->delivery_len) ?
-                            ptl_request->delivery_len : msg_length) - ev->mlength,
+                           ptl_request->delivery_len : msg_length) - ev->mlength,
                            ev->initiator,
                            ev->hdr_data,
                            ev->mlength,
diff --git a/ompi/mca/mtl/portals4/mtl_portals4_recv_short.c b/ompi/mca/mtl/portals4/mtl_portals4_recv_short.c
@@ -37,6 +37,7 @@ static int
 ompi_mtl_portals4_recv_block_progress(ptl_event_t *ev,
                                      ompi_mtl_portals4_base_request_t* ptl_base_request)
 {
+    int ret  = OMPI_SUCCESS;
     ompi_mtl_portals4_recv_short_request_t *ptl_request =
         (ompi_mtl_portals4_recv_short_request_t*) ptl_base_request;
     ompi_mtl_portals4_recv_short_block_t *block = ptl_request->block;
@@ -58,10 +59,10 @@ ompi_mtl_portals4_recv_block_progress(ptl_event_t *ev,
                         opal_list_remove_item(&ompi_mtl_portals4.recv_short_blocks,
                                               &block->base);
                         OPAL_THREAD_UNLOCK(&ompi_mtl_portals4.short_block_mutex);
-                        ompi_mtl_portals4_recv_short_block_free(block);
+                        ret = ompi_mtl_portals4_recv_short_block_free(block);
                     } else {
                         OPAL_THREAD_UNLOCK(&ompi_mtl_portals4.short_block_mutex);
-                        ompi_mtl_portals4_activate_block(block);
+                        ret = ompi_mtl_portals4_activate_block(block);
                     }
                     break;
 
@@ -89,12 +90,12 @@ ompi_mtl_portals4_recv_block_progress(ptl_event_t *ev,
                         opal_list_remove_item(&ompi_mtl_portals4.recv_short_blocks,
                                               &block->base);
                         OPAL_THREAD_UNLOCK(&ompi_mtl_portals4.short_block_mutex);
-                        ompi_mtl_portals4_recv_short_block_free(block);
+                        ret = ompi_mtl_portals4_recv_short_block_free(block);
                     } else {
                         OPAL_THREAD_UNLOCK(&ompi_mtl_portals4.short_block_mutex);
                         OPAL_OUTPUT_VERBOSE((10, ompi_mtl_base_framework.framework_output,
                                         "mtl:portals4 PTL_EVENT_AUTO_UNLINK received after PTL_EVENT_AUTO_FREE"));
-                        ompi_mtl_portals4_activate_block(block);
+                        ret = ompi_mtl_portals4_activate_block(block);
                     }
                     break;
 
@@ -133,7 +134,7 @@ ompi_mtl_portals4_recv_block_progress(ptl_event_t *ev,
             break;
     }
 
-    return OMPI_SUCCESS;
+    return ret;
 }
 
 
@@ -227,7 +228,7 @@ ompi_mtl_portals4_activate_block(ompi_mtl_portals4_recv_short_block_t *block)
 int
 ompi_mtl_portals4_recv_short_init(void)
 {
-    int i;
+    uint32_t i;
 
     OBJ_CONSTRUCT(&ompi_mtl_portals4.short_block_mutex, opal_mutex_t);
     OBJ_CONSTRUCT(&(ompi_mtl_portals4.recv_short_blocks), opal_list_t);
