#include "LinkAnal.h"
#include <iostream.h>



LinkAnal::LinkAnal()
{
hfile      = new TFile("link_anal.root","RECREATE","Vzn analysis");
hpacket_per_sec   = new TH1F("packet_per_sec","packets persecond",140,0.,140.0);

}

LinkAnal::~LinkAnal()
{
// Save all objects in this file
hfile->Write();
}

void
LinkAnal::open_file(char* filename)
{
  datafile.open(filename);
}

int
LinkAnal::read_line()
{
  // assumes line[] is read in

  if (strpbrk(line,":") !=NULL) {
    //cout<<line<<endl;
    return (0);
  }
  if (strncmp(&line[0]," ", 1) !=0) return (0);
  if (strncmp( &line[64], "STP", 3) == 0) return (0);

  char temp[200];
  //Packet packet;

  packet.num  = atoi( strncpy(temp, &line[0], 8) );
  packet.time = atof( strtok ( &line[8], " ") );
  packet.source.a1 = atoi( strtok(NULL, "."));
  packet.source.a2 = atoi( strtok(NULL, "."));
  packet.source.a3 = atoi( strtok(NULL, "."));
  packet.source.a4 = atoi( strtok(NULL, " "));

  packet.dest.a1 = atoi( strtok(NULL, "."));
  packet.dest.a2 = atoi( strtok(NULL, "."));
  packet.dest.a3 = atoi( strtok(NULL, "."));
  packet.dest.a4 = atoi( strtok(NULL, " "));

  int x = strcspn( &line[64], " ");
  strncpy( packet.prot, &line[64], x );
  packet.prot[x]=NULL;

  int y = strcspn( &line[65+x], "\n");
  strncpy( packet.message, &line[65+x], y );
  packet.message[y]=NULL;
  
  //cout << packet.source.a1 << "." << packet.source.a2 << "."<< packet.source.a3 << "."<< packet.source.a4 << "."<<endl;
  //cout << packet.dest.a1 << "." << packet.dest.a2 << "."<< packet.dest.a3 << "."<< packet.dest.a4 << "."<<endl;

  //cout<< packet.prot <<"  -"<< strlen( strtok ( &line[64], " ") )<<endl;
  //cout<<packet.message<<endl;
  //int i; cin>> i;
  //if (i==9) kstop=1;;	     

  return (1);
}

// -------------------------------------------------------------------------------
void
LinkAnal::read_file()
{
  datafile.getline( &line[0], 1000, '\n');  //skip 1st line

  int count1=0;
  int count2 = 0;
  kstop = 0;
  //vector<string> protocols;
  //vector<int>    protocol_cnt;
  
  while ( !datafile.eof()         )
  {
    datafile.getline( &line[0], 1000, '\n');
    count1++;
    count2++;
    if (count1>10000)
    {
      count1=0;
      cout<<count2<<endl;
    }


    if (!read_line()) continue;

    hpacket_per_sec->Fill(packet.time);

    //count # protocols
    //vector<string>itterator


    if (kstop) break;
  }


}