src/instr/instr_msg_process.c

   1 /* Copyright (c) 2010. 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 "instr/instr_private.h"
   8
   9 #ifdef HAVE_TRACING
  10
  11 XBT_LOG_NEW_DEFAULT_SUBCATEGORY (instr_msg_process, instr, "MSG process");
  12
  13 /*
  14  * TRACE_msg_set_process_category: tracing interface function
  15  */
  16 void TRACE_msg_set_process_category(m_process_t process, const char *category, const char *color)
  17 {
  18   xbt_die("deprecated");
  19 }
  20
  21 char *instr_process_id (m_process_t proc, char *str, int len)
  22 {
  23   return instr_process_id_2 (MSG_process_get_name(proc), MSG_process_get_PID(proc), str, len);
  24 }
  25
  26 char *instr_process_id_2 (const char *process_name, int process_pid, char *str, int len)
  27 {
  28   snprintf (str, len, "%s-%d", process_name, process_pid);
  29   return str;
  30 }
  31
  32 /*
  33  * Instrumentation functions to trace MSG processes (m_process_t)
  34  */
  35 void TRACE_msg_process_change_host(m_process_t process, m_host_t old_host, m_host_t new_host)
  36 {
  37   if (TRACE_msg_process_is_enabled()){
  38     static long long int counter = 0;
  39     char key[INSTR_DEFAULT_STR_SIZE];
  40     snprintf (key, INSTR_DEFAULT_STR_SIZE, "%lld", counter++);
  41
  42     int len = INSTR_DEFAULT_STR_SIZE;
  43     char str[INSTR_DEFAULT_STR_SIZE];
  44
  45     //start link
  46     container_t msg = getContainer(instr_process_id(process, str, len));
  47     type_t type = getType ("MSG_PROCESS_LINK", getRootType());
  48     new_pajeStartLink (MSG_get_clock(), getRootContainer(), type, msg, "M", key);
  49
  50     //destroy existing container of this process
  51     destroyContainer(getContainer(instr_process_id(process, str, len)));
  52
  53     //create new container on the new_host location
  54     msg = newContainer(instr_process_id(process, str, len), INSTR_MSG_PROCESS, getContainer(new_host->name));
  55
  56     //set the state of this new container
  57     type = getType ("MSG_PROCESS_STATE", msg->type);
  58     val_t value = getValueByName ("executing", type);
  59     new_pajeSetState (MSG_get_clock(), msg, type, value);
  60
  61     //end link
  62     msg = getContainer(instr_process_id(process, str, len));
  63     type = getType ("MSG_PROCESS_LINK", getRootType());
  64     new_pajeEndLink (MSG_get_clock(), getRootContainer(), type, msg, "M", key);
  65   }
  66 }
  67
  68 void TRACE_msg_process_create (const char *process_name, int process_pid, m_host_t host)
  69 {
  70   if (TRACE_msg_process_is_enabled()){
  71     int len = INSTR_DEFAULT_STR_SIZE;
  72     char str[INSTR_DEFAULT_STR_SIZE];
  73
  74     container_t host_container = getContainer(host->name);
  75     container_t msg = newContainer(instr_process_id_2(process_name, process_pid, str, len), INSTR_MSG_PROCESS, host_container);
  76
  77     type_t type = getType ("MSG_PROCESS_STATE", msg->type);
  78     val_t value = getValueByName ("executing", type);
  79     new_pajeSetState (MSG_get_clock(), msg, type, value);
  80   }
  81 }
  82
  83 void TRACE_msg_process_kill(m_process_t process)
  84 {
  85   if (TRACE_msg_process_is_enabled()){
  86     int len = INSTR_DEFAULT_STR_SIZE;
  87     char str[INSTR_DEFAULT_STR_SIZE];
  88
  89     //kill means that this process no longer exists, let's destroy it
  90     destroyContainer (getContainer(instr_process_id(process, str, len)));
  91   }
  92 }
  93
  94 void TRACE_msg_process_suspend(m_process_t process)
  95 {
  96   if (TRACE_msg_process_is_enabled()){
  97     int len = INSTR_DEFAULT_STR_SIZE;
  98     char str[INSTR_DEFAULT_STR_SIZE];
  99
 100     container_t process_container = getContainer (instr_process_id(process, str, len));
 101     type_t type = getType ("MSG_PROCESS_STATE", process_container->type);
 102     val_t value = getValueByName ("suspend", type);
 103     new_pajePushState (MSG_get_clock(), process_container, type, value);
 104   }
 105 }
 106
 107 void TRACE_msg_process_resume(m_process_t process)
 108 {
 109   if (TRACE_msg_process_is_enabled()){
 110     int len = INSTR_DEFAULT_STR_SIZE;
 111     char str[INSTR_DEFAULT_STR_SIZE];
 112
 113     container_t process_container = getContainer (instr_process_id(process, str, len));
 114     type_t type = getType ("MSG_PROCESS_STATE", process_container->type);
 115     new_pajePopState (MSG_get_clock(), process_container, type);
 116   }
 117 }
 118
 119 void TRACE_msg_process_sleep_in(m_process_t process)
 120 {
 121   if (TRACE_msg_process_is_enabled()){
 122     int len = INSTR_DEFAULT_STR_SIZE;
 123     char str[INSTR_DEFAULT_STR_SIZE];
 124
 125     container_t process_container = getContainer (instr_process_id(process, str, len));
 126     type_t type = getType ("MSG_PROCESS_STATE", process_container->type);
 127     val_t value = getValueByName ("sleep", type);
 128     new_pajePushState (MSG_get_clock(), process_container, type, value);
 129   }
 130 }
 131
 132 void TRACE_msg_process_sleep_out(m_process_t process)
 133 {
 134   if (TRACE_msg_process_is_enabled()){
 135     int len = INSTR_DEFAULT_STR_SIZE;
 136     char str[INSTR_DEFAULT_STR_SIZE];
 137
 138     container_t process_container = getContainer (instr_process_id(process, str, len));
 139     type_t type = getType ("MSG_PROCESS_STATE", process_container->type);
 140     new_pajePopState (MSG_get_clock(), process_container, type);
 141   }
 142 }
 143
 144 void TRACE_msg_process_end(m_process_t process)
 145 {
 146   if (TRACE_msg_process_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     destroyContainer (getContainer(instr_process_id(process, str, len)));
 152   }
 153 }
 154
 155 #endif /* HAVE_TRACING */