Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Merge branch 'master' of git+ssh://scm.gforge.inria.fr//gitroot/simgrid/simgrid
[simgrid.git] / examples / msg / energy-pstate / energy-pstate.c
1 /* Copyright (c) 2007-2010, 2013-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 "simgrid/msg.h"
8
9 /** @addtogroup MSG_examples
10  *
11  * - <b>energy-pstate/energy-pstate.c</b> Shows how a set of pstates can be defined for a host and how the current
12  * pstate can be
13  *     accessed/changed with @ref MSG_get_host_current_power_peak and @ref  MSG_set_host_pstate.
14  *     Make sure to read the platform XML file for details on how to declare the CPU capacity for each pstate.
15  */
16
17 XBT_LOG_NEW_DEFAULT_CATEGORY(test, "Pstate properties test");
18
19 static int dvfs(int argc, char *argv[])
20 {
21   double workload = 100E6;
22   msg_host_t host = MSG_host_self();
23
24   int nb = MSG_host_get_nb_pstates(host);
25   XBT_INFO("Count of Processor states=%d", nb);
26
27   double current_peak = MSG_host_get_current_power_peak(host);
28   XBT_INFO("Current power peak=%f", current_peak);
29
30   // Run a task
31   msg_task_t task1 = MSG_task_create ("t1", workload, 0, NULL);
32   MSG_task_execute (task1);
33   MSG_task_destroy(task1);
34
35   double task_time = MSG_get_clock();
36   XBT_INFO("Task1 simulation time: %e", task_time);
37
38   // Change power peak
39   int new_pstate = 2;
40
41   double peak_at = MSG_host_get_power_peak_at(host, new_pstate);
42   XBT_INFO("Changing power peak value to %f (at index %d)", peak_at, new_pstate);
43
44   MSG_host_set_pstate(host, new_pstate);
45
46   current_peak = MSG_host_get_current_power_peak(host);
47   XBT_INFO("Current power peak=%f", current_peak);
48
49   // Run a second task
50   task1 = MSG_task_create ("t1", workload, 0, NULL);
51   MSG_task_execute (task1);
52   MSG_task_destroy(task1);
53
54   task_time = MSG_get_clock() - task_time;
55   XBT_INFO("Task2 simulation time: %e", task_time);
56
57   // Verify the default pstate is set to 0
58   host = MSG_host_by_name("MyHost2");
59   int nb2 = MSG_host_get_nb_pstates(host);
60   XBT_INFO("Count of Processor states=%d", nb2);
61
62   double current_peak2 = MSG_host_get_current_power_peak(host);
63   XBT_INFO("Current power peak=%f", current_peak2);
64   return 0;
65 }
66
67 int main(int argc, char *argv[])
68 {
69   MSG_init(&argc, argv);
70
71   xbt_assert(argc == 2, "Usage: %s platform_file\n\tExample: %s msg_platform.xml\n", argv[0], argv[0]);
72
73   MSG_create_environment(argv[1]);
74
75   MSG_process_create("dvfs_test", dvfs, NULL, MSG_get_host_by_name("MyHost1"));
76   MSG_process_create("dvfs_test", dvfs, NULL, MSG_get_host_by_name("MyHost2"));
77
78   msg_error_t res = MSG_main();
79
80   XBT_INFO("Total simulation time: %e", MSG_get_clock());
81
82   return res != MSG_OK;
83 }