git-svn-id: http://ltt.polymtl.ca/svn@327 04897980-b3bd-0310-b5e0-8ef037075253
[lttv.git] / ltt / branches / poly / lttv / modules / guiEvents.c
1 //*! \defgroup GuiEvents libGuiEvents: The GUI Events display plugin */
2 /*\@{*/
3
4 /*! \file GuiEvents.c
5 * \brief Graphical plugin for showing events.
6 *
7 * This plugin lists all the events contained in the current time interval
8 * in a list.
9 *
10 * This plugin adds a Events Viewer functionnality to Linux TraceToolkit
11 * GUI when this plugin is loaded. The init and destroy functions add the
12 * viewer's insertion menu item and toolbar icon by calling gtkTraceSet's
13 * API functions. Then, when a viewer's object is created, the constructor
14 * creates ans register through API functions what is needed to interact
15 * with the TraceSet window.
16 *
17 * Coding standard :
18 * pm : parameter
19 * l : local
20 * g : global
21 * s : static
22 * h : hook
23 *
24 * Author : Karim Yaghmour
25 * Integrated to LTTng by Mathieu Desnoyers, June 2003
26 */
27
28 #include <math.h>
29
30 #include <glib.h>
31 #include <gmodule.h>
32 #include <gtk/gtk.h>
33 #include <gdk/gdk.h>
34
35 #include <lttv/module.h>
36 #include <lttv/hook.h>
37 #include <lttv/gtkTraceSet.h>
38 #include <lttv/processTrace.h>
39 #include <lttv/state.h>
40 #include <ltt/ltt.h>
41 #include <ltt/event.h>
42 #include <ltt/type.h>
43 #include <ltt/trace.h>
44 #include <string.h>
45
46 //#include "mw_api.h"
47 #include "gtktreeprivate.h"
48
49 #include "icons/hGuiEventsInsert.xpm"
50
51
52 static LttvHooks *before_event;
53
54 /** Array containing instanced objects. Used when module is unloaded */
55 static GSList *g_event_viewer_data_list = NULL ;
56
57 /** hook functions for update time interval, current time ... */
58 gboolean update_time_window(void * hook_data, void * call_data);
59 gboolean update_current_time(void * hook_data, void * call_data);
60 void remove_item_from_queue(GQueue * q, gboolean fromHead);
61 void remove_all_items_from_queue(GQueue * q);
62
63 typedef struct _RawTraceData{
64 unsigned cpu_id;
65 char * event_name;
66 LttTime time;
67 int pid;
68 unsigned entry_length;
69 char * event_description;
70 LttEventPosition ep;
71 } RawTraceData;
72
73 #define RESERVE_BIG_SIZE 1000
74 #define RESERVE_SMALL_SIZE 100
75
76 typedef enum _ScrollDirection{
77 SCROLL_STEP_UP,
78 SCROLL_STEP_DOWN,
79 SCROLL_PAGE_UP,
80 SCROLL_PAGE_DOWN,
81 SCROLL_JUMP,
82 SCROLL_NONE
83 } ScrollDirection;
84
85 typedef struct _EventViewerData {
86
87 MainWindow * mw;
88 TimeWindow time_window;
89 LttTime current_time;
90 LttvHooks * before_event_hooks;
91
92 gboolean append; //prepend or append item
93 GQueue * raw_trace_data_queue; //buf to contain raw trace data
94 GQueue * raw_trace_data_queue_tmp; //tmp buf to contain raw data
95 unsigned current_event_index;
96 double previous_value; //value of the slide
97 TimeInterval time_span;
98 // LttTime trace_start;
99 // LttTime trace_end;
100 unsigned start_event_index; //the first event shown in the window
101 unsigned end_event_index; //the last event shown in the window
102
103 //scroll window containing Tree View
104 GtkWidget * scroll_win;
105
106 /* Model containing list data */
107 GtkListStore *store_m;
108
109 GtkWidget *hbox_v;
110 /* Widget to display the data in a columned list */
111 GtkWidget *tree_v;
112 GtkAdjustment *vtree_adjust_c ;
113
114 /* Vertical scrollbar and it's adjustment */
115 GtkWidget *vscroll_vc;
116 GtkAdjustment *vadjust_c ;
117
118 /* Selection handler */
119 GtkTreeSelection *select_c;
120
121 guint num_visible_events;
122 guint first_event, last_event;
123
124 /* TEST DATA, TO BE READ FROM THE TRACE */
125 gint number_of_events ;
126 guint currently_selected_event ;
127 gboolean selected_event ;
128
129 } EventViewerData ;
130
131 //! Event Viewer's constructor hook
132 GtkWidget *h_gui_events(MainWindow *parent_window);
133 //! Event Viewer's constructor
134 EventViewerData *gui_events(MainWindow *parent_window);
135 //! Event Viewer's destructor
136 void gui_events_destructor(EventViewerData *event_viewer_data);
137 void gui_events_free(EventViewerData *event_viewer_data);
138
139 static int event_selected_hook(void *hook_data, void *call_data);
140
141 void tree_v_set_cursor(EventViewerData *event_viewer_data);
142 void tree_v_get_cursor(EventViewerData *event_viewer_data);
143
144 /* Prototype for selection handler callback */
145 static void tree_selection_changed_cb (GtkTreeSelection *selection, gpointer data);
146 static void v_scroll_cb (GtkAdjustment *adjustment, gpointer data);
147 static void tree_v_size_allocate_cb (GtkWidget *widget, GtkAllocation *alloc, gpointer data);
148 static void tree_v_size_request_cb (GtkWidget *widget, GtkRequisition *requisition, gpointer data);
149 static void tree_v_cursor_changed_cb (GtkWidget *widget, gpointer data);
150 static void tree_v_move_cursor_cb (GtkWidget *widget, GtkMovementStep arg1, gint arg2, gpointer data);
151 static void tree_v_grab_focus(GtkWidget *widget, gpointer data);
152
153
154 static void get_test_data(double time, guint list_height,
155 EventViewerData *event_viewer_data);
156
157 void add_test_data(EventViewerData *event_viewer_data);
158
159 static void get_events(EventViewerData* event_viewer_data, LttTime start,
160 LttTime end, unsigned max_num_events, unsigned * real_num_events);
161 static gboolean parse_event(void *hook_data, void *call_data);
162
163 static LttvModule *main_win_module;
164
165 /**
166 * plugin's init function
167 *
168 * This function initializes the Event Viewer functionnality through the
169 * gtkTraceSet API.
170 */
171 G_MODULE_EXPORT void init(LttvModule *self, int argc, char *argv[]) {
172
173 main_win_module = lttv_module_require(self, "mainwin", argc, argv);
174
175 if(main_win_module == NULL){
176 g_critical("Can't load Control Flow Viewer : missing mainwin\n");
177 return;
178 }
179
180 /* Register the toolbar insert button */
181 toolbar_item_reg(hGuiEventsInsert_xpm, "Insert Event Viewer", h_gui_events);
182
183 /* Register the menu item insert entry */
184 menu_item_reg("/", "Insert Event Viewer", h_gui_events);
185
186 }
187
188 void event_destroy_walk(gpointer data, gpointer user_data)
189 {
190 gui_events_destructor((EventViewerData*)data);
191 }
192
193 /**
194 * plugin's destroy function
195 *
196 * This function releases the memory reserved by the module and unregisters
197 * everything that has been registered in the gtkTraceSet API.
198 */
199 G_MODULE_EXPORT void destroy() {
200 int i;
201
202 EventViewerData *event_viewer_data;
203
204 if(g_event_viewer_data_list){
205 g_slist_foreach(g_event_viewer_data_list, event_destroy_walk, NULL );
206 g_slist_free(g_event_viewer_data_list);
207 }
208
209 /* Unregister the toolbar insert button */
210 toolbar_item_unreg(h_gui_events);
211
212 /* Unregister the menu item insert entry */
213 menu_item_unreg(h_gui_events);
214 }
215
216 /* Enumeration of the columns */
217 enum
218 {
219 CPUID_COLUMN,
220 EVENT_COLUMN,
221 TIME_COLUMN,
222 PID_COLUMN,
223 ENTRY_LEN_COLUMN,
224 EVENT_DESCR_COLUMN,
225 N_COLUMNS
226 };
227
228
229 /**
230 * Event Viewer's constructor hook
231 *
232 * This constructor is given as a parameter to the menuitem and toolbar button
233 * registration. It creates the list.
234 * @param parent_window A pointer to the parent window.
235 * @return The widget created.
236 */
237 GtkWidget *
238 h_gui_events(MainWindow * parent_window)
239 {
240 EventViewerData* event_viewer_data = gui_events(parent_window) ;
241
242 if(event_viewer_data)
243 return event_viewer_data->hbox_v;
244 else return NULL;
245
246 }
247
248 /**
249 * Event Viewer's constructor
250 *
251 * This constructor is used to create EventViewerData data structure.
252 * @return The Event viewer data created.
253 */
254 EventViewerData *
255 gui_events(MainWindow *parent_window)
256 {
257 LttTime start, end;
258 GtkTreeViewColumn *column;
259 GtkCellRenderer *renderer;
260 EventViewerData* event_viewer_data = g_new(EventViewerData,1) ;
261 RawTraceData * data;
262 unsigned size;
263
264 event_viewer_data->mw = parent_window;
265 get_time_window(event_viewer_data->mw, &event_viewer_data->time_window);
266 get_current_time(event_viewer_data->mw, &event_viewer_data->current_time);
267
268 event_viewer_data->before_event_hooks = lttv_hooks_new();
269 lttv_hooks_add(event_viewer_data->before_event_hooks, parse_event, event_viewer_data);
270
271 event_viewer_data->raw_trace_data_queue = g_queue_new();
272 event_viewer_data->raw_trace_data_queue_tmp = g_queue_new();
273
274 reg_update_time_window(update_time_window,event_viewer_data, event_viewer_data->mw);
275 reg_update_current_time(update_current_time,event_viewer_data, event_viewer_data->mw);
276
277 event_viewer_data->scroll_win = gtk_scrolled_window_new (NULL, NULL);
278 gtk_widget_show ( event_viewer_data->scroll_win);
279 gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(event_viewer_data->scroll_win),
280 GTK_POLICY_AUTOMATIC, GTK_POLICY_NEVER);
281
282 /* TEST DATA, TO BE READ FROM THE TRACE */
283 event_viewer_data->currently_selected_event = FALSE ;
284 event_viewer_data->selected_event = 0;
285
286 /* Create a model for storing the data list */
287 event_viewer_data->store_m = gtk_list_store_new (
288 N_COLUMNS, /* Total number of columns */
289 G_TYPE_INT, /* CPUID */
290 G_TYPE_STRING, /* Event */
291 G_TYPE_UINT64, /* Time */
292 G_TYPE_INT, /* PID */
293 G_TYPE_INT, /* Entry length */
294 G_TYPE_STRING); /* Event's description */
295
296 /* Create the viewer widget for the columned list */
297 event_viewer_data->tree_v = gtk_tree_view_new_with_model (GTK_TREE_MODEL (event_viewer_data->store_m));
298
299 g_signal_connect (G_OBJECT (event_viewer_data->tree_v), "size-allocate",
300 G_CALLBACK (tree_v_size_allocate_cb),
301 event_viewer_data);
302 g_signal_connect (G_OBJECT (event_viewer_data->tree_v), "size-request",
303 G_CALLBACK (tree_v_size_request_cb),
304 event_viewer_data);
305
306 g_signal_connect (G_OBJECT (event_viewer_data->tree_v), "cursor-changed",
307 G_CALLBACK (tree_v_cursor_changed_cb),
308 event_viewer_data);
309
310 g_signal_connect (G_OBJECT (event_viewer_data->tree_v), "move-cursor",
311 G_CALLBACK (tree_v_move_cursor_cb),
312 event_viewer_data);
313
314 g_signal_connect (G_OBJECT (event_viewer_data->tree_v), "grab-focus",
315 G_CALLBACK (tree_v_grab_focus),
316 event_viewer_data);
317
318 // Use on each column!
319 //gtk_tree_view_column_set_sizing(event_viewer_data->tree_v, GTK_TREE_VIEW_COLUMN_FIXED);
320
321 /* The view now holds a reference. We can get rid of our own
322 * reference */
323 g_object_unref (G_OBJECT (event_viewer_data->store_m));
324
325
326 /* Create a column, associating the "text" attribute of the
327 * cell_renderer to the first column of the model */
328 /* Columns alignment : 0.0 : Left 0.5 : Center 1.0 : Right */
329 renderer = gtk_cell_renderer_text_new ();
330 column = gtk_tree_view_column_new_with_attributes ("CPUID",
331 renderer,
332 "text", CPUID_COLUMN,
333 NULL);
334 gtk_tree_view_column_set_alignment (column, 0.0);
335 gtk_tree_view_column_set_fixed_width (column, 45);
336 gtk_tree_view_append_column (GTK_TREE_VIEW (event_viewer_data->tree_v), column);
337
338 renderer = gtk_cell_renderer_text_new ();
339 column = gtk_tree_view_column_new_with_attributes ("Event",
340 renderer,
341 "text", EVENT_COLUMN,
342 NULL);
343 gtk_tree_view_column_set_alignment (column, 0.0);
344 gtk_tree_view_column_set_fixed_width (column, 120);
345 gtk_tree_view_append_column (GTK_TREE_VIEW (event_viewer_data->tree_v), column);
346
347 renderer = gtk_cell_renderer_text_new ();
348 column = gtk_tree_view_column_new_with_attributes ("Time",
349 renderer,
350 "text", TIME_COLUMN,
351 NULL);
352 gtk_tree_view_column_set_alignment (column, 1.0);
353 gtk_tree_view_column_set_fixed_width (column, 120);
354 gtk_tree_view_append_column (GTK_TREE_VIEW (event_viewer_data->tree_v), column);
355
356 renderer = gtk_cell_renderer_text_new ();
357 column = gtk_tree_view_column_new_with_attributes ("PID",
358 renderer,
359 "text", PID_COLUMN,
360 NULL);
361 gtk_tree_view_column_set_alignment (column, 1.0);
362 gtk_tree_view_column_set_fixed_width (column, 45);
363 gtk_tree_view_append_column (GTK_TREE_VIEW (event_viewer_data->tree_v), column);
364
365 renderer = gtk_cell_renderer_text_new ();
366 column = gtk_tree_view_column_new_with_attributes ("Entry Length",
367 renderer,
368 "text", ENTRY_LEN_COLUMN,
369 NULL);
370 gtk_tree_view_column_set_alignment (column, 1.0);
371 gtk_tree_view_column_set_fixed_width (column, 60);
372 gtk_tree_view_append_column (GTK_TREE_VIEW (event_viewer_data->tree_v), column);
373
374 renderer = gtk_cell_renderer_text_new ();
375 column = gtk_tree_view_column_new_with_attributes ("Event's Description",
376 renderer,
377 "text", EVENT_DESCR_COLUMN,
378 NULL);
379 gtk_tree_view_column_set_alignment (column, 0.0);
380 gtk_tree_view_append_column (GTK_TREE_VIEW (event_viewer_data->tree_v), column);
381
382
383 /* Setup the selection handler */
384 event_viewer_data->select_c = gtk_tree_view_get_selection (GTK_TREE_VIEW (event_viewer_data->tree_v));
385 gtk_tree_selection_set_mode (event_viewer_data->select_c, GTK_SELECTION_SINGLE);
386 g_signal_connect (G_OBJECT (event_viewer_data->select_c), "changed",
387 G_CALLBACK (tree_selection_changed_cb),
388 event_viewer_data);
389
390 gtk_container_add (GTK_CONTAINER (event_viewer_data->scroll_win), event_viewer_data->tree_v);
391
392 event_viewer_data->hbox_v = gtk_hbox_new(0, 0);
393 gtk_box_pack_start(GTK_BOX(event_viewer_data->hbox_v), event_viewer_data->scroll_win, TRUE, TRUE, 0);
394
395 /* Create vertical scrollbar and pack it */
396 event_viewer_data->vscroll_vc = gtk_vscrollbar_new(NULL);
397 gtk_range_set_update_policy (GTK_RANGE(event_viewer_data->vscroll_vc),
398 GTK_UPDATE_DISCONTINUOUS);
399 gtk_box_pack_start(GTK_BOX(event_viewer_data->hbox_v), event_viewer_data->vscroll_vc, FALSE, TRUE, 0);
400
401 /* Get the vertical scrollbar's adjustment */
402 event_viewer_data->vadjust_c = gtk_range_get_adjustment(GTK_RANGE(event_viewer_data->vscroll_vc));
403 event_viewer_data->vtree_adjust_c = gtk_tree_view_get_vadjustment(
404 GTK_TREE_VIEW (event_viewer_data->tree_v));
405
406 g_signal_connect (G_OBJECT (event_viewer_data->vadjust_c), "value-changed",
407 G_CALLBACK (v_scroll_cb),
408 event_viewer_data);
409 /* Set the upper bound to the last event number */
410 event_viewer_data->previous_value = 0;
411 event_viewer_data->vadjust_c->lower = 0.0;
412 //event_viewer_data->vadjust_c->upper = event_viewer_data->number_of_events;
413 event_viewer_data->vadjust_c->value = 0.0;
414 event_viewer_data->vadjust_c->step_increment = 1.0;
415 event_viewer_data->vadjust_c->page_increment = 2.0;
416 // event_viewer_data->vtree_adjust_c->upper;
417 event_viewer_data->vadjust_c->page_size = 2.0;
418 // event_viewer_data->vtree_adjust_c->upper;
419 /* Raw event trace */
420 gtk_widget_show(event_viewer_data->hbox_v);
421 gtk_widget_show(event_viewer_data->tree_v);
422 gtk_widget_show(event_viewer_data->vscroll_vc);
423
424 /* Add the object's information to the module's array */
425 g_event_viewer_data_list = g_slist_append(g_event_viewer_data_list, event_viewer_data);
426
427 event_viewer_data->first_event = -1 ;
428 event_viewer_data->last_event = 0 ;
429
430 event_viewer_data->num_visible_events = 1;
431
432 //get the life span of the traceset and set the upper of the scroll bar
433 get_traceset_time_span(event_viewer_data->mw, &event_viewer_data->time_span);
434
435 start = ltt_time_sub(event_viewer_data->time_span.endTime, event_viewer_data->time_span.startTime);
436 event_viewer_data->vadjust_c->upper = ltt_time_to_double(start) * NANOSECONDS_PER_SECOND;
437
438 event_viewer_data->append = TRUE;
439
440 start.tv_sec = 0;
441 start.tv_nsec = 0;
442 end.tv_sec = G_MAXULONG;
443 end.tv_nsec = G_MAXULONG;
444
445 get_events(event_viewer_data, start,end, RESERVE_SMALL_SIZE, &size);
446
447 event_viewer_data->start_event_index = 0;
448 event_viewer_data->end_event_index = event_viewer_data->num_visible_events - 1;
449
450 // Test data
451 get_test_data(event_viewer_data->vadjust_c->value,
452 event_viewer_data->num_visible_events,
453 event_viewer_data);
454
455 /* Set the Selected Event */
456 // tree_v_set_cursor(event_viewer_data);
457
458
459 g_object_set_data_full(
460 G_OBJECT(event_viewer_data->hbox_v),
461 "event_viewer_data",
462 event_viewer_data,
463 (GDestroyNotify)gui_events_free);
464
465 return event_viewer_data;
466 }
467
468 void tree_v_set_cursor(EventViewerData *event_viewer_data)
469 {
470 GtkTreePath *path;
471
472 if(event_viewer_data->selected_event && event_viewer_data->first_event != -1)
473 {
474 // gtk_adjustment_set_value(event_viewer_data->vadjust_c,
475 // event_viewer_data->currently_selected_event);
476
477 path = gtk_tree_path_new_from_indices(
478 event_viewer_data->currently_selected_event-
479 event_viewer_data->first_event,
480 -1);
481
482 gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
483 gtk_tree_path_free(path);
484 }
485 }
486
487 void tree_v_get_cursor(EventViewerData *event_viewer_data)
488 {
489 GtkTreePath *path;
490 gint *indices;
491
492 gtk_tree_view_get_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), &path, NULL);
493 indices = gtk_tree_path_get_indices(path);
494
495 if(indices != NULL)
496 {
497 event_viewer_data->selected_event = TRUE;
498 event_viewer_data->currently_selected_event =
499 event_viewer_data->first_event + indices[0];
500
501 } else {
502 event_viewer_data->selected_event = FALSE;
503 event_viewer_data->currently_selected_event = 0;
504 }
505
506 gtk_tree_path_free(path);
507
508 }
509
510
511
512 void tree_v_move_cursor_cb (GtkWidget *widget, GtkMovementStep arg1, gint arg2, gpointer data)
513 {
514 GtkTreePath *path; // = gtk_tree_path_new();
515 gint *indices;
516 gdouble value;
517 EventViewerData *event_viewer_data = (EventViewerData*)data;
518
519 gtk_tree_view_get_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), &path, NULL);
520 if(path == NULL)
521 {
522 /* No prior cursor, put it at beginning of page and let the execution do */
523 path = gtk_tree_path_new_from_indices(0, -1);
524 gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
525 }
526
527 indices = gtk_tree_path_get_indices(path);
528
529 value = gtk_adjustment_get_value(event_viewer_data->vadjust_c);
530
531 if(arg1 == GTK_MOVEMENT_DISPLAY_LINES)
532 {
533 /* Move one line */
534 if(arg2 == 1)
535 {
536 /* move one line down */
537 if(indices[0] == event_viewer_data->num_visible_events - 1)
538 {
539 if(value + event_viewer_data->num_visible_events <=
540 event_viewer_data->number_of_events -1)
541 {
542 event_viewer_data->currently_selected_event += 1;
543 // gtk_adjustment_set_value(event_viewer_data->vadjust_c, value+1);
544 //gtk_tree_path_free(path);
545 //path = gtk_tree_path_new_from_indices(event_viewer_data->num_visible_events-1, -1);
546 //gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
547 g_signal_stop_emission_by_name(G_OBJECT(widget), "move-cursor");
548 }
549 }
550 } else {
551 /* Move one line up */
552 if(indices[0] == 0)
553 {
554 if(value - 1 >= 0 )
555 {
556 event_viewer_data->currently_selected_event -= 1;
557 // gtk_adjustment_set_value(event_viewer_data->vadjust_c, value-1);
558 //gtk_tree_path_free(path);
559 //path = gtk_tree_path_new_from_indices(0, -1);
560 //gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
561 g_signal_stop_emission_by_name(G_OBJECT(widget), "move-cursor");
562 }
563
564 }
565 }
566
567 }
568
569 if(arg1 == GTK_MOVEMENT_PAGES)
570 {
571 /* Move one page */
572 if(arg2 == 1)
573 {
574 if(event_viewer_data->num_visible_events == 1)
575 value += 1 ;
576 /* move one page down */
577 if(value + event_viewer_data->num_visible_events-1 <=
578 event_viewer_data->number_of_events )
579 {
580 event_viewer_data->currently_selected_event += event_viewer_data->num_visible_events-1;
581 // gtk_adjustment_set_value(event_viewer_data->vadjust_c,
582 // value+(event_viewer_data->num_visible_events-1));
583 //gtk_tree_path_free(path);
584 //path = gtk_tree_path_new_from_indices(0, -1);
585 //gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
586 g_signal_stop_emission_by_name(G_OBJECT(widget), "move-cursor");
587 }
588 } else {
589 /* Move one page up */
590 if(event_viewer_data->num_visible_events == 1)
591 value -= 1 ;
592
593 if(indices[0] < event_viewer_data->num_visible_events - 2 )
594 {
595 if(value - (event_viewer_data->num_visible_events-1) >= 0)
596 {
597 event_viewer_data->currently_selected_event -= event_viewer_data->num_visible_events-1;
598
599 // gtk_adjustment_set_value(event_viewer_data->vadjust_c,
600 // value-(event_viewer_data->num_visible_events-1));
601 //gtk_tree_path_free(path);
602 //path = gtk_tree_path_new_from_indices(0, -1);
603 //gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
604 g_signal_stop_emission_by_name(G_OBJECT(widget), "move-cursor");
605
606 } else {
607 /* Go to first Event */
608 event_viewer_data->currently_selected_event == 0 ;
609 // gtk_adjustment_set_value(event_viewer_data->vadjust_c,
610 // 0);
611 //gtk_tree_path_free(path);
612 //path = gtk_tree_path_new_from_indices(0, -1);
613 //gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
614 g_signal_stop_emission_by_name(G_OBJECT(widget), "move-cursor");
615
616 }
617 }
618
619 }
620
621 }
622
623 if(arg1 == GTK_MOVEMENT_BUFFER_ENDS)
624 {
625 /* Move to the ends of the buffer */
626 if(arg2 == 1)
627 {
628 /* move end of buffer */
629 event_viewer_data->currently_selected_event = event_viewer_data->number_of_events-1 ;
630 // gtk_adjustment_set_value(event_viewer_data->vadjust_c,
631 // event_viewer_data->number_of_events -
632 // event_viewer_data->num_visible_events);
633 //gtk_tree_path_free(path);
634 //path = gtk_tree_path_new_from_indices(event_viewer_data->num_visible_events-1, -1);
635 //gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
636 g_signal_stop_emission_by_name(G_OBJECT(widget), "move-cursor");
637 } else {
638 /* Move beginning of buffer */
639 event_viewer_data->currently_selected_event = 0 ;
640 // gtk_adjustment_set_value(event_viewer_data->vadjust_c, 0);
641 //gtk_tree_path_free(path);
642 //path = gtk_tree_path_new_from_indices(0, -1);
643 //gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), path, NULL, FALSE);
644 g_signal_stop_emission_by_name(G_OBJECT(widget), "move-cursor");
645 }
646
647 }
648
649
650 gtk_tree_path_free(path);
651 }
652
653 void tree_v_cursor_changed_cb (GtkWidget *widget, gpointer data)
654 {
655 EventViewerData *event_viewer_data = (EventViewerData*) data;
656 LttTime ltt_time;
657 guint64 time;
658 GtkTreeIter iter;
659 GtkTreeModel* model = GTK_TREE_MODEL(event_viewer_data->store_m);
660 GtkTreePath *path;
661
662 /* On cursor change, modify the currently selected event by calling
663 * the right API function */
664 tree_v_get_cursor(event_viewer_data);
665 /*
666 gtk_tree_view_get_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), &path, NULL);
667 if(gtk_tree_model_get_iter(model,&iter,path)){
668 gtk_tree_model_get(model, &iter, TIME_COLUMN, &time, -1);
669 ltt_time.tv_sec = time / NANOSECONDS_PER_SECOND;
670 ltt_time.tv_nsec = time % NANOSECONDS_PER_SECOND;
671
672 if(ltt_time.tv_sec != event_viewer_data->current_time.tv_sec ||
673 ltt_time.tv_nsec != event_viewer_data->current_time.tv_nsec)
674 set_current_time(event_viewer_data->mw,&ltt_time);
675 }else{
676 g_warning("Can not get iter\n");
677 }
678 */
679 }
680
681
682 void v_scroll_cb (GtkAdjustment *adjustment, gpointer data)
683 {
684 EventViewerData *event_viewer_data = (EventViewerData*)data;
685 GtkTreePath *tree_path;
686
687 get_test_data(adjustment->value, event_viewer_data->num_visible_events,
688 event_viewer_data);
689
690
691 if(event_viewer_data->currently_selected_event
692 >= event_viewer_data->first_event
693 &&
694 event_viewer_data->currently_selected_event
695 <= event_viewer_data->last_event
696 &&
697 event_viewer_data->selected_event)
698 {
699
700 tree_path = gtk_tree_path_new_from_indices(
701 event_viewer_data->currently_selected_event-
702 event_viewer_data->first_event,
703 -1);
704
705 // gtk_tree_view_set_cursor(GTK_TREE_VIEW(event_viewer_data->tree_v), tree_path,
706 // NULL, FALSE);
707 gtk_tree_path_free(tree_path);
708 }
709
710
711 }
712
713 gint get_cell_height(GtkTreeView *TreeView)
714 {
715 gint height, width;
716 GtkTreeViewColumn *column = gtk_tree_view_get_column(TreeView, 0);
717 GList *Render_List = gtk_tree_view_column_get_cell_renderers(column);
718 GtkCellRenderer *renderer = g_list_first(Render_List)->data;
719
720 gtk_tree_view_column_cell_get_size(column, NULL, NULL, NULL, NULL, &height);
721
722 return height;
723 }
724
725 void tree_v_size_allocate_cb (GtkWidget *widget, GtkAllocation *alloc, gpointer data)
726 {
727 EventViewerData *event_viewer_data = (EventViewerData*)data;
728 gint cell_height = get_cell_height(GTK_TREE_VIEW(event_viewer_data->tree_v));
729 gint last_num_visible_events = event_viewer_data->num_visible_events;
730 gdouble exact_num_visible;
731
732 exact_num_visible = ( alloc->height -
733 TREE_VIEW_HEADER_HEIGHT (GTK_TREE_VIEW(event_viewer_data->tree_v)) )
734 / (double)cell_height ;
735
736 event_viewer_data->num_visible_events = ceil(exact_num_visible) ;
737
738 /*
739 event_viewer_data->vadjust_c->page_increment =
740 floor(exact_num_visible);
741 event_viewer_data->vadjust_c->page_size =
742 floor(exact_num_visible);
743 */
744
745 if(event_viewer_data->num_visible_events != last_num_visible_events)
746 {
747 get_test_data(event_viewer_data->vadjust_c->value,
748 event_viewer_data->num_visible_events,
749 event_viewer_data);
750 }
751
752
753 }
754
755 void tree_v_size_request_cb (GtkWidget *widget, GtkRequisition *requisition, gpointer data)
756 {
757 gint h;
758 EventViewerData *event_viewer_data = (EventViewerData*)data;
759 gint cell_height = get_cell_height(GTK_TREE_VIEW(event_viewer_data->tree_v));
760
761 h = cell_height + TREE_VIEW_HEADER_HEIGHT
762 (GTK_TREE_VIEW(event_viewer_data->tree_v));
763 requisition->height = h;
764
765 }
766
767 void get_test_data(double time_value, guint list_height,
768 EventViewerData *event_viewer_data)
769 {
770 GtkTreeIter iter;
771 int i;
772 GtkTreeModel *model = GTK_TREE_MODEL(event_viewer_data->store_m);
773 GtkTreePath *tree_path;
774 RawTraceData * raw_data;
775 ScrollDirection direction = SCROLL_NONE;
776 GList * first;
777 int event_number;
778 double value = event_viewer_data->previous_value - time_value;
779 LttTime start, end, time;
780 LttEvent * ev;
781 unsigned backward_num, minNum, maxNum;
782 LttTracefile * tf;
783 unsigned block_num, event_num;
784 unsigned size = 1, count = 0;
785 gboolean need_backward_again, backward;
786
787
788 // if(event_number > event_viewer_data->last_event ||
789 // event_number + list_height-1 < event_viewer_data->first_event ||
790 // event_viewer_data->first_event == -1)
791 {
792 /* no event can be reused, clear and start from nothing */
793 if(value == -1.0) direction = SCROLL_STEP_DOWN;
794 else if(value == 1.0 ) direction = SCROLL_STEP_UP;
795 else if(value == -2.0) direction = SCROLL_PAGE_DOWN;
796 else if(value == 2.0 ) direction = SCROLL_PAGE_UP;
797 else if(value == 0.0 ) direction = SCROLL_NONE;
798 else direction = SCROLL_JUMP;
799
800 switch(direction){
801 case SCROLL_STEP_UP:
802 case SCROLL_PAGE_UP:
803 if(direction == SCROLL_PAGE_UP){
804 backward = list_height>event_viewer_data->start_event_index ? TRUE : FALSE;
805 }else{
806 backward = event_viewer_data->start_event_index == 0 ? TRUE : FALSE;
807 }
808 if(backward){
809 event_viewer_data->append = FALSE;
810 do{
811 if(direction == SCROLL_PAGE_UP){
812 minNum = list_height - event_viewer_data->start_event_index ;
813 }else{
814 minNum = 1;
815 }
816
817 first = event_viewer_data->raw_trace_data_queue->head;
818 raw_data = (RawTraceData*)g_list_nth_data(first,0);
819 end = raw_data->time;
820 end.tv_nsec--;
821 ltt_event_position_get(&raw_data->ep, &block_num, &event_num, &tf);
822 if(size !=0){
823 if(event_num > minNum){
824 backward_num = event_num > RESERVE_SMALL_SIZE
825 ? event_num - RESERVE_SMALL_SIZE : 1;
826 ltt_event_position_set(&raw_data->ep, block_num, backward_num);
827 ltt_tracefile_seek_position(tf, &raw_data->ep);
828 ev = ltt_tracefile_read(tf);
829 start = ltt_event_time(ev);
830 maxNum = G_MAXULONG;
831 }else{
832 if(block_num > 1){
833 ltt_event_position_set(&raw_data->ep, block_num-1, 1);
834 ltt_tracefile_seek_position(tf, &raw_data->ep);
835 ev = ltt_tracefile_read(tf);
836 start = ltt_event_time(ev);
837 }else{
838 start.tv_sec = 0;
839 start.tv_nsec = 0;
840 }
841 maxNum = G_MAXULONG;
842 }
843 }else{
844 if(block_num > count){
845 ltt_event_position_set(&raw_data->ep, block_num-count, 1);
846 ltt_tracefile_seek_position(tf, &raw_data->ep);
847 ev = ltt_tracefile_read(tf);
848 start = ltt_event_time(ev);
849 }else{
850 start.tv_sec = 0;
851 start.tv_nsec = 0;
852 }
853 maxNum = G_MAXULONG;
854 }
855
856 event_viewer_data->current_event_index = event_viewer_data->start_event_index;
857 get_events(event_viewer_data, start, end, maxNum, &size);
858 event_viewer_data->start_event_index = event_viewer_data->current_event_index;
859
860 if(size < minNum && (start.tv_sec !=0 || start.tv_nsec !=0))
861 need_backward_again = TRUE;
862 else need_backward_again = FALSE;
863 if(size == 0){
864 count++;
865 }else{
866 count = 0;
867 }
868 }while(need_backward_again);
869 }
870 if(direction == SCROLL_STEP_UP)
871 event_number = event_viewer_data->start_event_index - 1;
872 else
873 event_number = event_viewer_data->start_event_index - list_height;
874 break;
875 case SCROLL_STEP_DOWN:
876 if(event_viewer_data->end_event_index == event_viewer_data->number_of_events - 1){
877 event_viewer_data->append = TRUE;
878 first = event_viewer_data->raw_trace_data_queue->head;
879 raw_data = (RawTraceData*)g_list_nth_data(first,event_viewer_data->number_of_events - 1);
880 start = raw_data->time;
881 start.tv_nsec++;
882 end.tv_sec = G_MAXULONG;
883 end.tv_nsec = G_MAXULONG;
884 get_events(event_viewer_data, start, end, RESERVE_SMALL_SIZE, &size);
885 }else size = 1;
886 if(size > 0) event_number = event_viewer_data->start_event_index + 1;
887 else event_number = event_viewer_data->start_event_index;
888 break;
889 case SCROLL_PAGE_DOWN:
890 if(event_viewer_data->end_event_index >= event_viewer_data->number_of_events - 1 - list_height){
891 event_viewer_data->append = TRUE;
892 first = event_viewer_data->raw_trace_data_queue->head;
893 raw_data = (RawTraceData*)g_list_nth_data(first,event_viewer_data->number_of_events - 1);
894 start = raw_data->time;
895 start.tv_nsec++;
896 end.tv_sec = G_MAXULONG;
897 end.tv_nsec = G_MAXULONG;
898 get_events(event_viewer_data, start, end, RESERVE_SMALL_SIZE,&size);
899 }
900 if(list_height <= event_viewer_data->number_of_events - 1 - event_viewer_data->end_event_index)
901 event_number = event_viewer_data->start_event_index + list_height - 1;
902 else
903 event_number = event_viewer_data->number_of_events - 1 - list_height;
904 break;
905 case SCROLL_JUMP:
906 event_viewer_data->append = TRUE;
907 remove_all_items_from_queue(event_viewer_data->raw_trace_data_queue);
908 end.tv_sec = G_MAXULONG;
909 end.tv_nsec = G_MAXULONG;
910 time = ltt_time_from_double(time_value / NANOSECONDS_PER_SECOND);
911 start = ltt_time_add(event_viewer_data->time_span.startTime, time);
912 event_viewer_data->previous_value = time_value;
913 get_events(event_viewer_data, start, end, RESERVE_SMALL_SIZE,&size);
914 if(size < list_height){
915 event_viewer_data->append = FALSE;
916 first = event_viewer_data->raw_trace_data_queue->head;
917 raw_data = (RawTraceData*)g_list_nth_data(first,0);
918 end = raw_data->time;
919 end.tv_nsec--;
920 ltt_event_position_get(&raw_data->ep, &block_num, &event_num, &tf);
921
922 if(event_num > list_height - size){
923 backward_num = event_num > RESERVE_SMALL_SIZE
924 ? event_num - RESERVE_SMALL_SIZE : 1;
925 ltt_event_position_set(&raw_data->ep, block_num, backward_num);
926 ltt_tracefile_seek_position(tf, &raw_data->ep);
927 ev = ltt_tracefile_read(tf);
928 start = ltt_event_time(ev);
929 maxNum = G_MAXULONG;
930 event_viewer_data->current_event_index = 0;
931 get_events(event_viewer_data, start, end, maxNum, &size);
932 event_viewer_data->start_event_index = event_viewer_data->current_event_index;
933 }
934 event_number = event_viewer_data->raw_trace_data_queue->length - list_height;
935 }else{
936 event_number = 0;
937 }
938 break;
939 case SCROLL_NONE:
940 event_number = event_viewer_data->current_event_index;
941 break;
942 default:
943 break;
944 }
945
946 //update the value of the scroll bar
947 if(direction != SCROLL_NONE && direction != SCROLL_JUMP){
948 first = event_viewer_data->raw_trace_data_queue->head;
949 raw_data = (RawTraceData*)g_list_nth_data(first,event_number);
950 time = ltt_time_sub(raw_data->time, event_viewer_data->time_span.startTime);
951 event_viewer_data->vadjust_c->value = ltt_time_to_double(time) * NANOSECONDS_PER_SECOND;
952 g_signal_stop_emission_by_name(G_OBJECT(event_viewer_data->vadjust_c), "value-changed");
953 event_viewer_data->previous_value = event_viewer_data->vadjust_c->value;
954 }
955
956
957 event_viewer_data->start_event_index = event_number;
958 event_viewer_data->end_event_index = event_number + list_height - 1;
959
960 first = event_viewer_data->raw_trace_data_queue->head;
961 gtk_list_store_clear(event_viewer_data->store_m);
962 for(i=event_number; i<event_number+list_height; i++)
963 {
964 guint64 real_data;
965
966 if(i>=event_viewer_data->number_of_events) break;
967
968 raw_data = (RawTraceData*)g_list_nth_data(first, i);
969
970 // Add a new row to the model
971 real_data = raw_data->time.tv_sec;
972 real_data *= NANOSECONDS_PER_SECOND;
973 real_data += raw_data->time.tv_nsec;
974 gtk_list_store_append (event_viewer_data->store_m, &iter);
975 gtk_list_store_set (event_viewer_data->store_m, &iter,
976 CPUID_COLUMN, raw_data->cpu_id,
977 EVENT_COLUMN, raw_data->event_name,
978 TIME_COLUMN, real_data,
979 PID_COLUMN, raw_data->pid,
980 ENTRY_LEN_COLUMN, raw_data->entry_length,
981 EVENT_DESCR_COLUMN, raw_data->event_description,
982 -1);
983 /*
984 gtk_list_store_append (event_viewer_data->store_m, &iter);
985 gtk_list_store_set (event_viewer_data->store_m, &iter,
986 CPUID_COLUMN, 0,
987 EVENT_COLUMN, "event irq",
988 TIME_COLUMN, i,
989 PID_COLUMN, 100,
990 ENTRY_LEN_COLUMN, 17,
991 EVENT_DESCR_COLUMN, "Detailed information",
992 -1);
993 */
994 }
995 }
996 #ifdef DEBUG //do not use this, it's slower and broken
997 // } else {
998 /* Some events will be reused */
999 if(event_number < event_viewer_data->first_event)
1000 {
1001 /* scrolling up, prepend events */
1002 tree_path = gtk_tree_path_new_from_indices
1003 (event_number+list_height-1 -
1004 event_viewer_data->first_event + 1,
1005 -1);
1006 for(i=0; i<event_viewer_data->last_event-(event_number+list_height-1);
1007 i++)
1008 {
1009 /* Remove the last events from the list */
1010 if(gtk_tree_model_get_iter(model, &iter, tree_path))
1011 gtk_list_store_remove(event_viewer_data->store_m, &iter);
1012 }
1013
1014 for(i=event_viewer_data->first_event-1; i>=event_number; i--)
1015 {
1016 if(i>=event_viewer_data->number_of_events) break;
1017 /* Prepend new events */
1018 gtk_list_store_prepend (event_viewer_data->store_m, &iter);
1019 gtk_list_store_set (event_viewer_data->store_m, &iter,
1020 CPUID_COLUMN, 0,
1021 EVENT_COLUMN, "event irq",
1022 TIME_COLUMN, i,
1023 PID_COLUMN, 100,
1024 ENTRY_LEN_COLUMN, 17,
1025 EVENT_DESCR_COLUMN, "Detailed information",
1026 -1);
1027 }
1028 } else {
1029 /* Scrolling down, append events */
1030 for(i=event_viewer_data->first_event; i<event_number; i++)
1031 {
1032 /* Remove these events from the list */
1033 gtk_tree_model_get_iter_first(model, &iter);
1034 gtk_list_store_remove(event_viewer_data->store_m, &iter);
1035 }
1036 for(i=event_viewer_data->last_event+1; i<event_number+list_height; i++)
1037 {
1038 if(i>=event_viewer_data->number_of_events) break;
1039 /* Append new events */
1040 gtk_list_store_append (event_viewer_data->store_m, &iter);
1041 gtk_list_store_set (event_viewer_data->store_m, &iter,
1042 CPUID_COLUMN, 0,
1043 EVENT_COLUMN, "event irq",
1044 TIME_COLUMN, i,
1045 PID_COLUMN, 100,
1046 ENTRY_LEN_COLUMN, 17,
1047 EVENT_DESCR_COLUMN, "Detailed information",
1048 -1);
1049 }
1050
1051 }
1052 //}
1053 #endif //DEBUG
1054 event_viewer_data->first_event = event_viewer_data->start_event_index ;
1055 event_viewer_data->last_event = event_viewer_data->end_event_index ;
1056
1057
1058
1059 }
1060
1061
1062 void add_test_data(EventViewerData *event_viewer_data)
1063 {
1064 GtkTreeIter iter;
1065 int i;
1066
1067 for(i=0; i<10; i++)
1068 {
1069 /* Add a new row to the model */
1070 gtk_list_store_append (event_viewer_data->store_m, &iter);
1071 gtk_list_store_set (event_viewer_data->store_m, &iter,
1072 CPUID_COLUMN, 0,
1073 EVENT_COLUMN, "event irq",
1074 TIME_COLUMN, i,
1075 PID_COLUMN, 100,
1076 ENTRY_LEN_COLUMN, 17,
1077 EVENT_DESCR_COLUMN, "Detailed information",
1078 -1);
1079 }
1080
1081 }
1082
1083 void
1084 gui_events_free(EventViewerData *event_viewer_data)
1085 {
1086 if(event_viewer_data){
1087 lttv_hooks_remove(event_viewer_data->before_event_hooks,parse_event);
1088 lttv_hooks_destroy(event_viewer_data->before_event_hooks);
1089
1090 remove_all_items_from_queue (event_viewer_data->raw_trace_data_queue);
1091 g_queue_free(event_viewer_data->raw_trace_data_queue);
1092 g_queue_free(event_viewer_data->raw_trace_data_queue_tmp);
1093
1094 unreg_update_time_window(update_time_window,event_viewer_data, event_viewer_data->mw);
1095 unreg_update_current_time(update_current_time,event_viewer_data, event_viewer_data->mw);
1096
1097 g_event_viewer_data_list = g_slist_remove(g_event_viewer_data_list, event_viewer_data);
1098 g_free(event_viewer_data);
1099 }
1100 }
1101
1102 void
1103 gui_events_destructor(EventViewerData *event_viewer_data)
1104 {
1105 guint index;
1106
1107 /* May already been done by GTK window closing */
1108 if(GTK_IS_WIDGET(event_viewer_data->hbox_v)){
1109 gtk_widget_destroy(event_viewer_data->hbox_v);
1110 event_viewer_data = NULL;
1111 }
1112
1113 /* Destroy the Tree View */
1114 //gtk_widget_destroy(event_viewer_data->tree_v);
1115
1116 /* Clear raw event list */
1117 //gtk_list_store_clear(event_viewer_data->store_m);
1118 //gtk_widget_destroy(GTK_WIDGET(event_viewer_data->store_m));
1119
1120 //gui_events_free(event_viewer_data);
1121 }
1122
1123 //FIXME : call hGuiEvents_Destructor for corresponding data upon widget destroy
1124
1125 static void
1126 tree_selection_changed_cb (GtkTreeSelection *selection, gpointer data)
1127 {
1128 EventViewerData *event_viewer_data = (EventViewerData*)data;
1129 GtkTreeIter iter;
1130 GtkTreeModel *model = GTK_TREE_MODEL(event_viewer_data->store_m);
1131 gchar *event;
1132
1133 if (gtk_tree_selection_get_selected (selection, &model, &iter))
1134 {
1135 gtk_tree_model_get (model, &iter, EVENT_COLUMN, &event, -1);
1136
1137 g_free (event);
1138 }
1139 }
1140
1141
1142 int event_selected_hook(void *hook_data, void *call_data)
1143 {
1144 EventViewerData *event_viewer_data = (EventViewerData*) hook_data;
1145 guint *event_number = (guint*) call_data;
1146
1147 event_viewer_data->currently_selected_event = *event_number;
1148 event_viewer_data->selected_event = TRUE ;
1149
1150 tree_v_set_cursor(event_viewer_data);
1151
1152 }
1153
1154
1155 gboolean update_time_window(void * hook_data, void * call_data)
1156 {
1157 EventViewerData *event_viewer_data = (EventViewerData*) hook_data;
1158 event_viewer_data->time_window = *(TimeWindow*)call_data;
1159
1160 return FALSE;
1161 }
1162
1163 gboolean update_current_time(void * hook_data, void * call_data)
1164 {
1165 EventViewerData *event_viewer_data = (EventViewerData*) hook_data;
1166 event_viewer_data->current_time = *(LttTime*)call_data;
1167 uint64_t nsec = event_viewer_data->current_time.tv_sec * NANOSECONDS_PER_SECOND
1168 + event_viewer_data->current_time.tv_nsec;
1169 GtkTreeIter iter;
1170 uint64_t time;
1171 int count = 0;
1172 GtkTreeModel* model = (GtkTreeModel*)event_viewer_data->store_m;
1173
1174
1175 if(gtk_tree_model_get_iter_first(model, &iter)){
1176 while(1){
1177 gtk_tree_model_get(model, &iter, TIME_COLUMN, &time, -1);
1178 if(time < nsec){
1179 if(!gtk_tree_model_iter_next(model, &iter)){
1180 return TRUE;
1181 }
1182 count++;
1183 }else{
1184 break;
1185 }
1186 }
1187 // event_selected_hook(event_viewer_data, &count);
1188 }
1189
1190 return FALSE;
1191 }
1192
1193 void tree_v_grab_focus(GtkWidget *widget, gpointer data){
1194 EventViewerData *event_viewer_data = (EventViewerData *)data;
1195 MainWindow * mw = event_viewer_data->mw;
1196 set_focused_pane(mw, gtk_widget_get_parent(event_viewer_data->hbox_v));
1197 }
1198
1199 void get_events(EventViewerData* event_viewer_data, LttTime start,
1200 LttTime end,unsigned max_num_events, unsigned * real_num_events)
1201 {
1202 int size;
1203 RawTraceData * data;
1204 context_add_hooks_api(event_viewer_data->mw, NULL, NULL, NULL, NULL, NULL, NULL,
1205 NULL, NULL, NULL,event_viewer_data->before_event_hooks,NULL);
1206 process_traceset_api(event_viewer_data->mw, start, end, max_num_events);
1207 context_remove_hooks_api(event_viewer_data->mw, NULL, NULL, NULL, NULL, NULL, NULL,
1208 NULL, NULL, NULL,event_viewer_data->before_event_hooks,NULL);
1209
1210 size = event_viewer_data->raw_trace_data_queue_tmp->length;
1211 *real_num_events = size;
1212 if(size > 0){
1213 int pid, tmpPid, i;
1214 GList * list, *tmpList;
1215
1216 //if the queue is full, remove some data, keep the size of the queue constant
1217 while(event_viewer_data->raw_trace_data_queue->length + size > RESERVE_BIG_SIZE){
1218 remove_item_from_queue(event_viewer_data->raw_trace_data_queue,
1219 event_viewer_data->append);
1220 }
1221
1222 //update pid if it is not known
1223 if(event_viewer_data->raw_trace_data_queue->length > 0){
1224 list = event_viewer_data->raw_trace_data_queue->head;
1225 tmpList = event_viewer_data->raw_trace_data_queue_tmp->head;
1226 if(event_viewer_data->append){
1227 data = (RawTraceData*)g_list_nth_data(list, event_viewer_data->raw_trace_data_queue->length-1);
1228 pid = data->pid;
1229 data = (RawTraceData*)g_list_nth_data(tmpList, 0);
1230 tmpPid = data->pid;
1231 }else{
1232 data = (RawTraceData*)g_list_nth_data(list, 0);
1233 pid = data->pid;
1234 data = (RawTraceData*)g_list_nth_data(tmpList, event_viewer_data->raw_trace_data_queue_tmp->length-1);
1235 tmpPid = data->pid;
1236 }
1237
1238 if(pid == -1 && tmpPid != -1){
1239 for(i=0;i<event_viewer_data->raw_trace_data_queue->length;i++){
1240 data = (RawTraceData*)g_list_nth_data(list,i);
1241 if(data->pid == -1) data->pid = tmpPid;
1242 }
1243 }else if(pid != -1 && tmpPid == -1){
1244 for(i=0;i<event_viewer_data->raw_trace_data_queue_tmp->length;i++){
1245 data = (RawTraceData*)g_list_nth_data(tmpList,i);
1246 if(data->pid == -1) data->pid = pid;
1247 }
1248 }
1249 }
1250
1251 //add data from tmp queue into the queue
1252 event_viewer_data->number_of_events = event_viewer_data->raw_trace_data_queue->length
1253 + event_viewer_data->raw_trace_data_queue_tmp->length;
1254 if(event_viewer_data->append){
1255 if(event_viewer_data->raw_trace_data_queue->length > 0)
1256 event_viewer_data->current_event_index = event_viewer_data->raw_trace_data_queue->length - 1;
1257 else event_viewer_data->current_event_index = 0;
1258 while((data = g_queue_pop_head(event_viewer_data->raw_trace_data_queue_tmp)) != NULL){
1259 g_queue_push_tail(event_viewer_data->raw_trace_data_queue, data);
1260 }
1261 }else{
1262 event_viewer_data->current_event_index += event_viewer_data->raw_trace_data_queue_tmp->length;
1263 while((data = g_queue_pop_tail(event_viewer_data->raw_trace_data_queue_tmp)) != NULL){
1264 g_queue_push_head(event_viewer_data->raw_trace_data_queue, data);
1265 }
1266 }
1267 }
1268 }
1269
1270 static void get_event_detail(LttEvent *e, LttField *f, GString * s)
1271 {
1272 LttType *type;
1273 LttField *element;
1274 char *name;
1275 int nb, i;
1276
1277 type = ltt_field_type(f);
1278 switch(ltt_type_class(type)) {
1279 case LTT_INT:
1280 g_string_append_printf(s, " %ld", ltt_event_get_long_int(e,f));
1281 break;
1282
1283 case LTT_UINT:
1284 g_string_append_printf(s, " %lu", ltt_event_get_long_unsigned(e,f));
1285 break;
1286
1287 case LTT_FLOAT:
1288 g_string_append_printf(s, " %g", ltt_event_get_double(e,f));
1289 break;
1290
1291 case LTT_STRING:
1292 g_string_append_printf(s, " \"%s\"", ltt_event_get_string(e,f));
1293 break;
1294
1295 case LTT_ENUM:
1296 g_string_append_printf(s, " %s", ltt_enum_string_get(type,
1297 ltt_event_get_unsigned(e,f)-1));
1298 break;
1299
1300 case LTT_ARRAY:
1301 case LTT_SEQUENCE:
1302 g_string_append_printf(s, " {");
1303 nb = ltt_event_field_element_number(e,f);
1304 element = ltt_field_element(f);
1305 for(i = 0 ; i < nb ; i++) {
1306 ltt_event_field_element_select(e,f,i);
1307 get_event_detail(e, element, s);
1308 }
1309 g_string_append_printf(s, " }");
1310 break;
1311
1312 case LTT_STRUCT:
1313 g_string_append_printf(s, " {");
1314 nb = ltt_type_member_number(type);
1315 for(i = 0 ; i < nb ; i++) {
1316 element = ltt_field_member(f,i);
1317 ltt_type_member_type(type, i, &name);
1318 g_string_append_printf(s, " %s = ", name);
1319 get_event_detail(e, element, s);
1320 }
1321 g_string_append_printf(s, " }");
1322 break;
1323 }
1324
1325 }
1326
1327 static void get_pid(unsigned * in, unsigned * out, char * s)
1328 {
1329 char * str;
1330 str = strstr(s, "out =");
1331 if (str){
1332 str = str + 5;
1333 sscanf(str,"%d", out);
1334 }else{
1335 g_warning("Can not find out pid\n");
1336 }
1337
1338 str = strstr(s,"in =");
1339 if (str){
1340 str = str + 4;
1341 sscanf(str,"%d", in);
1342 }else{
1343 g_warning("Can not find in pid\n");
1344 }
1345 }
1346
1347 gboolean parse_event(void *hook_data, void *call_data)
1348 {
1349 EventViewerData *event_viewer_data = (EventViewerData *)hook_data;
1350 LttvTracefileContext *tfc = (LttvTracefileContext *)call_data;
1351 LttvTracefileState *tfs = (LttvTracefileState *)call_data;
1352
1353 RawTraceData * tmp_raw_trace_data,*prev_raw_trace_data = NULL, *data=NULL;
1354 LttEvent *e;
1355 LttTime time;
1356 LttField * field;
1357 unsigned in=0, out=0;
1358 int i;
1359 GString * detail_event = g_string_new("");
1360 GList * list;
1361
1362 e = tfc->e;
1363 field = ltt_event_field(e);
1364 time = ltt_event_time(e);
1365
1366 if(event_viewer_data->raw_trace_data_queue_tmp->length){
1367 list = g_list_last(event_viewer_data->raw_trace_data_queue_tmp->head);
1368 prev_raw_trace_data = (RawTraceData *)(list->data);
1369 }
1370
1371 tmp_raw_trace_data = g_new(RawTraceData,1);
1372 tmp_raw_trace_data->cpu_id = ltt_event_cpu_id(e);
1373 tmp_raw_trace_data->event_name = g_strdup(ltt_eventtype_name(ltt_event_eventtype(e)));
1374 tmp_raw_trace_data->time = time;
1375
1376 if(prev_raw_trace_data) tmp_raw_trace_data->pid = prev_raw_trace_data->pid;
1377 else tmp_raw_trace_data->pid = -1;
1378
1379 tmp_raw_trace_data->entry_length = field == NULL ? 0 : field->field_size;
1380 if(field) get_event_detail(e, field, detail_event);
1381 tmp_raw_trace_data->event_description = g_strdup(detail_event->str);
1382
1383 if(strcmp(tmp_raw_trace_data->event_name, "schedchange") == 0){
1384 get_pid(&in, &out, detail_event->str);
1385 }
1386
1387
1388 if(in != 0 || out != 0){
1389 tmp_raw_trace_data->pid = in;
1390 if(prev_raw_trace_data && prev_raw_trace_data->pid == -1){
1391 list = event_viewer_data->raw_trace_data_queue_tmp->head;
1392 for(i=0;i<event_viewer_data->raw_trace_data_queue_tmp->length;i++){
1393 data = (RawTraceData *)g_list_nth_data(list,i);
1394 data->pid = out;
1395 }
1396 }
1397 }
1398
1399 ltt_event_position(e, &tmp_raw_trace_data->ep);
1400
1401 if(event_viewer_data->raw_trace_data_queue_tmp->length >= RESERVE_SMALL_SIZE){
1402 if(event_viewer_data->append){
1403 list = g_list_last(event_viewer_data->raw_trace_data_queue_tmp->head);
1404 data = (RawTraceData *)(list->data);
1405 if(data->time.tv_sec == time.tv_sec &&
1406 data->time.tv_nsec == time.tv_nsec){
1407 g_queue_push_tail(event_viewer_data->raw_trace_data_queue_tmp,tmp_raw_trace_data);
1408 }else{
1409 g_free(tmp_raw_trace_data);
1410 }
1411 }else{
1412 remove_item_from_queue(event_viewer_data->raw_trace_data_queue_tmp,TRUE);
1413 g_queue_push_tail(event_viewer_data->raw_trace_data_queue_tmp,tmp_raw_trace_data);
1414 }
1415 }else{
1416 g_queue_push_tail (event_viewer_data->raw_trace_data_queue_tmp,tmp_raw_trace_data);
1417 }
1418
1419 g_string_free(detail_event, TRUE);
1420
1421 return FALSE;
1422 }
1423
1424 void remove_item_from_queue(GQueue * q, gboolean fromHead)
1425 {
1426 RawTraceData *data1, *data2 = NULL;
1427 GList * list;
1428
1429 if(fromHead){
1430 data1 = (RawTraceData *)g_queue_pop_head(q);
1431 list = g_list_first(q->head);
1432 if(list)
1433 data2 = (RawTraceData *)(list->data);
1434 }else{
1435 data1 = (RawTraceData *)g_queue_pop_tail(q);
1436 list = g_list_last(q->head);
1437 if(list)
1438 data2 = (RawTraceData *)(list->data);
1439 }
1440
1441 if(data2){
1442 if(data1->time.tv_sec == data2->time.tv_sec &&
1443 data1->time.tv_nsec == data2->time.tv_nsec){
1444 remove_item_from_queue(q, fromHead);
1445 }
1446 }
1447
1448 g_free(data1);
1449
1450 return;
1451 }
1452
1453 void remove_all_items_from_queue(GQueue *q)
1454 {
1455 RawTraceData *data;
1456 while((data = (RawTraceData *)g_queue_pop_head(q)) != NULL){
1457 g_free(data);
1458 }
1459 }
1460
1461
This page took 0.059612 seconds and 4 git commands to generate.