ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

Improved error detection of request types

Просмотр исходного кода 
This commit was SVN r15857.
Этот коммит содержится в:
Aurelien Bouteiller 2007-08-14 17:24:46 +00:00
родитель 67399e7c31
Коммит fa7f6f6722
2 изменённых файлов: 8 добавлений и 9 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

6
ompi/mca/pml/v/protocol_pessimist/vprotocol_pessimist_sender_based.c
Просмотреть файл

@ -72,9 +72,9 @@ void vprotocol_pessimist_sender_based_alloc(size_t len)
munmap(sb.sb_addr, sb.sb_length); munmap(sb.sb_addr, sb.sb_length);
/* Take care of alignement of sb_offset */ /* Take care of alignement of sb_offset */
sb.sb_offset += (intptr_t) sb.sb_cursor - (intptr_t) sb.sb_addr; sb.sb_offset += (uintptr_t) sb.sb_cursor - (uintptr_t) sb.sb_addr;
sb.sb_cursor = (char *) ((intptr_t) (sb.sb_offset % sb.sb_pagesize)); sb.sb_cursor = (char *) ((uintptr_t) (sb.sb_offset % sb.sb_pagesize));
sb.sb_offset -= (intptr_t) sb.sb_cursor; sb.sb_offset -= (uintptr_t) sb.sb_cursor;
/* Adjusting sb_length for the largest application message to fit */ /* Adjusting sb_length for the largest application message to fit */
if(sb.sb_length < len) if(sb.sb_length < len)

11
ompi/mca/pml/v/protocol_pessimist/vprotocol_pessimist_sender_based.h
Просмотреть файл

@ -74,12 +74,12 @@ void vprotocol_pessimist_sender_based_alloc(size_t len);
mca_vprotocol_pessimist.sender_based.sb_cursor, \ mca_vprotocol_pessimist.sender_based.sb_cursor, \
req->req_bytes_packed, MPI_PACKED, 0, 0, \ req->req_bytes_packed, MPI_PACKED, 0, 0, \
mca_vprotocol_pessimist.sender_based.sb_comm, \ mca_vprotocol_pessimist.sender_based.sb_comm, \
& VPESSIMIST_REQ(req)->sb_reqs[0]); \ &VPESSIMIST_SEND_REQ(req)->sb_reqs[0]); \
mca_pml_v.host_pml.pml_isend(req->req_base.req_addr, \ mca_pml_v.host_pml.pml_isend(req->req_base.req_addr, \
req->req_base.req_count, req->req_base.req_datatype, 0, 0, \ req->req_base.req_count, req->req_base.req_datatype, 0, 0, \
MCA_PML_BASE_SEND_READY, \ MCA_PML_BASE_SEND_READY, \
mca_vprotocol_pessimist.sender_based.sb_comm, \ mca_vprotocol_pessimist.sender_based.sb_comm, \
& VPESSIMIST_REQ(req)->sb_reqs[1]); \ &VPESSIMIST_SEND_REQ(req)->sb_reqs[1]); \
} while(0); } while(0);
#define __SENDER_BASED_PACK(req) do { \ #define __SENDER_BASED_PACK(req) do { \
@ -94,7 +94,7 @@ void vprotocol_pessimist_sender_based_alloc(size_t len);
mca_vprotocol_pessimist.sender_based.sb_cursor += \ mca_vprotocol_pessimist.sender_based.sb_cursor += \
sizeof(vprotocol_pessimist_sender_based_header_t); \ sizeof(vprotocol_pessimist_sender_based_header_t); \
\ \
__SENDER_BASED_IOV_PACK(req); \ __SENDER_BASED_SENDRECV_PACK(req); \
mca_vprotocol_pessimist.sender_based.sb_cursor += sbhdr->size; \ mca_vprotocol_pessimist.sender_based.sb_cursor += sbhdr->size; \
mca_vprotocol_pessimist.sender_based.sb_vacant -= (sbhdr->size + \ mca_vprotocol_pessimist.sender_based.sb_vacant -= (sbhdr->size + \
sizeof(vprotocol_pessimist_sender_based_header_t)); \ sizeof(vprotocol_pessimist_sender_based_header_t)); \
@ -117,9 +117,8 @@ void vprotocol_pessimist_sender_based_alloc(size_t len);
/** Ensure sender based is finished before allowing user to touch send buffer /** Ensure sender based is finished before allowing user to touch send buffer
*/ */
#define VPROTOCOL_PESSIMIST_SENDER_BASED_FLUSH(REQ) #define VPROTOCOL_PESSIMIST_SENDER_BASED_FLUSH(REQ) do { \
#define DUMMYCOMMENT do { \ if(NULL != VPESSIMIST_REQ(REQ)->sb_reqs[0]) \
if(VPESSIMIST_REQ(REQ)->sb_reqs[0]) \
{ \ { \
ompi_request_wait_all(2, VPESSIMIST_REQ(REQ)->sb_reqs, \ ompi_request_wait_all(2, VPESSIMIST_REQ(REQ)->sb_reqs, \
MPI_STATUSES_IGNORE); \ MPI_STATUSES_IGNORE); \