1 /* Copyright (c) 2010. The SimGrid Team.
2 * All rights reserved. */
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. */
7 #include "instr/instr_private.h"
11 XBT_LOG_NEW_DEFAULT_SUBCATEGORY (instr_msg, instr, "MSG");
14 * TRACE_msg_set_task_category: tracing interface function
16 void TRACE_msg_set_task_category(m_task_t task, const char *category)
18 if (!TRACE_is_active())
21 xbt_assert3(task->category == NULL, "Task %p(%s) already has a category (%s).",
22 task, task->name, task->category);
23 if (TRACE_msg_task_is_enabled()){
24 xbt_assert2(task->name != NULL,
25 "Task %p(%s) must have a unique name in order to be traced, if --cfg=tracing/msg/task:1 is used.",
27 xbt_assert3(getContainer(task->name)==NULL,
28 "Task %p(%s). Tracing already knows a task with name %s."
29 "The name of each task must be unique, if --cfg=tracing/msg/task:1 is used.", task, task->name, task->name);
32 if (category == NULL) {
33 //if user provides a NULL category, task is no longer traced
34 xbt_free (task->category);
35 task->category = NULL;
40 task->category = xbt_strdup (category);
41 DEBUG3("MSG task %p(%s), category %s", task, task->name, task->category);
43 if (TRACE_msg_task_is_enabled()){
44 m_host_t host = MSG_host_self();
45 container_t host_container = getContainer(host->name);
46 //check to see if there is a container with the task->name
47 xbt_assert3(getContainer(task->name) == NULL,
48 "Task %p(%s). Tracing already knows a task with name %s."
49 "The name of each task must be unique, if --cfg=tracing/msg/task:1 is used.", task, task->name, task->name);
50 container_t msg = newContainer(task->name, INSTR_MSG_TASK, host_container);
51 type_t type = getType (task->category);
53 type = getVariableType(task->category, NULL, msg->type);
55 new_pajeSetVariable (SIMIX_get_clock(), msg, type, 1);
57 type = getType ("MSG_TASK_STATE");
58 new_pajePushState (MSG_get_clock(), msg, type, "created");
62 /* MSG_task_create related function*/
63 void TRACE_msg_task_create(m_task_t task)
65 static long long counter = 0;
66 task->counter = counter++;
67 task->category = NULL;
68 DEBUG2("CREATE %p, %lld", task, task->counter);
71 /* MSG_task_execute related functions */
72 void TRACE_msg_task_execute_start(m_task_t task)
74 if (!task->category) return;
76 DEBUG3("EXEC,in %p, %lld, %s", task, task->counter, task->category);
78 if (TRACE_msg_task_is_enabled()){
79 container_t task_container = getContainer (task->name);
80 type_t type = getType ("MSG_TASK_STATE");
81 new_pajePushState (MSG_get_clock(), task_container, type, "MSG_task_execute");
84 if (TRACE_msg_process_is_enabled()){
85 int len = INSTR_DEFAULT_STR_SIZE;
86 char str[INSTR_DEFAULT_STR_SIZE];
88 container_t process_container = getContainer (instr_process_id(MSG_process_self(), str, len));
89 type_t type = getType ("MSG_PROCESS_STATE");
90 new_pajePushState (MSG_get_clock(), process_container, type, "task_execute");
94 void TRACE_msg_task_execute_end(m_task_t task)
96 if (!task->category) return;
98 DEBUG3("EXEC,out %p, %lld, %s", task, task->counter, task->category);
100 if (TRACE_msg_task_is_enabled()){
101 container_t task_container = getContainer (task->name);
102 type_t type = getType ("MSG_TASK_STATE");
103 new_pajePopState (MSG_get_clock(), task_container, type);
106 if (TRACE_msg_process_is_enabled()){
107 int len = INSTR_DEFAULT_STR_SIZE;
108 char str[INSTR_DEFAULT_STR_SIZE];
110 container_t process_container = getContainer (instr_process_id(MSG_process_self(), str, len));
111 type_t type = getType ("MSG_PROCESS_STATE");
112 new_pajePopState (MSG_get_clock(), process_container, type);
116 /* MSG_task_destroy related functions */
117 void TRACE_msg_task_destroy(m_task_t task)
119 if (!(TRACE_msg_task_is_enabled() &&
120 task->category)) return;
122 //that's the end, let's destroy it
123 destroyContainer (getContainer(task->name));
125 DEBUG3("DESTROY %p, %lld, %s", task, task->counter, task->category);
128 xbt_free(task->category);
129 task->category = NULL;
133 /* MSG_task_get related functions */
134 void TRACE_msg_task_get_start(void)
138 if (TRACE_msg_task_is_enabled()){
139 //task not received yet, nothing to do
142 if (TRACE_msg_process_is_enabled()){
143 int len = INSTR_DEFAULT_STR_SIZE;
144 char str[INSTR_DEFAULT_STR_SIZE];
146 container_t process_container = getContainer (instr_process_id(MSG_process_self(), str, len));
147 type_t type = getType ("MSG_PROCESS_STATE");
148 new_pajePushState (MSG_get_clock(), process_container, type, "receive");
152 void TRACE_msg_task_get_end(double start_time, m_task_t task)
154 if (!task->category) return;
156 DEBUG3("GET,out %p, %lld, %s", task, task->counter, task->category);
158 if (TRACE_msg_task_is_enabled()){
161 //if (TRACE_msg_volume_is_enabled()){
162 // TRACE_msg_volume_end(task);
165 m_host_t host = MSG_host_self();
166 container_t host_container = getContainer(host->name);
167 container_t msg = newContainer(task->name, INSTR_MSG_TASK, host_container);
168 type_t type = getType (task->category);
169 new_pajeSetVariable (SIMIX_get_clock(), msg, type, 1);
171 type = getType ("MSG_TASK_STATE");
172 new_pajePushState (MSG_get_clock(), msg, type, "created");
174 type = getType ("MSG_TASK_LINK");
175 char key[INSTR_DEFAULT_STR_SIZE];
176 snprintf (key, INSTR_DEFAULT_STR_SIZE, "%lld", task->counter);
177 new_pajeEndLink (MSG_get_clock(), getRootContainer(), type, msg, "SR", key);
180 if (TRACE_msg_process_is_enabled()){
181 int len = INSTR_DEFAULT_STR_SIZE;
182 char str[INSTR_DEFAULT_STR_SIZE];
184 container_t process_container = getContainer (instr_process_id(MSG_process_self(), str, len));
185 type_t type = getType ("MSG_PROCESS_STATE");
186 new_pajePopState (MSG_get_clock(), process_container, type);
188 char key[INSTR_DEFAULT_STR_SIZE];
189 snprintf (key, INSTR_DEFAULT_STR_SIZE, "p%lld", task->counter);
190 type = getType ("MSG_PROCESS_TASK_LINK");
191 new_pajeEndLink(MSG_get_clock(), getRootContainer(), type, process_container, "SR", key);
195 /* MSG_task_put related functions */
196 int TRACE_msg_task_put_start(m_task_t task)
198 if (!task->category) return 0;
200 DEBUG3("PUT,in %p, %lld, %s", task, task->counter, task->category);
202 if (TRACE_msg_task_is_enabled()){
204 container_t msg = getContainer (task->name);
205 type_t type = getType ("MSG_TASK_STATE");
206 new_pajePopState (MSG_get_clock(), msg, type);
208 type = getType ("MSG_TASK_LINK");
209 char key[INSTR_DEFAULT_STR_SIZE];
210 snprintf (key, INSTR_DEFAULT_STR_SIZE, "%lld", task->counter);
211 new_pajeStartLink(MSG_get_clock(), getRootContainer(), type, msg, "SR", key);
213 destroyContainer (msg);
216 //if (TRACE_msg_volume_is_enabled()){
217 // TRACE_msg_volume_start(task);
221 if (TRACE_msg_process_is_enabled()){
222 int len = INSTR_DEFAULT_STR_SIZE;
223 char str[INSTR_DEFAULT_STR_SIZE];
225 container_t process_container = getContainer (instr_process_id(MSG_process_self(), str, len));
226 type_t type = getType ("MSG_PROCESS_STATE");
227 new_pajePushState (MSG_get_clock(), process_container, type, "send");
229 char key[INSTR_DEFAULT_STR_SIZE];
230 snprintf (key, INSTR_DEFAULT_STR_SIZE, "p%lld", task->counter);
231 type = getType ("MSG_PROCESS_TASK_LINK");
232 new_pajeStartLink(MSG_get_clock(), getRootContainer(), type, process_container, "SR", key);
238 void TRACE_msg_task_put_end(void)
242 if (TRACE_msg_task_is_enabled()){
243 //task no longer exists here
246 if (TRACE_msg_process_is_enabled()){
247 int len = INSTR_DEFAULT_STR_SIZE;
248 char str[INSTR_DEFAULT_STR_SIZE];
250 container_t process_container = getContainer (instr_process_id(MSG_process_self(), str, len));
251 type_t type = getType ("MSG_PROCESS_STATE");
252 new_pajePopState (MSG_get_clock(), process_container, type);
256 #endif /* HAVE_TRACING */