src/msg/instr_msg_vm.cpp

   1 /* Copyright (c) 2012-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 "msg_private.h"
   8
   9
  10 XBT_LOG_NEW_DEFAULT_SUBCATEGORY (instr_msg_vm, instr, "MSG VM");
  11
  12
  13 char *instr_vm_id (msg_vm_t vm, char *str, int len)
  14 {
  15         return instr_vm_id_2 (MSG_vm_get_name(vm), str, len);
  16 }
  17
  18 char *instr_vm_id_2 (const char *vm_name, char *str, int len)
  19 {
  20   snprintf (str, len, "%s", vm_name);
  21   return str;
  22 }
  23
  24 /*
  25  * Instrumentation functions to trace MSG VMs (msg_vm_t)
  26  */
  27 void TRACE_msg_vm_change_host(msg_vm_t vm, msg_host_t old_host, msg_host_t new_host)
  28 {
  29   if (TRACE_msg_vm_is_enabled()){
  30     static long long int counter = 0;
  31     char key[INSTR_DEFAULT_STR_SIZE];
  32     snprintf (key, INSTR_DEFAULT_STR_SIZE, "%lld", counter++);
  33
  34     int len = INSTR_DEFAULT_STR_SIZE;
  35     char str[INSTR_DEFAULT_STR_SIZE];
  36
  37     //start link
  38     container_t msg = PJ_container_get (instr_vm_id(vm, str, len));
  39     type_t type = PJ_type_get ("MSG_VM_LINK", PJ_type_get_root());
  40     new_pajeStartLink (MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key);
  41
  42     //destroy existing container of this vm
  43     container_t existing_container = PJ_container_get(instr_vm_id(vm, str, len));
  44     PJ_container_remove_from_parent (existing_container);
  45     PJ_container_free(existing_container);
  46
  47     //create new container on the new_host location
  48     PJ_container_new(instr_vm_id(vm, str, len), INSTR_MSG_VM, PJ_container_get(SIMIX_host_get_name(new_host)));
  49
  50     //end link
  51     msg = PJ_container_get(instr_vm_id(vm, str, len));
  52     type = PJ_type_get ("MSG_VM_LINK", PJ_type_get_root());
  53     new_pajeEndLink (MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key);
  54   }
  55 }
  56
  57 void TRACE_msg_vm_create(const char *vm_name, msg_host_t host)
  58 {
  59   if (TRACE_msg_vm_is_enabled()){
  60     int len = INSTR_DEFAULT_STR_SIZE;
  61     char str[INSTR_DEFAULT_STR_SIZE];
  62
  63     container_t host_container = PJ_container_get (SIMIX_host_get_name(host));
  64     PJ_container_new(instr_vm_id_2(vm_name, str, len), INSTR_MSG_VM, host_container);
  65   }
  66 }
  67
  68 void TRACE_msg_vm_start(msg_vm_t vm)
  69 {
  70   if (TRACE_msg_vm_is_enabled()){
  71     int len = INSTR_DEFAULT_STR_SIZE;
  72     char str[INSTR_DEFAULT_STR_SIZE];
  73
  74     container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
  75     type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
  76     val_t value = PJ_value_get_or_new ("start", "0 0 1", type); //start is blue
  77     new_pajePushState (MSG_get_clock(), vm_container, type, value);
  78   }
  79
  80 }
  81
  82 void TRACE_msg_vm_kill(msg_vm_t vm) {
  83   if (TRACE_msg_vm_is_enabled()) {
  84     int len = INSTR_DEFAULT_STR_SIZE;
  85     char str[INSTR_DEFAULT_STR_SIZE];
  86
  87     //kill means that this vm no longer exists, let's destroy it
  88     container_t process = PJ_container_get (instr_vm_id(vm, str, len));
  89     PJ_container_remove_from_parent (process);
  90     PJ_container_free (process);
  91   }
  92 }
  93
  94 void TRACE_msg_vm_suspend(msg_vm_t vm)
  95 {
  96   if (TRACE_msg_vm_is_enabled()){
  97     int len = INSTR_DEFAULT_STR_SIZE;
  98     char str[INSTR_DEFAULT_STR_SIZE];
  99
 100     container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
 101     type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
 102     val_t value = PJ_value_get_or_new ("suspend", "1 0 0", type); //suspend is red
 103     new_pajePushState (MSG_get_clock(), vm_container, type, value);
 104   }
 105 }
 106
 107 void TRACE_msg_vm_resume(msg_vm_t vm)
 108 {
 109   if (TRACE_msg_vm_is_enabled()){
 110     int len = INSTR_DEFAULT_STR_SIZE;
 111     char str[INSTR_DEFAULT_STR_SIZE];
 112
 113     container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
 114     type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
 115     new_pajePopState (MSG_get_clock(), vm_container, type);
 116   }
 117 }
 118
 119 void TRACE_msg_vm_save(msg_vm_t vm)
 120 {
 121   if (TRACE_msg_vm_is_enabled()){
 122     int len = INSTR_DEFAULT_STR_SIZE;
 123     char str[INSTR_DEFAULT_STR_SIZE];
 124
 125     container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
 126     type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
 127     val_t value = PJ_value_get_or_new ("save", "0 1 0", type); //save is green
 128     new_pajePushState (MSG_get_clock(), vm_container, type, value);
 129   }
 130 }
 131
 132 void TRACE_msg_vm_restore(msg_vm_t vm)
 133 {
 134   if (TRACE_msg_vm_is_enabled()){
 135     int len = INSTR_DEFAULT_STR_SIZE;
 136     char str[INSTR_DEFAULT_STR_SIZE];
 137
 138     container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
 139     type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
 140     new_pajePopState (MSG_get_clock(), vm_container, type);
 141   }
 142 }
 143
 144 void TRACE_msg_vm_end(msg_vm_t vm)
 145 {
 146   if (TRACE_msg_vm_is_enabled()) {
 147     int len = INSTR_DEFAULT_STR_SIZE;
 148     char str[INSTR_DEFAULT_STR_SIZE];
 149
 150     //that's the end, let's destroy it
 151     container_t container = PJ_container_get (instr_vm_id(vm, str, len));
 152     PJ_container_remove_from_parent (container);
 153     PJ_container_free (container);
 154   }
 155 }