src/msg/instr_msg_process.cpp

   1 /* Copyright (c) 2010, 2012-2017. The SimGrid Team. All rights reserved.    */
   2
   3 /* This program is free software; you can redistribute it and/or modify it
   4  * under the terms of the license (GNU LGPL) which comes with this package. */
   5
   6 #include "simgrid/s4u/Host.hpp"
   7 #include "src/instr/instr_private.hpp"
   8 #include "src/msg/msg_private.hpp"
   9 #include "src/simix/ActorImpl.hpp"
  10
  11 XBT_LOG_NEW_DEFAULT_SUBCATEGORY (instr_msg_process, instr, "MSG process");
  12
  13 char *instr_process_id (msg_process_t proc, char *str, int len)
  14 {
  15   return instr_process_id_2(proc->getCname(), proc->getPid(), str, len);
  16 }
  17
  18 char *instr_process_id_2 (const char *process_name, int process_pid, char *str, int len)
  19 {
  20   snprintf (str, len, "%s-%d", process_name, process_pid);
  21   return str;
  22 }
  23
  24 /*
  25  * Instrumentation functions to trace MSG processes (msg_process_t)
  26  */
  27 void TRACE_msg_process_change_host(msg_process_t process, msg_host_t new_host)
  28 {
  29   if (TRACE_msg_process_is_enabled()){
  30     static long long int counter = 0;
  31
  32     char key[INSTR_DEFAULT_STR_SIZE];
  33     snprintf (key, INSTR_DEFAULT_STR_SIZE, "%lld", counter++);
  34
  35     int len = INSTR_DEFAULT_STR_SIZE;
  36     char str[INSTR_DEFAULT_STR_SIZE];
  37
  38     //start link
  39     container_t msg = PJ_container_get (instr_process_id(process, str, len));
  40     simgrid::instr::Type* type = PJ_type_get_root()->getChild("MSG_PROCESS_LINK");
  41     new simgrid::instr::StartLinkEvent(MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key);
  42
  43     //destroy existing container of this process
  44     TRACE_msg_process_destroy (MSG_process_get_name (process), MSG_process_get_PID (process));
  45
  46     //create new container on the new_host location
  47     TRACE_msg_process_create (MSG_process_get_name (process), MSG_process_get_PID (process), new_host);
  48
  49     //end link
  50     msg = PJ_container_get(instr_process_id(process, str, len));
  51     type = PJ_type_get_root()->getChild("MSG_PROCESS_LINK");
  52     new simgrid::instr::EndLinkEvent(MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key);
  53   }
  54 }
  55
  56 void TRACE_msg_process_create (const char *process_name, int process_pid, msg_host_t host)
  57 {
  58   if (TRACE_msg_process_is_enabled()){
  59     int len = INSTR_DEFAULT_STR_SIZE;
  60     char str[INSTR_DEFAULT_STR_SIZE];
  61
  62     container_t host_container = PJ_container_get(host->getCname());
  63     new simgrid::instr::Container(instr_process_id_2(process_name, process_pid, str, len),
  64                                   simgrid::instr::INSTR_MSG_PROCESS, host_container);
  65   }
  66 }
  67
  68 void TRACE_msg_process_destroy (const char *process_name, int process_pid)
  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 process = PJ_container_get_or_null(instr_process_id_2(process_name, process_pid, str, len));
  75     if (process) {
  76       PJ_container_remove_from_parent (process);
  77       delete process;
  78     }
  79   }
  80 }
  81
  82 void TRACE_msg_process_kill(smx_process_exit_status_t status, msg_process_t process)
  83 {
  84   if (TRACE_msg_process_is_enabled() && status==SMX_EXIT_FAILURE){
  85     //kill means that this process no longer exists, let's destroy it
  86     TRACE_msg_process_destroy(process->getCname(), process->getPid());
  87   }
  88 }
  89
  90 void TRACE_msg_process_suspend(msg_process_t process)
  91 {
  92   if (TRACE_msg_process_is_enabled()){
  93     int len = INSTR_DEFAULT_STR_SIZE;
  94     char str[INSTR_DEFAULT_STR_SIZE];
  95
  96     container_t process_container = PJ_container_get (instr_process_id(process, str, len));
  97     simgrid::instr::Type* type    = process_container->type_->getChild("MSG_PROCESS_STATE");
  98     simgrid::instr::Value* val    = simgrid::instr::Value::get("suspend", type);
  99     new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, type, val);
 100   }
 101 }
 102
 103 void TRACE_msg_process_resume(msg_process_t process)
 104 {
 105   if (TRACE_msg_process_is_enabled()){
 106     int len = INSTR_DEFAULT_STR_SIZE;
 107     char str[INSTR_DEFAULT_STR_SIZE];
 108
 109     container_t process_container = PJ_container_get (instr_process_id(process, str, len));
 110     simgrid::instr::Type* type    = process_container->type_->getChild("MSG_PROCESS_STATE");
 111     new simgrid::instr::PopStateEvent(MSG_get_clock(), process_container, type);
 112   }
 113 }
 114
 115 void TRACE_msg_process_sleep_in(msg_process_t process)
 116 {
 117   if (TRACE_msg_process_is_enabled()){
 118     int len = INSTR_DEFAULT_STR_SIZE;
 119     char str[INSTR_DEFAULT_STR_SIZE];
 120
 121     container_t process_container = PJ_container_get (instr_process_id(process, str, len));
 122     simgrid::instr::Type* type    = process_container->type_->getChild("MSG_PROCESS_STATE");
 123     simgrid::instr::Value* val    = simgrid::instr::Value::get("sleep", type);
 124     new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, type, val);
 125   }
 126 }
 127
 128 void TRACE_msg_process_sleep_out(msg_process_t process)
 129 {
 130   if (TRACE_msg_process_is_enabled()){
 131     int len = INSTR_DEFAULT_STR_SIZE;
 132     char str[INSTR_DEFAULT_STR_SIZE];
 133
 134     container_t process_container = PJ_container_get (instr_process_id(process, str, len));
 135     simgrid::instr::Type* type    = process_container->type_->getChild("MSG_PROCESS_STATE");
 136     new simgrid::instr::PopStateEvent(MSG_get_clock(), process_container, type);
 137   }
 138 }