examples/msg/cloud/simple_vm
examples/msg/cloud/two_tasks_vm
examples/msg/energy/pstate/pstate
+examples/msg/energy/onoff/onoff
examples/msg/energy/e2/e2
examples/msg/energy/e3/e3
examples/msg/pastry/pastry
get_data_size(t) -> get_bytes_amount(t)
- Massive cleanups in the functions related to the energy
- MSG_host_get_pstate_number() -> MSG_host_get_nb_pstates()
- - New: MSG_host_get_pstate()
+ - New: MSG_host_get_pstate()
+ * New example:
+ - msg/energy/onoff: switching hosts on and off
jMSG:
* Interface improvement:
- Rename Host.isAvail() to Host.isOn()
ADD_TESH_FACTORIES(msg-cloud-simple-vm "thread;ucontext;raw;boost" --setenv bindir=${CMAKE_BINARY_DIR}/examples/msg/cloud/ --setenv srcdir=${CMAKE_HOME_DIRECTORY}/examples/msg/cloud/ --cd ${CMAKE_BINARY_DIR}/examples/msg/cloud/ ${CMAKE_HOME_DIRECTORY}/examples/msg/cloud/simple_vm.tesh)
ADD_TESH_FACTORIES(msg-energy-pstates "thread;boost" --setenv srcdir=${CMAKE_HOME_DIRECTORY}/examples/msg --cd ${CMAKE_BINARY_DIR}/examples/msg ${CMAKE_HOME_DIRECTORY}/examples/msg/energy/pstate/pstate.tesh)
ADD_TESH_FACTORIES(msg-energy-consumption "thread;ucontext;raw;boost" --setenv srcdir=${CMAKE_HOME_DIRECTORY}/examples/msg --cd ${CMAKE_BINARY_DIR}/examples/msg ${CMAKE_HOME_DIRECTORY}/examples/msg/energy/e2/energy_consumption.tesh)
+ ADD_TESH_FACTORIES(msg-energy-onoff "thread;ucontext;raw;boost" --setenv srcdir=${CMAKE_HOME_DIRECTORY}/examples/msg --cd ${CMAKE_BINARY_DIR}/examples/msg ${CMAKE_HOME_DIRECTORY}/examples/msg/energy/onoff/onoff.tesh)
ADD_TESH_FACTORIES(msg-energy-concurrent-tasks "thread;ucontext;raw;boost" --setenv srcdir=${CMAKE_HOME_DIRECTORY}/examples/msg --cd ${CMAKE_BINARY_DIR}/examples/msg ${CMAKE_HOME_DIRECTORY}/examples/msg/energy/e3/concurrent_tasks.tesh)
ADD_TESH_FACTORIES(msg-token-ring "thread;ucontext;raw;boost" --setenv srcdir=${CMAKE_HOME_DIRECTORY} --cd ${CMAKE_BINARY_DIR}/examples/msg/token_ring ${CMAKE_HOME_DIRECTORY}/examples/msg/token_ring/token_ring.tesh)
ADD_TESH_FACTORIES(msg-migration "thread;ucontext;raw;boost" --setenv srcdir=${CMAKE_HOME_DIRECTORY}/examples/msg --cd ${CMAKE_BINARY_DIR}/examples/msg ${CMAKE_HOME_DIRECTORY}/examples/msg/migration/migration.tesh)
add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/msg/energy/pstate)
add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/msg/energy/e2)
add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/msg/energy/e3)
+add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/msg/energy/onoff)
add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/msg/exception)
add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/msg/gpu)
add_subdirectory(${CMAKE_HOME_DIRECTORY}/examples/msg/gtnets)
--- /dev/null
+cmake_minimum_required(VERSION 2.6)
+
+set(EXECUTABLE_OUTPUT_PATH "${CMAKE_CURRENT_BINARY_DIR}")
+
+add_executable(onoff onoff.c)
+
+### Add definitions for compile
+target_link_libraries(onoff simgrid )
+
+set(tesh_files
+ ${tesh_files}
+ ${CMAKE_CURRENT_SOURCE_DIR}/energy_consumption.tesh
+ PARENT_SCOPE
+ )
+
+set(xml_files
+ ${xml_files}
+ ${CMAKE_CURRENT_SOURCE_DIR}/deployment_onoff.xml
+ PARENT_SCOPE
+ )
+
+set(examples_src
+ ${examples_src}
+ ${CMAKE_CURRENT_SOURCE_DIR}/onoff.c
+ PARENT_SCOPE
+ )
+
+set(bin_files
+ ${bin_files}
+ PARENT_SCOPE
+ )
--- /dev/null
+<?xml version='1.0'?>
+<!DOCTYPE platform SYSTEM "http://simgrid.gforge.inria.fr/simgrid.dtd">
+<platform version="3">
+
+ <process host="MyHost2" function="onoff_test" />
+
+</platform>
--- /dev/null
+/* Copyright (c) 2007-2010, 2013-2014. 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. */
+
+#include<stdio.h>
+
+#include "simgrid/msg.h"
+#include "xbt/sysdep.h" /* calloc */
+#include "simgrid/plugins.h"
+
+/* Create a log channel to have nice outputs. */
+#include "xbt/log.h"
+#include "xbt/asserts.h"
+
+XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test,
+ "Messages specific for this msg example");
+
+static void simulate_bootup(msg_host_t host) {
+
+ int previous_pstate = MSG_host_get_pstate(host);
+
+ XBT_INFO("Switch to virtual pstate 3, that encodes the shutting down state in the XML file of that example");
+ MSG_host_set_pstate(host,3);
+
+ msg_host_t host_list[1] = {host};
+ double flops_amount[1] = {1};
+ double bytes_amount[1] = {0};
+
+ XBT_INFO("Actually start the host");
+ MSG_host_on(host);
+
+ XBT_INFO("Simulate the boot up by executing one flop on that host");
+ // We use a parallel task to run some task on a remote host.
+ msg_task_t bootup = MSG_parallel_task_create("boot up", 1, host_list, flops_amount, bytes_amount, NULL);
+ MSG_task_execute(bootup);
+ MSG_task_destroy(bootup);
+
+ XBT_INFO("Switch back to previously selected pstate %d", previous_pstate);
+ MSG_host_set_pstate(host, previous_pstate);
+}
+
+static void simulate_shutdown(msg_host_t host) {
+
+ int previous_pstate = MSG_host_get_pstate(host);
+
+ XBT_INFO("Switch to virtual pstate 4, that encodes the shutting down state in the XML file of that example");
+ MSG_host_set_pstate(host,4);
+
+ msg_host_t host_list[1] = {host};
+ double flops_amount[1] = {1};
+ double bytes_amount[1] = {0};
+
+ XBT_INFO("Simulate the shutdown by executing one flop on that remote host (using a parallel task)");
+ msg_task_t shutdown = MSG_parallel_task_create("shutdown", 1, host_list, flops_amount, bytes_amount, NULL);
+ MSG_task_execute(shutdown);
+ MSG_task_destroy(shutdown);
+
+ XBT_INFO("Switch back to previously selected pstate %d", previous_pstate);
+ MSG_host_set_pstate(host, previous_pstate);
+
+ XBT_INFO("Actually shutdown the host");
+ MSG_host_off(host);
+}
+
+static int onoff(int argc, char *argv[]) {
+ msg_host_t host1 = MSG_get_host_by_name("MyHost1");
+
+ XBT_INFO("Energetic profile: %s",
+ MSG_host_get_property_value(host1,"watt_per_state"));
+ XBT_INFO("Initial peak speed=%.0E flop/s; Energy dissipated =%.0E J",
+ MSG_host_get_current_power_peak(host1), MSG_host_get_consumed_energy(host1));
+
+ XBT_INFO("Sleep for 10 seconds");
+ MSG_process_sleep(10);
+ XBT_INFO("Done sleeping. Current peak speed=%.0E; Energy dissipated=%.2f J",
+ MSG_host_get_current_power_peak(host1), MSG_host_get_consumed_energy(host1));
+
+ simulate_shutdown(host1);
+ XBT_INFO("Host1 is now OFF. Current peak speed=%.0E flop/s; Energy dissipated=%.0f J",
+ MSG_host_get_current_power_peak(host1), MSG_host_get_consumed_energy(host1));
+
+ XBT_INFO("Sleep for 10 seconds");
+ MSG_process_sleep(10);
+ XBT_INFO("Done sleeping. Current peak speed=%.0E; Energy dissipated=%.2f J",
+ MSG_host_get_current_power_peak(host1), MSG_host_get_consumed_energy(host1));
+
+ simulate_bootup(host1);
+ XBT_INFO("Host1 is now ON again. Current peak speed=%.0E flop/s; Energy dissipated=%.0f J",
+ MSG_host_get_current_power_peak(host1), MSG_host_get_consumed_energy(host1));
+
+
+ return 0;
+}
+
+int main(int argc, char *argv[])
+{
+ msg_error_t res = MSG_OK;
+ sg_energy_plugin_init();
+ MSG_init(&argc, argv);
+
+ if (argc != 3) {
+ XBT_CRITICAL("Usage: %s platform_file deployment_file\n",
+ argv[0]);
+ XBT_CRITICAL
+ ("example: %s msg_platform.xml msg_deployment.xml\n",
+ argv[0]);
+ exit(1);
+ }
+
+ MSG_create_environment(argv[1]);
+
+ /* Application deployment */
+ MSG_function_register("onoff_test", onoff);
+
+ MSG_launch_application(argv[2]);
+
+ res = MSG_main();
+
+ XBT_INFO("Total simulation time: %.2f", MSG_get_clock());
+
+ if (res == MSG_OK)
+ return 0;
+ else
+ return 1;
+}
+
--- /dev/null
+#! ./tesh
+
+p Testing the mechanism for computing host energy consumption
+
+! output sort
+$ $SG_TEST_EXENV energy/onoff/onoff$EXEEXT ${srcdir:=.}/energy/onoff/platform_onoff.xml ${srcdir:=.}/energy/onoff/deployment_onoff.xml "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n"
+> [ 0.000000] (1:onoff_test@MyHost2) Energetic profile: 95.0:200.0,93.0:170.0,90.0:150.0, 120:120,110:110
+> [ 0.000000] (1:onoff_test@MyHost2) Initial peak speed=1E+08 flop/s; Energy dissipated =0E+00 J
+> [ 0.000000] (1:onoff_test@MyHost2) Sleep for 10 seconds
+> [ 10.000000] (1:onoff_test@MyHost2) Done sleeping. Current peak speed=1E+08; Energy dissipated=950.00 J
+> [ 10.000000] (1:onoff_test@MyHost2) Switch to virtual pstate 4, that encodes the shutting down state in the XML file of that example
+> [ 10.000000] (1:onoff_test@MyHost2) Simulate the shutdown by executing one flop on that remote host (using a parallel task)
+> [ 16.997901] (1:onoff_test@MyHost2) Switch back to previously selected pstate 0
+> [ 16.997901] (1:onoff_test@MyHost2) Actually shutdown the host
+> [ 16.997901] (1:onoff_test@MyHost2) Host1 is now OFF. Current peak speed=1E+08 flop/s; Energy dissipated=1720 J
+> [ 16.997901] (1:onoff_test@MyHost2) Sleep for 10 seconds
+> [ 26.997901] (1:onoff_test@MyHost2) Done sleeping. Current peak speed=1E+08; Energy dissipated=1819.77 J
+> [ 26.997901] (1:onoff_test@MyHost2) Switch to virtual pstate 3, that encodes the shutting down state in the XML file of that example
+> [ 26.997901] (1:onoff_test@MyHost2) Actually start the host
+> [ 26.997901] (1:onoff_test@MyHost2) Simulate the boot up by executing one flop on that host
+> [176.997893] (0:@) Total simulation time: 177.00
+> [176.997893] (0:@) Total energy of host MyHost1: 19819.768169 Joules
+> [176.997893] (0:@) Total energy of host MyHost2: 17699.789313 Joules
+> [176.997893] (1:onoff_test@MyHost2) Switch back to previously selected pstate 0
+> [176.997893] (1:onoff_test@MyHost2) Host1 is now ON again. Current peak speed=1E+08 flop/s; Energy dissipated=19820 J
--- /dev/null
+<?xml version='1.0'?>
+<!DOCTYPE platform SYSTEM "http://simgrid.gforge.inria.fr/simgrid.dtd">
+<platform version="3">
+<AS id="AS0" routing="Full">
+
+ <!-- Use the pstate mechanism to encode the boot/shutdown time and energy -->
+
+ <!-- That may be seen as a misuse of the pstate mechanism and crude hack,
+ but this is efficient: we can do what we want without too much burden,
+ and since the whole intelligence is at user level, we do control the model.
+
+ The same could be done to encode the time and energy to switch
+ between pstates. These times seem negligeable in our
+ experiments, but if they are important to you, now you know how
+ to do that. -->
+
+ <!-- pstate values:
+ * 0-2: real pstates
+ 0: p1 100 MFlops/s, [idle: 95W -> full burning: 200W]
+ 1: p2 50 MFlops/s, [idle: 93W -> full burning: 170W]
+ 2: p3 20 MFlops/s, [idel: 90W -> full burning: 150W]
+ * 3: booting up was measured to take 150s and 18000J.
+ So we create a pstate with 1 flop/150 s so that the
+ application burns 1 flop in that virtual pstate to
+ simulate a boot.
+ Multiply everything by 1000 or whatever if this trick is
+ too painful to you, that's the same by the end.
+ The energy consumption is 18000/150=120W
+ * 4: shuting down was measured to take 7 s and 770 J
+
+ Please note that we tried to put sensible values in this file
+ but you should still take them with a grain of salt. If you
+ want a realistic simulation, you have to actually benchmark
+ your platform and application, and use the values that are
+ right for you. -->
+
+
+ <host id="MyHost1" power="100.0Mf,50.0Mf,20.0Mf, 0.006666667f,0.1429f" pstate="0" >
+ <prop id="watt_per_state"value="95.0:200.0,93.0:170.0,90.0:150.0, 120:120,110:110" />
+ <prop id="watt_off" value="10" />
+ </host>
+ <host id="MyHost2" power="100.0Mf" >
+ <prop id="watt_per_state" value="100.0:200.0" />
+ <prop id="watt_off" value="10" />
+ </host>
+
+ <link id="link1" bandwidth="100kBps" latency="0"/>
+ <route src="MyHost1" dst="MyHost2"><link_ctn id="link1"/></route>
+
+</AS>
+</platform>