--- rawreader/src/Main.cpp	2006/12/10 12:21:21	1.2
+++ rawreader/src/Main.cpp	2007/01/28 10:55:46	1.5
@@ -19,83 +19,124 @@
 void confluence(char [], char [], char [], char [], char [], int[]);
 void sort(char [], char [], char [], char[], char [], int[]);
 
-
-
+char MYSQL[120];
+char database[120];
+char arina[120];
+float YODA_flag;
+float transmit_flag;
+int print_flag;
+char timesync[120];  
+ 
 int main(int argc, char *argv[])
 {
+
 // char stop;
  float IndexQ, quality[100];     /*Quality index*/
  int real_route[64];
  int rc=0;
  int r_counter;                  /*Route counter*/               
 
- char MainPath[80];      /* /home/pamelaprod/ */
+ char MainPath[120];      /* /home/pamelaprod/rawreader/ */
+
  char INF[80];           /*Full out information file name nnnnn_cln1.inf*/
  char fni[80];           /*Full initial file name nnnnnmmm.pam*/
  char fno[80];           /*Full out helping file name nnnnn_work.dat*/
  char path[80];          /*Initial path*/
- char name[80];          /*Initial file name nnnnn_out.pam*/
+ char name[80];          /*Initial file name nnnnnmmm.pam*/
  char protocol[80];      /*Full out file name nnnnn_protocol.txt*/
- char RAW[80];           /*Directory for RAW data*/
  char nnnnn_TMP[80];     /*Directory for processed data*/
  char command[180];      /*DOS command*/
  char str_del[80];       /*Delete Cln1 directory in case of good quality*/
- char temp[80];          /*For temporary file*/ 
+ char temp[120];         /*For temporary file*/ 
  char temp1[80];         /*For temporary file*/
  char temp2[80];         /*For temporary file*/ 
  char temp3[80];         /*For temporary file*/ 
  char temp4[80];
 
- char fni2[80];          /*Initial file mmm_nnnnn_cln1.pam*/
- char inf2[80];          /*File name mmm_nnnnn_cln2.inf*/
- char pam2[80];          /*File name mmm_nnnnn_cln2.pam*/
- char name2[80];         /*Initial file name mmm_counter_nnnnn_cln1.pam*/
- char name_ql[80];       /*File name mmm_nnnnn_ql.log*/
- char log2[80];          /*File name mmm_nnnnn_cln2.log*/
- char fno2[80];          /*Out help file mmm_nnnnn_work.dat*/
- char path2[80];         /*Path for ...Temp/nnnnn_TMP/mmm/Cln2/*/
- char mmm[80];           /*For route number*/
- char name_route[4];     /*Route number in the file name*/
-
- char path3[80];         /*Path for ...Level0/nnnnn_mmm_L0/*/
-
- int Rcount=0;           /*Number of Routes*/
+ char fni2[100];          /*Initial file mmm_nnnnn_cln1.pam*/
+ char inf2[100];          /*File name mmm_nnnnn_cln2.inf*/
+ char pam2[100];          /*File name mmm_nnnnn_cln2.pam*/
+ char name2[100];         /*Initial file name mmm_counter_nnnnn_cln1.pam*/
+ char log2[100];          /*File name mmm_nnnnn_cln2.log*/ 
+ char name_ql[80];        /*File name mmm_nnnnn_ql.log*/
+ char fno2[80];           /*Out help file mmm_nnnnn_work.dat*/
+ char path2[80];          /*Path for ...Temp/nnnnn_TMP/mmm/Cln2/*/
+ char mmm[80];            /*For route number*/
+ char name_route[4];      /*Route number in the file name*/
+
+ char path3[100];         /*Path for ...Level0/nnnnn_mmm_L0/*/
+ char exten[10];          /*Extension for the raw initial file*/
+ char temporary[80], Tymesync[80];
+ int Rcount=0;            /*Number of Routes*/
  int packet_type[NumberPack]={0x07, 0x08, 0x09, 0x10, 0x11, 0x12, 0x13, 0x16, 0x17, 0x18, 0x19,
 	  0x1A, 0x1B, 0x1C, 0x1D, 0x20, 0x21, 0x22, 0x23, 0x24, 0x25, 0x30, 0x50, 0x51, 0x52, 0x53,
 	  0x54, 0x55, 0x60, 0x70, 0x71, 0x72, 0x73, 0x74, 0x75, 0x76, 0x77, 0x81, 0x82, 0x83, 0x84,
 	  0x85, 0x86, 0x88, 0x89, 0x8A, 0xA1, 0xAB, 0xF0, 0xF1, 0xF2, 0xF3, 0xF4};/*PAMELA packet type code*/	  
  int i, j;
  int stop;
- char *ttt=new char[Nmax];
   
  for (i=0;i<100;i++) quality[i]=0;
  for (i=0;i<64;i++) real_route[i]=0; 
-// int RTtoMT,RT,Timesync,OBTtimesync;
 
  FILE *ftime_sync;     
  FILE *fff, *tmp, *tmp1, *tmp2, *tmp3, *tmp4;
+ ifstream fpath;
+  
+//Read parameters from the initial file 
+ fpath.open("/home/pamelaprod/rawreader/bin/parameters.dat", ios::out);
+ if (!fpath) {cout<<"can not open file with input parameters \n"; exit(1);}
+ fpath.getline(MainPath,100,'\n');
+ sscanf(MainPath,"%s",MainPath);
+ fpath.getline(timesync,100,'\n');
+ sscanf(timesync,"%s",timesync);
+ fpath.getline(arina,100,'\n');
+ sscanf(arina,"%s",arina);
+ fpath.getline(MYSQL,100,'\n');
+ sscanf(MYSQL,"%s",MYSQL); 
+ fpath.getline(database,100,'\n');
+ sscanf(database,"%s",database);
+ fpath.getline(temp,120,'\n');
+ sscanf(temp,"%f",&YODA_flag); 
+ fpath.getline(temp,120,'\n');
+ sscanf(temp,"%f",&transmit_flag);  
+ fpath.getline(temp,120,'\n');
+ sscanf(temp,"%i",&print_flag);   
+
+/* cout<<"MainPath="<<MainPath<<" "<<strlen(MainPath)<<"\n";
+ cout<<"timesync="<<timesync<<" "<<strlen(timesync)<<"\n";   
+ cout<<"arina="<<arina<<" "<<strlen(arina)<<"\n"; 
+ cout<<"MYSQL="<<MYSQL<<" "<<strlen(MYSQL)<<"\n"; 
+ cout<<"database="<<database<<" "<<strlen(database)<<"\n"; 
+ cout<<"YODA_flag="<<YODA_flag<<"\n";  
+ cout<<"transmit_flag="<<transmit_flag<<"\n";
+ cout<<"print_flag="<<print_flag<<"\n";*/
+ 
+ fpath.close();
  
 // mikhailov 06.12.2004 
-ftime_sync=fopen("/home/pamelaprod/rawreader/bin/timesync.dat","r+");
+ftime_sync=fopen(timesync,"r+");
+if (!ftime_sync) {cout<<"can not open file with time synchronization \n"; exit(1);}
 while(feof(ftime_sync)==0) 
 {fscanf(ftime_sync,"%u%[ ]%u%[ ]%u%[ ]%u\n",&RTtoMT, temp, &RT, temp, &Timesync, temp, &OBTtimesync);}
 fclose(ftime_sync);
 // end mikhailov 
 
-// cout<<"global_err="<<GLOBAL_LEN_ER<<"\n";
- if (strlen(argv[2])!=12) {cout<<"WRONG RAW FILE NAME\n"; exit(0);} 
-
- strcpy(fni,argv[1]);
- strcat(fni,argv[2]);
-
+ if (print_flag>0) cout<<"global_err="<<GLOBAL_LEN_ER<<"\n";
  strcpy(name,argv[2]);
  name_route[0]=name[5];
  name_route[1]=name[6]; 
  name_route[2]=name[7]; 
  name_route[3]='\0';
  
- strcpy(MainPath,"/home/pamelaprod/rawreader/level0/");
+ for(i=0;i<3;i++)
+ {exten[i]=name[i+9];}
+ exten[3]='\0';
+ 
+ if ((strlen(argv[2])!=12)||(strncmp(exten,"pam",3)!=0)) {cout<<"WRONG RAW FILE NAME\n"; exit(1);} 
 
+ strcpy(fni,argv[1]);
+ strcat(fni,argv[2]);
+ 
 /**************Creation directory nnnnn**********************/
  strncat(strcpy(nnnnn_TMP,MainPath),argv[2],5);
  strcpy(temp,nnnnn_TMP);
@@ -112,7 +153,7 @@
   printf("directory %s already exists - rewriting \n",strncat(strcpy(temp1," "),argv[2],5));
   fclose(tmp);
   remove(temp);
-//  exit(0);
+//  exit(1);
  }
 /****************************************************************/
 
@@ -149,87 +190,86 @@
   rename(temp2,temp3);
  }
  
- strcat(strcpy(temp,nnnnn_TMP),"/tmp.dat");
- tmp=fopen(temp, "w+");
-
- for(i=0;i<256;i++)
+ if (CLN2_FLAG>0)
  {
-  fprintf(tmp,"%03i",i);
-  fseek(tmp,0,0);
-  fgets(mmm,10,tmp);
-  fseek(tmp,0,0);
-  strcat(strcat(strcat(strcat(strcat(strcpy(temp1,nnnnn_TMP),"/"),name_route),"_"),mmm),"/tmp.dat");
-  
-  if ((tmp1=fopen(temp1,"w"))!=0)
+  for(i=0;i<256;i++)
   {
-   fclose(tmp1);
-   remove(temp1);
-   strcat(strncat(strcat(strcat(strcat(strcpy(name2,name_route),"_"),mmm),"_"),name,5),"_cln1.pam");
-   strcat(strcat(strcat(strcat(strcat(strcat(strcpy(fni2,nnnnn_TMP),"/"),name_route),"_"),mmm),"/Cln1/"),name2);
-   name2[0]='\0';
-   strcat(strcat(strcat(strcat(strcat(strncat(name2,name,5),"_"),name_route),"_"),mmm),"_cln1.pam");
-   strcpy(temp4,path);
-   strcat(strcat(strcat(strcat(temp4,name_route),"_"),mmm),"/Cln2/tmp.dat");
-   if ((tmp4=fopen(temp4,"w"))==0)
+   sprintf(temp4,"%03i",i);
+   sscanf(temp4,"%3s",mmm); mmm[3]='\0';
+   strcat(strcat(strcat(strcat(strcat(strcpy(temp1,nnnnn_TMP),"/"),name_route),"_"),mmm),"/tmp.dat");
+  
+   if ((tmp1=fopen(temp1,"w"))!=0)
    {
+    fclose(tmp1);
+    remove(temp1);
+    name2[0]='\0';
+    strcat(strcat(strcat(strcat(strcat(strncat(name2,name,5),"_"),name_route),"_"),mmm),"_cln1.pam");
+    if (CLN1_MEPHI==0) 
+    {strcat(strcat(strcat(strcat(strcat(strcat(strcpy(fni2,nnnnn_TMP),"/"),name_route),"_"),mmm),"/Cln1/"),name2);}
+    else
+    {strcat(strcat(strncat(strcpy(fni2,""),nnnnn_TMP,strlen(nnnnn_TMP)-5),"Cln1/"),name2);}
+    strcpy(temp4,path);
+    strcat(strcat(strcat(strcat(temp4,name_route),"_"),mmm),"/Cln2/tmp.dat");
+    if ((tmp4=fopen(temp4,"w"))==0)
+    {
 /**************Creation directory nnnnn\xxx_mmm\Cln2****************/
-    strcat(strcat(strcat(strcat(strcat(strcat(strcpy(command,"mkdir "),nnnnn_TMP),"/"),name_route),"_"),mmm),"/Cln2");
-    system(command);
+     strcat(strcat(strcat(strcat(strcat(strcat(strcpy(command,"mkdir "),nnnnn_TMP),"/"),name_route),"_"),mmm),"/Cln2");
+     system(command);
 /*******************************************************************/
-   }
-   else
-   {
-    fclose(tmp4);
-    remove(temp4);
-   }
-   strcat(strcat(strcat(strcat(strcat(strcpy(path2,nnnnn_TMP),"/"),name_route),"_"),mmm),"/Cln2/");
-   strcat(strncat(strcpy(inf2,path2),name2,13),"_cln2.inf");
-   strcat(strncat(strcpy(log2,path2),name2,13),"_cln2.log");
-   strcat(strncat(strcpy(pam2,path2),name2,13),"_cln2.pam");
-   strcat(strncat(strcpy(fno2,path2),name2,13),"_work.dat");
-
-   IndexQ=quality[i-1];
-   r_counter=i; 
-   verify(fni2, inf2, log2, pam2, fno2, path2, name, name2, packet_type, IndexQ, r_counter, real_route); /////////////////////////////////
-   //Delete Cln1
-   if (IndexQ>0.999)
-   {strcpy(str_del,"rm -r -f ");
-    strncat(str_del,fni2,strlen(fni2)-22);
-    if (system(str_del)) cout<<"Can not delete Cln1 for counter="<<r_counter<<"\n";
-   }
-   strcat(strcat(strcat(strcat(strcat(strncat(strcpy(path3,MainPath),argv[2],5),"/"),name_route),"_"),mmm),"/packets");
-
-   strcat(strcpy(temp2,path3),"/tmpM.dat");
-   if ((tmp2=fopen(temp2,"w"))==0)  
-   {        
+    }
+    else
+    {
+     fclose(tmp4);
+     remove(temp4);
+    }
+    strcat(strcat(strcat(strcat(strcat(strcpy(path2,nnnnn_TMP),"/"),name_route),"_"),mmm),"/Cln2/");
+    strcat(strncat(strcpy(inf2,path2),name2,13),"_cln2.inf");
+    strcat(strncat(strcpy(log2,path2),name2,13),"_cln2.log");
+    strcat(strncat(strcpy(pam2,path2),name2,13),"_cln2.pam"); 
+    strcat(strncat(strcpy(fno2,path2),name2,13),"_work.dat");
+
+    IndexQ=quality[i-1];
+    r_counter=i;
+    verify(fni2, inf2, log2, pam2, fno2, path2, name, name2, packet_type, IndexQ, r_counter, real_route); /////////////////////////////////    
+    strcat(strcat(strcat(strcat(strcat(strcat(strcpy(fni2,nnnnn_TMP),"/"),name_route),"_"),mmm),"/Cln1/"),name2);
+    //Delete Cln1
+    if (IndexQ>0.999)
+    {strcpy(str_del,"rm -r -f ");
+     strncat(str_del,fni2,strlen(fni2)-22);
+     if (system(str_del)) cout<<"Can not delete Cln1 for counter="<<r_counter<<"\n";
+    }
+    strcat(strcat(strcat(strcat(strcat(strncat(strcpy(path3,MainPath),argv[2],5),"/"),name_route),"_"),mmm),"/packets");
+
+    strcat(strcpy(temp2,path3),"/tmpM.dat");
+    if ((tmp2=fopen(temp2,"w"))==0)  
+    {        
 /**************Creation directory level0\nnnnn\counter_mmm\packets***************/
-    strcat(strcpy(command,"mkdir "),path3);
-    system(command);
+     strcat(strcpy(command,"mkdir "),path3);
+     system(command);
 /*******************************************************************/      
-   }
-   else
-   {
-    fclose(tmp2);
-    remove(temp2);
-    printf("directory for file %s already exists - rewriting \n",
-    strcat(strcat(strcat(strcat(strncat(strcpy(temp3," "),argv[2],5),"_"),name_route),"_"),mmm));
-   }
-   strcat(path3,"/");
-   sort(log2, pam2, path2, path3, name2, packet_type); /////////////////////////////////////
-   strcat(strncat(strcat(strcat(strcpy(name_ql,path3),mmm),"_"),argv[2],5),"_ql.log");
-   strcpy(temp3,"/home/pamelaprod/rawreader/bin/coordinate.exe");
-   if ((tmp3=fopen(temp3,"r"))==0)
-   {printf("file %s does not exist\n",temp3);}
-   else
-   {
-    fclose(tmp3);
-    strcat(strcat(strcpy(command,temp3)," "),name_ql);
+    }
+    else
+    {
+     fclose(tmp2);
+     remove(temp2);
+     printf("directory for file %s already exists - rewriting \n",
+     strcat(strcat(strcat(strcat(strncat(strcpy(temp3," "),argv[2],5),"_"),name_route),"_"),mmm));
+    }
+    strcat(path3,"/");
+    sort(log2, pam2, path2, path3, name2, packet_type); /////////////////////////////////////
+    strcat(strncat(strcat(strcat(strcpy(name_ql,path3),mmm),"_"),argv[2],5),"_ql.log");
+    strcpy(temp3,"/home/pamelaprod/rawreader/bin/coordinate.exe");
+    if ((tmp3=fopen(temp3,"r"))==0)
+    {printf("file %s does not exist\n",temp3);}
+    else
+    {
+     fclose(tmp3);
+     strcat(strcat(strcpy(command,temp3)," "),name_ql);
 //    system(command);
-   }          
+    }
+   }              
   }
  }
- fclose(tmp);
- remove(temp); delete [] ttt;
 
  return 0;
 }