dumpheader.c

/****************************************************************************
**  SIONLIB     http://www.fz-juelich.de/jsc/sionlib                       **
*****************************************************************************
**  Copyright (c) 2008-2016                                                **
**  Forschungszentrum Juelich, Juelich Supercomputing Centre               **
**                                                                         **
**  See the file COPYRIGHT in the package base directory for details       **
****************************************************************************/
/*
 * dumpheader.c
 *
 *  Created on: Sep 8, 2008
 *      Author: gstu0808
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>

#include "sion.h"
#include "sion_fd.h"

#define FILENAME_LENGTH 1024

void usage(char *name) {
  fprintf(stderr, "Usage: %s options <sionfn> \n\nwith the following optional options (default values in parenthesis):\n\n",name);

  fprintf(stderr, "  [-a]                   print all information about all blocks \n");
  fprintf(stderr, "  [-v]                   verbose mode \n");
  exit(1);
}


int main(int argc, char **argv)
{
  FILE *fileptr;
  char infilename[FILENAME_LENGTH];
  int i,j,rank,blknum;

  /* options */
  int  printall=0;
  int  verbose=0;

  /* for file infomation */
  char *sionstr;
  size_t nread;
  sion_int32 lendianness;
  sion_int32 lfsblksize;
  sion_int32 lntasks, lnfiles;
  sion_int64 *sion_chunkcount;

  sion_int64 *sion_tmpintfield;
  char *prefix;

  int sid,size,blocks,gblknum, ntasks,nfiles, maxblocks;
  sion_int32 fsblksize,endianness;
  sion_int64  start_of_varheader;
  sion_int64 *sion_chunksizes;
  sion_int64 *sion_globalranks;

  sion_int64  globalskip;
  sion_int64 *sion_currentpos;
  sion_int64 *sion_currentblocknr;
  sion_int64 *siondump_sum_bytsionlibes_per_task;
  sion_int64  siondump_sum_bytes;
  sion_int64  siondump_filesize;
  _sion_filedesc *sion_filedesc;

  /* parse command line */
  i=1;
  while( i < argc ) {
    if( argv[i][0] == '-' ) {
      switch( argv[i][1] ) {
                  case 'a':
                          printall = 1;
                          break;
                  case 'v':
                          verbose++;
                          break;
                  case 'h':
                          usage(argv[0]);
                          break;
                  default:
                          usage(argv[0]);
      }
    }
    i++;
  }

  strcpy(infilename,argv[argc-1]);

  fileptr=fopen(infilename,"r");
  if (! fileptr ) {
    fprintf(stderr, "cannot open %s for reading, aborting ...\n", infilename);
  }

  sionstr = (char *) malloc(strlen(SION_ID)*sizeof(char));
  nread=fread(sionstr,1,strlen(SION_ID),fileptr);
  if(nread!=strlen(SION_ID)) {
    fprintf(stderr, "sionlib: cannot read header from file, aborting ... (%d)\n",nread);
  }
  printf("sionstr=\"%c%c%c%c\"\n",sionstr[0],sionstr[1],sionstr[2],sionstr[3]);
  /* Check if this is a sion file */
  if (strncmp(sionstr,SION_ID,strlen(SION_ID))) {
    fprintf(stderr, "sionlib: not a sion file(ID: %c%c%c%c)\n",sionstr[0],sionstr[1],sionstr[2],sionstr[3]);
  }

  nread=fread(&lendianness,1,sizeof(lendianness),fileptr);
  if(nread!=sizeof(lendianness)) {
    fprintf(stderr, "sionlib: cannot read header from file, aborting ... (%d)\n",sizeof(lendianness));
  }
  printf("endianness = 0x%X\n",lendianness);

  nread=fread(&lfsblksize,1,sizeof(lfsblksize),fileptr);
  if(nread!=sizeof(lfsblksize)) {
    fprintf(stderr, "sionlib: cannot read header from file, aborting ... (%d)\n",sizeof(lfsblksize));
  }
  printf("fsblksize= %d\n",lfsblksize);

  nread=fread(&lntasks,1,sizeof(lntasks),fileptr);
  if(nread!=sizeof(lntasks)) {
    fprintf(stderr, "sionlib: cannot read header from file, aborting ... (%d)\n",sizeof(lntasks));
  }
  printf("ntasks     = %d\n",lntasks);

  nread=fread(&lnfiles,1,sizeof(lnfiles),fileptr);
  if(nread!=sizeof(lnfiles)) {
    fprintf(stderr, "sionlib: cannot read header from file, aborting ... (%d)\n",sizeof(lnfiles));
  }
  printf("nfiles     = %d\n",lnfiles);

  prefix=malloc(SION_FILENAME_LENGTH);
  nread=fread(prefix,1,SION_FILENAME_LENGTH,fileptr);
  if(nread!=SION_FILENAME_LENGTH) {
    fprintf(stderr, "sionlib: cannot read file name %d info to the header, aborting ... (%d!=%d)\n",i+1,SION_FILENAME_LENGTH,nread);
  }
  printf("prefix=\"%s\"\n",prefix);

  sion_globalranks = (sion_int64 *)malloc(lntasks*sizeof(sion_int64));
  nread=fread(sion_globalranks,sizeof(sion_int64),lntasks,fileptr);
  if(nread!=lntasks) {
    fprintf(stderr, "sionlib: cannot read header(globalranks) from file, aborting ... (%d!=%d)\n",nread,lntasks);
  }
  printf("Read globalranks\n");
  for (i=0;i<lntasks;i++)
    printf("\tsion_globalranks[%d]=%lld\n",i,sion_globalranks[i]);

  sion_chunksizes = (sion_int64 *)malloc(MAXCHUNKS*lntasks*sizeof(sion_int64));
  nread=fread(sion_chunksizes,sizeof(sion_int64),lntasks,fileptr);
  if(nread!=lntasks) {
    fprintf(stderr, "sionlib: cannot read header(chunksizes) from file, aborting ... (%d!=%d)\n",nread,lntasks);
  }
  printf("Read chunksizes\n");
  for (i=0;i<lntasks;i++)
    printf("\tsion_chunksizes[%d]=%lld\n",i,sion_chunksizes[i]);

  nread=fread(&maxblocks,1,sizeof(maxblocks),fileptr);
  if(nread!=sizeof(maxblocks)) {
    fprintf(stderr, "sionlib: cannot read header(maxblocks) from file, aborting ... (%d!=%d)\n",nread,sizeof(maxblocks));
  }
  printf("maxblocks     = %d\n",maxblocks);

  nread=fread(&start_of_varheader,1,sizeof(start_of_varheader),fileptr);
  if(nread!=sizeof(start_of_varheader)) {
    fprintf(stderr, "sionlib: cannot read header(start_of_varheader) from file, aborting ... (%d!=%d)\n",nread,sizeof(start_of_varheader));
  }
  printf("start_of_varheader= %lld\n",start_of_varheader);

  fflush(fileptr);
  lseek(fileno(fileptr),(off_t) start_of_varheader,SEEK_SET);

  sion_chunkcount = (sion_int64 *)malloc(lntasks*sizeof(sion_int64));
  nread=fread(sion_chunkcount,sizeof(sion_int64),lntasks, fileptr );
  if(nread!=lntasks)
    {
      fprintf(stderr, "sionlib: cannot read chunkcount[] from meta block 2 of file, aborting ... (%d)\n",lntasks);
    }

  for(i=0;i<lntasks;i++)
    printf("numblocks on task %02d is %10lld\n",i,sion_chunkcount[i]);


 /* free(sion_chunksizes); */
 /* sion_chunksizes = (sion_int64 *) malloc(lntasks*sizeof(sion_int64)); */
  for(i=0;i<maxblocks;i++)
    {
          nread=fread(sion_chunksizes,sizeof(sion_int64),lntasks, fileptr );
          if(nread!=lntasks)
            {
              fprintf(stderr, "sionlib: cannot read chunksizes[%d] from meta block 2 of file, aborting ... (%d)\n",i,lntasks);
            }
          printf("Block %02d:\n",i);
          for(j=0;j<lntasks;j++) printf("\ttotal chunksize for task %02d: %10lld\n",j,sion_chunksizes[j]);
    }

  fclose(fileptr);
  return 0;
}