X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d986e6476b81a3ea909bf5d6e86e392cc00192f1..85f2d2b7075a3104ccf23b83f926c0513cac9600:/examples/smpi/mc/mutual_exclusion.c diff --git a/examples/smpi/mc/mutual_exclusion.c b/examples/smpi/mc/mutual_exclusion.c index c63b9fd4b6..0fb0a756fb 100644 --- a/examples/smpi/mc/mutual_exclusion.c +++ b/examples/smpi/mc/mutual_exclusion.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2014. The SimGrid Team. +/* Copyright (c) 2014-2023. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -7,26 +7,27 @@ #include #include #include +#include #define GRANT_TAG 0 #define REQUEST_TAG 1 #define RELEASE_TAG 2 int main(int argc, char **argv){ - int err, size, rank; + int size; + int rank; int recv_buff; MPI_Status status; - int CS_used = 0; xbt_dynar_t requests = xbt_dynar_new(sizeof(int), NULL); /* Initialize MPI */ - err = MPI_Init(&argc, &argv); + int err = MPI_Init(&argc, &argv); if(err != MPI_SUCCESS){ printf("MPI initialization failed !\n"); exit(1); } - MC_ignore(&(status.count), sizeof(status.count)); + MC_ignore(&status.count, sizeof status.count); /* Get number of processes */ MPI_Comm_size(MPI_COMM_WORLD, &size); @@ -34,6 +35,7 @@ int main(int argc, char **argv){ MPI_Comm_rank(MPI_COMM_WORLD, &rank); if(rank == 0){ /* Coordinator */ + int CS_used = 0; while(1){ MPI_Recv(&recv_buff, 1, MPI_INT, MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &status); if(status.MPI_TAG == REQUEST_TAG){ @@ -41,7 +43,7 @@ int main(int argc, char **argv){ printf("CS already used. Queue the request.\n"); xbt_dynar_push(requests, &recv_buff); }else{ - printf("CS idle. Grant immediatly.\n"); + printf("CS idle. Grant immediately.\n"); MPI_Send(&rank, 1, MPI_INT, recv_buff, GRANT_TAG, MPI_COMM_WORLD); CS_used = 1; }