You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
234 lines
6.1 KiB
C
234 lines
6.1 KiB
C
#include <sys/time.h>
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include "psb_internals.h"
|
|
|
|
|
|
#ifdef LowerUnderscore
|
|
#define mpi_wtime mpi_wtime_
|
|
#define mpi_send mpi_send_
|
|
#define mpi_isend mpi_isend_
|
|
#define mpi_irecv mpi_irecv_
|
|
#define mpi_wait mpi_wait_
|
|
#define mpi_alltoall mpi_alltoall_
|
|
#define mpi_alltoallv mpi_alltoallv_
|
|
#define mpi_allgather mpi_allgather_
|
|
#define mpi_allgatherv mpi_allgatherv_
|
|
#endif
|
|
#ifdef LowerDoubleUnderscore
|
|
#define mpi_wtime mpi_wtime__
|
|
#define mpi_send mpi_send__
|
|
#define mpi_isend mpi_isend__
|
|
#define mpi_irecv mpi_irecv__
|
|
#define mpi_wait mpi_wait__
|
|
#define mpi_alltoall mpi_alltoall__
|
|
#define mpi_alltoallv mpi_alltoallv__
|
|
#define mpi_allgather mpi_allgather__
|
|
#define mpi_allgatherv mpi_allgatherv__
|
|
#endif
|
|
#ifdef LowerCase
|
|
#define mpi_wtime mpi_wtime
|
|
#define mpi_send mpi_send
|
|
#define mpi_isend mpi_isend
|
|
#define mpi_irecv mpi_irecv
|
|
#define mpi_wait mpi_wait
|
|
#define mpi_alltoall mpi_alltoall
|
|
#define mpi_alltoallv mpi_alltoallv
|
|
#define mpi_allgather mpi_allgather
|
|
#define mpi_allgatherv mpi_allgatherv
|
|
#endif
|
|
#ifdef UpperUnderscore
|
|
#define mpi_wtime MPI_WTIME_
|
|
#define mpi_send MPI_SEND_
|
|
#define mpi_isend MPI_ISEND_
|
|
#define mpi_irecv MPI_IRECV_
|
|
#define mpi_wait MPI_WAIT_
|
|
#define mpi_alltoall MPI_ALLTOALL_
|
|
#define mpi_alltoallv MPI_ALLTOALLV_
|
|
#define mpi_allgather MPI_ALLGATHER_
|
|
#define mpi_allgatherv MPI_ALLGATHERV_
|
|
#endif
|
|
#ifdef UpperDoubleUnderscore
|
|
#define mpi_wtime MPI_WTIME__
|
|
#define mpi_send MPI_SEND__
|
|
#define mpi_isend MPI_ISEND__
|
|
#define mpi_irecv MPI_IRECV__
|
|
#define mpi_wait MPI_WAIT__
|
|
#define mpi_alltoall MPI_ALLTOALL__
|
|
#define mpi_alltoallv MPI_ALLTOALLV__
|
|
#define mpi_allgather MPI_ALLGATHER__
|
|
#define mpi_allgatherv MPI_ALLGATHERV__
|
|
#endif
|
|
#ifdef UpperCase
|
|
#define mpi_wtime MPI_WTIME
|
|
#define mpi_send MPI_SEND
|
|
#define mpi_isend MPI_ISEND
|
|
#define mpi_irecv MPI_IRECV
|
|
#define mpi_wait MPI_WAIT
|
|
#define mpi_alltoall MPI_ALLTOALL
|
|
#define mpi_alltoallv MPI_ALLTOALLV
|
|
#define mpi_allgather MPI_ALLGATHER
|
|
#define mpi_allgatherv MPI_ALLGATHERV
|
|
#endif
|
|
|
|
#define mpi_integer 1
|
|
#define mpi_integer8 2
|
|
#define mpi_real 3
|
|
#define mpi_double 4
|
|
#define mpi_complex 5
|
|
#define mpi_double_complex 6
|
|
|
|
double mpi_wtime()
|
|
{
|
|
struct timeval tt;
|
|
struct timezone tz;
|
|
double temp;
|
|
if (gettimeofday(&tt,&tz) != 0) {
|
|
fprintf(stderr,"Fatal error for gettimeofday ??? \n");
|
|
temp=0.0;
|
|
} else {
|
|
temp = ((double)tt.tv_sec) + ((double)tt.tv_usec)*1.0e-6;
|
|
}
|
|
return(temp);
|
|
}
|
|
|
|
|
|
void mpi_wait()
|
|
{
|
|
return;
|
|
}
|
|
void mpi_send()
|
|
{
|
|
return;
|
|
}
|
|
void mpi_isend()
|
|
{
|
|
return;
|
|
}
|
|
void mpi_irecv()
|
|
{
|
|
return;
|
|
}
|
|
|
|
|
|
void mpi_alltoall(void* sdb, int* sdc, int* sdt,
|
|
void* rvb, int* rvc, int* rvt, int* comm, int* ierr)
|
|
{
|
|
int i,j,k;
|
|
|
|
if (*sdt == mpi_integer) {
|
|
memcpy(rvb,sdb, (*sdc)*sizeof(int));
|
|
}
|
|
if (*sdt == mpi_integer8) {
|
|
memcpy(rvb,sdb, (*sdc)*2*sizeof(int));
|
|
}
|
|
if (*sdt == mpi_real) {
|
|
memcpy(rvb,sdb, (*sdc)*sizeof(float));
|
|
}
|
|
if (*sdt == mpi_double) {
|
|
memcpy(rvb,sdb, (*sdc)*sizeof(double));
|
|
}
|
|
if (*sdt == mpi_complex) {
|
|
memcpy(rvb,sdb, (*sdc)*2*sizeof(float));
|
|
}
|
|
if (*sdt == mpi_double_complex) {
|
|
memcpy(rvb,sdb, (*sdc)*2*sizeof(double));
|
|
}
|
|
*ierr = 0;
|
|
}
|
|
|
|
void mpi_alltoallv(void* sdb, int* sdc, int* sdspl, int* sdt,
|
|
void* rvb, int* rvc, int* rdspl, int* rvt, int* comm, int* ierr)
|
|
{
|
|
int i,j,k;
|
|
|
|
|
|
if (*sdt == mpi_integer) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*sizeof(int)),
|
|
(void *)((char *)sdb+sdspl[0]*sizeof(int)),(*sdc)*sizeof(int));
|
|
}
|
|
if (*sdt == mpi_integer8) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*2*sizeof(int)),
|
|
(void *)((char *)sdb+sdspl[0]*2*sizeof(int)),(*sdc)*2*sizeof(int));
|
|
}
|
|
if (*sdt == mpi_real) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*sizeof(float)),
|
|
(void *)((char *)sdb+sdspl[0]*sizeof(float)),(*sdc)*sizeof(float));
|
|
}
|
|
if (*sdt == mpi_double) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*sizeof(double)),
|
|
(void *)((char *)sdb+sdspl[0]*sizeof(double)),(*sdc)*sizeof(double));
|
|
}
|
|
if (*sdt == mpi_complex) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*2*sizeof(float)),
|
|
(void *)((char *)sdb+sdspl[0]*2*sizeof(float)),(*sdc)*2*sizeof(float));
|
|
}
|
|
if (*sdt == mpi_double_complex) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*2*sizeof(double)),
|
|
(void *)((char *)sdb+sdspl[0]*2*sizeof(double)),(*sdc)*2*sizeof(double));
|
|
}
|
|
*ierr = 0;
|
|
}
|
|
|
|
|
|
void mpi_allgather(void* sdb, int* sdc, int* sdt,
|
|
void* rvb, int* rvc, int* rvt, int* comm, int* ierr)
|
|
{
|
|
int i,j,k;
|
|
|
|
if (*sdt == mpi_integer) {
|
|
memcpy(rvb,sdb, (*sdc)*sizeof(int));
|
|
}
|
|
if (*sdt == mpi_integer8) {
|
|
memcpy(rvb,sdb, (*sdc)*2*sizeof(int));
|
|
}
|
|
if (*sdt == mpi_real) {
|
|
memcpy(rvb,sdb, (*sdc)*sizeof(float));
|
|
}
|
|
if (*sdt == mpi_double) {
|
|
memcpy(rvb,sdb, (*sdc)*sizeof(double));
|
|
}
|
|
if (*sdt == mpi_complex) {
|
|
memcpy(rvb,sdb, (*sdc)*2*sizeof(float));
|
|
}
|
|
if (*sdt == mpi_double_complex) {
|
|
memcpy(rvb,sdb, (*sdc)*2*sizeof(double));
|
|
}
|
|
*ierr = 0;
|
|
}
|
|
|
|
void mpi_allgatherv(void* sdb, int* sdc, int* sdt,
|
|
void* rvb, int* rvc, int* rdspl,
|
|
int* rvt, int* comm, int* ierr)
|
|
{
|
|
int i,j,k;
|
|
|
|
if (*sdt == mpi_integer) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*sizeof(int)),
|
|
(void *)((char *)sdb),(*sdc)*sizeof(int));
|
|
}
|
|
if (*sdt == mpi_integer8) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*2*sizeof(int)),
|
|
(void *)((char *)sdb),(*sdc)*2*sizeof(int));
|
|
}
|
|
if (*sdt == mpi_real) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*sizeof(float)),
|
|
(void *)((char *)sdb),(*sdc)*sizeof(float));
|
|
}
|
|
if (*sdt == mpi_double) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*sizeof(double)),
|
|
(void *)((char *)sdb),(*sdc)*sizeof(double));
|
|
}
|
|
if (*sdt == mpi_complex) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*2*sizeof(float)),
|
|
(void *)((char *)sdb),(*sdc)*2*sizeof(float));
|
|
}
|
|
if (*sdt == mpi_double_complex) {
|
|
memcpy((void *)((char *)rvb+rdspl[0]*2*sizeof(double)),
|
|
(void *)((char *)sdb),(*sdc)*2*sizeof(double));
|
|
}
|
|
|
|
|
|
*ierr = 0;
|
|
}
|