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

Still tracking useless dependencies ...

Просмотр исходного кода 
This commit was SVN r5782.
Этот коммит содержится в:
George Bosilca 2005-05-19 22:39:04 +00:00
родитель de4d7d2be3
Коммит af9195eee7
8 изменённых файлов: 34 добавлений и 33 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

13
src/mca/pml/pml.h
Просмотреть файл

@ -64,7 +64,6 @@
#include "ompi_config.h"
#include "class/ompi_list.h"
#include "communicator/communicator.h"
#include "datatype/datatype.h"
#include "request/request.h"
#include "mca/mca.h"
#include "mpi.h" /* needed for MPI_ANY_TAG */
@ -241,7 +240,7 @@ typedef int (*mca_pml_base_module_del_comm_fn_t)(struct ompi_communicator_t* com
typedef int (*mca_pml_base_module_irecv_init_fn_t)(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,
@ -263,7 +262,7 @@ typedef int (*mca_pml_base_module_irecv_init_fn_t)(
typedef int (*mca_pml_base_module_irecv_fn_t)(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,
@ -285,7 +284,7 @@ typedef int (*mca_pml_base_module_irecv_fn_t)(
typedef int (*mca_pml_base_module_recv_fn_t)(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,
@ -308,7 +307,7 @@ typedef int (*mca_pml_base_module_recv_fn_t)(
typedef int (*mca_pml_base_module_isend_init_fn_t)(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,
@ -333,7 +332,7 @@ typedef int (*mca_pml_base_module_isend_init_fn_t)(
typedef int (*mca_pml_base_module_isend_fn_t)(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,
@ -357,7 +356,7 @@ typedef int (*mca_pml_base_module_isend_fn_t)(
typedef int (*mca_pml_base_module_send_fn_t)(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,

12
src/mca/pml/teg/pml_teg.h
Просмотреть файл

@ -149,7 +149,7 @@ extern int mca_pml_teg_cancelled(
extern int mca_pml_teg_isend_init(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,
@ -160,7 +160,7 @@ extern int mca_pml_teg_isend_init(
extern int mca_pml_teg_isend(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,
@ -171,7 +171,7 @@ extern int mca_pml_teg_isend(
extern int mca_pml_teg_send(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,
@ -181,7 +181,7 @@ extern int mca_pml_teg_send(
extern int mca_pml_teg_irecv_init(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,
@ -191,7 +191,7 @@ extern int mca_pml_teg_irecv_init(
extern int mca_pml_teg_irecv(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,
@ -201,7 +201,7 @@ extern int mca_pml_teg_irecv(
extern int mca_pml_teg_recv(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,

6
src/mca/pml/teg/pml_teg_irecv.c
Просмотреть файл

@ -21,7 +21,7 @@
int mca_pml_teg_irecv_init(void *addr,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int src,
int tag,
struct ompi_communicator_t *comm,
@ -43,7 +43,7 @@ int mca_pml_teg_irecv_init(void *addr,
int mca_pml_teg_irecv(void *addr,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int src,
int tag,
struct ompi_communicator_t *comm,
@ -71,7 +71,7 @@ int mca_pml_teg_irecv(void *addr,
int mca_pml_teg_recv(void *addr,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int src,
int tag,
struct ompi_communicator_t *comm,

6
src/mca/pml/teg/pml_teg_isend.c
Просмотреть файл

@ -24,7 +24,7 @@
int mca_pml_teg_isend_init(void *buf,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int dst,
int tag,
mca_pml_base_send_mode_t sendmode,
@ -52,7 +52,7 @@ int mca_pml_teg_isend_init(void *buf,
int mca_pml_teg_isend(void *buf,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int dst,
int tag,
mca_pml_base_send_mode_t sendmode,
@ -79,7 +79,7 @@ int mca_pml_teg_isend(void *buf,
int mca_pml_teg_send(void *buf,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int dst,
int tag,
mca_pml_base_send_mode_t sendmode,

6
src/mca/pml/teg/pml_teg_sendreq.c
Просмотреть файл

@ -79,8 +79,8 @@ OBJ_CLASS_INSTANCE(
int mca_pml_teg_send_request_schedule(mca_ptl_base_send_request_t* req)
{
ompi_proc_t *proc = ompi_comm_peer_lookup(req->req_send.req_base.req_comm, req->req_send.req_base.req_peer);
mca_pml_proc_t* proc_pml = proc->proc_pml;
ompi_proc_t *proc;
mca_pml_proc_t* proc_pml;
int send_count = 0;
size_t bytes_remaining;
size_t num_ptl_avail;
@ -93,6 +93,8 @@ int mca_pml_teg_send_request_schedule(mca_ptl_base_send_request_t* req)
* the scheduling logic once for every call.
*/
if(OMPI_THREAD_ADD32(&req->req_lock,1) == 1) {
proc = ompi_comm_peer_lookup(req->req_send.req_base.req_comm, req->req_send.req_base.req_peer);
proc_pml = proc->proc_pml;
do {
/* allocate remaining bytes to PTLs */
bytes_remaining = req->req_send.req_bytes_packed - req->req_offset;

12
src/mca/pml/uniq/pml_uniq.h
Просмотреть файл

@ -147,7 +147,7 @@ extern int mca_pml_uniq_cancelled(
extern int mca_pml_uniq_isend_init(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,
@ -158,7 +158,7 @@ extern int mca_pml_uniq_isend_init(
extern int mca_pml_uniq_isend(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,
@ -169,7 +169,7 @@ extern int mca_pml_uniq_isend(
extern int mca_pml_uniq_send(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int dst,
int tag,
mca_pml_base_send_mode_t mode,
@ -179,7 +179,7 @@ extern int mca_pml_uniq_send(
extern int mca_pml_uniq_irecv_init(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,
@ -189,7 +189,7 @@ extern int mca_pml_uniq_irecv_init(
extern int mca_pml_uniq_irecv(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,
@ -199,7 +199,7 @@ extern int mca_pml_uniq_irecv(
extern int mca_pml_uniq_recv(
void *buf,
size_t count,
ompi_datatype_t *datatype,
struct ompi_datatype_t *datatype,
int src,
int tag,
struct ompi_communicator_t* comm,

6
src/mca/pml/uniq/pml_uniq_irecv.c
Просмотреть файл

@ -21,7 +21,7 @@
int mca_pml_uniq_irecv_init(void *addr,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int src,
int tag,
struct ompi_communicator_t *comm,
@ -43,7 +43,7 @@ int mca_pml_uniq_irecv_init(void *addr,
int mca_pml_uniq_irecv(void *addr,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int src,
int tag,
struct ompi_communicator_t *comm,
@ -71,7 +71,7 @@ int mca_pml_uniq_irecv(void *addr,
int mca_pml_uniq_recv(void *addr,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int src,
int tag,
struct ompi_communicator_t *comm,

6
src/mca/pml/uniq/pml_uniq_isend.c
Просмотреть файл

@ -24,7 +24,7 @@
int mca_pml_uniq_isend_init(void *buf,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int dst,
int tag,
mca_pml_base_send_mode_t sendmode,
@ -52,7 +52,7 @@ int mca_pml_uniq_isend_init(void *buf,
int mca_pml_uniq_isend(void *buf,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int dst,
int tag,
mca_pml_base_send_mode_t sendmode,
@ -79,7 +79,7 @@ int mca_pml_uniq_isend(void *buf,
int mca_pml_uniq_send(void *buf,
size_t count,
ompi_datatype_t * datatype,
struct ompi_datatype_t * datatype,
int dst,
int tag,
mca_pml_base_send_mode_t sendmode,