Fix immediate completion notification of sends in NA SM
@@ -3003,6 +3003,14 @@ na_sm_msg_send_unexpected(na_class_t *na_class, na_context_t *context,
goto done;
}
+ /* Notify local completion */
+ if (hg_event_set(NA_SM_PRIVATE_DATA(na_class)->self_addr->local_notify)
+ != HG_UTIL_SUCCESS) {
+ NA_LOG_ERROR("Could not signal local completion");
+ ret = NA_PROTOCOL_ERROR;
+ goto done;
+ }
+
done:
if (ret != NA_SUCCESS) {
na_sm_op_destroy(na_class, (na_op_id_t) na_sm_op_id);
@@ -3183,6 +3191,14 @@ na_sm_msg_send_expected(na_class_t NA_UNUSED *na_class, na_context_t *context,
goto done;
}
+ /* Notify local completion */
+ if (hg_event_set(NA_SM_PRIVATE_DATA(na_class)->self_addr->local_notify)
+ != HG_UTIL_SUCCESS) {
+ NA_LOG_ERROR("Could not signal local completion");
+ ret = NA_PROTOCOL_ERROR;
+ goto done;
+ }
+
done:
if (ret != NA_SUCCESS) {
na_sm_op_destroy(na_class, (na_op_id_t) na_sm_op_id);
