X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/61427a88a76a2c2ef25d0d5b8132995c6f550e5c..b5ce35d0a47049999d7a28185745a2a37e01d7c3:/examples/smpi/mc/mutual_exclusion.c diff --git a/examples/smpi/mc/mutual_exclusion.c b/examples/smpi/mc/mutual_exclusion.c index 35f7b82205..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,6 +7,7 @@ #include #include #include +#include #define GRANT_TAG 0 #define REQUEST_TAG 1 @@ -17,7 +18,6 @@ int main(int argc, char **argv){ int rank; int recv_buff; MPI_Status status; - int CS_used = 0; xbt_dynar_t requests = xbt_dynar_new(sizeof(int), NULL); /* Initialize MPI */ @@ -27,7 +27,7 @@ int main(int argc, char **argv){ 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); @@ -35,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){ @@ -42,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; }