← Back to branch summary

~ubuntu-branches/ubuntu/raring/simgrid/raring

« back to all changes in this revision

Viewing changes to src/msg/instr_msg_vm.c

  • Committer: Package Import Robot
  • Author(s): Martin Quinson
  • Date: 2013-01-31 00:24:51 UTC
  • mfrom: (10.1.6 sid)
  • Revision ID: package-import@ubuntu.com-20130131002451-krejhf7w7h24lpsc
Tags: 3.9~rc1-1
* New upstream release: the "Grasgory" release. Major changes:
  - Gras was completely removed from this version.
  - Documentation reorganization to ease browsing it.
  - New default value for the TCP_gamma parameter: 4MiB

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/msg/instr_msg_vm.c
 
1
/* Copyright (c) 2012. 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 "msg_private.h"
 
8
 
 
9
#ifdef HAVE_TRACING
 
10
 
 
11
XBT_LOG_NEW_DEFAULT_SUBCATEGORY (instr_msg_vm, instr, "MSG VM");
 
12
 
 
13
 
 
14
char *instr_vm_id (msg_vm_t vm, char *str, int len)
 
15
{
 
16
  return instr_vm_id_2 (vm->name, str, len);
 
17
}
 
18
 
 
19
char *instr_vm_id_2 (const char *vm_name, char *str, int len)
 
20
{
 
21
  snprintf (str, len, "%s", vm_name);
 
22
  return str;
 
23
}
 
24
 
 
25
/*
 
26
 * Instrumentation functions to trace MSG VMs (msg_vm_t)
 
27
 */
 
28
void TRACE_msg_vm_change_host(msg_vm_t vm, msg_host_t old_host, msg_host_t new_host)
 
29
{
 
30
  if (TRACE_msg_vm_is_enabled()){
 
31
    static long long int counter = 0;
 
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_vm_id(vm, str, len));
 
40
    type_t type = PJ_type_get ("MSG_VM_LINK", PJ_type_get_root());
 
41
    new_pajeStartLink (MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key);
 
42
 
 
43
    //destroy existing container of this vm
 
44
    container_t existing_container = PJ_container_get(instr_vm_id(vm, str, len));
 
45
    PJ_container_remove_from_parent (existing_container);
 
46
    PJ_container_free(existing_container);
 
47
 
 
48
    //create new container on the new_host location
 
49
    msg = PJ_container_new(instr_vm_id(vm, str, len), INSTR_MSG_VM, PJ_container_get(SIMIX_host_get_name(new_host)));
 
50
 
 
51
    //end link
 
52
    msg = PJ_container_get(instr_vm_id(vm, str, len));
 
53
    type = PJ_type_get ("MSG_VM_LINK", PJ_type_get_root());
 
54
    new_pajeEndLink (MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key);
 
55
  }
 
56
}
 
57
 
 
58
void TRACE_msg_vm_create (const char *vm_name, msg_host_t host)
 
59
{
 
60
  if (TRACE_msg_vm_is_enabled()){
 
61
    int len = INSTR_DEFAULT_STR_SIZE;
 
62
    char str[INSTR_DEFAULT_STR_SIZE];
 
63
 
 
64
    container_t host_container = PJ_container_get (SIMIX_host_get_name(host));
 
65
    PJ_container_new(instr_vm_id_2(vm_name, str, len), INSTR_MSG_VM, host_container);
 
66
  }
 
67
}
 
68
 
 
69
void TRACE_msg_vm_kill(msg_vm_t vm) {
 
70
  if (TRACE_msg_vm_is_enabled()) {
 
71
    int len = INSTR_DEFAULT_STR_SIZE;
 
72
    char str[INSTR_DEFAULT_STR_SIZE];
 
73
 
 
74
    //kill means that this vm no longer exists, let's destroy it
 
75
    container_t process = PJ_container_get (instr_vm_id(vm, str, len));
 
76
    PJ_container_remove_from_parent (process);
 
77
    PJ_container_free (process);
 
78
  }
 
79
}
 
80
 
 
81
void TRACE_msg_vm_suspend(msg_vm_t vm)
 
82
{
 
83
  if (TRACE_msg_vm_is_enabled()){
 
84
    int len = INSTR_DEFAULT_STR_SIZE;
 
85
    char str[INSTR_DEFAULT_STR_SIZE];
 
86
 
 
87
    container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
 
88
    type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
 
89
    val_t value = PJ_value_get ("suspend", type);
 
90
    new_pajePushState (MSG_get_clock(), vm_container, type, value);
 
91
  }
 
92
}
 
93
 
 
94
void TRACE_msg_vm_resume(msg_vm_t vm)
 
95
{
 
96
  if (TRACE_msg_vm_is_enabled()){
 
97
    int len = INSTR_DEFAULT_STR_SIZE;
 
98
    char str[INSTR_DEFAULT_STR_SIZE];
 
99
 
 
100
    container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
 
101
    type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
 
102
    new_pajePopState (MSG_get_clock(), vm_container, type);
 
103
  }
 
104
}
 
105
 
 
106
void TRACE_msg_vm_sleep_in(msg_vm_t vm)
 
107
{
 
108
  if (TRACE_msg_vm_is_enabled()){
 
109
    int len = INSTR_DEFAULT_STR_SIZE;
 
110
    char str[INSTR_DEFAULT_STR_SIZE];
 
111
 
 
112
    container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
 
113
    type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
 
114
    val_t value = PJ_value_get ("sleep", type);
 
115
    new_pajePushState (MSG_get_clock(), vm_container, type, value);
 
116
  }
 
117
}
 
118
 
 
119
void TRACE_msg_vm_sleep_out(msg_vm_t vm)
 
120
{
 
121
  if (TRACE_msg_vm_is_enabled()){
 
122
    int len = INSTR_DEFAULT_STR_SIZE;
 
123
    char str[INSTR_DEFAULT_STR_SIZE];
 
124
 
 
125
    container_t vm_container = PJ_container_get (instr_vm_id(vm, str, len));
 
126
    type_t type = PJ_type_get ("MSG_VM_STATE", vm_container->type);
 
127
    new_pajePopState (MSG_get_clock(), vm_container, type);
 
128
  }
 
129
}
 
130
 
 
131
void TRACE_msg_vm_end(msg_vm_t vm)
 
132
{
 
133
  if (TRACE_msg_vm_is_enabled()) {
 
134
    int len = INSTR_DEFAULT_STR_SIZE;
 
135
    char str[INSTR_DEFAULT_STR_SIZE];
 
136
 
 
137
    //that's the end, let's destroy it
 
138
    container_t container = PJ_container_get (instr_vm_id(vm, str, len));
 
139
    PJ_container_remove_from_parent (container);
 
140
    PJ_container_free (container);
 
141
  }
 
142
}
 
143
 
 
144
#endif /* HAVE_TRACING */