chech if send request was cached
This commit was SVN r2573.
Этот коммит содержится в:
родитель
1c55827902
Коммит
25b516ae83
@ -208,7 +208,7 @@ int mca_ptl_tcp_send(
|
||||
{
|
||||
mca_ptl_tcp_send_frag_t* sendfrag;
|
||||
int rc;
|
||||
if (offset == 0) {
|
||||
if (offset == 0 && sendreq->req_cached) {
|
||||
sendfrag = &((mca_ptl_tcp_send_request_t*)sendreq)->req_frag;
|
||||
} else {
|
||||
ompi_list_item_t* item;
|
||||
|
@ -381,8 +381,6 @@ mca_ptl_base_module_t** mca_ptl_tcp_component_init(int *num_ptl_modules,
|
||||
bool *have_hidden_threads)
|
||||
{
|
||||
mca_ptl_base_module_t **ptls;
|
||||
int rc;
|
||||
|
||||
*num_ptl_modules = 0;
|
||||
*allow_multi_user_threads = true;
|
||||
*have_hidden_threads = OMPI_HAVE_THREADS;
|
||||
|
@ -95,8 +95,10 @@ static inline void mca_ptl_tcp_send_frag_progress(mca_ptl_tcp_send_frag_t* frag)
|
||||
/* the first fragment is allocated with the request,
|
||||
* all others need to be returned to free list
|
||||
*/
|
||||
if(frag->frag_send.frag_base.frag_header.hdr_frag.hdr_frag_offset != 0)
|
||||
if(request->req_cached == false ||
|
||||
frag->frag_send.frag_base.frag_header.hdr_frag.hdr_frag_offset != 0) {
|
||||
mca_ptl_tcp_send_frag_return(frag->frag_send.frag_base.frag_owner, frag);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user