Skip to content

Commit d5aaeb7

Browse files
committed
btl/ugni: return a descriptor from sendi
Signed-off-by: Nathan Hjelm <[email protected]>
1 parent a19e702 commit d5aaeb7

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

opal/mca/btl/ugni/btl_ugni_send.c

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -119,10 +119,9 @@ int mca_btl_ugni_sendi (struct mca_btl_base_module_t *btl,
119119
int rc;
120120

121121
do {
122-
if (OPAL_UNLIKELY(OPAL_SUCCESS != mca_btl_ugni_check_endpoint_state (endpoint) ||
123-
opal_list_get_size (&endpoint->frag_wait_list))) {
124-
break;
125-
}
122+
BTL_VERBOSE(("btl/ugni isend sending fragment from %d -> %d. length = %" PRIu64
123+
" endoint state %d", OPAL_PROC_MY_NAME.vpid, endpoint->peer_proc->proc_name.vpid,
124+
payload_size + header_size, endpoint->state));
126125

127126
flags |= MCA_BTL_DES_FLAGS_BTL_OWNERSHIP;
128127

@@ -135,7 +134,8 @@ int mca_btl_ugni_sendi (struct mca_btl_base_module_t *btl,
135134
}
136135

137136
assert (packed_size == payload_size);
138-
if (OPAL_UNLIKELY(NULL == frag)) {
137+
if (OPAL_UNLIKELY(NULL == frag || OPAL_SUCCESS != mca_btl_ugni_check_endpoint_state (endpoint) ||
138+
opal_list_get_size (&endpoint->frag_wait_list))) {
139139
break;
140140
}
141141

@@ -152,8 +152,9 @@ int mca_btl_ugni_sendi (struct mca_btl_base_module_t *btl,
152152
} while (0);
153153

154154
if (NULL != descriptor) {
155-
*descriptor = NULL;
155+
*descriptor = &frag->base;
156156
}
157+
157158
return OPAL_ERR_OUT_OF_RESOURCE;
158159
}
159160

0 commit comments

Comments
 (0)