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