-/* $Id$tag */
-
/* smpi_mpi_dt.c -- MPI primitives to handle datatypes */
+/* FIXME: a very incomplete implementation */
-/* Note: a very incomplete implementation */
-
-/* Copyright (c) 2009 Stephane Genaud. */
-/* All rights reserved. */
+/* Copyright (c) 2009, 2010. The SimGrid Team.
+ * All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
- * * under the terms of the license (GNU LGPL) which comes with this package. */
-
+ * under the terms of the license (GNU LGPL) which comes with this package. */
#include <stdio.h>
#include <stdlib.h>
/* First check if we really have something to do */
if(recvcount == 0) {
retval = sendcount == 0 ? MPI_SUCCESS : MPI_ERR_TRUNCATE;
- } else if(sendtype == recvtype) {
- /* If same datatypes used, just copy. */
- count = sendcount < recvcount ? sendcount : recvcount;
- memcpy(recvbuf, sendbuf, smpi_datatype_size(sendtype) * count);
- retval = sendcount > recvcount ? MPI_ERR_TRUNCATE : MPI_SUCCESS;
- } else {
- /* FIXME: cases
- * - If receive packed.
- * - If send packed
- * to be treated once we have the MPI_Pack things ...
- **/
- retval = MPI_SUCCESS;
- }
- return retval;
+ } else {
+ /* FIXME: treat packed cases */
+ sendcount *= smpi_datatype_size(sendtype);
+ recvcount *= smpi_datatype_size(recvtype);
+ count = sendcount < recvcount ? sendcount : recvcount;
+ memcpy(recvbuf, sendbuf, count);
+ retval = sendcount > recvcount ? MPI_ERR_TRUNCATE : MPI_SUCCESS;
+ }
+ return retval;
}
typedef struct s_smpi_mpi_op {
}
static void max_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, MAX_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, MAX_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, MAX_OP);
}
static void min_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, MIN_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, MIN_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, MIN_OP);
}
static void sum_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, SUM_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, SUM_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, SUM_OP);
}
static void prod_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, PROD_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, PROD_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, PROD_OP);
}
static void land_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, LAND_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, LAND_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, LAND_OP);
}
static void lor_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, LOR_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, LOR_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, LOR_OP);
}
static void lxor_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, LXOR_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, LXOR_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, LXOR_OP);
}
static void band_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, BAND_OP);
+ } if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, BAND_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, BAND_OP);
}
static void bor_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, BOR_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, BOR_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, BOR_OP);
}
static void bxor_func(void* a, void* b, int* length, MPI_Datatype* datatype) {
- if(*datatype == MPI_SHORT) {
+ if(*datatype == MPI_CHAR) {
+ APPLY_FUNC(a, b, length, char, BXOR_OP);
+ } else if(*datatype == MPI_SHORT) {
APPLY_FUNC(a, b, length, short, BXOR_OP);
} else if(*datatype == MPI_INT) {
APPLY_FUNC(a, b, length, int, BXOR_OP);