X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6760cb07d6b57be16928d95339d71e57c4e24f36..1c6f56eb14514a972f9e6e31dbbbf8f3601d2dc0:/include/smpi/smpi.h diff --git a/include/smpi/smpi.h b/include/smpi/smpi.h index 5d5dfb5289..9842282c7b 100644 --- a/include/smpi/smpi.h +++ b/include/smpi/smpi.h @@ -64,6 +64,7 @@ typedef struct { int MPI_SOURCE; int MPI_TAG; int MPI_ERROR; + int count; } MPI_Status; #define MPI_STATUS_IGNORE NULL @@ -159,7 +160,7 @@ XBT_PUBLIC(double) MPI_Wtime(void); XBT_PUBLIC(int) MPI_Address(void *location, MPI_Aint *address); XBT_PUBLIC(int) MPI_Type_free(MPI_Datatype* datatype); -XBT_PUBLIC(int) MPI_Type_size(MPI_Datatype datatype, size_t* size); +XBT_PUBLIC(int) MPI_Type_size(MPI_Datatype datatype, int* size); XBT_PUBLIC(int) MPI_Type_get_extent(MPI_Datatype datatype, MPI_Aint* lb, MPI_Aint* extent); XBT_PUBLIC(int) MPI_Type_extent(MPI_Datatype datatype, MPI_Aint* extent); XBT_PUBLIC(int) MPI_Type_lb(MPI_Datatype datatype, MPI_Aint* disp); @@ -184,6 +185,7 @@ XBT_PUBLIC(int) MPI_Group_range_excl(MPI_Group group, int n, int ranges[][3], MP XBT_PUBLIC(int) MPI_Comm_rank(MPI_Comm comm, int* rank); XBT_PUBLIC(int) MPI_Comm_size(MPI_Comm comm, int* size); XBT_PUBLIC(int) MPI_Get_processor_name(char *name, int *resultlen); +XBT_PUBLIC(int) MPI_Get_count(MPI_Status* status, MPI_Datatype datatype, int* count); XBT_PUBLIC(int) MPI_Comm_group(MPI_Comm comm, MPI_Group* group); XBT_PUBLIC(int) MPI_Comm_compare(MPI_Comm comm1, MPI_Comm comm2, int* result); @@ -235,19 +237,31 @@ XBT_PUBLIC(int) MPI_Comm_split(MPI_Comm comm, int color, int key, XBT_IMPORT_NO_EXPORT(int) smpi_simulated_main(int argc, char** argv); XBT_PUBLIC(MPI_Comm) smpi_process_comm_self(void); /* -XBT_PUBLIC(unsigned int) smpi_sleep(unsigned int); XBT_PUBLIC(void) smpi_exit(int); -XBT_PUBLIC(int) smpi_gettimeofday(struct timeval* tv, struct timezone* tz); */ -/* -TODO -XBT_PUBLIC(void) smpi_do_once_1(const char* file, int line); -XBT_PUBLIC(int) smpi_do_once_2(void); -XBT_PUBLIC(void) smpi_do_once_3(void); +XBT_PUBLIC(unsigned int) smpi_sleep(unsigned int secs); +XBT_PUBLIC(int) smpi_gettimeofday(struct timeval* tv, struct timezone* tz); +XBT_PUBLIC(void) smpi_sample_1(int global, const char* file, int line, int max); +XBT_PUBLIC(int) smpi_sample_2(int global, const char* file, int line); +XBT_PUBLIC(void) smpi_sample_3(int global, const char* file, int line); +XBT_PUBLIC(void) smpi_sample_flops(double flops); -#define SMPI_DO_ONCE for (smpi_do_once_1(__FILE__, __LINE__); smpi_do_once_2(); smpi_do_once_3()) -*/ +#define SMPI_SAMPLE_LOCAL(num) for(smpi_sample_1(0, __FILE__, __LINE__, num); \ + smpi_sample_2(0, __FILE__, __LINE__); \ + smpi_sample_3(0, __FILE__, __LINE__)) + +#define SMPI_SAMPLE_GLOBAL(num) for(smpi_sample_1(1, __FILE__, __LINE__, num); \ + smpi_sample_2(1, __FILE__, __LINE__); \ + smpi_sample_3(1, __FILE__, __LINE__)) + +#define SMPI_SAMPLE_DELAY(flops) for(smpi_sample_flops(flops); 0; ) + +XBT_PUBLIC(void*) smpi_shared_malloc(size_t size, const char* file, int line); +#define SMPI_SHARED_MALLOC(size) smpi_shared_malloc(size, __FILE__, __LINE__) + +XBT_PUBLIC(void) smpi_shared_free(void* data); +#define SMPI_SHARED_FREE(data) smpi_shared_free(data) SG_END_DECL() #endif