Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
remove the argc/argv version of simcall_process_create
[simgrid.git] / src / msg / instr_msg_task.cpp
1 /* Copyright (c) 2010-2018. 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 "mc/mc.h"
8 #include "src/instr/instr_private.hpp"
9 #include "src/msg/msg_private.hpp"
10
11 #include <atomic>
12
13 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(instr_msg, instr, "MSG instrumentation");
14
15 void TRACE_msg_set_task_category(msg_task_t task, const char *category)
16 {
17   xbt_assert(task->category == nullptr, "Task %p(%s) already has a category (%s).",
18       task, task->name, task->category);
19
20   //if user provides a nullptr category, task is no longer traced
21   if (category == nullptr) {
22     xbt_free (task->category);
23     task->category = nullptr;
24     XBT_DEBUG("MSG task %p(%s), category removed", task, task->name);
25     return;
26   }
27
28   //set task category
29   task->category = xbt_strdup (category);
30   XBT_DEBUG("MSG task %p(%s), category %s", task, task->name, task->category);
31 }
32
33 /* MSG_task_create related function*/
34 void TRACE_msg_task_create(msg_task_t task)
35 {
36   static std::atomic_ullong counter{0};
37   task->counter = counter++;
38   task->category = nullptr;
39
40   if(MC_is_active())
41     MC_ignore_heap(&(task->counter), sizeof(task->counter));
42
43   XBT_DEBUG("CREATE %p, %lld", task, task->counter);
44 }
45
46 /* MSG_task_execute related functions */
47 void TRACE_msg_task_execute_start(msg_task_t task)
48 {
49   XBT_DEBUG("EXEC,in %p, %lld, %s", task, task->counter, task->category);
50
51   if (TRACE_actor_is_enabled())
52     simgrid::instr::Container::by_name(instr_pid(MSG_process_self()))->get_state("ACTOR_STATE")->push_event("execute");
53 }
54
55 void TRACE_msg_task_execute_end(msg_task_t task)
56 {
57   XBT_DEBUG("EXEC,out %p, %lld, %s", task, task->counter, task->category);
58
59   if (TRACE_actor_is_enabled())
60     simgrid::instr::Container::by_name(instr_pid(MSG_process_self()))->get_state("ACTOR_STATE")->pop_event();
61 }
62
63 /* MSG_task_destroy related functions */
64 void TRACE_msg_task_destroy(msg_task_t task)
65 {
66   XBT_DEBUG("DESTROY %p, %lld, %s", task, task->counter, task->category);
67
68   //free category
69   xbt_free(task->category);
70   task->category = nullptr;
71 }
72
73 /* MSG_task_get related functions */
74 void TRACE_msg_task_get_start()
75 {
76   XBT_DEBUG("GET,in");
77
78   if (TRACE_actor_is_enabled())
79     simgrid::instr::Container::by_name(instr_pid(MSG_process_self()))->get_state("ACTOR_STATE")->push_event("receive");
80 }
81
82 void TRACE_msg_task_get_end(msg_task_t task)
83 {
84   XBT_DEBUG("GET,out %p, %lld, %s", task, task->counter, task->category);
85
86   if (TRACE_actor_is_enabled()) {
87     container_t process_container = simgrid::instr::Container::by_name(instr_pid(MSG_process_self()));
88     process_container->get_state("ACTOR_STATE")->pop_event();
89
90     std::string key = std::string("p") + std::to_string(task->counter);
91     simgrid::instr::Container::get_root()->get_link("ACTOR_TASK_LINK")->end_event(process_container, "SR", key);
92   }
93 }
94
95 /* MSG_task_put related functions */
96 void TRACE_msg_task_put_start(msg_task_t task)
97 {
98   XBT_DEBUG("PUT,in %p, %lld, %s", task, task->counter, task->category);
99
100   if (TRACE_actor_is_enabled()) {
101     container_t process_container = simgrid::instr::Container::by_name(instr_pid(MSG_process_self()));
102     process_container->get_state("ACTOR_STATE")->push_event("send");
103
104     std::string key = std::string("p") + std::to_string(task->counter);
105     simgrid::instr::Container::get_root()->get_link("ACTOR_TASK_LINK")->start_event(process_container, "SR", key);
106   }
107 }
108
109 void TRACE_msg_task_put_end()
110 {
111   XBT_DEBUG("PUT,out");
112
113   if (TRACE_actor_is_enabled())
114     simgrid::instr::Container::by_name(instr_pid(MSG_process_self()))->get_state("ACTOR_STATE")->pop_event();
115 }