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 name of a tracefile
 666  ****************************************************************************/
 667
 668 char *ltt_tracefile_name(LttTracefile *tf)
 669 {
 670   return tf->name;
 671 }
 672
 673 /*****************************************************************************
 674  *Function name
 675  *    ltt_tracefile_seek_time: seek to the first event of the trace with time
 676  *                             larger or equal to time
 677  *Input params
 678  *    t                      : tracefile
 679  *    time                   : criteria of the time
 680  ****************************************************************************/
 681
 682 void ltt_tracefile_seek_time(LttTracefile *t, LttTime time)
 683 {
 684   int err;
 685   LttTime lttTime;
 686   int headTime = timecmp(&(t->a_block_start->time), &time);
 687   int tailTime = timecmp(&(t->a_block_end->time), &time);
 688   LttEvent * ev;
 689
 690   if(headTime < 0 && tailTime > 0){
 691     lttTime = getEventTime(t);
 692     err = timecmp(&lttTime, &time);
 693     if(err > 0){
 694       if(t->which_event==2 || timecmp(&t->prev_event_time,&time)<0){
 695         return;
 696       }else{
 697         updateTracefile(t);
 698         return ltt_tracefile_seek_time(t, time);
 699       }
 700     }else if(err < 0){
 701       while(1){
 702         ev = ltt_tracefile_read(t);
 703         if(ev == NULL){
 704           g_print("End of file\n");
 705           return;
 706         }
 707         lttTime = getEventTime(t);
 708         err = timecmp(&lttTime, &time);
 709         if(err >= 0)return;
 710       }
 711     }else return;
 712   }else if(headTime > 0){
 713     if(t->which_block == 1){
 714       updateTracefile(t);
 715     }else{
 716       if(timecmp(&(t->prev_block_end_time),&time) >= 0 ){
 717         err=readBlock(t,t->which_block-1);
 718         if(err) g_error("Can not read tracefile: %s\n", t->name);
 719         return ltt_tracefile_seek_time(t, time) ;
 720       }else{
 721         updateTracefile(t);
 722       }
 723     }
 724   }else if(tailTime < 0){
 725     if(t->which_block != t->block_number){
 726       err=readBlock(t,t->which_block+1);
 727       if(err) g_error("Can not read tracefile: %s\n", t->name);
 728     }else {
 729       g_print("End of file\n");
 730       return;
 731     }
 732     if(tailTime < 0) return ltt_tracefile_seek_time(t, time);
 733   }else if(headTime == 0){
 734     updateTracefile(t);
 735   }else if(tailTime == 0){
 736     t->cur_event_pos = t->a_block_end - EVENT_HEADER_SIZE;
 737     t->current_event_time = time;
 738     t->cur_heart_beat_number = 0;
 739     t->prev_event_time.tv_sec = 0;
 740     t->prev_event_time.tv_nsec = 0;
 741     return;
 742   }
 743 }
 744
 745 /*****************************************************************************
 746  *Function name
 747  *    ltt_tracefile_read : read the current event, set the pointer to the next
 748  *Input params
 749  *    t                  : tracefile
 750  *Return value
 751  *    LttEvent *        : an event to be processed
 752  ****************************************************************************/
 753
 754 LttEvent *ltt_tracefile_read(LttTracefile *t)
 755 {
 756   LttEvent * lttEvent = &t->an_event;
 757   int err;
 758
 759   if(t->cur_event_pos == t->buffer + t->block_size){
 760     if(t->which_block == t->block_number){
 761       g_free(lttEvent);
 762       return NULL;
 763     }
 764     err = readBlock(t, t->which_block + 1);
 765     if(err)g_error("Can not read tracefile");
 766   }
 767
 768   lttEvent->event_id = (int)(*(uint16_t *)(t->cur_event_pos));
 769   if(lttEvent->event_id == TRACE_TIME_HEARTBEAT)
 770     t->cur_heart_beat_number++;
 771
 772   t->prev_event_time  = t->current_event_time;
 773   //  t->current_event_time = getEventTime(t);
 774
 775   lttEvent->time_delta = *(uint32_t*)(t->cur_event_pos + EVENT_ID_SIZE);
 776   lttEvent->event_time = t->current_event_time;
 777
 778   lttEvent->event_cycle_count = ((uint64_t)1)<<32  * t->cur_heart_beat_number
 779                                 + lttEvent->time_delta;
 780
 781   lttEvent->tracefile = t;
 782   lttEvent->data = t->cur_event_pos + EVENT_HEADER_SIZE;
 783   lttEvent->which_block = t->which_block;
 784   lttEvent->which_event = t->which_event;
 785
 786   //update the fields of the current event and go to the next event
 787   err = skipEvent(t);
 788   if(err == ERANGE) g_error("event id is out of range\n");
 789
 790   return lttEvent;
 791 }
 792
 793 /****************************************************************************
 794  *Function name
 795  *    readFile    : wrap function to read from a file
 796  *Input Params
 797  *    fd          : file descriptor
 798  *    buf         : buf to contain the content
 799  *    size        : number of bytes to be read
 800  *    mesg        : message to be printed if some thing goes wrong
 801  *return value
 802  *    0           : success
 803  *    EIO         : can not read from the file
 804  ****************************************************************************/
 805
 806 int readFile(int fd, void * buf, size_t size, char * mesg)
 807 {
 808    ssize_t nbBytes;
 809    nbBytes = read(fd, buf, size);
 810    if(nbBytes != size){
 811      printf("%s\n",mesg);
 812      return EIO;
 813    }
 814    return 0;
 815 }
 816
 817 /****************************************************************************
 818  *Function name
 819  *    readBlock       : read a block from the file
 820  *Input Params
 821  *    lttdes          : ltt trace file
 822  *    whichBlock      : the block which will be read
 823  *return value
 824  *    0               : success
 825  *    EINVAL          : lseek fail
 826  *    EIO             : can not read from the file
 827  ****************************************************************************/
 828
 829 int readBlock(LttTracefile * tf, int whichBlock)
 830 {
 831   off_t nbBytes;
 832   uint32_t lostSize;
 833
 834   if(whichBlock - tf->which_block == 1 && tf->which_block != 0){
 835     tf->prev_block_end_time = tf->a_block_end->time;
 836     tf->prev_event_time     = tf->a_block_end->time;
 837   }else{
 838     tf->prev_block_end_time.tv_sec = 0;
 839     tf->prev_block_end_time.tv_nsec = 0;
 840     tf->prev_event_time.tv_sec = 0;
 841     tf->prev_event_time.tv_nsec = 0;
 842   }
 843
 844   nbBytes=lseek(tf->fd,(off_t)((whichBlock-1)*tf->block_size), SEEK_SET);
 845   if(nbBytes == -1) return EINVAL;
 846
 847   if(readFile(tf->fd,tf->buffer,tf->block_size,"Unable to read a block"))
 848     return EIO;
 849
 850   tf->a_block_start=(BlockStart *) (tf->buffer + EVENT_HEADER_SIZE);
 851   lostSize = *(uint32_t*)(tf->buffer + tf->block_size - sizeof(uint32_t));
 852   tf->a_block_end=(BlockEnd *)(tf->buffer + tf->block_size -
 853                                 lostSize + EVENT_HEADER_SIZE);
 854
 855   tf->which_block = whichBlock;
 856   tf->which_event = 1;
 857   tf->cur_event_pos = tf->buffer;//the beginning of the block, block start ev
 858   tf->cur_heart_beat_number = 0;
 859
 860   getCyclePerNsec(tf);
 861
 862   tf->current_event_time = getEventTime(tf);
 863
 864   return 0;
 865 }
 866
 867 /*****************************************************************************
 868  *Function name
 869  *    updateTracefile : reinitialize the info of the block which is already
 870  *                      in the buffer
 871  *Input params
 872  *    tf              : tracefile
 873  ****************************************************************************/
 874
 875 void updateTracefile(LttTracefile * tf)
 876 {
 877   tf->which_event = 1;
 878   tf->cur_event_pos = tf->buffer;
 879   tf->current_event_time = getEventTime(tf);
 880   tf->cur_heart_beat_number = 0;
 881
 882   tf->prev_event_time.tv_sec = 0;
 883   tf->prev_event_time.tv_nsec = 0;
 884 }
 885
 886 /*****************************************************************************
 887  *Function name
 888  *    skipEvent : go to the next event, update the fields of the current event
 889  *Input params
 890  *    t         : tracefile
 891  *return value
 892  *    0               : success
 893  *    ERANGE          : event id is out of range
 894  ****************************************************************************/
 895
 896 int skipEvent(LttTracefile * t)
 897 {
 898   int evId, err;
 899   void * evData;
 900   LttEventType * evT;
 901   LttField * rootFld;
 902
 903   evId   = (int)(*(uint16_t *)(t->cur_event_pos));
 904   evData = t->cur_event_pos + EVENT_HEADER_SIZE;
 905
 906   evT    = ltt_trace_eventtype_get(t->trace,(unsigned)evId);
 907
 908   if(evT) rootFld = evT->root_field;
 909   else return ERANGE;
 910
 911   if(rootFld){
 912     //event has string/sequence or the last event is not the same event
 913     if((evT->latest_block!=t->which_block || evT->latest_event!=t->which_event)
 914        && rootFld->field_fixed == 0){
 915       setFieldsOffset(t, evT, evData, t->trace);
 916     }
 917     t->cur_event_pos += EVENT_HEADER_SIZE + rootFld->field_size;
 918   }else t->cur_event_pos += EVENT_HEADER_SIZE;
 919
 920   evT->latest_block = t->which_block;
 921   evT->latest_event = t->which_event;
 922
 923   //the next event is in the next block
 924   if(evId == TRACE_BLOCK_END){
 925     t->cur_event_pos = t->buffer + t->block_size;
 926   }else{
 927     t->which_event++;
 928     t->current_event_time = getEventTime(t);
 929   }
 930
 931   return 0;
 932 }
 933
 934 /*****************************************************************************
 935  *Function name
 936  *    getCyclePerNsec : calculate cycles per nsec for current block
 937  *Input Params
 938  *    t               : tracefile
 939  ****************************************************************************/
 940
 941 void getCyclePerNsec(LttTracefile * t)
 942 {
 943   LttTime           lBufTotalTime; /* Total time for this buffer */
 944   LttCycleCount     lBufTotalNSec; /* Total time for this buffer in nsecs */
 945   LttCycleCount     lBufTotalCycle;/* Total cycles for this buffer */
 946
 947   /* Calculate the total time for this buffer */
 948   TimeSub(lBufTotalTime,t->a_block_end->time, t->a_block_start->time);
 949
 950   /* Calculate the total cycles for this bufffer */
 951   lBufTotalCycle = t->a_block_end->cycle_count
 952                    - t->a_block_start->cycle_count;
 953
 954   /* Convert the total time to nsecs */
 955   lBufTotalNSec = lBufTotalTime.tv_sec * 1000000000 + lBufTotalTime.tv_nsec;
 956
 957   t->cycle_per_nsec = (double)lBufTotalCycle / (double)lBufTotalNSec;
 958 }
 959
 960 /****************************************************************************
 961  *Function name
 962  *    getEventTime    : obtain the time of an event
 963  *Input params
 964  *    tf              : tracefile
 965  *Return value
 966  *    LttTime        : the time of the event
 967  ****************************************************************************/
 968
 969 LttTime getEventTime(LttTracefile * tf)
 970 {
 971   LttTime       time;
 972   LttCycleCount cycle_count;      // cycle count for the current event
 973   LttCycleCount lEventTotalCycle; // Total cycles from start for event
 974   double        lEventNSec;       // Total usecs from start for event
 975   LttTime       lTimeOffset;      // Time offset in struct LttTime
 976   uint16_t      evId;
 977
 978   evId = *(uint16_t*)tf->cur_event_pos;
 979   if(evId == TRACE_BLOCK_START)
 980     return tf->a_block_start->time;
 981   else if(evId == TRACE_BLOCK_END)
 982     return tf->a_block_end->time;
 983
 984
 985   // Calculate total time in cycles from start of buffer for this event
 986   cycle_count = (LttCycleCount)*(uint32_t*)(tf->cur_event_pos + EVENT_ID_SIZE);
 987   if(tf->cur_heart_beat_number)
 988     cycle_count += ((uint64_t)1)<<32  * tf->cur_heart_beat_number;
 989   lEventTotalCycle = cycle_count - tf->a_block_start->cycle_count;
 990
 991   // Convert it to nsecs
 992   lEventNSec = lEventTotalCycle / tf->cycle_per_nsec;
 993
 994   // Determine offset in struct LttTime
 995   lTimeOffset.tv_nsec = (long)lEventNSec % 1000000000;
 996   lTimeOffset.tv_sec  = (long)lEventNSec / 1000000000;
 997
 998   TimeAdd(time, tf->a_block_start->time, lTimeOffset);
 999
1000   return time;
1001 }
1002
1003 /*****************************************************************************
1004  *Function name
1005  *    setFieldsOffset : set offset of the fields
1006  *Input params
1007  *    tracefile       : opened trace file
1008  *    evT             : the event type
1009  *    evD             : event data, it may be NULL
1010  ****************************************************************************/
1011
1012 void setFieldsOffset(LttTracefile *tf,LttEventType *evT,void *evD,LttTrace* t)
1013 {
1014   LttField * rootFld = evT->root_field;
1015   //  rootFld->base_address = evD;
1016
1017   if(rootFld)
1018     rootFld->field_size = getFieldtypeSize(tf, evT, 0,0,rootFld, evD,t);
1019 }
1020
1021 /*****************************************************************************
1022  *Function name
1023  *    getFieldtypeSize: get the size of the field type (primitive type)
1024  *Input params
1025  *    tracefile       : opened trace file
1026  *    evT             : event type
1027  *    offsetRoot      : offset from the root
1028  *    offsetParent    : offset from the parrent
1029  *    fld             : field
1030  *    evD             : event data, it may be NULL
1031  *Return value
1032  *    int             : size of the field
1033  ****************************************************************************/
1034
1035 int getFieldtypeSize(LttTracefile * t, LttEventType * evT, int offsetRoot,
1036              int offsetParent, LttField * fld, void *evD, LttTrace *trace)
1037 {
1038   int size, size1, element_number, i, offset1, offset2;
1039   LttType * type = fld->field_type;
1040
1041   if(t){
1042     if(evT->latest_block==t->which_block && evT->latest_event==t->which_event){
1043       return fld->field_size;
1044     }
1045   }
1046
1047   if(fld->field_fixed == 1){
1048     if(fld == evT->root_field) return fld->field_size;
1049   }
1050
1051   if(type->type_class != LTT_STRUCT && type->type_class != LTT_ARRAY &&
1052      type->type_class != LTT_SEQUENCE && type->type_class != LTT_STRING){
1053     if(fld->field_fixed == -1){
1054       size = (int) ltt_type_size(trace, type);
1055       fld->field_fixed = 1;
1056     }else size = fld->field_size;
1057
1058   }else if(type->type_class == LTT_ARRAY){
1059     element_number = (int) type->element_number;
1060     if(fld->field_fixed == -1){
1061       size = getFieldtypeSize(t, evT, offsetRoot,0,fld->child[0], NULL, trace);
1062       if(size == 0){ //has string or sequence
1063         fld->field_fixed = 0;
1064       }else{
1065         fld->field_fixed = 1;
1066         size *= element_number;
1067       }
1068     }else if(fld->field_fixed == 0){// has string or sequence
1069       size = 0;
1070       for(i=0;i<element_number;i++){
1071         size += getFieldtypeSize(t, evT, offsetRoot+size,size,
1072                                 fld->child[0], evD+size, trace);
1073       }
1074     }else size = fld->field_size;
1075
1076   }else if(type->type_class == LTT_SEQUENCE){
1077     size1 = (int) ltt_type_size(trace, type);
1078     if(fld->field_fixed == -1){
1079       fld->sequ_number_size = size1;
1080       fld->field_fixed = 0;
1081       size = getFieldtypeSize(t, evT, offsetRoot,0,fld->child[0], NULL, trace);
1082       fld->element_size = size;
1083     }else{//0: sequence
1084       element_number = getIntNumber(size1,evD);
1085       type->element_number = element_number;
1086       if(fld->element_size > 0){
1087         size = element_number * fld->element_size;
1088       }else{//sequence has string or sequence
1089         size = 0;
1090         for(i=0;i<element_number;i++){
1091           size += getFieldtypeSize(t, evT, offsetRoot+size+size1,size+size1,
1092                                    fld->child[0], evD+size+size1, trace);
1093         }
1094       }
1095       size += size1;
1096     }
1097
1098   }else if(type->type_class == LTT_STRING){
1099     size = 0;
1100     if(fld->field_fixed == -1){
1101       fld->field_fixed = 0;
1102     }else{//0: string
1103       size = strlen((char*)evD) + 1; //include end : '\0'
1104     }
1105
1106   }else if(type->type_class == LTT_STRUCT){
1107     element_number = (int) type->element_number;
1108     size = 0;
1109     if(fld->field_fixed == -1){
1110       offset1 = offsetRoot;
1111       offset2 = 0;
1112       for(i=0;i<element_number;i++){
1113         size1=getFieldtypeSize(t, evT,offset1,offset2, fld->child[i], NULL, trace);
1114         if(size1 > 0 && size >= 0){
1115           size += size1;
1116           if(offset1 >= 0) offset1 += size1;
1117           offset2 += size1;
1118         }else{
1119           size = -1;
1120           offset1 = -1;
1121           offset2 = -1;
1122         }
1123       }
1124       if(size == -1){
1125         fld->field_fixed = 0;
1126         size = 0;
1127       }else fld->field_fixed = 1;
1128     }else if(fld->field_fixed == 0){
1129       offset1 = offsetRoot;
1130       offset2 = 0;
1131       for(i=0;i<element_number;i++){
1132         size=getFieldtypeSize(t,evT,offset1,offset2,fld->child[i],evD+offset2, trace);
1133         offset1 += size;
1134         offset2 += size;
1135       }
1136       size = offset2;
1137     }else size = fld->field_size;
1138   }
1139
1140   fld->offset_root     = offsetRoot;
1141   fld->offset_parent   = offsetParent;
1142   if(!evD){
1143     fld->fixed_root    = (offsetRoot==-1)   ? 0 : 1;
1144     fld->fixed_parent  = (offsetParent==-1) ? 0 : 1;
1145   }
1146   fld->field_size      = size;
1147
1148   return size;
1149 }
1150
1151 /*****************************************************************************
1152  *Function name
1153  *    timecmp   : compare two time
1154  *Input params
1155  *    t1        : first time
1156  *    t2        : second time
1157  *Return value
1158  *    int       : 0: t1 == t2; -1: t1 < t2; 1: t1 > t2
1159  ****************************************************************************/
1160
1161 int timecmp(LttTime * t1, LttTime * t2)
1162 {
1163   if(t1->tv_sec < t2->tv_sec) return -1;
1164   if(t1->tv_sec > t2->tv_sec) return 1;
1165   if(t1->tv_nsec < t2->tv_nsec) return -1;
1166   if(t1->tv_nsec > t2->tv_nsec) return 1;
1167   return 0;
1168 }
1169
1170 /*****************************************************************************
1171  *Function name
1172  *    getIntNumber    : get an integer number
1173  *Input params
1174  *    size            : the size of the integer
1175  *    evD             : the event data
1176  *Return value
1177  *    int             : an integer
1178  ****************************************************************************/
1179
1180 int getIntNumber(int size, void *evD)
1181 {
1182   int64_t i;
1183   if(size == 1)      i = *(int8_t *)evD;
1184   else if(size == 2) i = *(int16_t *)evD;
1185   else if(size == 4) i = *(int32_t *)evD;
1186   else if(size == 8) i = *(int64_t *)evD;
1187
1188   return (int) i;
1189 }
1190
1191 /*****************************************************************************
1192  *Function name
1193  *    getDataEndianType : get the data type size and endian type of the local
1194  *                        machine
1195  *Input params
1196  *    size              : size of data type
1197  *    endian            : endian type, little or big
1198  ****************************************************************************/
1199
1200 void getDataEndianType(LttArchSize * size, LttArchEndian * endian)
1201 {
1202   int i = 1;
1203   char c = (char) i;
1204   int sizeInt=sizeof(int), sizeLong=sizeof(long), sizePointer=sizeof(void *);
1205
1206   if(c == 1) *endian = LTT_LITTLE_ENDIAN;
1207   else *endian = LTT_BIG_ENDIAN;
1208
1209   if(sizeInt == 2 && sizeLong == 4 && sizePointer == 4)
1210     *size = LTT_LP32;
1211   else if(sizeInt == 4 && sizeLong == 4 && sizePointer == 4)
1212     *size = LTT_ILP32;
1213   else if(sizeInt == 4 && sizeLong == 8 && sizePointer == 8)
1214     *size = LTT_LP64;
1215   else if(sizeInt == 8 && sizeLong == 8 && sizePointer == 8)
1216     *size = LTT_ILP64;
1217   else *size = LTT_UNKNOWN;
1218 }
1219