2 * Copyright (C) 2011 Mathieu Bain <mathieu.bain@polymtl.ca>
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License Version 2 as
6 * published by the Free Software Foundation;
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
13 * You should have received a copy of the GNU General Public License
14 * along with this program; if not, write to the Free Software
15 * Foundation, Inc., 59 Temple Place - Suite 330, Boston,
21 #include <sys/types.h>
24 #include <babeltrace/babeltrace.h>
26 #include "lttngtoptypes.h"
28 #include "iostreamtop.h"
30 void add_file(struct processtop
*proc
, struct files
*file
, int fd
)
32 if (proc
->process_files_table
->len
<= fd
) {
33 g_ptr_array_set_size(proc
->process_files_table
, fd
);
34 g_ptr_array_add(proc
->process_files_table
, file
);
36 g_ptr_array_index(proc
->process_files_table
, fd
) = file
;
42 void insert_file(struct processtop
*proc
, int fd
)
46 if (fd
>= proc
->process_files_table
->len
) {
47 tmp
= g_new0(struct files
, 1);
48 tmp
->name
= "Unknown";
49 add_file(proc
, tmp
, fd
);
52 tmp
= g_ptr_array_index(proc
->process_files_table
, fd
);
54 tmp
= g_new0(struct files
, 1);
55 tmp
->name
= "Unknown";
59 add_file(proc
, tmp
, fd
);
64 void close_file(struct processtop
*proc
, int fd
)
68 len
= proc
->process_files_table
->len
;
71 * It is possible that a file was open before taking the trace
72 * and its fd could be greater than all of the others fd
76 g_ptr_array_remove_index_fast(proc
->process_files_table
, fd
);
77 g_ptr_array_set_size(proc
->process_files_table
, len
+ 1);
81 struct files
*get_file(struct processtop
*proc
, int fd
)
84 tmp
= g_ptr_array_index(proc
->process_files_table
, fd
);
88 void show_table(GPtrArray
*tab
)
93 for (i
= 0 ; i
< tab
->len
; i
++) {
94 file
= g_ptr_array_index(tab
, i
);
96 fprintf(stderr
, "NULL, ");
98 fprintf(stderr
, "%s, ", file
->name
);
100 fprintf(stderr
, "]\n\n");
103 int update_iostream_ret(struct lttngtop
*ctx
, int tid
, char *comm
,
104 unsigned long timestamp
, uint64_t cpu_id
, int ret
)
106 struct processtop
*tmp
;
107 struct files
*tmpfile
;
110 tmp
= get_proc(ctx
, tid
, comm
, timestamp
);
112 if (tmp
->syscall_info
!= NULL
) {
113 if (tmp
->syscall_info
->type
== __NR_read
115 tmp
->totalfileread
+= ret
;
116 tmp
->fileread
+= ret
;
117 tmpfile
= get_file(tmp
, tmp
->syscall_info
->fd
);
118 tmpfile
->read
+= ret
;
119 } else if (tmp
->syscall_info
->type
== __NR_write
121 tmp
->totalfilewrite
+= ret
;
122 tmp
->filewrite
+= ret
;
123 tmpfile
= get_file(tmp
, tmp
->syscall_info
->fd
);
124 tmpfile
->write
+= ret
;
125 } else if (tmp
->syscall_info
->type
== __NR_open
127 add_file(tmp
, tmp
->files_history
->file
, ret
);
131 g_free(tmp
->syscall_info
);
132 tmp
->syscall_info
= NULL
;
137 struct syscalls
*create_syscall_info(unsigned int type
, uint64_t cpu_id
,
138 unsigned int tid
, int fd
)
140 struct syscalls
*syscall_info
;
142 syscall_info
= g_new0(struct syscalls
, 1);
143 syscall_info
->type
= type
;
144 syscall_info
->cpu_id
= cpu_id
;
145 syscall_info
->tid
= tid
;
146 syscall_info
->fd
= fd
;
151 struct file_history
*create_file(struct file_history
*history
, char *file_name
)
153 struct files
*new_file
;
154 struct file_history
*new_history
;
156 new_file
= g_new0(struct files
, 1);
157 new_history
= g_new0(struct file_history
, 1);
158 new_file
->name
= strdup(file_name
);
161 new_history
->file
= new_file
;
162 new_history
->next
= history
;
167 enum bt_cb_ret
handle_exit_syscall(struct bt_ctf_event
*call_data
,
170 struct definition
*scope
;
171 unsigned long timestamp
;
176 timestamp
= bt_ctf_get_timestamp(call_data
);
177 if (timestamp
== -1ULL)
180 comm
= get_context_comm(call_data
);
181 tid
= get_context_tid(call_data
);
183 scope
= bt_ctf_get_top_level_scope(call_data
,
185 ret
= bt_ctf_get_int64(bt_ctf_get_field(call_data
,
187 if (bt_ctf_field_get_error()) {
188 fprintf(stderr
, "Missing ret context info\n");
192 cpu_id
= get_cpu_id(call_data
);
195 * if we encounter an exit_syscall and
196 * it is not for a syscall read or write
197 * we just abort the execution of this callback
199 if ((update_iostream_ret(<tngtop
, tid
, comm
, timestamp
, cpu_id
, ret
)) < 0)
200 return BT_CB_ERROR_CONTINUE
;
205 return BT_CB_ERROR_STOP
;
209 enum bt_cb_ret
handle_sys_write(struct bt_ctf_event
*call_data
,
212 struct definition
*scope
;
213 struct processtop
*tmp
;
214 unsigned long timestamp
;
220 timestamp
= bt_ctf_get_timestamp(call_data
);
221 if (timestamp
== -1ULL)
224 comm
= get_context_comm(call_data
);
225 tid
= get_context_tid(call_data
);
226 cpu_id
= get_cpu_id(call_data
);
228 scope
= bt_ctf_get_top_level_scope(call_data
,
230 fd
= bt_ctf_get_uint64(bt_ctf_get_field(call_data
,
232 if (bt_ctf_field_get_error()) {
233 fprintf(stderr
, "Missing fd context info\n");
237 tmp
= get_proc(<tngtop
, tid
, comm
, timestamp
);
238 tmp
->syscall_info
= create_syscall_info(__NR_write
, cpu_id
, tid
, fd
);
240 insert_file(tmp
, fd
);
245 return BT_CB_ERROR_STOP
;
248 enum bt_cb_ret
handle_sys_read(struct bt_ctf_event
*call_data
,
251 struct processtop
*tmp
;
252 struct definition
*scope
;
253 unsigned long timestamp
;
259 timestamp
= bt_ctf_get_timestamp(call_data
);
260 if (timestamp
== -1ULL)
263 comm
= get_context_comm(call_data
);
264 tid
= get_context_tid(call_data
);
265 cpu_id
= get_cpu_id(call_data
);
267 scope
= bt_ctf_get_top_level_scope(call_data
,
269 fd
= bt_ctf_get_uint64(bt_ctf_get_field(call_data
,
271 if (bt_ctf_field_get_error()) {
272 fprintf(stderr
, "Missing fd context info\n");
276 tmp
= get_proc(<tngtop
, tid
, comm
, timestamp
);
277 tmp
->syscall_info
= create_syscall_info(__NR_read
, cpu_id
, tid
, fd
);
279 insert_file(tmp
, fd
);
284 return BT_CB_ERROR_STOP
;
288 enum bt_cb_ret
handle_sys_open(struct bt_ctf_event
*call_data
,
292 struct processtop
*tmp
;
293 struct definition
*scope
;
294 unsigned long timestamp
;
300 timestamp
= bt_ctf_get_timestamp(call_data
);
301 if (timestamp
== -1ULL)
304 comm
= get_context_comm(call_data
);
305 tid
= get_context_tid(call_data
);
306 cpu_id
= get_cpu_id(call_data
);
308 scope
= bt_ctf_get_top_level_scope(call_data
,
310 file
= bt_ctf_get_string(bt_ctf_get_field(call_data
,
311 scope
, "_filename"));
312 if (bt_ctf_field_get_error()) {
313 fprintf(stderr
, "Missing fd context info\n");
317 tmp
= get_proc(<tngtop
, tid
, comm
, timestamp
);
318 tmp
->syscall_info
= create_syscall_info(__NR_open
, cpu_id
, tid
, -1);
320 tmp
->files_history
= create_file(tmp
->files_history
, file
);
325 return BT_CB_ERROR_STOP
;
329 enum bt_cb_ret
handle_sys_close(struct bt_ctf_event
*call_data
,
332 struct definition
*scope
;
333 unsigned long timestamp
;
335 struct processtop
*tmp
;
339 timestamp
= bt_ctf_get_timestamp(call_data
);
340 if (timestamp
== -1ULL)
343 comm
= get_context_comm(call_data
);
344 tid
= get_context_tid(call_data
);
346 scope
= bt_ctf_get_top_level_scope(call_data
,
348 fd
= bt_ctf_get_uint64(bt_ctf_get_field(call_data
,
350 if (bt_ctf_field_get_error()) {
351 fprintf(stderr
, "Missing fd context info\n");
355 tmp
= get_proc(<tngtop
, tid
, comm
, timestamp
);
361 return BT_CB_ERROR_STOP
;
This page took 0.03684 seconds and 5 git commands to generate.