fix for latency issue
This commit was SVN r1715.
Этот коммит содержится в:
родитель
1cafe1b6c0
Коммит
ae9a547055
@ -167,14 +167,11 @@ int mca_ptl_tcp_peer_send(mca_ptl_base_peer_t* ptl_peer, mca_ptl_tcp_send_frag_t
|
|||||||
if (NULL != ptl_peer->peer_send_frag) {
|
if (NULL != ptl_peer->peer_send_frag) {
|
||||||
ompi_list_append(&ptl_peer->peer_frags, (ompi_list_item_t*)frag);
|
ompi_list_append(&ptl_peer->peer_frags, (ompi_list_item_t*)frag);
|
||||||
} else {
|
} else {
|
||||||
#if 0
|
|
||||||
if(mca_ptl_tcp_send_frag_handler(frag, ptl_peer->peer_sd)) {
|
if(mca_ptl_tcp_send_frag_handler(frag, ptl_peer->peer_sd)) {
|
||||||
OMPI_THREAD_UNLOCK(&ptl_peer->peer_send_lock);
|
OMPI_THREAD_UNLOCK(&ptl_peer->peer_send_lock);
|
||||||
mca_ptl_tcp_send_frag_progress(frag);
|
mca_ptl_tcp_send_frag_progress(frag);
|
||||||
return rc;
|
return rc;
|
||||||
} else
|
} else {
|
||||||
#endif
|
|
||||||
{
|
|
||||||
ptl_peer->peer_send_frag = frag;
|
ptl_peer->peer_send_frag = frag;
|
||||||
ompi_event_add(&ptl_peer->peer_send_event, 0);
|
ompi_event_add(&ptl_peer->peer_send_event, 0);
|
||||||
}
|
}
|
||||||
|
Загрузка…
Ссылка в новой задаче
Block a user