Add a module to compute various statistics
[lttv.git] / ltt / branches / poly / ltt / tracefile.c
1 #include <stdio.h>
2 #include <fcntl.h>
3 #include <sys/stat.h>
4 #include <sys/types.h>
5 #include <dirent.h>
6 #include <linux/errno.h>
7
8 #include <ltt/LTTTypes.h>
9 #include "parser.h"
10 #include <ltt/trace.h>
11
12 #define DIR_NAME_SIZE 256
13
14 /* set the offset of the fields belonging to the event,
15 need the information of the archecture */
16 void setFieldsOffset(LttTracefile *tf,LttEventType *evT,void *evD,LttTrace *t);
17
18 /* get the size of the field type according to the archtecture's
19 size and endian type(info of the archecture) */
20 int getFieldtypeSize(LttTracefile * tf, LttEventType * evT, int offsetRoot,
21 int offsetParent, LttField *fld, void *evD, LttTrace* t);
22
23 /* read a fixed size or a block information from the file (fd) */
24 int readFile(int fd, void * buf, size_t size, char * mesg);
25 int readBlock(LttTracefile * tf, int whichBlock);
26
27 /* calculate cycles per nsec for current block */
28 void getCyclePerNsec(LttTracefile * t);
29
30 /* reinitialize the info of the block which is already in the buffer */
31 void updateTracefile(LttTracefile * tf);
32
33 /* go to the next event */
34 int skipEvent(LttTracefile * t);
35
36 /* compare two time (LttTime), 0:t1=t2, -1:t1<t2, 1:t1>t2 */
37 int timecmp(LttTime * t1, LttTime * t2);
38
39
40
41 /*****************************************************************************
42 *Function name
43 * ltt_tracefile_open : open a trace file, construct a LttTracefile
44 *Input params
45 * t : the trace containing the tracefile
46 * fileName : path name of the trace file
47 *Return value
48 * : a pointer to a tracefile
49 ****************************************************************************/
50
51 LttTracefile* ltt_tracefile_open(LttTrace * t, char * fileName)
52 {
53 LttTracefile * tf;
54 struct stat lTDFStat; /* Trace data file status */
55 BlockStart a_block_start;
56
57 tf = g_new(LttTracefile, 1);
58
59 //open the file
60 tf->name = g_strdup(fileName);
61 tf->trace = t;
62 tf->fd = open(fileName, O_RDONLY, 0);
63 if(tf->fd < 0){
64 g_error("Unable to open input data file %s\n", fileName);
65 }
66
67 // Get the file's status
68 if(fstat(tf->fd, &lTDFStat) < 0){
69 g_error("Unable to get the status of the input data file %s\n", fileName);
70 }
71
72 // Is the file large enough to contain a trace
73 if(lTDFStat.st_size < sizeof(BlockStart) + EVENT_HEADER_SIZE){
74 g_print("The input data file %s does not contain a trace\n", fileName);
75 g_free(tf->name);
76 close(tf->fd);
77 g_free(tf);
78 return NULL;
79 }
80
81 //store the size of the file
82 tf->file_size = lTDFStat.st_size;
83 tf->block_size = t->system_description->ltt_block_size;
84 tf->block_number = tf->file_size / tf->block_size;
85 tf->which_block = 0;
86
87 //allocate memory to contain the info of a block
88 tf->buffer = (void *) g_new(char, t->system_description->ltt_block_size);
89
90 //read the first block
91 if(readBlock(tf,1)) exit(1);
92
93 return tf;
94 }
95
96
97 /*****************************************************************************
98 *Open control and per cpu tracefiles
99 ****************************************************************************/
100
101 void ltt_tracefile_open_cpu(LttTrace *t, char * tracefile_name)
102 {
103 LttTracefile * tf;
104 tf = ltt_tracefile_open(t,tracefile_name);
105 if(!tf) return;
106 t->per_cpu_tracefile_number++;
107 g_ptr_array_add(t->per_cpu_tracefiles, tf);
108 }
109
110 void ltt_tracefile_open_control(LttTrace *t, char * control_name)
111 {
112 LttTracefile * tf;
113 LttEvent * ev;
114 LttFacility * f;
115 uint16_t evId;
116 void * pos;
117 FacilityLoad fLoad;
118 int i;
119
120 tf = ltt_tracefile_open(t,control_name);
121 if(!tf) return;
122 t->control_tracefile_number++;
123 g_ptr_array_add(t->control_tracefiles,tf);
124
125 //parse facilities tracefile to get base_id
126 if(strcmp(&control_name[strlen(control_name)-10],"facilities") ==0){
127 while(1){
128 ev = ltt_tracefile_read(tf);
129 if(!ev)return; // end of file
130
131 if(ev->event_id == TRACE_FACILITY_LOAD){
132 pos = ev->data;
133 fLoad.name = (char*)pos;
134 fLoad.checksum = *(LttChecksum*)(pos + strlen(fLoad.name));
135 fLoad.base_code = *(uint32_t*)(pos + strlen(fLoad.name) + sizeof(LttChecksum));
136
137 for(i=0;i<t->facility_number;i++){
138 f = (LttFacility*)g_ptr_array_index(t->facilities,i);
139 if(strcmp(f->name,fLoad.name)==0 && fLoad.checksum==f->checksum){
140 f->base_id = fLoad.base_code;
141 break;
142 }
143 }
144 if(i==t->facility_number)
145 g_error("Facility: %s, checksum: %d is not founded\n",
146 fLoad.name,fLoad.checksum);
147 }else if(ev->event_id == TRACE_BLOCK_START){
148 continue;
149 }else if(ev->event_id == TRACE_BLOCK_END){
150 break;
151 }else g_error("Not valid facilities trace file\n");
152 }
153 }
154 }
155
156 /*****************************************************************************
157 *Function name
158 * ltt_tracefile_close: close a trace file,
159 *Input params
160 * t : tracefile which will be closed
161 ****************************************************************************/
162
163 void ltt_tracefile_close(LttTracefile *t)
164 {
165 g_free(t->name);
166 g_free(t->buffer);
167 close(t->fd);
168 g_free(t);
169 }
170
171
172 /*****************************************************************************
173 *Get system information
174 ****************************************************************************/
175 void getSystemInfo(LttSystemDescription* des, char * pathname)
176 {
177 FILE * fp;
178 int i;
179 int entry_number = 15;
180 char buf[DIR_NAME_SIZE];
181 char description[4*DIR_NAME_SIZE];
182 char * ptr;
183
184 fp = fopen(pathname,"r");
185 if(!fp){
186 g_error("Can not open file : %s\n", pathname);
187 }
188
189 while(fgets(buf,DIR_NAME_SIZE, fp)!= NULL){
190 ptr = buf;
191 while(isspace(*ptr)) ptr++;
192 if(strlen(ptr) == 0) continue;
193 break;
194 }
195
196 if(strlen(ptr) == 0) g_error("Not a valid file: %s\n", pathname);
197 if(strncmp("<system",ptr,7) !=0)g_error("Not a valid file: %s\n", pathname);
198
199 for(i=0;i<entry_number;i++){
200 if(fgets(buf,DIR_NAME_SIZE, fp)== NULL)
201 g_error("Not a valid file: %s\n", pathname);
202 buf[strlen(buf)-1] = '\0';
203 ptr = buf;
204 while(isspace(*ptr)) ptr++;
205 switch(i){
206 case 0:
207 if(strncmp("node_name=",ptr,10)!=0)
208 g_error("Not a valid file: %s\n", pathname);
209 des->node_name = g_strdup(ptr+10);
210 break;
211 case 1:
212 if(strncmp("domainname=",ptr,11)!=0)
213 g_error("Not a valid file: %s\n", pathname);
214 des->domain_name = g_strdup(ptr+11);
215 break;
216 case 2:
217 if(strncmp("cpu=",ptr,4)!=0)
218 g_error("Not a valid file: %s\n", pathname);
219 des->nb_cpu = (unsigned)atoi(ptr+4);
220 break;
221 case 3:
222 if(strncmp("arch_size=",ptr,10)!=0)
223 g_error("Not a valid file: %s\n", pathname);
224 if(strcmp(ptr+10,"\"LP32\"") == 0) des->size = LTT_LP32;
225 else if(strcmp(ptr+10,"\"ILP32\"") == 0) des->size = LTT_ILP32;
226 else if(strcmp(ptr+10,"\"LP64\"") == 0) des->size = LTT_LP64;
227 else if(strcmp(ptr+10,"\"ILP64\"") == 0) des->size = LTT_ILP64;
228 else if(strcmp(ptr+10,"\"UNKNOWN\"") == 0) des->size = LTT_UNKNOWN;
229 break;
230 case 4:
231 if(strncmp("endian=",ptr,7)!=0)
232 g_error("Not a valid file: %s\n", pathname);
233 if(strcmp(ptr+7,"\"LITTLE_ENDIAN\"") == 0)
234 des->endian = LTT_LITTLE_ENDIAN;
235 else if(strcmp(ptr+7,"\"BIG_ENDIAN\"") == 0)
236 des->endian = LTT_BIG_ENDIAN;
237 break;
238 case 5:
239 if(strncmp("kernel_name=",ptr,12)!=0)
240 g_error("Not a valid file: %s\n", pathname);
241 des->kernel_name = g_strdup(ptr+12);
242 break;
243 case 6:
244 if(strncmp("kernel_release=",ptr,15)!=0)
245 g_error("Not a valid file: %s\n", pathname);
246 des->kernel_release = g_strdup(ptr+15);
247 break;
248 case 7:
249 if(strncmp("kernel_version=",ptr,15)!=0)
250 g_error("Not a valid file: %s\n", pathname);
251 des->kernel_version = g_strdup(ptr+15);
252 break;
253 case 8:
254 if(strncmp("machine=",ptr,8)!=0)
255 g_error("Not a valid file: %s\n", pathname);
256 des->machine = g_strdup(ptr+8);
257 break;
258 case 9:
259 if(strncmp("processor=",ptr,10)!=0)
260 g_error("Not a valid file: %s\n", pathname);
261 des->processor = g_strdup(ptr+10);
262 break;
263 case 10:
264 if(strncmp("hardware_platform=",ptr,18)!=0)
265 g_error("Not a valid file: %s\n", pathname);
266 des->hardware_platform = g_strdup(ptr+18);
267 break;
268 case 11:
269 if(strncmp("operating_system=",ptr,17)!=0)
270 g_error("Not a valid file: %s\n", pathname);
271 des->operating_system = g_strdup(ptr+17);
272 break;
273 case 12:
274 if(strncmp("ltt_major_version=",ptr,18)!=0)
275 g_error("Not a valid file: %s\n", pathname);
276 ptr += 18;
277 // ptr++;//skip begining "
278 // ptr[strlen(ptr)-1] = '\0'; //get rid of the ending "
279 des->ltt_major_version = (unsigned)atoi(ptr);
280 break;
281 case 13:
282 if(strncmp("ltt_minor_version=",ptr,18)!=0)
283 g_error("Not a valid file: %s\n", pathname);
284 ptr += 18;
285 // ptr++;//skip begining "
286 // ptr[strlen(ptr)-1] = '\0'; //get rid of the ending "
287 des->ltt_minor_version = (unsigned)atoi(ptr);
288 break;
289 case 14:
290 if(strncmp("ltt_block_size=",ptr,15)!=0)
291 g_error("Not a valid file: %s\n", pathname);
292 ptr += 15;
293 // ptr++;//skip begining "
294 // ptr[strlen(ptr)-1] = '\0'; //get rid of the ending "
295 des->ltt_block_size = (unsigned)atoi(ptr);
296 break;
297 default:
298 g_error("Not a valid file: %s\n", pathname);
299 }
300 }
301
302 //get description
303 description[0] = '\0';
304 if(fgets(buf,DIR_NAME_SIZE, fp)== NULL)
305 g_error("Not a valid file: %s\n", pathname);
306 ptr = buf;
307 while(isspace(*ptr)) ptr++;
308 if(*ptr != '>') g_error("Not a valid file: %s\n", pathname);
309 while((ptr=fgets(buf,DIR_NAME_SIZE, fp))!= NULL){
310 ptr = buf;
311 while(isspace(*ptr)) ptr++;
312 if(strncmp("</system>",ptr,9) == 0 )break;
313 strcat(description, buf);
314 }
315 if(!ptr)g_error("Not a valid file: %s\n", pathname);
316 if(description[0] = '\0')des->description = NULL;
317 des->description = g_strdup(description);
318
319 fclose(fp);
320 }
321
322 /*****************************************************************************
323 *The following functions get facility/tracefile information
324 ****************************************************************************/
325
326 void getFacilityInfo(LttTrace *t, char* eventdefs)
327 {
328 DIR * dir;
329 struct dirent *entry;
330 char * ptr;
331 int i,j;
332 LttFacility * f;
333 LttEventType * et;
334 char name[DIR_NAME_SIZE];
335
336 dir = opendir(eventdefs);
337 if(!dir) g_error("Can not open directory: %s\n", eventdefs);
338
339 while((entry = readdir(dir)) != NULL){
340 ptr = &entry->d_name[strlen(entry->d_name)-4];
341 if(strcmp(ptr,".xml") != 0) continue;
342 strcpy(name,eventdefs);
343 strcat(name,entry->d_name);
344 ltt_facility_open(t,name);
345 }
346 closedir(dir);
347
348 for(j=0;j<t->facility_number;j++){
349 f = (LttFacility*)g_ptr_array_index(t->facilities, j);
350 for(i=0; i<f->event_number; i++){
351 et = f->events[i];
352 setFieldsOffset(NULL, et, NULL, t);
353 }
354 }
355 }
356
357 void getControlFileInfo(LttTrace *t, char* control)
358 {
359 DIR * dir;
360 struct dirent *entry;
361 char name[DIR_NAME_SIZE];
362
363 dir = opendir(control);
364 if(!dir) g_error("Can not open directory: %s\n", control);
365
366 while((entry = readdir(dir)) != NULL){
367 if(strcmp(entry->d_name,"facilities") != 0 &&
368 strcmp(entry->d_name,"interrupts") != 0 &&
369 strcmp(entry->d_name,"processes") != 0) continue;
370
371 strcpy(name,control);
372 strcat(name,entry->d_name);
373 ltt_tracefile_open_control(t,name);
374 }
375 closedir(dir);
376 }
377
378 void getCpuFileInfo(LttTrace *t, char* cpu)
379 {
380 DIR * dir;
381 struct dirent *entry;
382 char name[DIR_NAME_SIZE];
383
384 dir = opendir(cpu);
385 if(!dir) g_error("Can not open directory: %s\n", cpu);
386
387 while((entry = readdir(dir)) != NULL){
388 if(strcmp(entry->d_name,".") != 0 &&
389 strcmp(entry->d_name,"..") != 0 ){
390 strcpy(name,cpu);
391 strcat(name,entry->d_name);
392 ltt_tracefile_open_cpu(t,name);
393 }else continue;
394 }
395 closedir(dir);
396 }
397
398 /*****************************************************************************
399 *A trace is specified as a pathname to the directory containing all the
400 *associated data (control tracefiles, per cpu tracefiles, event
401 *descriptions...).
402 *
403 *When a trace is closed, all the associated facilities, types and fields
404 *are released as well.
405 ****************************************************************************/
406
407 LttTrace *ltt_trace_open(char *pathname)
408 {
409 LttTrace * t;
410 LttSystemDescription * sys_description;
411 char eventdefs[DIR_NAME_SIZE];
412 char info[DIR_NAME_SIZE];
413 char control[DIR_NAME_SIZE];
414 char cpu[DIR_NAME_SIZE];
415 char tmp[DIR_NAME_SIZE];
416 gboolean has_slash = FALSE;
417
418 //establish the pathname to different directories
419 if(pathname[strlen(pathname)-1] == '/')has_slash = TRUE;
420 strcpy(eventdefs,pathname);
421 if(!has_slash)strcat(eventdefs,"/");
422 strcat(eventdefs,"eventdefs/");
423
424 strcpy(info,pathname);
425 if(!has_slash)strcat(info,"/");
426 strcat(info,"info/");
427
428 strcpy(control,pathname);
429 if(!has_slash)strcat(control,"/");
430 strcat(control,"control/");
431
432 strcpy(cpu,pathname);
433 if(!has_slash)strcat(cpu,"/");
434 strcat(cpu,"cpu/");
435
436 //new trace
437 t = g_new(LttTrace, 1);
438 sys_description = g_new(LttSystemDescription, 1);
439 t->pathname = g_strdup(pathname);
440 t->facility_number = 0;
441 t->control_tracefile_number = 0;
442 t->per_cpu_tracefile_number = 0;
443 t->system_description = sys_description;
444 t->control_tracefiles = g_ptr_array_new();
445 t->per_cpu_tracefiles = g_ptr_array_new();
446 t->facilities = g_ptr_array_new();
447 getDataEndianType(&(t->my_arch_size), &(t->my_arch_endian));
448
449 //get system description
450 strcpy(tmp,info);
451 strcat(tmp,"system.xml");
452 getSystemInfo(sys_description, tmp);
453
454 //get facilities info
455 getFacilityInfo(t,eventdefs);
456
457 //get control tracefile info
458 getControlFileInfo(t,control);
459
460 //get cpu tracefile info
461 getCpuFileInfo(t,cpu);
462
463 return t;
464 }
465
466 void ltt_trace_close(LttTrace *t)
467 {
468 int i;
469 LttTracefile * tf;
470 LttFacility * f;
471
472 g_free(t->pathname);
473
474 //free system_description
475 g_free(t->system_description->description);
476 g_free(t->system_description->node_name);
477 g_free(t->system_description->domain_name);
478 g_free(t->system_description->kernel_name);
479 g_free(t->system_description->kernel_release);
480 g_free(t->system_description->kernel_version);
481 g_free(t->system_description->machine);
482 g_free(t->system_description->processor);
483 g_free(t->system_description->hardware_platform);
484 g_free(t->system_description->operating_system);
485 g_free(t->system_description);
486
487 //free control_tracefiles
488 for(i=0;i<t->control_tracefile_number;i++){
489 tf = (LttTracefile*)g_ptr_array_index(t->control_tracefiles,i);
490 ltt_tracefile_close(tf);
491 }
492 g_ptr_array_free(t->control_tracefiles, TRUE);
493
494 //free per_cpu_tracefiles
495 for(i=0;i<t->per_cpu_tracefile_number;i++){
496 tf = (LttTracefile*)g_ptr_array_index(t->per_cpu_tracefiles,i);
497 ltt_tracefile_close(tf);
498 }
499 g_ptr_array_free(t->per_cpu_tracefiles, TRUE);
500
501 //free facilities
502 for(i=0;i<t->facility_number;i++){
503 f = (LttFacility*)g_ptr_array_index(t->facilities,i);
504 ltt_facility_close(f);
505 }
506 g_ptr_array_free(t->facilities, TRUE);
507
508 g_free(t);
509
510 g_blow_chunks();
511 }
512
513
514 /*****************************************************************************
515 *Get the system description of the trace
516 ****************************************************************************/
517
518 LttSystemDescription *ltt_trace_system_description(LttTrace *t)
519 {
520 return t->system_description;
521 }
522
523 /*****************************************************************************
524 * The following functions discover the facilities of the trace
525 ****************************************************************************/
526
527 unsigned ltt_trace_facility_number(LttTrace *t)
528 {
529 return (unsigned)(t->facility_number);
530 }
531
532 LttFacility *ltt_trace_facility_get(LttTrace *t, unsigned i)
533 {
534 return (LttFacility*)g_ptr_array_index(t->facilities, i);
535 }
536
537 /*****************************************************************************
538 *Function name
539 * ltt_trace_facility_find : find facilities in the trace
540 *Input params
541 * t : the trace
542 * name : facility name
543 *Output params
544 * position : position of the facility in the trace
545 *Return value
546 * : the number of facilities
547 ****************************************************************************/
548
549 unsigned ltt_trace_facility_find(LttTrace *t, char *name, unsigned *position)
550 {
551 int i, count=0;
552 LttFacility * f;
553 for(i=0;i<t->facility_number;i++){
554 f = (LttFacility*)g_ptr_array_index(t->facilities, i);
555 if(strcmp(f->name,name)==0){
556 count++;
557 if(count==1) *position = i;
558 }else{
559 if(count) break;
560 }
561 }
562 return count;
563 }
564
565 /*****************************************************************************
566 * Functions to discover all the event types in the trace
567 ****************************************************************************/
568
569 unsigned ltt_trace_eventtype_number(LttTrace *t)
570 {
571 int i;
572 unsigned count = 0;
573 LttFacility * f;
574 for(i=0;i<t->facility_number;i++){
575 f = (LttFacility*)g_ptr_array_index(t->facilities, i);
576 count += f->event_number;
577 }
578 return count;
579 }
580
581 LttFacility * ltt_trace_facility_by_id(LttTrace * trace, unsigned id)
582 {
583 LttFacility * facility;
584 int i;
585 for(i=0;i<trace->facility_number;i++){
586 facility = (LttFacility*) g_ptr_array_index(trace->facilities,i);
587 if(id >= facility->base_id &&
588 id < facility->base_id + facility->event_number)
589 break;
590 }
591 if(i==trace->facility_number) return NULL;
592 else return facility;
593 }
594
595 LttEventType *ltt_trace_eventtype_get(LttTrace *t, unsigned evId)
596 {
597 LttFacility * f;
598 f = ltt_trace_facility_by_id(t,evId);
599 if(!f) return NULL;
600 return f->events[evId - f->base_id];
601 }
602
603 /*****************************************************************************
604 *There is one "per cpu" tracefile for each CPU, numbered from 0 to
605 *the maximum number of CPU in the system. When the number of CPU installed
606 *is less than the maximum, some positions are unused. There are also a
607 *number of "control" tracefiles (facilities, interrupts...).
608 ****************************************************************************/
609 unsigned ltt_trace_control_tracefile_number(LttTrace *t)
610 {
611 return t->control_tracefile_number;
612 }
613
614 unsigned ltt_trace_per_cpu_tracefile_number(LttTrace *t)
615 {
616 return t->per_cpu_tracefile_number;
617 }
618
619 /*****************************************************************************
620 *It is possible to search for the tracefiles by name or by CPU position.
621 *The index within the tracefiles of the same type is returned if found
622 *and a negative value otherwise.
623 ****************************************************************************/
624
625 int ltt_trace_control_tracefile_find(LttTrace *t, char *name)
626 {
627 LttTracefile * tracefile;
628 int i;
629 for(i=0;i<t->control_tracefile_number;i++){
630 tracefile = (LttTracefile*)g_ptr_array_index(t->control_tracefiles, i);
631 if(strcmp(tracefile->name, name)==0)break;
632 }
633 if(i == t->control_tracefile_number) return -1;
634 return i;
635 }
636
637 int ltt_trace_per_cpu_tracefile_find(LttTrace *t, unsigned i)
638 {
639 LttTracefile * tracefile;
640 int j, name;
641 for(j=0;j<t->per_cpu_tracefile_number;j++){
642 tracefile = (LttTracefile*)g_ptr_array_index(t->per_cpu_tracefiles, j);
643 name = atoi(tracefile->name);
644 if(name == (int)i)break;
645 }
646 if(j == t->per_cpu_tracefile_number) return -1;
647 return j;
648 }
649
650 /*****************************************************************************
651 *Get a specific tracefile
652 ****************************************************************************/
653
654 LttTracefile *ltt_trace_control_tracefile_get(LttTrace *t, unsigned i)
655 {
656 return (LttTracefile*)g_ptr_array_index(t->control_tracefiles, i);
657 }
658
659 LttTracefile *ltt_trace_per_cpu_tracefile_get(LttTrace *t, unsigned i)
660 {
661 return (LttTracefile*)g_ptr_array_index(t->per_cpu_tracefiles, i);
662 }
663
664 /*****************************************************************************
665 * Get the start time and end time of the trace
666 ****************************************************************************/
667
668 void ltt_trace_time_span_get(LttTrace *t, LttTime *start, LttTime *end)
669 {
670 LttTime startSmall, startTmp, endBig, endTmp;
671 int i, j=0;
672 LttTracefile * tf;
673
674 for(i=0;i<t->control_tracefile_number;i++){
675 tf = g_ptr_array_index(t->control_tracefiles, i);
676 readBlock(tf,1);
677 startTmp = tf->a_block_start->time;
678 readBlock(tf,tf->block_number);
679 endTmp = tf->a_block_end->time;
680 if(i==0){
681 startSmall = startTmp;
682 endBig = endTmp;
683 j = 1;
684 continue;
685 }
686 if(timecmp(&startSmall,&startTmp) > 0) startSmall = startTmp;
687 if(timecmp(&endBig,&endTmp) < 0) endBig = endTmp;
688 }
689
690 for(i=0;i<t->per_cpu_tracefile_number;i++){
691 tf = g_ptr_array_index(t->per_cpu_tracefiles, i);
692 readBlock(tf,1);
693 startTmp = tf->a_block_start->time;
694 readBlock(tf,tf->block_number);
695 endTmp = tf->a_block_end->time;
696 if(j == 0 && i==0){
697 startSmall = startTmp;
698 endBig = endTmp;
699 continue;
700 }
701 if(timecmp(&startSmall,&startTmp) > 0) startSmall = startTmp;
702 if(timecmp(&endBig,&endTmp) < 0) endBig = endTmp;
703 }
704
705 *start = startSmall;
706 *end = endBig;
707 }
708
709
710 /*****************************************************************************
711 *Get the name of a tracefile
712 ****************************************************************************/
713
714 char *ltt_tracefile_name(LttTracefile *tf)
715 {
716 return tf->name;
717 }
718
719 /*****************************************************************************
720 * Get the number of blocks in the tracefile
721 ****************************************************************************/
722
723 unsigned ltt_tracefile_block_number(LttTracefile *tf)
724 {
725 return tf->block_number;
726 }
727
728 /*****************************************************************************
729 *Function name
730 * ltt_tracefile_seek_time: seek to the first event of the trace with time
731 * larger or equal to time
732 *Input params
733 * t : tracefile
734 * time : criteria of the time
735 ****************************************************************************/
736
737 void ltt_tracefile_seek_time(LttTracefile *t, LttTime time)
738 {
739 int err;
740 LttTime lttTime;
741 int headTime = timecmp(&(t->a_block_start->time), &time);
742 int tailTime = timecmp(&(t->a_block_end->time), &time);
743 LttEvent * ev;
744
745 if(headTime < 0 && tailTime > 0){
746 if(timecmp(&(t->a_block_end->time),&(t->current_event_time)) !=0){
747 lttTime = getEventTime(t);
748 err = timecmp(&lttTime, &time);
749 if(err > 0){
750 if(t->which_event==2 || timecmp(&t->prev_event_time,&time)<0){
751 return;
752 }else{
753 updateTracefile(t);
754 return ltt_tracefile_seek_time(t, time);
755 }
756 }else if(err < 0){
757 while(1){
758 ev = ltt_tracefile_read(t);
759 if(ev == NULL){
760 g_print("End of file\n");
761 return;
762 }
763 lttTime = getEventTime(t);
764 err = timecmp(&lttTime, &time);
765 if(err >= 0)return;
766 }
767 }else return;
768 }else{//we are at the end of the block
769 updateTracefile(t);
770 return ltt_tracefile_seek_time(t, time);
771 }
772 }else if(headTime >= 0){
773 if(t->which_block == 1){
774 updateTracefile(t);
775 }else{
776 if(timecmp(&(t->prev_block_end_time),&time) >= 0 ){
777 err=readBlock(t,t->which_block-1);
778 if(err) g_error("Can not read tracefile: %s\n", t->name);
779 return ltt_tracefile_seek_time(t, time) ;
780 }else{
781 updateTracefile(t);
782 }
783 }
784 }else if(tailTime < 0){
785 if(t->which_block != t->block_number){
786 err=readBlock(t,t->which_block+1);
787 if(err) g_error("Can not read tracefile: %s\n", t->name);
788 }else {
789 g_print("End of file\n");
790 return;
791 }
792 if(tailTime < 0) return ltt_tracefile_seek_time(t, time);
793 }else if(tailTime == 0){
794 t->cur_event_pos = t->last_event_pos;
795 t->current_event_time = time;
796 t->cur_heart_beat_number = 0;
797 t->prev_event_time.tv_sec = 0;
798 t->prev_event_time.tv_nsec = 0;
799 return;
800 }
801 }
802
803 /*****************************************************************************
804 * Seek to the first event with position equal or larger to ep
805 ****************************************************************************/
806
807 void ltt_tracefile_seek_position(LttTracefile *t, LttEventPosition *ep)
808 {
809 //if we are at the right place, just return
810 if(t->which_block == ep->block_num && t->which_event == ep->event_num)
811 return;
812
813 if(t->which_block == ep->block_num) updateTracefile(t);
814 else readBlock(t,ep->block_num);
815
816 //event offset is availiable
817 if(ep->old_position){
818 t->cur_heart_beat_number = ep->heart_beat_number;
819 t->cur_event_pos = t->buffer + ep->event_offset;
820 return;
821 }
822
823 //only block number and event index are availiable
824 while(t->which_event < ep->event_num) ltt_tracefile_read(t);
825
826 return;
827 }
828
829 /*****************************************************************************
830 *Function name
831 * ltt_tracefile_read : read the current event, set the pointer to the next
832 *Input params
833 * t : tracefile
834 *Return value
835 * LttEvent * : an event to be processed
836 ****************************************************************************/
837
838 LttEvent *ltt_tracefile_read(LttTracefile *t)
839 {
840 LttEvent * lttEvent = &t->an_event;
841 int err;
842
843 if(t->cur_event_pos == t->buffer + t->block_size){
844 if(t->which_block == t->block_number){
845 return NULL;
846 }
847 err = readBlock(t, t->which_block + 1);
848 if(err)g_error("Can not read tracefile");
849 }
850
851 lttEvent->event_id = (int)(*(uint16_t *)(t->cur_event_pos));
852 if(lttEvent->event_id == TRACE_TIME_HEARTBEAT)
853 t->cur_heart_beat_number++;
854
855 t->prev_event_time = t->current_event_time;
856 // t->current_event_time = getEventTime(t);
857
858 lttEvent->time_delta = *(uint32_t*)(t->cur_event_pos + EVENT_ID_SIZE);
859 lttEvent->event_time = t->current_event_time;
860
861 lttEvent->tracefile = t;
862 lttEvent->data = t->cur_event_pos + EVENT_HEADER_SIZE;
863 lttEvent->which_block = t->which_block;
864 lttEvent->which_event = t->which_event;
865
866 //update the fields of the current event and go to the next event
867 err = skipEvent(t);
868 if(err == ERANGE) g_error("event id is out of range\n");
869
870 lttEvent->event_cycle_count = t->cur_cycle_count;
871
872 return lttEvent;
873 }
874
875 /****************************************************************************
876 *Function name
877 * readFile : wrap function to read from a file
878 *Input Params
879 * fd : file descriptor
880 * buf : buf to contain the content
881 * size : number of bytes to be read
882 * mesg : message to be printed if some thing goes wrong
883 *return value
884 * 0 : success
885 * EIO : can not read from the file
886 ****************************************************************************/
887
888 int readFile(int fd, void * buf, size_t size, char * mesg)
889 {
890 ssize_t nbBytes;
891 nbBytes = read(fd, buf, size);
892 if(nbBytes != size){
893 printf("%s\n",mesg);
894 return EIO;
895 }
896 return 0;
897 }
898
899 /****************************************************************************
900 *Function name
901 * readBlock : read a block from the file
902 *Input Params
903 * lttdes : ltt trace file
904 * whichBlock : the block which will be read
905 *return value
906 * 0 : success
907 * EINVAL : lseek fail
908 * EIO : can not read from the file
909 ****************************************************************************/
910
911 int readBlock(LttTracefile * tf, int whichBlock)
912 {
913 off_t nbBytes;
914 uint32_t lostSize;
915
916 if(whichBlock - tf->which_block == 1 && tf->which_block != 0){
917 tf->prev_block_end_time = tf->a_block_end->time;
918 tf->prev_event_time = tf->a_block_end->time;
919 }else{
920 tf->prev_block_end_time.tv_sec = 0;
921 tf->prev_block_end_time.tv_nsec = 0;
922 tf->prev_event_time.tv_sec = 0;
923 tf->prev_event_time.tv_nsec = 0;
924 }
925
926 nbBytes=lseek(tf->fd,(off_t)((whichBlock-1)*tf->block_size), SEEK_SET);
927 if(nbBytes == -1) return EINVAL;
928
929 if(readFile(tf->fd,tf->buffer,tf->block_size,"Unable to read a block"))
930 return EIO;
931
932 tf->a_block_start=(BlockStart *) (tf->buffer + EVENT_HEADER_SIZE);
933 lostSize = *(uint32_t*)(tf->buffer + tf->block_size - sizeof(uint32_t));
934 tf->a_block_end=(BlockEnd *)(tf->buffer + tf->block_size -
935 lostSize + EVENT_HEADER_SIZE);
936 tf->last_event_pos = tf->buffer + tf->block_size - lostSize;
937
938 tf->which_block = whichBlock;
939 tf->which_event = 1;
940 tf->cur_event_pos = tf->buffer;//the beginning of the block, block start ev
941 tf->cur_heart_beat_number = 0;
942
943 getCyclePerNsec(tf);
944
945 tf->current_event_time = getEventTime(tf);
946
947 return 0;
948 }
949
950 /*****************************************************************************
951 *Function name
952 * updateTracefile : reinitialize the info of the block which is already
953 * in the buffer
954 *Input params
955 * tf : tracefile
956 ****************************************************************************/
957
958 void updateTracefile(LttTracefile * tf)
959 {
960 tf->which_event = 1;
961 tf->cur_event_pos = tf->buffer;
962 tf->current_event_time = getEventTime(tf);
963 tf->cur_heart_beat_number = 0;
964
965 tf->prev_event_time.tv_sec = 0;
966 tf->prev_event_time.tv_nsec = 0;
967 }
968
969 /*****************************************************************************
970 *Function name
971 * skipEvent : go to the next event, update the fields of the current event
972 *Input params
973 * t : tracefile
974 *return value
975 * 0 : success
976 * ERANGE : event id is out of range
977 ****************************************************************************/
978
979 int skipEvent(LttTracefile * t)
980 {
981 int evId, err;
982 void * evData;
983 LttEventType * evT;
984 LttField * rootFld;
985
986 evId = (int)(*(uint16_t *)(t->cur_event_pos));
987 evData = t->cur_event_pos + EVENT_HEADER_SIZE;
988
989 evT = ltt_trace_eventtype_get(t->trace,(unsigned)evId);
990
991 if(evT) rootFld = evT->root_field;
992 else return ERANGE;
993
994 if(rootFld){
995 //event has string/sequence or the last event is not the same event
996 if((evT->latest_block!=t->which_block || evT->latest_event!=t->which_event)
997 && rootFld->field_fixed == 0){
998 setFieldsOffset(t, evT, evData, t->trace);
999 }
1000 t->cur_event_pos += EVENT_HEADER_SIZE + rootFld->field_size;
1001 }else t->cur_event_pos += EVENT_HEADER_SIZE;
1002
1003 evT->latest_block = t->which_block;
1004 evT->latest_event = t->which_event;
1005
1006 //the next event is in the next block
1007 if(evId == TRACE_BLOCK_END){
1008 t->cur_event_pos = t->buffer + t->block_size;
1009 }else{
1010 t->which_event++;
1011 t->current_event_time = getEventTime(t);
1012 }
1013
1014 return 0;
1015 }
1016
1017 /*****************************************************************************
1018 *Function name
1019 * getCyclePerNsec : calculate cycles per nsec for current block
1020 *Input Params
1021 * t : tracefile
1022 ****************************************************************************/
1023
1024 void getCyclePerNsec(LttTracefile * t)
1025 {
1026 LttTime lBufTotalTime; /* Total time for this buffer */
1027 LttCycleCount lBufTotalNSec; /* Total time for this buffer in nsecs */
1028 LttCycleCount lBufTotalCycle;/* Total cycles for this buffer */
1029
1030 /* Calculate the total time for this buffer */
1031 TimeSub(lBufTotalTime,t->a_block_end->time, t->a_block_start->time);
1032
1033 /* Calculate the total cycles for this bufffer */
1034 lBufTotalCycle = t->a_block_end->cycle_count;
1035 lBufTotalCycle -= t->a_block_start->cycle_count;
1036
1037 /* Convert the total time to nsecs */
1038 lBufTotalNSec = lBufTotalTime.tv_sec;
1039 lBufTotalNSec *= NANSECOND_CONST;
1040 lBufTotalNSec += lBufTotalTime.tv_nsec;
1041
1042 t->cycle_per_nsec = (double)lBufTotalCycle / (double)lBufTotalNSec;
1043 }
1044
1045 /****************************************************************************
1046 *Function name
1047 * getEventTime : obtain the time of an event
1048 *Input params
1049 * tf : tracefile
1050 *Return value
1051 * LttTime : the time of the event
1052 ****************************************************************************/
1053
1054 LttTime getEventTime(LttTracefile * tf)
1055 {
1056 LttTime time;
1057 LttCycleCount cycle_count; // cycle count for the current event
1058 LttCycleCount lEventTotalCycle; // Total cycles from start for event
1059 double lEventNSec; // Total usecs from start for event
1060 LttTime lTimeOffset; // Time offset in struct LttTime
1061 uint16_t evId;
1062 int64_t nanoSec, tmpCycleCount = (((uint64_t)1)<<32);
1063 static LttCycleCount preCycleCount = 0;
1064 static int count = 0;
1065
1066 evId = *(uint16_t*)tf->cur_event_pos;
1067 if(evId == TRACE_BLOCK_START){
1068 count = 0;
1069 preCycleCount = 0;
1070 tf->cur_cycle_count = tf->a_block_start->cycle_count;
1071 return tf->a_block_start->time;
1072 }else if(evId == TRACE_BLOCK_END){
1073 count = 0;
1074 preCycleCount = 0;
1075 tf->cur_cycle_count = tf->a_block_end->cycle_count;
1076 return tf->a_block_end->time;
1077 }
1078
1079 // Calculate total time in cycles from start of buffer for this event
1080 cycle_count = (LttCycleCount)*(uint32_t*)(tf->cur_event_pos + EVENT_ID_SIZE);
1081
1082 if(cycle_count < preCycleCount)count++;
1083 preCycleCount = cycle_count;
1084 cycle_count += tmpCycleCount * count;
1085
1086 if(tf->cur_heart_beat_number > count)
1087 cycle_count += tmpCycleCount * (tf->cur_heart_beat_number - count);
1088
1089 tf->cur_cycle_count = cycle_count;
1090
1091 lEventTotalCycle = cycle_count;
1092 lEventTotalCycle -= tf->a_block_start->cycle_count;
1093
1094 // Convert it to nsecs
1095 lEventNSec = lEventTotalCycle / tf->cycle_per_nsec;
1096 nanoSec = lEventNSec;
1097
1098 // Determine offset in struct LttTime
1099 lTimeOffset.tv_nsec = nanoSec % NANSECOND_CONST;
1100 lTimeOffset.tv_sec = nanoSec / NANSECOND_CONST;
1101
1102 TimeAdd(time, tf->a_block_start->time, lTimeOffset);
1103
1104 return time;
1105 }
1106
1107 /*****************************************************************************
1108 *Function name
1109 * setFieldsOffset : set offset of the fields
1110 *Input params
1111 * tracefile : opened trace file
1112 * evT : the event type
1113 * evD : event data, it may be NULL
1114 ****************************************************************************/
1115
1116 void setFieldsOffset(LttTracefile *tf,LttEventType *evT,void *evD,LttTrace* t)
1117 {
1118 LttField * rootFld = evT->root_field;
1119 // rootFld->base_address = evD;
1120
1121 if(rootFld)
1122 rootFld->field_size = getFieldtypeSize(tf, evT, 0,0,rootFld, evD,t);
1123 }
1124
1125 /*****************************************************************************
1126 *Function name
1127 * getFieldtypeSize: get the size of the field type (primitive type)
1128 *Input params
1129 * tracefile : opened trace file
1130 * evT : event type
1131 * offsetRoot : offset from the root
1132 * offsetParent : offset from the parrent
1133 * fld : field
1134 * evD : event data, it may be NULL
1135 *Return value
1136 * int : size of the field
1137 ****************************************************************************/
1138
1139 int getFieldtypeSize(LttTracefile * t, LttEventType * evT, int offsetRoot,
1140 int offsetParent, LttField * fld, void *evD, LttTrace *trace)
1141 {
1142 int size, size1, element_number, i, offset1, offset2;
1143 LttType * type = fld->field_type;
1144
1145 if(t){
1146 if(evT->latest_block==t->which_block && evT->latest_event==t->which_event){
1147 return fld->field_size;
1148 }
1149 }
1150
1151 if(fld->field_fixed == 1){
1152 if(fld == evT->root_field) return fld->field_size;
1153 }
1154
1155 if(type->type_class != LTT_STRUCT && type->type_class != LTT_ARRAY &&
1156 type->type_class != LTT_SEQUENCE && type->type_class != LTT_STRING){
1157 if(fld->field_fixed == -1){
1158 size = (int) ltt_type_size(trace, type);
1159 fld->field_fixed = 1;
1160 }else size = fld->field_size;
1161
1162 }else if(type->type_class == LTT_ARRAY){
1163 element_number = (int) type->element_number;
1164 if(fld->field_fixed == -1){
1165 size = getFieldtypeSize(t, evT, offsetRoot,0,fld->child[0], NULL, trace);
1166 if(size == 0){ //has string or sequence
1167 fld->field_fixed = 0;
1168 }else{
1169 fld->field_fixed = 1;
1170 size *= element_number;
1171 }
1172 }else if(fld->field_fixed == 0){// has string or sequence
1173 size = 0;
1174 for(i=0;i<element_number;i++){
1175 size += getFieldtypeSize(t, evT, offsetRoot+size,size,
1176 fld->child[0], evD+size, trace);
1177 }
1178 }else size = fld->field_size;
1179
1180 }else if(type->type_class == LTT_SEQUENCE){
1181 size1 = (int) ltt_type_size(trace, type);
1182 if(fld->field_fixed == -1){
1183 fld->sequ_number_size = size1;
1184 fld->field_fixed = 0;
1185 size = getFieldtypeSize(t, evT, offsetRoot,0,fld->child[0], NULL, trace);
1186 fld->element_size = size;
1187 }else{//0: sequence
1188 element_number = getIntNumber(size1,evD);
1189 type->element_number = element_number;
1190 if(fld->element_size > 0){
1191 size = element_number * fld->element_size;
1192 }else{//sequence has string or sequence
1193 size = 0;
1194 for(i=0;i<element_number;i++){
1195 size += getFieldtypeSize(t, evT, offsetRoot+size+size1,size+size1,
1196 fld->child[0], evD+size+size1, trace);
1197 }
1198 }
1199 size += size1;
1200 }
1201
1202 }else if(type->type_class == LTT_STRING){
1203 size = 0;
1204 if(fld->field_fixed == -1){
1205 fld->field_fixed = 0;
1206 }else{//0: string
1207 size = strlen((char*)evD) + 1; //include end : '\0'
1208 }
1209
1210 }else if(type->type_class == LTT_STRUCT){
1211 element_number = (int) type->element_number;
1212 size = 0;
1213 if(fld->field_fixed == -1){
1214 offset1 = offsetRoot;
1215 offset2 = 0;
1216 for(i=0;i<element_number;i++){
1217 size1=getFieldtypeSize(t, evT,offset1,offset2, fld->child[i], NULL, trace);
1218 if(size1 > 0 && size >= 0){
1219 size += size1;
1220 if(offset1 >= 0) offset1 += size1;
1221 offset2 += size1;
1222 }else{
1223 size = -1;
1224 offset1 = -1;
1225 offset2 = -1;
1226 }
1227 }
1228 if(size == -1){
1229 fld->field_fixed = 0;
1230 size = 0;
1231 }else fld->field_fixed = 1;
1232 }else if(fld->field_fixed == 0){
1233 offset1 = offsetRoot;
1234 offset2 = 0;
1235 for(i=0;i<element_number;i++){
1236 size=getFieldtypeSize(t,evT,offset1,offset2,fld->child[i],evD+offset2, trace);
1237 offset1 += size;
1238 offset2 += size;
1239 }
1240 size = offset2;
1241 }else size = fld->field_size;
1242 }
1243
1244 fld->offset_root = offsetRoot;
1245 fld->offset_parent = offsetParent;
1246 if(!evD){
1247 fld->fixed_root = (offsetRoot==-1) ? 0 : 1;
1248 fld->fixed_parent = (offsetParent==-1) ? 0 : 1;
1249 }
1250 fld->field_size = size;
1251
1252 return size;
1253 }
1254
1255 /*****************************************************************************
1256 *Function name
1257 * timecmp : compare two time
1258 *Input params
1259 * t1 : first time
1260 * t2 : second time
1261 *Return value
1262 * int : 0: t1 == t2; -1: t1 < t2; 1: t1 > t2
1263 ****************************************************************************/
1264
1265 int timecmp(LttTime * t1, LttTime * t2)
1266 {
1267 if(t1->tv_sec < t2->tv_sec) return -1;
1268 if(t1->tv_sec > t2->tv_sec) return 1;
1269 if(t1->tv_nsec < t2->tv_nsec) return -1;
1270 if(t1->tv_nsec > t2->tv_nsec) return 1;
1271 return 0;
1272 }
1273
1274 /*****************************************************************************
1275 *Function name
1276 * getIntNumber : get an integer number
1277 *Input params
1278 * size : the size of the integer
1279 * evD : the event data
1280 *Return value
1281 * int : an integer
1282 ****************************************************************************/
1283
1284 int getIntNumber(int size, void *evD)
1285 {
1286 int64_t i;
1287 if(size == 1) i = *(int8_t *)evD;
1288 else if(size == 2) i = *(int16_t *)evD;
1289 else if(size == 4) i = *(int32_t *)evD;
1290 else if(size == 8) i = *(int64_t *)evD;
1291
1292 return (int) i;
1293 }
1294
1295 /*****************************************************************************
1296 *Function name
1297 * getDataEndianType : get the data type size and endian type of the local
1298 * machine
1299 *Input params
1300 * size : size of data type
1301 * endian : endian type, little or big
1302 ****************************************************************************/
1303
1304 void getDataEndianType(LttArchSize * size, LttArchEndian * endian)
1305 {
1306 int i = 1;
1307 char c = (char) i;
1308 int sizeInt=sizeof(int), sizeLong=sizeof(long), sizePointer=sizeof(void *);
1309
1310 if(c == 1) *endian = LTT_LITTLE_ENDIAN;
1311 else *endian = LTT_BIG_ENDIAN;
1312
1313 if(sizeInt == 2 && sizeLong == 4 && sizePointer == 4)
1314 *size = LTT_LP32;
1315 else if(sizeInt == 4 && sizeLong == 4 && sizePointer == 4)
1316 *size = LTT_ILP32;
1317 else if(sizeInt == 4 && sizeLong == 8 && sizePointer == 8)
1318 *size = LTT_LP64;
1319 else if(sizeInt == 8 && sizeLong == 8 && sizePointer == 8)
1320 *size = LTT_ILP64;
1321 else *size = LTT_UNKNOWN;
1322 }
1323
This page took 0.060816 seconds and 4 git commands to generate.