Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge branch 'master' of scm.gforge.inria.fr:/gitroot/simgrid/simgrid
[simgrid.git] / teshsuite / msg / process / process.c
1 /* Copyright (c) 2010-2015. The SimGrid Team.
2  * All rights reserved.                                                     */
3
4 /* This program is free software; you can redistribute it and/or modify it
5  * under the terms of the license (GNU LGPL) which comes with this package. */
6
7 #include <stdio.h>
8 #include "simgrid/msg.h"            /* Yeah! If you want to use msg, you need to include simgrid/msg.h */
9 #include "xbt/sysdep.h"         /* calloc, printf */
10
11 /* Create a log channel to have nice outputs. */
12 #include "xbt/log.h"
13 #include "xbt/asserts.h"
14 XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test,
15                              "Messages specific for this msg example");
16
17 int master(int argc, char *argv[]);
18 int slave(int argc, char *argv[]);
19
20 /** Emitter function  */
21 int master(int argc, char *argv[])
22 {
23   xbt_swag_t process_list = MSG_host_get_process_list(MSG_host_self());
24   msg_process_t process = NULL;
25   MSG_process_sleep(1);
26   xbt_swag_foreach(process, process_list) {
27     XBT_INFO("Process(pid=%d, ppid=%d, name=%s)",
28              MSG_process_get_PID(process), MSG_process_get_PPID(process),
29              MSG_process_get_name(process));
30     if (MSG_process_self_PID() != MSG_process_get_PID(process))
31       MSG_process_kill(process);
32   }
33   process = MSG_process_create("slave from master",
34                                slave, NULL, MSG_host_self());
35   MSG_process_sleep(2);
36
37   XBT_INFO("Suspend Process(pid=%d)", MSG_process_get_PID(process));
38   MSG_process_suspend(process);
39
40   XBT_INFO("Process(pid=%d) is %ssuspended",
41            MSG_process_get_PID(process),
42            (MSG_process_is_suspended(process)) ? "" : "not ");
43   MSG_process_sleep(2);
44
45   XBT_INFO("Resume Process(pid=%d)", MSG_process_get_PID(process));
46   MSG_process_resume(process);
47
48   XBT_INFO("Process(pid=%d) is %ssuspended",
49            MSG_process_get_PID(process),
50            (MSG_process_is_suspended(process)) ? "" : "not ");
51   MSG_process_sleep(2);
52   MSG_process_kill(process);
53
54   XBT_INFO("Goodbye now!");
55   return 0;
56 }                               /* end_of_master */
57
58 /** Receiver function  */
59 int slave(int argc, char *argv[])
60 {
61   MSG_process_sleep(.5);
62   XBT_INFO("Slave started (PID:%d, PPID:%d)",
63            MSG_process_self_PID(), MSG_process_self_PPID());
64   while(1){
65     XBT_INFO("Plop i am %ssuspended",
66              (MSG_process_is_suspended(MSG_process_self())) ? "" : "not ");
67     MSG_process_sleep(1);
68   }
69   XBT_INFO("I'm done. See you!");
70   return 0;
71 }                               /* end_of_slave */
72
73 /** Main function */
74 int main(int argc, char *argv[])
75 {
76   msg_error_t res;
77   const char *platform_file;
78   const char *application_file;
79
80   MSG_init(&argc, argv);
81   if (argc != 3) {
82     printf("Usage: %s platform_file deployment_file\n", argv[0]);
83     printf("example: %s msg_platform.xml msg_deployment.xml\n", argv[0]);
84     exit(1);
85   }
86   platform_file = argv[1];
87   application_file = argv[2];
88
89   {                             /*  Simulation setting */
90     MSG_create_environment(platform_file);
91   }
92   {                             /*   Application deployment */
93     MSG_function_register("master", master);
94     MSG_function_register("slave", slave);
95
96     MSG_launch_application(application_file);
97   }
98   res = MSG_main();
99
100   XBT_INFO("Simulation time %g", MSG_get_clock());
101
102   if (res == MSG_OK)
103     return 0;
104   else
105     return 1;
106 }                               /* end_of_main */