X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4f9895249bc169bdd6b1be3b60ce24af0008d63f..e2d280829e07d8b5e96c96bd4b2fd815e8311102:/examples/msg/mc/bugged1_liveness.c diff --git a/examples/msg/mc/bugged1_liveness.c b/examples/msg/mc/bugged1_liveness.c index 04945213c5..d334f66d0c 100644 --- a/examples/msg/mc/bugged1_liveness.c +++ b/examples/msg/mc/bugged1_liveness.c @@ -1,14 +1,13 @@ -/* Copyright (c) 2012-2015. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2012-2018. 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. */ -/***************** Centralized Mutual Exclusion Algorithm *********************/ -/* This example implements a centralized mutual exclusion algorithm. */ -/* Bug : CS requests of client 1 not satisfied */ -/* LTL property checked : G(r->F(cs)); (r=request of CS, cs=CS ok) */ -/******************************************************************************/ +/***************** Centralized Mutual Exclusion Algorithm *******************/ +/* This example implements a centralized mutual exclusion algorithm. */ +/* Bug : CS requests of client 1 not satisfied */ +/* LTL property checked : G(r->F(cs)); (r=request of CS, cs=CS ok) */ +/****************************************************************************/ #ifdef GARBAGE_STACK #include @@ -16,14 +15,12 @@ #include #endif -#include "simgrid/msg.h" -#include "mc/mc.h" -#include "xbt/automaton.h" -#include "bugged1_liveness.h" +#include +#include XBT_LOG_NEW_DEFAULT_CATEGORY(bugged1_liveness, "my log messages"); -int r=0; +int r=0; int cs=0; #ifdef GARBAGE_STACK @@ -39,20 +36,21 @@ static void garbage_stack(void) { static int coordinator(int argc, char *argv[]) { - int CS_used = 0; - msg_task_t task = NULL, answer = NULL; + int CS_used = 0; + msg_task_t task = NULL; + msg_task_t answer = NULL; xbt_dynar_t requests = xbt_dynar_new(sizeof(char *), NULL); char *req; - while(1){ + while(1){ MSG_task_receive(&task, "coordinator"); - const char *kind = MSG_task_get_name(task); - if (!strcmp(kind, "request")) { + const char *kind = MSG_task_get_name(task); + if (!strcmp(kind, "request")) { req = MSG_task_get_data(task); - if (CS_used) { + if (CS_used) { XBT_INFO("CS already used. Queue the request."); xbt_dynar_push(requests, &req); - } else { + } else { if(strcmp(req, "1") != 0){ XBT_INFO("CS idle. Grant immediatly"); answer = MSG_task_create("grant", 0, 1000, NULL); @@ -89,7 +87,8 @@ static int client(int argc, char *argv[]) int my_pid = MSG_process_get_PID(MSG_process_self()); char *my_mailbox = xbt_strdup(argv[1]); - msg_task_t grant = NULL, release = NULL; + msg_task_t grant = NULL; + msg_task_t release = NULL; while(1){ XBT_INFO("Ask the request"); @@ -130,7 +129,7 @@ static int client(int argc, char *argv[]) r=0; XBT_INFO("Propositions changed : r=0, cs=0"); } - + } return 0; } @@ -139,7 +138,7 @@ static int raw_client(int argc, char *argv[]) { #ifdef GARBAGE_STACK // At this point the stack of the callee (client) is probably filled with - // zeros and unitialized variables will contain 0. This call will place + // zeros and uninitialized variables will contain 0. This call will place // random byes in the stack of the callee: garbage_stack(); #endif