1
1

-- Update ptl/elan with the latest tree

This commit was SVN r3034.
Этот коммит содержится в:
Weikuan Yu 2004-10-11 02:08:39 +00:00
родитель 508dbc4453
Коммит ad60bfdb6b
3 изменённых файлов: 13 добавлений и 6 удалений

Просмотреть файл

@ -468,6 +468,7 @@ mca_ptl_elan_matched (mca_ptl_base_module_t * ptl,
/* XXX: progress the request based on the status of this recv frag
* It is possible to employ a scheduling logic here.
* Then Done with this fragment, i.e., data */
mca_ptl_elan_recv_frag_done (header, frag, request);
mca_ptl_elan_recv_frag_done (header,
(mca_ptl_elan_recv_frag_t *)frag, request);
}
}

Просмотреть файл

@ -191,8 +191,9 @@ mca_ptl_elan_send_desc_done (
|| mca_pml_base_send_request_matched(req)) {
if(ompi_atomic_fetch_and_set_int (&frag->frag_progressed, 1) == 0)
{
ptl->super.ptl_send_progress(ptl, req,
header->hdr_frag.hdr_frag_length);
ptl->super.ptl_send_progress(
(struct mca_ptl_base_module_t*) ptl,
req, header->hdr_frag.hdr_frag_length);
}
LOG_PRINT(PTL_ELAN_DEBUG_SEND, "return frag %p desc %p type %d\n",

Просмотреть файл

@ -146,7 +146,9 @@ mca_ptl_elan_last_frag_ack (struct mca_ptl_elan_module_t *ptl,
req->req_peer_size);
if(ompi_atomic_fetch_and_set_int (&desc->frag_progressed, 1) == 0) {
ptl->super.ptl_send_progress(ptl, req, header->hdr_ack.hdr_dst_size);
ptl->super.ptl_send_progress(
(struct mca_ptl_base_module_t*) ptl,
req, header->hdr_ack.hdr_dst_size);
}
/* Return a frag or if not cached, or it is a follow up */
@ -424,7 +426,8 @@ mca_ptl_elan_init_put_desc (struct mca_ptl_elan_send_frag_t *frag,
pml_req->req_peer_size);
/* FIXME: initialize convertor and get the fragment copied out */
if(size_in > 0 && 0) {
#if OMPI_PTL_ELAN_USE_DTP
if(size_in > 0) {
struct iovec iov;
ompi_convertor_t *convertor;
@ -458,7 +461,9 @@ mca_ptl_elan_init_put_desc (struct mca_ptl_elan_send_frag_t *frag,
return;
}
size_out = iov.iov_len;
} else {
} else
#endif
{
size_out = size_in;
}