From a28877c438152045726c8882e363ff1422d99280 Mon Sep 17 00:00:00 2001
From: Marion Guthmuller <marion.guthmuller@loria.fr>
Date: Tue, 26 Jun 2012 10:59:45 +0200
Subject: [PATCH] model-checker : keep one bugged1 example for liveness
 properties

---
 examples/msg/mc/bugged1_liveness.c | 121 +++++++++++++++++++++++++++++
 1 file changed, 121 insertions(+)
 create mode 100644 examples/msg/mc/bugged1_liveness.c

diff --git a/examples/msg/mc/bugged1_liveness.c b/examples/msg/mc/bugged1_liveness.c
new file mode 100644
index 0000000000..672f9a9d42
--- /dev/null
+++ b/examples/msg/mc/bugged1_liveness.c
@@ -0,0 +1,121 @@
+/***************** Centralized Mutual Exclusion Algorithm *********************/
+/* This example implements a centralized mutual exclusion algorithm.          */
+/* 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"
+#include "mc/mc.h"
+#include "xbt/automaton.h"
+#include "bugged1_liveness.h"
+
+XBT_LOG_NEW_DEFAULT_CATEGORY(bugged1_liveness, "my log messages");
+
+int r=0; 
+int cs=0;
+
+int predR(){
+  return r;
+}
+
+int predCS(){
+  return cs;
+}
+
+
+int coordinator(int argc, char *argv[])
+{
+
+  int CS_used = 0;           
+
+  while (1) {
+    m_task_t task = NULL;
+    MSG_task_receive(&task, "coordinator");
+    const char *kind = MSG_task_get_name(task); 
+    if (!strcmp(kind, "request")) {    
+      char *req = MSG_task_get_data(task);
+      if (CS_used) {           
+        XBT_INFO("CS already used.");
+      } else {               
+        if(strcmp(req, "2") == 0){
+          XBT_INFO("CS idle. Grant immediatly");
+          m_task_t answer = MSG_task_create("grant", 0, 1000, NULL);
+          MSG_task_send(answer, req);
+          CS_used = 1;
+        }
+      }
+    } else {         
+      XBT_INFO("CS release. resource now idle");
+      CS_used = 0;
+    }
+    MSG_task_destroy(task);
+  }
+ 
+  return 0;
+}
+
+int client(int argc, char *argv[])
+{
+  int my_pid = MSG_process_get_PID(MSG_process_self());
+
+  char *my_mailbox = bprintf("%s", argv[1]);
+
+
+  while(1) {
+      
+    XBT_INFO("Ask the request");
+    MSG_task_send(MSG_task_create("request", 0, 1000, my_mailbox), "coordinator");
+
+    if(strcmp(my_mailbox, "1") == 0){
+      r = 1;
+      cs = 0;
+      XBT_INFO("Propositions changed : r=1, cs=0");
+    }
+
+
+    m_task_t grant = NULL;
+    MSG_task_receive(&grant, my_mailbox);
+    const char *kind = MSG_task_get_name(grant);
+
+    if((strcmp(my_mailbox, "1") == 0) && (strcmp("grant", kind) == 0)){
+      cs = 1;
+      r = 0;
+      XBT_INFO("Propositions changed : r=0, cs=1");
+    }
+
+
+    MSG_task_destroy(grant);
+    XBT_INFO("%s got the answer. Sleep a bit and release it", argv[1]);
+    MSG_process_sleep(1);
+    MSG_task_send(MSG_task_create("release", 0, 1000, NULL), "coordinator");
+
+    MSG_process_sleep(my_pid);
+    
+    if(strcmp(my_mailbox, "1") == 0){
+      cs=0;
+      r=0;
+      XBT_INFO("Propositions changed : r=0, cs=0");
+    }
+    
+  }
+
+  return 0;
+}
+
+int main(int argc, char *argv[])
+{
+
+  MSG_init(&argc, argv);
+
+  MSG_config("model-check/property","promela1_bugged1_liveness");
+  MC_automaton_new_propositional_symbol("r", &predR);
+  MC_automaton_new_propositional_symbol("cs", &predCS);
+  
+  MSG_create_environment("../msg_platform.xml");
+  MSG_function_register("coordinator", coordinator);
+  MSG_function_register("client", client);
+  MSG_launch_application("deploy_bugged1_liveness.xml");
+  MSG_main();
+
+  return 0;
+}
-- 
2.20.1