-- Fix up elan_put address
-- Need attention on flow control and the number of outstanding DMA This commit was SVN r2501.
Этот коммит содержится в:
родитель
254bce7f43
Коммит
100e24b072
@ -424,7 +424,10 @@ mca_ptl_elan_init_put_desc (struct mca_ptl_elan_send_frag_t *frag,
|
|||||||
hdr->hdr_frag.hdr_src_ptr.pval = frag; /* No need to hook a frag */
|
hdr->hdr_frag.hdr_src_ptr.pval = frag; /* No need to hook a frag */
|
||||||
hdr->hdr_frag.hdr_dst_ptr = pml_req->req_peer_match;
|
hdr->hdr_frag.hdr_dst_ptr = pml_req->req_peer_match;
|
||||||
hdr->hdr_frag.hdr_frag_length = size_in;
|
hdr->hdr_frag.hdr_frag_length = size_in;
|
||||||
desc->src_elan_addr = elan4_main2elan (ctx, pml_req->req_base.req_addr);
|
|
||||||
|
/* FIXME: provide a fix according to data contiguity */
|
||||||
|
desc->src_elan_addr = elan4_main2elan (ctx,
|
||||||
|
((char *)pml_req->req_base.req_addr + offset));
|
||||||
desc->dst_elan_addr = (E4_Addr)pml_req->req_peer_addr.lval;
|
desc->dst_elan_addr = (E4_Addr)pml_req->req_peer_addr.lval;
|
||||||
desc->desc_buff = hdr;
|
desc->desc_buff = hdr;
|
||||||
LOG_PRINT(PTL_ELAN_DEBUG_PUT, " remote req %p addr %lx, length %d\n",
|
LOG_PRINT(PTL_ELAN_DEBUG_PUT, " remote req %p addr %lx, length %d\n",
|
||||||
|
@ -103,7 +103,7 @@ do { \
|
|||||||
#define OMPI_PTL_ELAN_ZERO_FFRAG (0)
|
#define OMPI_PTL_ELAN_ZERO_FFRAG (0)
|
||||||
|
|
||||||
#define OMPI_PTL_ELAN_ENABLE_GET (0)
|
#define OMPI_PTL_ELAN_ENABLE_GET (0)
|
||||||
#define OMPI_PTL_ELAN_COMP_QUEUE (1)
|
#define OMPI_PTL_ELAN_COMP_QUEUE (0)
|
||||||
#define OMPI_PTL_ELAN_THREADING \
|
#define OMPI_PTL_ELAN_THREADING \
|
||||||
(OMPI_PTL_ELAN_COMP_QUEUE && OMPI_HAVE_POSIX_THREADS)
|
(OMPI_PTL_ELAN_COMP_QUEUE && OMPI_HAVE_POSIX_THREADS)
|
||||||
|
|
||||||
|
@ -9,7 +9,7 @@
|
|||||||
|
|
||||||
#define MYBUFSIZE (4*1024*1024)
|
#define MYBUFSIZE (4*1024*1024)
|
||||||
#define CHECK 1
|
#define CHECK 1
|
||||||
#define PONG 0
|
#define PONG 1
|
||||||
|
|
||||||
char s_buf[MYBUFSIZE];
|
char s_buf[MYBUFSIZE];
|
||||||
char r_buf[MYBUFSIZE];
|
char r_buf[MYBUFSIZE];
|
||||||
|
Загрузка…
Ссылка в новой задаче
Block a user