X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/01a66c0fe18041cddd1ca2ded9a2b1c38e61fae2..056d48c9fa3d5fa5afd2be695f54edbc5fd5434d:/examples/msg/mc/bugged1_liveness.c diff --git a/examples/msg/mc/bugged1_liveness.c b/examples/msg/mc/bugged1_liveness.c index b6949dda0c..fda05544cf 100644 --- a/examples/msg/mc/bugged1_liveness.c +++ b/examples/msg/mc/bugged1_liveness.c @@ -1,12 +1,23 @@ +/* Copyright (c) 2012-2015. 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) */ /******************************************************************************/ -#include "msg/msg.h" +#ifdef GARBAGE_STACK +#include +#include +#include +#endif + +#include "simgrid/msg.h" #include "mc/mc.h" -#include "xbt/automaton.h" #include "bugged1_liveness.h" XBT_LOG_NEW_DEFAULT_CATEGORY(bugged1_liveness, "my log messages"); @@ -14,18 +25,19 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(bugged1_liveness, "my log messages"); int r=0; int cs=0; -int predR(){ - return r; -} - -int predCS(){ - return cs; +#ifdef GARBAGE_STACK +/** Do not use a clean stack */ +static void garbage_stack(void) { + const size_t size = 256; + int fd = open("/dev/urandom", O_RDONLY); + char foo[size]; + read(fd, foo, size); + close(fd); } +#endif - -int coordinator(int argc, char *argv[]) +static int coordinator(int argc, char *argv[]) { - int CS_used = 0; msg_task_t task = NULL, answer = NULL; xbt_dynar_t requests = xbt_dynar_new(sizeof(char *), NULL); @@ -48,7 +60,7 @@ int coordinator(int argc, char *argv[]) answer = NULL; } } - } else { + } else { if (!xbt_dynar_is_empty(requests)) { XBT_INFO("CS release. Grant to queued requests (queue size: %lu)", xbt_dynar_length(requests)); xbt_dynar_shift(requests, &req); @@ -68,17 +80,16 @@ int coordinator(int argc, char *argv[]) kind = NULL; req = NULL; } - return 0; } -int client(int argc, char *argv[]) +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; - + while(1){ XBT_INFO("Ask the request"); MSG_task_send(MSG_task_create("request", 0, 1000, my_mailbox), "coordinator"); @@ -112,7 +123,7 @@ int client(int argc, char *argv[]) release = NULL; MSG_process_sleep(my_pid); - + if(strcmp(my_mailbox, "1") == 0){ cs=0; r=0; @@ -120,28 +131,33 @@ int client(int argc, char *argv[]) } } - return 0; } -int main(int argc, char *argv[]) +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 uninitialized variables will contain 0. This call will place + // random byes in the stack of the callee: + garbage_stack(); +#endif + return client(argc, argv); +} +int main(int argc, char *argv[]) +{ MSG_init(&argc, argv); - char **options = &argv[1]; + MC_automaton_new_propositional_symbol_pointer("r", &r); + MC_automaton_new_propositional_symbol_pointer("cs", &cs); - MSG_config("model-check/property","promela_bugged1_liveness"); - MC_automaton_new_propositional_symbol("r", &predR); - MC_automaton_new_propositional_symbol("cs", &predCS); + MSG_create_environment(argv[1]); - const char* platform_file = options[0]; - const char* application_file = options[1]; - - MSG_create_environment(platform_file); MSG_function_register("coordinator", coordinator); - MSG_function_register("client", client); - MSG_launch_application(application_file); + MSG_function_register("client", raw_client); + MSG_launch_application(argv[2]); + MSG_main(); return 0;