1 |
cafagna |
1.1 |
#include "descript.h"
|
2 |
cafagna |
1.2 |
#include "flag.h"
|
3 |
cafagna |
1.1 |
|
4 |
|
|
void filename(char [], char [], char [], char[], int, char[]);
|
5 |
|
|
void FindRoute(int[], int*);
|
6 |
|
|
short int CRC(int []);
|
7 |
|
|
int restrict(int [], long long int[], int);
|
8 |
|
|
|
9 |
cafagna |
1.4 |
extern char database[120];
|
10 |
|
|
extern char MYSQL[120];
|
11 |
cafagna |
1.3 |
extern int print_flag;
|
12 |
|
|
|
13 |
cafagna |
1.4 |
int route_good1=0, route_good2=0, route_good3=0;
|
14 |
|
|
int pack_good1=0, pack_good2=0, pack_good3=0;
|
15 |
|
|
int number_good1=0, number_good2=0, number_good3=0;
|
16 |
|
|
|
17 |
cafagna |
1.1 |
void read(char fni[], char fno[], char INF[],
|
18 |
cafagna |
1.3 |
char protocol[], char path[], char name[], char nnnnn_TMP[], float quality[], int real_route[], int &Rcount)
|
19 |
cafagna |
1.1 |
{
|
20 |
cafagna |
1.3 |
FILE *fo, *fout, *foRout, *foMiss, *fo_log_kadr, *fo_route, *fo_tmp;
|
21 |
cafagna |
1.1 |
ifstream fin;
|
22 |
cafagna |
1.3 |
ofstream fo_cln1, fokadr_cln1, fo_info;
|
23 |
cafagna |
1.1 |
|
24 |
|
|
char buf[1024];
|
25 |
|
|
// char stop1;
|
26 |
cafagna |
1.3 |
char ch1,ch2,ch3,ch, ch4[80], ch5[5];
|
27 |
cafagna |
1.4 |
char file_route[100]; /*protocol binary filesm nnnnn_mmm_xxx_cln1Er.log*/
|
28 |
|
|
char miss_file[100]; /*protocol files nnnnn_mmm_xxx_mis_cln1.dat*/
|
29 |
|
|
char cln1_file[100]; /*route binary data files nnnnn_mmm_xxx_cln1.pam*/
|
30 |
|
|
char cln1_kadr[100]; /*route binary data files nnnnn_mmm_xxx_cln1.bin*/
|
31 |
|
|
char log_kadr[100]; /*log binary data files nnnnn_mmm_xxx_cln1.log*/
|
32 |
|
|
char log_route[100]; /*log binary file for number of routes*/
|
33 |
cafagna |
1.1 |
char Short_Buf[8], Name_Buf[4];
|
34 |
cafagna |
1.4 |
char temp[10], temp1[80], connection[120], command[80], name11[80];
|
35 |
cafagna |
1.1 |
short int CalcCheckSum;
|
36 |
|
|
|
37 |
|
|
int LenthBuf=1015, flag_help=0;
|
38 |
|
|
int i, j, k, file_length=0, Hex[3];
|
39 |
cafagna |
1.3 |
int N_er=0; /*Number of cadre with name error*/
|
40 |
|
|
int CRC0_er=0; /*Number of cadre with CRC0 error*/
|
41 |
|
|
int P_er=0; /*Number of cadre with packet error number*/
|
42 |
cafagna |
1.1 |
int end=0; /*End of last pamela packet*/
|
43 |
cafagna |
1.3 |
// Buffers for Cadre analysis
|
44 |
cafagna |
1.1 |
int buffer1[1024], buffer2[1024], buffer3[1024];
|
45 |
|
|
int rr=0;
|
46 |
cafagna |
1.3 |
int cirquit_no=0, route=0;
|
47 |
|
|
|
48 |
cafagna |
1.1 |
int header1, header2, header3, CRC_0[3], CRC_1[3];
|
49 |
|
|
long long int icount_int;
|
50 |
|
|
long long int icount_frac, tmpP, numP[3];
|
51 |
cafagna |
1.3 |
long int N1=0; /* Number of identified cadres*/
|
52 |
|
|
long long int icount=0; /* Number of bytes in identified cadres*/
|
53 |
cafagna |
1.1 |
long long int icount_total=0; /* Total number of bytes*/
|
54 |
cafagna |
1.3 |
long long int packet_first[100];/* First cadre number for each route*/
|
55 |
|
|
long long int packet_last[100]; /* Second cadre number for each route*/
|
56 |
cafagna |
1.4 |
long long int count_missed[100];/* Number of missed cadres in each route*/
|
57 |
|
|
long long int count_sec_missed[100];
|
58 |
cafagna |
1.3 |
unsigned long long int count_ident[100]; /* Number of good bytes in each route*/
|
59 |
|
|
unsigned long long int count_tot[100]; /* Total number of bytes in each route*/
|
60 |
|
|
int NumRout[1000]; /* Number of route*/
|
61 |
|
|
long long int Num_kadrs[1000]; /* Number of identified cadres in each route*/
|
62 |
|
|
long int Num_good_kadrs[1000]; /* Number of normal cadres in each route*/
|
63 |
|
|
long long int Num_bad_kadrs[1000]; /* Bad cadres number in each route*/
|
64 |
|
|
|
65 |
|
|
int counter=0; /* Last byte position in truncated cadre*/
|
66 |
|
|
int adr1=0; /* Initial byte of cadre in cln1.bin*/
|
67 |
|
|
int adr2=0; /* Last byte of cadre in cln2.bin*/
|
68 |
cafagna |
1.1 |
int tmp=0;
|
69 |
cafagna |
1.3 |
int numPack[4]; /* Number of cadre in given route*/
|
70 |
cafagna |
1.4 |
|
71 |
cafagna |
1.1 |
int adress[4];
|
72 |
cafagna |
1.3 |
int R_er[100]; /* Route errors number in given route*/
|
73 |
|
|
int R_er_interf1[100]; /* Interface Route error at the begining of the route*/
|
74 |
|
|
int R_er_interf2[100]; /* Interface Route error at end of route*/
|
75 |
|
|
int Mis_group[1000]; /* Number of missed cadres group
|
76 |
cafagna |
1.2 |
for each route*/
|
77 |
cafagna |
1.3 |
float first_missed[100];
|
78 |
cafagna |
1.1 |
int Pack_Er[1000]; /* Number of packets with packet number
|
79 |
cafagna |
1.2 |
error for each route*/
|
80 |
cafagna |
1.3 |
int CRC_bad_kadr[3]; /* Current CRC bad cadre number*/
|
81 |
cafagna |
1.1 |
int flag_pack[3]; /* Flag for error in packet number*/
|
82 |
cafagna |
1.3 |
int flag_rout[3]; /* Flag for error in route number*/
|
83 |
cafagna |
1.1 |
int flag_name[3]; /* Flag for name error*/
|
84 |
|
|
int flag_CRC0[3]; /* Flag for CRC0 error*/
|
85 |
|
|
int flag_CRC[3]; /* Flag for CRC error*/
|
86 |
|
|
int flag_CRC_cor[3]; /* Flag for CRC error correction*/
|
87 |
|
|
int flag_tr[3]; /* Truncate flag*/
|
88 |
|
|
short int flags; /* Number for all errors*/
|
89 |
cafagna |
1.4 |
int num_rows=0;
|
90 |
|
|
int control[1];
|
91 |
|
|
control[0]=0;
|
92 |
|
|
control[1]=0;
|
93 |
cafagna |
1.1 |
for (j=0; j<4; j++) {adress[j]=0; numPack[j]=0;}
|
94 |
|
|
for (j=0; j<1024; j++)
|
95 |
|
|
{buffer1[j]=0; buffer2[j]=0; buffer3[j]=0;}
|
96 |
|
|
for (i=0; i<100; i++)
|
97 |
|
|
{Num_kadrs[i]=0;
|
98 |
|
|
NumRout[i]=0;
|
99 |
|
|
packet_first[i]=0;
|
100 |
|
|
packet_last[i]=0;
|
101 |
|
|
count_missed[i]=0;
|
102 |
|
|
count_sec_missed[i]=0;
|
103 |
cafagna |
1.3 |
first_missed[i]=0;
|
104 |
cafagna |
1.1 |
count_ident[i]=0;
|
105 |
|
|
count_tot[i]=0;
|
106 |
|
|
R_er[i]=0;
|
107 |
|
|
R_er_interf1[i]=0;
|
108 |
|
|
Num_bad_kadrs[i]=0;
|
109 |
|
|
Num_good_kadrs[i]=0;
|
110 |
|
|
quality[i]=0; Mis_group[i]=0; Pack_Er[i]=0;
|
111 |
|
|
R_er_interf2[i]=0;}
|
112 |
|
|
for (i=0; i<3; i++)
|
113 |
|
|
{numP[i]=0; CRC_bad_kadr[i]=0; Hex[i]=0;
|
114 |
|
|
flag_pack[i]=0; flag_rout[i]=0;
|
115 |
|
|
flag_name[i]=0; flag_CRC0[i]=0; flag_tr[i]=0;
|
116 |
|
|
flag_CRC[i]=0; flag_CRC_cor[i]=0;}
|
117 |
cafagna |
1.3 |
|
118 |
|
|
stringstream oss;
|
119 |
|
|
|
120 |
|
|
strcpy(connection,MYSQL);
|
121 |
|
|
strcat(connection,database);
|
122 |
cafagna |
1.4 |
TSQLServer *sqlServer = TSQLServer::Connect(connection,"pamelaprod","rawprod");
|
123 |
|
|
if (sqlServer==0) {cerr<<"can not connect with MYSQL sever\n"; exit(1);}
|
124 |
cafagna |
1.1 |
// open input file "nnnnnmmm.pam"
|
125 |
cafagna |
1.4 |
fin.open(fni, ifstream::binary);
|
126 |
|
|
if(fin.good()==0) {cerr<<"can not open input file"; exit(1);}
|
127 |
cafagna |
1.1 |
//open output file "nnnnnmmm_work.dat"
|
128 |
|
|
fout=fopen(fno, "wb");
|
129 |
cafagna |
1.4 |
if(fout==0) {cerr<<"can not open work file"; exit(1);}
|
130 |
cafagna |
1.3 |
|
131 |
|
|
strcpy(ch5,"info");
|
132 |
|
|
strcpy(ch4,fno);
|
133 |
|
|
for(i=0;i<4;i++){ch4[strlen(ch4)-8+i]=ch5[i];}
|
134 |
|
|
// open input file "nnnnnmmm_info.dat"
|
135 |
|
|
fo_info.open(ch4, ifstream::binary);
|
136 |
cafagna |
1.4 |
if(fo_info.good()==0) {cerr<<"can not open info file"; exit(1);}
|
137 |
cafagna |
1.3 |
|
138 |
cafagna |
1.1 |
//open output file "nnnnnmmm_protocol.txt"
|
139 |
|
|
fo=fopen(protocol, "wb");
|
140 |
cafagna |
1.4 |
if(fo==0) {cerr<<"can not open protocol file"; exit(1);}
|
141 |
cafagna |
1.1 |
//open output file "nnnnnmmm_route.log"
|
142 |
|
|
strncpy(log_route,INF,strlen(INF)-9);
|
143 |
|
|
log_route[strlen(INF)-9]='\0';
|
144 |
|
|
strcat(log_route,"_route.log");
|
145 |
|
|
fo_route=fopen(log_route, "wb");
|
146 |
cafagna |
1.4 |
if(fo_route==0) {cerr<<"can not open file for routes number"; exit(1);}
|
147 |
cafagna |
1.1 |
/////////////////////////////////////////////////////////////////
|
148 |
|
|
// cin>>stop1;
|
149 |
cafagna |
1.4 |
k=0;
|
150 |
cafagna |
1.1 |
while(fin.eof()==0)
|
151 |
|
|
{
|
152 |
cafagna |
1.3 |
counter=0; //pounter for position of cadre truncation
|
153 |
cafagna |
1.1 |
N_er=0;
|
154 |
|
|
P_er=0;
|
155 |
|
|
CRC0_er=0;
|
156 |
|
|
if (N1==0) Rcount=1;
|
157 |
|
|
/**********************data reading********************************/
|
158 |
|
|
fin.read(Name_Buf,3);
|
159 |
|
|
if (fin.eof()) break;
|
160 |
|
|
fin.read(Short_Buf,5);
|
161 |
|
|
if (fin.eof()) break;
|
162 |
|
|
ch1=Name_Buf[0];
|
163 |
|
|
ch2=Name_Buf[1];
|
164 |
|
|
ch3=Name_Buf[2];
|
165 |
|
|
tmpP=(long int)(unsigned char)(Short_Buf[1])+
|
166 |
|
|
256*(long int)(unsigned char)(Short_Buf[2])+
|
167 |
|
|
256*256*(long int)(unsigned char)(Short_Buf[3]);
|
168 |
|
|
icount+=8; icount_total+=8;
|
169 |
|
|
count_ident[Rcount-1]+=8; count_tot[Rcount-1]+=8;
|
170 |
|
|
|
171 |
|
|
while((ch1!=(char)(CODE1)&&ch2!=(char)(CODE2)&&
|
172 |
cafagna |
1.4 |
(N1==0||(buffer3[1023]!=(int)(unsigned char)(Short_Buf[4])||buffer3[3]!=(int)(unsigned char)(Short_Buf[0]))))
|
173 |
cafagna |
1.1 |
||
|
174 |
|
|
(ch2!=(char)(CODE2)&&ch3!=(char)(CODE3)&&(buffer3[1023]!=(int)(unsigned char)(Short_Buf[4])||(numP[2]+1)!=tmpP))
|
175 |
|
|
||
|
176 |
cafagna |
1.4 |
(ch3!=(char)(CODE3)&&ch1!=(char)(CODE1)&&(buffer3[1023]!=(int)(unsigned char)(Short_Buf[4])||
|
177 |
|
|
(buffer3[5]!=(int)(unsigned char)(Short_Buf[2])&& buffer3[6]!=(int)(unsigned char)(Short_Buf[3]))))
|
178 |
cafagna |
1.1 |
||
|
179 |
|
|
(ch1!=(char)(CODE1)&&
|
180 |
cafagna |
1.4 |
(buffer3[1023]!=(int)(unsigned char)(Short_Buf[4])&& buffer3[3]!=(int)(unsigned char)(Short_Buf[0])&&
|
181 |
|
|
buffer3[5]!=(int)(unsigned char)(Short_Buf[2])&& buffer3[6]!=(int)(unsigned char)(Short_Buf[3])))
|
182 |
cafagna |
1.1 |
||
|
183 |
|
|
(ch2!=(char)(CODE2)&&
|
184 |
cafagna |
1.4 |
(buffer3[1023]!=(int)(unsigned char)(Short_Buf[4])&& buffer3[3]!=(int)(unsigned char)(Short_Buf[0])&&
|
185 |
|
|
buffer3[5]!=(int)(unsigned char)(Short_Buf[2])&& buffer3[6]!=(int)(unsigned char)(Short_Buf[3])))
|
186 |
cafagna |
1.1 |
||
|
187 |
|
|
(ch3!=(char)(CODE3)&&
|
188 |
cafagna |
1.4 |
(buffer3[1023]!=(int)(unsigned char)(Short_Buf[4])&& buffer3[3]!=(int)(unsigned char)(Short_Buf[0])&&
|
189 |
|
|
buffer3[5]!=(int)(unsigned char)(Short_Buf[2])&& buffer3[6]!=(int)(unsigned char)(Short_Buf[3])))
|
190 |
cafagna |
1.1 |
||
|
191 |
|
|
(ch1!=(char)(CODE1)&&ch2!=(char)(CODE2)&&ch3!=(char)(CODE3)))
|
192 |
|
|
{fin.get(ch);
|
193 |
cafagna |
1.2 |
if (fin.eof()) {break;}
|
194 |
cafagna |
1.1 |
ch1=ch2; ch2=ch3; ch3=Short_Buf[0];
|
195 |
|
|
for (i=0;i<4;i++) Short_Buf[i]=Short_Buf[i+1]; Short_Buf[4]=ch;
|
196 |
|
|
icount_total+=1; count_tot[Rcount-1]+=1;
|
197 |
|
|
tmpP=(long int)(unsigned char)(Short_Buf[1])+
|
198 |
|
|
256*(long int)(unsigned char)(Short_Buf[2])+
|
199 |
|
|
256*256*(long int)(unsigned char)(Short_Buf[3]);
|
200 |
|
|
}
|
201 |
|
|
if ((fin.eof())&&(N1==0))
|
202 |
|
|
{
|
203 |
|
|
fclose(fout);
|
204 |
cafagna |
1.3 |
fo_info.close();
|
205 |
cafagna |
1.1 |
remove(fno);
|
206 |
|
|
fclose(fo);
|
207 |
|
|
remove(protocol);
|
208 |
|
|
remove(INF);
|
209 |
cafagna |
1.4 |
exit(1);
|
210 |
cafagna |
1.1 |
}
|
211 |
|
|
/*****************************************************************/
|
212 |
|
|
/*********************data reading********************************/
|
213 |
|
|
fin.read(buf,LenthBuf);
|
214 |
|
|
if (fin.eof()) break;
|
215 |
|
|
icount+=1015; icount_total+=1015;
|
216 |
|
|
count_ident[Rcount-1]+=1015; count_tot[Rcount-1]+=1015;
|
217 |
|
|
/****************************************************************/
|
218 |
|
|
/********************data reading********************************/
|
219 |
|
|
fin.get(ch);
|
220 |
|
|
icount+=1; icount_total+=1;
|
221 |
|
|
count_ident[Rcount-1]+=1; count_tot[Rcount-1]+=1;
|
222 |
|
|
if (fin.eof()) break;
|
223 |
|
|
/***************************************************************/
|
224 |
|
|
N1+=1; Num_kadrs[Rcount-1]+=1;
|
225 |
|
|
|
226 |
|
|
/**********************DATA ANALYSIS****************************/
|
227 |
|
|
/***************************************************************/
|
228 |
|
|
header1=(unsigned char)(ch1);
|
229 |
|
|
header2=(unsigned char)(ch2);
|
230 |
|
|
header3=(unsigned char)(ch3);
|
231 |
|
|
switch (N1)
|
232 |
|
|
{
|
233 |
|
|
case 1:{
|
234 |
|
|
buffer3[0]=(int)(unsigned char)(ch1);
|
235 |
|
|
buffer3[1]=(int)(unsigned char)(ch2);
|
236 |
|
|
buffer3[2]=(int)(unsigned char)(ch3);
|
237 |
|
|
buffer3[3]=(int)(unsigned char)(Short_Buf[0]);
|
238 |
|
|
buffer3[4]=(int)(unsigned char)(Short_Buf[1]);
|
239 |
|
|
buffer3[5]=(int)(unsigned char)(Short_Buf[2]);
|
240 |
|
|
buffer3[6]=(int)(unsigned char)(Short_Buf[3]);
|
241 |
|
|
buffer3[7]=(int)(unsigned char)(Short_Buf[4]);
|
242 |
|
|
for (i=0; i<1015; i++)
|
243 |
|
|
{buffer3[i+8]=(int)(unsigned char)(buf[i]);}
|
244 |
|
|
buffer3[1023]=(int)(unsigned char)(ch);
|
245 |
|
|
for (i=0; i<1024; i++)
|
246 |
|
|
{buffer1[i]=buffer3[i];buffer2[i]=buffer3[i];}
|
247 |
|
|
|
248 |
|
|
NumRout[Rcount-1]=1;
|
249 |
|
|
numP[2]=(long int)(unsigned char)(Short_Buf[1])+
|
250 |
|
|
256*(long int)(unsigned char)(Short_Buf[2])+
|
251 |
|
|
256*256*(long int)(unsigned char)(Short_Buf[3]);
|
252 |
|
|
CRC_bad_kadr[2]=0;
|
253 |
|
|
flag_pack[2]=0; flag_rout[2]=0;
|
254 |
|
|
flag_name[2]=0; flag_CRC0[2]=0; flag_tr[2]=0;
|
255 |
cafagna |
1.3 |
flag_CRC[2]=0; flag_CRC_cor[2]=0;
|
256 |
cafagna |
1.1 |
for (i=0; i<2; i++)
|
257 |
|
|
{numP[i]=numP[2];CRC_bad_kadr[i]=CRC_bad_kadr[2];
|
258 |
|
|
flag_pack[i]=flag_pack[2]; flag_rout[i]=flag_rout[2];
|
259 |
|
|
flag_name[i]=flag_name[2]; flag_CRC0[i]=flag_CRC0[2];
|
260 |
|
|
flag_CRC[i]=flag_CRC[2]; flag_tr[i]=flag_tr[2];
|
261 |
|
|
flag_CRC_cor[i]=flag_CRC_cor[2];}
|
262 |
|
|
CRC_0[2]=(int)(unsigned char)(Short_Buf[4]);
|
263 |
|
|
for (i=0; i<2; i++)
|
264 |
|
|
{CRC_0[i]=CRC_0[2];}
|
265 |
|
|
CRC_1[2]=(int)(unsigned char)(ch);
|
266 |
|
|
for (i=0; i<2; i++)
|
267 |
|
|
{CRC_1[i]=CRC_1[2];}
|
268 |
|
|
packet_first[Rcount-1]=numP[2];
|
269 |
cafagna |
1.4 |
control[0]=0; control[1]=0;
|
270 |
cafagna |
1.1 |
break;
|
271 |
|
|
}
|
272 |
|
|
default:{
|
273 |
|
|
for (i=0; i<1024; i++)
|
274 |
|
|
{buffer1[i]=buffer2[i];buffer2[i]=buffer3[i];}
|
275 |
|
|
buffer3[0]=(int)(unsigned char)(ch1);
|
276 |
|
|
buffer3[1]=(int)(unsigned char)(ch2);
|
277 |
|
|
buffer3[2]=(int)(unsigned char)(ch3);
|
278 |
|
|
buffer3[3]=(int)(unsigned char)(Short_Buf[0]);
|
279 |
|
|
buffer3[4]=(int)(unsigned char)(Short_Buf[1]);
|
280 |
|
|
buffer3[5]=(int)(unsigned char)(Short_Buf[2]);
|
281 |
|
|
buffer3[6]=(int)(unsigned char)(Short_Buf[3]);
|
282 |
|
|
buffer3[7]=(int)(unsigned char)(Short_Buf[4]);
|
283 |
|
|
for (i=0; i<1015; i++)
|
284 |
|
|
{buffer3[i+8]=(int)(unsigned char)(buf[i]);}
|
285 |
|
|
buffer3[1023]=(int)(unsigned char)(ch);
|
286 |
|
|
|
287 |
|
|
for (i=0; i<2; i++)
|
288 |
|
|
{numP[i]=numP[i+1]; CRC_bad_kadr[i]=CRC_bad_kadr[i+1];
|
289 |
|
|
flag_pack[i]=flag_pack[i+1];
|
290 |
|
|
flag_rout[i]=flag_rout[i+1];
|
291 |
|
|
flag_name[i]=flag_name[i+1];
|
292 |
|
|
flag_CRC0[i]=flag_CRC0[i+1];
|
293 |
|
|
flag_tr[i]=flag_tr[i+1];
|
294 |
|
|
flag_CRC[i]=flag_CRC[i+1];
|
295 |
|
|
flag_CRC_cor[i]=flag_CRC_cor[i+1];}
|
296 |
|
|
numP[2]=(long int)(unsigned char)(Short_Buf[1])+
|
297 |
|
|
256*(long int)(unsigned char)(Short_Buf[2])+
|
298 |
|
|
256*256*(long int)(unsigned char)(Short_Buf[3]);
|
299 |
|
|
CRC_bad_kadr[2]=0;
|
300 |
|
|
flag_pack[2]=0; flag_rout[2]=0;
|
301 |
|
|
flag_name[2]=0; flag_CRC0[2]=0;
|
302 |
|
|
flag_CRC[2]=0; flag_CRC_cor[2]=0; flag_tr[2]=0;
|
303 |
|
|
for (i=0; i<2; i++) CRC_0[i]=CRC_0[i+1];
|
304 |
|
|
CRC_0[2]=(int)(unsigned char)(Short_Buf[4]);
|
305 |
|
|
for (i=0; i<2; i++) {CRC_1[i]=CRC_1[i+1];}
|
306 |
|
|
CRC_1[2]=(int)(unsigned char)(ch);
|
307 |
cafagna |
1.4 |
control[0]=control[1];
|
308 |
|
|
control[1]=0;
|
309 |
cafagna |
1.1 |
}
|
310 |
|
|
}
|
311 |
cafagna |
1.4 |
// if (print_flag>0 && fmod(N1,10000)==0) cout<<N1<<"\n";
|
312 |
cafagna |
1.5 |
if (print_flag>0 && !(N1%10000)) cout<<N1<<"\n";
|
313 |
cafagna |
1.1 |
|
314 |
|
|
/******************CRC ERROR ANALYSIS***************************/
|
315 |
|
|
CalcCheckSum=CRC(buffer3);
|
316 |
|
|
if (CalcCheckSum!=(short int)(buffer3[1023]))
|
317 |
cafagna |
1.3 |
{
|
318 |
|
|
//write in file nnnnnmmm_info.dat
|
319 |
|
|
fo_info<<"real CRC = "<<hex<<buffer3[1023]<<" (calculated CRC ="<<CalcCheckSum<<") in cadre "<<dec<<numP[2]<<"\n";
|
320 |
|
|
//write in file nnnnnmmm_work.dat
|
321 |
cafagna |
1.4 |
fprintf(fout,"%10i %4i %4i\n", numP[2], CalcCheckSum, buffer3[1023]);
|
322 |
cafagna |
1.2 |
|
323 |
cafagna |
1.1 |
flag_CRC[2]=1;
|
324 |
|
|
Num_bad_kadrs[Rcount-1]+=1;
|
325 |
|
|
CRC_bad_kadr[2]=numP[2];
|
326 |
|
|
counter=restrict(buffer3,numP,buffer2[3]);
|
327 |
|
|
if (counter!=0)
|
328 |
cafagna |
1.3 |
{fo_info<<" truncate byte="<<counter<<" in cadre "<<numP[2]<<"\n";
|
329 |
|
|
if (print_flag>0)
|
330 |
cafagna |
1.4 |
{cout<<" truncate counter="<<counter<<" route="<<buffer2[3]<<" "<<buffer3[3]<<" cadre="<<numP[2]<<" "<<numP[1]<<" "<<numP[0]<<"\n";}
|
331 |
cafagna |
1.1 |
fin.seekg(-(1024-counter),ios::cur);
|
332 |
|
|
icount-=1024;
|
333 |
|
|
count_ident[Rcount-1]-=1024;
|
334 |
|
|
count_tot[Rcount-1]-=1024-counter;
|
335 |
|
|
icount_total-=1024-counter;
|
336 |
|
|
N1-=1;
|
337 |
|
|
CRC_bad_kadr[2]=0;
|
338 |
|
|
flag_tr[2]=1;
|
339 |
|
|
Num_kadrs[Rcount-1]-=1;
|
340 |
|
|
Num_bad_kadrs[Rcount-1]-=1;}
|
341 |
|
|
}
|
342 |
|
|
|
343 |
|
|
/******************HEADER ANALYSIS*******************************/
|
344 |
|
|
if ((header1!=(int)(CODE1))||(header2!=(int)(CODE2))||(header3!=(int)(CODE3)))
|
345 |
|
|
{flag_name[2]=1; N_er=N1;}
|
346 |
|
|
/****************************************************************/
|
347 |
|
|
|
348 |
|
|
/******************CRC0 ANALYSIS*********************************/
|
349 |
|
|
if ((buffer2[7]!=buffer1[1023])&&
|
350 |
|
|
((numP[1]==numP[0]+1)||(numP[1]==numP[2]-1))&&(flag_tr[1]!=1)&&(flag_tr[0]!=1)&&(N1>2))
|
351 |
|
|
{flag_CRC0[1]=1; CRC0_er=N1-1;}
|
352 |
|
|
/****************************************************************/
|
353 |
|
|
|
354 |
cafagna |
1.4 |
/******************CADRE NUMBER ANALYSIS*************************/
|
355 |
cafagna |
1.1 |
if ((numP[1]!=(numP[0]+1))&&(numP[1]!=(numP[2]-1))&&(N1!=1)&&(CRC_bad_kadr[1]==numP[1])&&(numP[1]!=0))
|
356 |
|
|
{P_er=N1-1; flag_pack[1]=1;
|
357 |
|
|
//Correct error packet number//
|
358 |
|
|
tmpP=numP[0]+1;
|
359 |
|
|
for (i=0;i<3;i++) Hex[i]=0;
|
360 |
|
|
for (i=0;i<3;i++)
|
361 |
|
|
{if (tmpP/(long int)(pow(256.,2-i))>=1)
|
362 |
|
|
{Hex[2-i]=(int)(tmpP/(long int)(pow(256.,2-i)));
|
363 |
|
|
tmpP=tmpP-(long int)pow(256.,2-i)*(int)(tmpP/(long int)(pow(256.,2-i)));}}
|
364 |
cafagna |
1.4 |
// for (i=4;i<7;i++) (buffer2[i]=Hex[i-4]);
|
365 |
cafagna |
1.1 |
if (buffer2[1023]==(int)(CRC(buffer2))) flag_CRC_cor[1]=1;
|
366 |
|
|
|
367 |
|
|
tmpP=numP[2]-1;
|
368 |
|
|
for (i=0;i<3;i++) Hex[i]=0;
|
369 |
|
|
for (i=0;i<3;i++)
|
370 |
|
|
{if (tmpP/(long int)(pow(256.,2-i))>=1)
|
371 |
|
|
{Hex[2-i]=(int)(tmpP/(long int)(pow(256.,2-i)));
|
372 |
|
|
tmpP=tmpP-(long int)pow(256.,2-i)*(int)(tmpP/(long int)(pow(256.,2-i)));}}
|
373 |
cafagna |
1.4 |
// for (i=4;i<7;i++) (buffer2[i]=Hex[i-4]);
|
374 |
cafagna |
1.1 |
if (buffer2[1023]==(int)(CRC(buffer2))) flag_CRC_cor[1]=1;
|
375 |
|
|
}
|
376 |
|
|
/////////////////////////////////////////////////////////////////////
|
377 |
|
|
if ((numP[2]!=(numP[1]+1))&&(N1!=1)&&(buffer3[3]==buffer2[3])&&(CRC_bad_kadr[2]==numP[2])&&(numP[2]!=0)) flag_pack[2]=1;
|
378 |
|
|
if (flag_pack[2]!=1) packet_last[Rcount-1]=numP[2];
|
379 |
cafagna |
1.3 |
////////Missing cadre analysis////////////////////////////////////
|
380 |
|
|
/**route number: 10 (10 19 10) 10 ******************************/
|
381 |
|
|
/**cadre number: 21 (22 17 18) 19 ******************************/
|
382 |
|
|
/**missed cadres: 21 20 19 18 17 ******************************/
|
383 |
cafagna |
1.1 |
if ((numP[1]<numP[0])&&(numP[1]==numP[2]-1)&&(buffer1[3]==buffer3[3])&&(flag_tr[1]==0)&&
|
384 |
cafagna |
1.4 |
(flag_pack[0]==0)&&(flag_pack[1]==0)&&(flag_pack[2]==0)&&(control[0]==0))
|
385 |
cafagna |
1.1 |
{Mis_group[Rcount-1]+=1;
|
386 |
cafagna |
1.3 |
count_sec_missed[Rcount-1]+=numP[0]-1-numP[1];
|
387 |
cafagna |
1.4 |
fprintf(foMiss,"secondary transmitted cadres may be %lli - %lli number of cadres=%lli\n",
|
388 |
|
|
numP[1],numP[0],numP[0]-1-numP[1]);
|
389 |
cafagna |
1.3 |
}
|
390 |
cafagna |
1.1 |
/**route number: 10 (10 19 10) 10 ******************************/
|
391 |
cafagna |
1.3 |
/**cadre number: 11 (12 15 20) 21 ******************************/
|
392 |
cafagna |
1.4 |
/**missed cadres: 16 17 18 19 ******************************/
|
393 |
cafagna |
1.1 |
if ((numP[1]>numP[0]+1)&&(numP[1]<numP[2]-1)&&(buffer1[3]==buffer3[3])&&(flag_tr[1]==0)&&
|
394 |
cafagna |
1.4 |
(flag_pack[0]==0)&&(flag_pack[1]==0)&&(flag_pack[2]==0))
|
395 |
cafagna |
1.1 |
{Mis_group[Rcount-1]+=1;
|
396 |
cafagna |
1.3 |
fprintf(foMiss,"1) %9lli%9lli\n",numP[1]+1,numP[2]-1);
|
397 |
cafagna |
1.4 |
if (print_flag>0) cout<<"1) "<<numP[0]<<" "<<numP[1]<<" "<<numP[2]<<"\n";
|
398 |
cafagna |
1.1 |
count_missed[Rcount-1]+=numP[2]-numP[1]-1;}
|
399 |
|
|
/**route number: (10 10 10) 10 10 ******************************/
|
400 |
cafagna |
1.4 |
/**cadre number: (11 29 15) 14 15 ******************************/
|
401 |
cafagna |
1.3 |
/**number of missed cadres:2 ******************************/
|
402 |
cafagna |
1.1 |
else if (((numP[1]<numP[0]+1)||(numP[1]>numP[2]-1))&&(numP[2]-numP[0]>2)&&
|
403 |
|
|
(buffer1[3]==buffer3[3])&&(buffer1[3]==buffer2[3])&&(flag_tr[1]==0)&&
|
404 |
|
|
(flag_pack[2]==0)&&(flag_pack[1]==1)&&(flag_pack[0]==0))
|
405 |
|
|
{Mis_group[Rcount-1]+=1;
|
406 |
cafagna |
1.4 |
fprintf(foMiss,"2) %9lli%9lli\n",numP[0]+1,numP[2]-1);
|
407 |
|
|
if (print_flag>0) cout<<"2) "<<numP[0]<<" "<<numP[1]<<" "<<numP[2]<<"\n";
|
408 |
cafagna |
1.1 |
count_missed[Rcount-1]+=numP[2]-numP[0]-1-1;}
|
409 |
cafagna |
1.4 |
else if (((numP[1]<numP[0]+1)||(numP[1]>numP[2]-1))&&((numP[2]-numP[0])==2)&&
|
410 |
|
|
(buffer1[3]==buffer3[3])&&(buffer1[3]==buffer2[3])&&(flag_tr[1]==0))
|
411 |
|
|
{control[1]=1;}
|
412 |
|
|
/**route number: (10 10 10) 10 10 ******************************/
|
413 |
|
|
/**cadre number: (11 15 16) 17 18 ******************************/
|
414 |
|
|
/**missed kadrs: 12 13 14 ******************************/
|
415 |
|
|
else if ((numP[1]>numP[0]+1)&&(numP[1]<=numP[2]-1)&&(buffer1[3]==buffer3[3])&&(buffer1[3]==buffer2[3])&&
|
416 |
|
|
(flag_tr[1]==0)&&(flag_pack[2]==0)&&(flag_pack[1]==0)&&(flag_pack[0]==0)&&(control[0]==0))
|
417 |
|
|
{Mis_group[Rcount-1]+=1;
|
418 |
|
|
fprintf(foMiss,"3) %9lli%9lli\n",numP[0]+1,numP[1]-1);
|
419 |
|
|
if (print_flag>0) cout<<"3) "<<numP[0]<<" "<<numP[1]<<" "<<numP[2]<<"\n";
|
420 |
|
|
count_missed[Rcount-1]+=numP[1]-numP[0]-1;}
|
421 |
cafagna |
1.3 |
/**route number:(10 10 )10 10 10 10 ******************************/
|
422 |
|
|
/**cadre number:( 1 11 )12 13 14 15 ******************************/
|
423 |
cafagna |
1.4 |
/**number of missed cadres: 10 ******************************/
|
424 |
|
|
else if ((N1>2)&&(abs(numP[1]-pack_good3)>abs(Num_kadrs[Rcount-1]-number_good3-1))&&
|
425 |
|
|
(buffer2[3]==route_good3)&&(flag_tr[2]==0)&&(flag_pack[2]==0)&&(numP[2]>numP[0]+2)&&(control[0]==0))
|
426 |
|
|
{Mis_group[Rcount-1]+=1;
|
427 |
|
|
if (pack_good3<numP[2]) count_missed[Rcount-1]+=abs(numP[2]-pack_good3)-1;
|
428 |
|
|
fprintf(foMiss,"4) %9lli%9lli number of missed cadres=%i\n", pack_good3, numP[1], abs(numP[1]-pack_good3-1));
|
429 |
|
|
if (print_flag>0) cout<<"P1="<<numP[0]<<" P2="<<numP[1]<<" P3="<<numP[2]<<"\n";
|
430 |
|
|
// cout<<"pack_good1="<<pack_good1<<" pack_good2="<<pack_good2<<" pack_good3="<<pack_good3<<"\n";
|
431 |
|
|
// cout<<"number_good1="<<number_good1<<" number_good2="<<number_good2<<" number_good3="<<number_good3<<"\n";
|
432 |
|
|
}
|
433 |
cafagna |
1.3 |
//truncate cadres
|
434 |
cafagna |
1.4 |
/**route number: 10 (10 10 10) 10 ******************************/
|
435 |
cafagna |
1.3 |
/**cadre number: 11 (12 13 14) 15 ******************************/
|
436 |
|
|
/**missed truncate cadre:13 ******************************/
|
437 |
cafagna |
1.1 |
else if ((numP[0]<numP[2]-1)&&(buffer1[3]==buffer3[3])&&
|
438 |
|
|
(flag_tr[0]==0)&&(flag_tr[1]==1)&&(flag_tr[2]==0)&&
|
439 |
|
|
(flag_pack[2]==0)&&(flag_pack[1]==0)&&(flag_pack[0]==0))
|
440 |
|
|
{Mis_group[Rcount-1]+=1;
|
441 |
cafagna |
1.3 |
fprintf(foMiss,"5) %9lli%9lli\n",numP[0]+1,numP[2]-1);
|
442 |
cafagna |
1.1 |
count_missed[Rcount-1]+=numP[2]-numP[0]-1;}
|
443 |
|
|
/***************************************************************/
|
444 |
|
|
|
445 |
cafagna |
1.4 |
if (flag_CRC[2]!=1)
|
446 |
|
|
{
|
447 |
|
|
pack_good1=pack_good2;
|
448 |
|
|
pack_good2=pack_good3;
|
449 |
|
|
route_good1=route_good2;
|
450 |
|
|
route_good2=route_good3;
|
451 |
|
|
number_good1=number_good2;
|
452 |
|
|
number_good2=number_good3;
|
453 |
|
|
|
454 |
|
|
pack_good3=numP[2];
|
455 |
|
|
route_good3=buffer3[3];
|
456 |
|
|
number_good3=Num_kadrs[Rcount-1];
|
457 |
|
|
}
|
458 |
cafagna |
1.1 |
/******************ROUTE NUMBER ANALYSIS**************************/
|
459 |
|
|
if ((buffer2[3]!=buffer1[3])&&(buffer2[3]!=buffer3[3])&&(buffer1[3]!=buffer3[3])&&
|
460 |
|
|
(flag_pack[2]==0)&&(flag_pack[1]==0)&&(flag_pack[0]==0))
|
461 |
|
|
{
|
462 |
cafagna |
1.2 |
|
463 |
cafagna |
1.1 |
}
|
464 |
|
|
/**************First route***************************************/
|
465 |
|
|
/**route number: (0 4) 4*****************************************/
|
466 |
cafagna |
1.3 |
/**cadre number: (0 1) 2*****************************************/
|
467 |
cafagna |
1.1 |
if (N1==2)
|
468 |
|
|
{packet_first[Rcount-1]=numP[1];
|
469 |
|
|
packet_last[Rcount-1]=numP[2];
|
470 |
|
|
NumRout[Rcount-1]=1;
|
471 |
|
|
// CREATE FILE NAMES
|
472 |
cafagna |
1.4 |
filename(file_route, miss_file, cln1_file, path, NumRout[Rcount-1], name);
|
473 |
cafagna |
1.1 |
strncpy(cln1_kadr,cln1_file,strlen(cln1_file)-3);
|
474 |
|
|
cln1_kadr[strlen(cln1_file)-3]='\0';
|
475 |
|
|
strcat(cln1_kadr,"bin");
|
476 |
|
|
strncpy(log_kadr,file_route,strlen(file_route)-6);
|
477 |
|
|
log_kadr[strlen(file_route)-6]='\0';
|
478 |
|
|
strcat(log_kadr,"_bin.log");
|
479 |
|
|
//Open files for new route
|
480 |
cafagna |
1.3 |
foRout=fopen(file_route, "wb"); //nnnnn_mmm_xxx_cln1Er.log
|
481 |
|
|
foMiss=fopen(miss_file, "wb"); //nnnnn_mmm_xxx_mis_cln1.dat
|
482 |
|
|
if (CLN1_MEPHI>0)
|
483 |
|
|
{strcpy(ch4,"");
|
484 |
|
|
strncat(ch4,path,strlen(path)-6);
|
485 |
|
|
strcat(strcpy(temp1,ch4),"Cln1/tmp.dat");
|
486 |
|
|
if ((fo_tmp=fopen(temp1,"w"))==NULL)
|
487 |
|
|
{strcat(strcat(strcpy(command,"mkdir "),ch4),"Cln1");
|
488 |
|
|
//Creata special directory for cln1 files
|
489 |
|
|
system(command);
|
490 |
|
|
}
|
491 |
|
|
else
|
492 |
|
|
{
|
493 |
|
|
fclose(fo_tmp);
|
494 |
|
|
remove(temp1);
|
495 |
|
|
}
|
496 |
|
|
for(i=0;i<22;i++)
|
497 |
|
|
{name11[i]=cln1_file[i+strlen(cln1_file)-22];}
|
498 |
|
|
name11[22]='\0';
|
499 |
|
|
strcat(strcat(ch4,"Cln1/"),name11);
|
500 |
|
|
strcpy(cln1_file,ch4);
|
501 |
|
|
}
|
502 |
|
|
fo_cln1.open(cln1_file, ios::binary); //nnnnn_mmm_xxx_cln1.pam
|
503 |
|
|
|
504 |
cafagna |
1.1 |
if (!fo_cln1) cout<<"can not open "<<cln1_file<<"\n";
|
505 |
cafagna |
1.3 |
fokadr_cln1.open(cln1_kadr,ios::binary); //nnnnn_mmm_xxx_cln1.bin
|
506 |
cafagna |
1.1 |
if (!fokadr_cln1) cout<<"can not open "<<cln1_kadr<<"\n";
|
507 |
cafagna |
1.3 |
fo_log_kadr=fopen(log_kadr,"wb"); //nnnnn_mmm_xxx_cln1_bin.log
|
508 |
cafagna |
1.4 |
}
|
509 |
cafagna |
1.3 |
/***************New route****************************************/
|
510 |
|
|
/**route number: 7 ( 7 0 8) 8*********************************/
|
511 |
|
|
/**cadre number: 199 (200 0 1) 2*********************************/
|
512 |
|
|
/**route number: 7 ( 7 8 8) 8*********************************/
|
513 |
|
|
/**cadre number: 199 (200 0 1) 2*********************************/
|
514 |
cafagna |
1.1 |
if ( ((buffer1[3]!=buffer3[3])&&(buffer2[3]==0)&&(N1>3)&&(numP[1]!=numP[0]+1)&&(numP[1]<10))||
|
515 |
cafagna |
1.4 |
((buffer1[3]!=buffer2[3])&&(buffer2[3]==buffer3[3])&&(buffer1[3]!=0)&&(numP[1]!=numP[0]+1)&&(numP[1]<10)&&
|
516 |
|
|
(flag_pack[0]==0)&&(flag_pack[1]==0))||
|
517 |
cafagna |
1.1 |
((numP[2]==numP[1]+1)&&(numP[1]==0)&&(Num_kadrs[Rcount-1]>1000000)) )
|
518 |
|
|
{Rcount+=1;
|
519 |
|
|
packet_last[Rcount-2]=numP[0];
|
520 |
|
|
packet_first[Rcount-1]=numP[1];
|
521 |
|
|
NumRout[Rcount-1]=Rcount;
|
522 |
cafagna |
1.3 |
if (print_flag>0)
|
523 |
|
|
{cout<<"New route="<<Rcount<<" "<<buffer1[3]<<" "<<buffer2[3]<<" "<<buffer3[3]<<"\n";
|
524 |
|
|
cout<<numP[0]<<" "<<numP[1]<<" "<<numP[2]<<"\n";}
|
525 |
cafagna |
1.1 |
if (flag_tr[1]==0)
|
526 |
|
|
{Num_kadrs[Rcount-2]-=2;
|
527 |
|
|
Num_kadrs[Rcount-1]+=2;
|
528 |
|
|
count_ident[Rcount-1]+=2048; count_ident[Rcount-2]-=2048;
|
529 |
|
|
count_tot[Rcount-1]+=2048; count_tot[Rcount-2]-=2048;}
|
530 |
|
|
else
|
531 |
|
|
{Num_kadrs[Rcount-2]-=1;
|
532 |
|
|
Num_kadrs[Rcount-1]+=1;
|
533 |
|
|
count_ident[Rcount-1]+=1024; count_ident[Rcount-2]-=1024;
|
534 |
|
|
count_tot[Rcount-1]+=1024; count_tot[Rcount-2]-=1024;}
|
535 |
|
|
// CREATE FILE NAMES
|
536 |
cafagna |
1.3 |
filename(file_route, miss_file, cln1_file, path, NumRout[Rcount-1], name);
|
537 |
cafagna |
1.1 |
strncpy(cln1_kadr,cln1_file,strlen(cln1_file)-3);
|
538 |
|
|
cln1_kadr[strlen(cln1_file)-3]='\0';
|
539 |
|
|
strcat(cln1_kadr,"bin");
|
540 |
|
|
strncpy(log_kadr,file_route,strlen(file_route)-6);
|
541 |
|
|
log_kadr[strlen(file_route)-6]='\0';
|
542 |
|
|
strcat(log_kadr,"_bin.log");
|
543 |
|
|
fclose(foRout); //Close files
|
544 |
|
|
fo_cln1.close(); //for old
|
545 |
|
|
fclose(foMiss); //route
|
546 |
|
|
fokadr_cln1.close();
|
547 |
|
|
fclose(fo_log_kadr);
|
548 |
|
|
//Open files for new route
|
549 |
cafagna |
1.3 |
foRout=fopen(file_route, "wb"); //nnnnn_mmm_xxx_cln1Er.log
|
550 |
|
|
foMiss=fopen(miss_file, "wb"); //nnnnn_mmm_xxx_mis_cln1.dat
|
551 |
|
|
fo_cln1.open(cln1_file, ios::binary); //nnnnn_mmm_xxx_cln1.pam
|
552 |
|
|
fokadr_cln1.open(cln1_kadr,ios::binary); //nnnnn_mmm_xxx_cln1.bin
|
553 |
|
|
fo_log_kadr=fopen(log_kadr,"wb"); //nnnnn_mmm_xxx_cln1_bin.log
|
554 |
cafagna |
1.1 |
if ((CRC_bad_kadr[2]==numP[2])&&(numP[2]!=0)) {Num_bad_kadrs[Rcount-1]+=1; Num_bad_kadrs[Rcount-2]-=1;}
|
555 |
|
|
if ((CRC_bad_kadr[1]==numP[1])&&(numP[1]!=0))
|
556 |
|
|
{Num_bad_kadrs[Rcount-1]+=1; Num_bad_kadrs[Rcount-2]-=1;
|
557 |
|
|
flags=(short int)(pow((float)(2*flag_name[1]),4)+
|
558 |
|
|
pow((float)(2*flag_rout[1]),1)+
|
559 |
|
|
pow((float)(2*flag_pack[1]),2)+
|
560 |
|
|
pow((float)(2*flag_CRC0[1]),3)+
|
561 |
|
|
pow((float)(2*flag_CRC[1]),5)+
|
562 |
|
|
pow((float)(2*flag_CRC_cor[1]),6));
|
563 |
|
|
fprintf(foRout,"%1c%1c%1c%1c",(char)(buffer2[4]),(char)(buffer2[5]),(char)(buffer2[6]),(char)(flags));
|
564 |
cafagna |
1.3 |
fo_info<<"New route: cadre="<<CRC_bad_kadr[1]<<" error flag="<<flags<<"\n";
|
565 |
|
|
CRC_bad_kadr[1]-=1;}
|
566 |
cafagna |
1.1 |
}
|
567 |
|
|
|
568 |
cafagna |
1.2 |
if (((numP[1]==0)&&(N1>1))||(N1==2))
|
569 |
cafagna |
1.1 |
{rr=0;
|
570 |
|
|
FindRoute(buffer2, &rr);
|
571 |
|
|
if (rr>0)
|
572 |
|
|
{
|
573 |
|
|
real_route[Rcount]=rr;
|
574 |
|
|
}
|
575 |
|
|
else
|
576 |
|
|
{
|
577 |
|
|
real_route[Rcount]=0;
|
578 |
|
|
}
|
579 |
|
|
}
|
580 |
|
|
/***************************************************************/
|
581 |
|
|
if (CRC_bad_kadr[1]==numP[1])
|
582 |
|
|
{
|
583 |
|
|
//Correct CRC0 error/////////////////////////////////////////////////
|
584 |
cafagna |
1.3 |
if (flag_CRC0[1]!=0)
|
585 |
|
|
{
|
586 |
|
|
buffer2[7]=buffer1[1023];
|
587 |
|
|
if (buffer2[1023]==(int)(CRC(buffer2))) flag_CRC_cor[1]=1;
|
588 |
|
|
}
|
589 |
cafagna |
1.1 |
//Correct name error/////////////////////////////////////////////////
|
590 |
cafagna |
1.3 |
if (flag_name[1]!=0)
|
591 |
|
|
{buffer2[0]=(int)(CODE1);
|
592 |
|
|
buffer2[1]=(int)(CODE2);
|
593 |
|
|
buffer2[2]=(int)(CODE3);
|
594 |
|
|
if (buffer2[1023]==(int)(CRC(buffer2))) flag_CRC_cor[1]=1;
|
595 |
|
|
}
|
596 |
cafagna |
1.1 |
}
|
597 |
|
|
////////////////////////////////////////////////////////////////////
|
598 |
|
|
/*******************************************************************/
|
599 |
|
|
if ((CRC_bad_kadr[1]==numP[1])&&(numP[1]!=0)&&(N1>1))
|
600 |
|
|
{
|
601 |
|
|
flags=(short int)(pow((float)(2*flag_name[1]),4)+
|
602 |
|
|
pow((float)(2*flag_rout[1]),1)+
|
603 |
|
|
pow((float)(2*flag_pack[1]),2)+
|
604 |
|
|
pow((float)(2*flag_CRC0[1]),3)+
|
605 |
|
|
pow((float)(2*flag_CRC[1]),5)+
|
606 |
|
|
pow((float)(2*flag_CRC_cor[1]),6));
|
607 |
|
|
fprintf(foRout,"%1c%1c%1c%1c",(char)(buffer2[4]),
|
608 |
|
|
(char)(buffer2[5]),(char)(buffer2[6]),(char)(flags));
|
609 |
cafagna |
1.4 |
fo_info<<" error flag="<<flags<<" in cadre "<<numP[1]<<"\n";}
|
610 |
cafagna |
1.3 |
|
611 |
cafagna |
1.1 |
/***************************************************************/
|
612 |
|
|
//*Packet analysis**********************************************
|
613 |
cafagna |
1.3 |
if (N_er!=0) fo_info<<"Name error "<<N_er<<" in cadre "<<numP[2]<<"\n";
|
614 |
|
|
if (P_er!=0) fo_info<<"Number packet error "<<numP[1]<<" in cadre "<<P_er<<"\n";
|
615 |
|
|
if (CRC0_er!=0) fo_info<<"CRC0 error "<<numP[1]<<" in cadre "<<CRC0_er<<"\n";
|
616 |
cafagna |
1.1 |
|
617 |
|
|
/***************PAMELA data extracting for each route***********/
|
618 |
|
|
// if (N1!=1&&(flag_CRC[1]==0||(flag_rout[1]==0&&flag_pack[1]==0)||
|
619 |
|
|
// (flag_CRC[1]!=0&&flag_CRC_cor[1]==1)))
|
620 |
cafagna |
1.2 |
if ((N1!=1)&&(flag_tr[1]==0))
|
621 |
cafagna |
1.1 |
{end=0;
|
622 |
|
|
if (buffer2[3]!=buffer1[3]||buffer2[3]!=buffer3[3])
|
623 |
|
|
{for (i=8;i<1020;i++)
|
624 |
|
|
{
|
625 |
|
|
// if (fmodf(float((Num_kadrs[Rcount-1]-1)*1015+i-8),float(64))==0.&&buffer2[i]==0&&buffer2[i+1]==0&&
|
626 |
|
|
// buffer2[i+2]==0&&buffer2[i+3]==0) end=1;
|
627 |
|
|
if (end!=1) fo_cln1<<(unsigned char)buffer2[i];
|
628 |
|
|
}
|
629 |
|
|
if (end!=1) for(i=1020;i<1023;i++) {fo_cln1<<(unsigned char)buffer2[i];}
|
630 |
|
|
}
|
631 |
|
|
else {for(i=8;i<1023;i++) fo_cln1<<(unsigned char)buffer2[i];}
|
632 |
|
|
for (i=0;i<1024;i++) {fokadr_cln1<<(unsigned char)buffer2[i];}
|
633 |
cafagna |
1.3 |
//Write in file nnnnn_mmm_xxx_cln1_bin.log
|
634 |
cafagna |
1.1 |
tmp=numP[1];
|
635 |
|
|
for (k=0;k<4;k++) numPack[k]=0;
|
636 |
cafagna |
1.2 |
for (k=0;k<3;k++)
|
637 |
|
|
{if (tmp/(long int)(pow(256.,2-k))>=1)
|
638 |
|
|
{numPack[2-k]=(int)(tmp/(long int)(pow(256.,2-k)));
|
639 |
|
|
tmp=tmp-(long int)pow(256.,2-k)*(int)(tmp/(long int)(pow(256.,2-k)));}}
|
640 |
|
|
for (i=0;i<3;i++) fputc((int)(unsigned char)(numPack[i]),fo_log_kadr);
|
641 |
cafagna |
1.1 |
adr1=icount-1024*2;
|
642 |
|
|
for (k=0;k<4;k++) adress[k]=0;
|
643 |
|
|
for (k=0;k<4;k++)
|
644 |
|
|
{if (adr1/(long int)(pow(256.,3-k))>=1)
|
645 |
|
|
{adress[3-k]=(int)(adr1/(long int)(pow(256.,3-k)));
|
646 |
|
|
adr1=adr1-(long int)pow(256.,3-k)*
|
647 |
|
|
(int)(adr1/(long int)(pow(256.,3-k)));}}
|
648 |
|
|
for (i=0;i<4;i++) fputc((int)(unsigned char)(adress[i]),fo_log_kadr);
|
649 |
|
|
adr2=icount-1024;
|
650 |
|
|
for (k=0;k<4;k++) adress[k]=0;
|
651 |
|
|
for (k=0;k<4;k++)
|
652 |
|
|
{if (adr2/(long int)(pow(256.,3-k))>=1)
|
653 |
|
|
{adress[3-k]=(int)(adr2/(long int)(pow(256.,3-k)));
|
654 |
|
|
adr2=adr2-(long int)pow(256.,3-k)*
|
655 |
|
|
(int)(adr2/(long int)(pow(256.,3-k)));}}
|
656 |
|
|
for (i=0;i<4;i++) fputc((int)(unsigned char)(adress[i]),fo_log_kadr);
|
657 |
|
|
fputc(flags,fo_log_kadr);
|
658 |
|
|
}
|
659 |
|
|
}
|
660 |
|
|
/***************************************************************/
|
661 |
|
|
/***************************************************************/
|
662 |
cafagna |
1.4 |
if (flag_CRC[2]==0||(flag_rout[2]==0&&flag_pack[2]==0)||(flag_CRC[2]!=0&&flag_CRC_cor[2]==1))
|
663 |
cafagna |
1.1 |
{end=0;
|
664 |
|
|
for (i=0;i<1024;i++) fokadr_cln1<<(unsigned char)buffer3[i];
|
665 |
cafagna |
1.3 |
//Write in file nnnnn_mmm_xxx_cln1_bin.log
|
666 |
cafagna |
1.1 |
tmp=numP[2];
|
667 |
|
|
for (k=0;k<4;k++) numPack[k]=0;
|
668 |
cafagna |
1.2 |
for (k=0;k<3;k++)
|
669 |
|
|
{if (tmp/(long int)(pow(256.,2-k))>=1)
|
670 |
|
|
{numPack[2-k]=(int)(tmp/(long int)(pow(256.,2-k)));
|
671 |
|
|
tmp=tmp-(long int)pow(256.,2-k)*
|
672 |
|
|
(int)(tmp/(long int)(pow(256.,2-k)));}}
|
673 |
|
|
for (i=0;i<3;i++) fputc((int)(unsigned char)(numPack[i]),fo_log_kadr);
|
674 |
cafagna |
1.1 |
adr1=icount-1024;
|
675 |
|
|
for (k=0;k<4;k++) adress[k]=0;
|
676 |
|
|
for (k=0;k<4;k++)
|
677 |
|
|
{if (adr1/(long int)(pow(256.,3-k))>=1)
|
678 |
|
|
{adress[3-k]=(int)(adr1/(long int)(pow(256.,3-k)));
|
679 |
|
|
adr1=adr1-(long int)pow(256.,3-k)*
|
680 |
|
|
(int)(adr1/(long int)(pow(256.,3-k)));}}
|
681 |
|
|
for (i=0;i<4;i++) fputc((int)(unsigned char)(adress[i]),fo_log_kadr);
|
682 |
|
|
adr2=icount;
|
683 |
|
|
for (k=0;k<4;k++) adress[k]=0;
|
684 |
|
|
for (k=0;k<4;k++)
|
685 |
|
|
{if (adr2/(long int)(pow(256.,3-k))>=1)
|
686 |
|
|
{adress[3-k]=(int)(adr2/(long int)(pow(256.,3-k)));
|
687 |
|
|
adr2=adr2-(long int)pow(256.,3-k)*
|
688 |
|
|
(int)(adr2/(long int)(pow(256.,3-k)));}}
|
689 |
|
|
for (i=0;i<4;i++) fputc((int)(unsigned char)(adress[i]),fo_log_kadr);
|
690 |
|
|
fputc(flags,fo_log_kadr);
|
691 |
|
|
|
692 |
|
|
for (i=8;i<1019;i++)
|
693 |
|
|
{
|
694 |
|
|
// if (fmodf(float((Num_kadrs[Rcount-1]-1)*1015+i-8),
|
695 |
|
|
// float(64))==0.&&buffer3[i]==0&&buffer3[i+1]==0&&
|
696 |
|
|
// buffer3[i+2]==0&&buffer3[i+3]==0&&buffer3[i+4]==0) end=1;
|
697 |
|
|
if (end!=1) fo_cln1<<(unsigned char)buffer3[i];
|
698 |
|
|
}
|
699 |
|
|
if (end!=1) {for(i=1019;i<1023;i++) {fo_cln1<<(unsigned char)buffer3[i];}}
|
700 |
|
|
}
|
701 |
|
|
|
702 |
|
|
icount_int = (int)(icount/1024);
|
703 |
|
|
icount_frac= icount%1024;
|
704 |
|
|
|
705 |
|
|
//***protocol file***********************************************
|
706 |
|
|
file_length=(int)(strlen(name));
|
707 |
cafagna |
1.2 |
fprintf(fo,"file name=/home/ntsomz/downlinks/%s\n",name);
|
708 |
|
|
fprintf(fo,"file size= %i,%i kByte \n", icount_int, icount_frac);
|
709 |
|
|
fprintf(fo,"number identified cadres= %i\n", N1);
|
710 |
|
|
fprintf(fo,"number of routes= %i\n", Rcount);
|
711 |
cafagna |
1.3 |
|
712 |
|
|
for(i=0;i<5;i++) {temp[i]=name[i]; temp[5]='\0';}
|
713 |
|
|
sscanf(temp,"%5d", &cirquit_no);
|
714 |
|
|
for(i=0;i<3;i++) {temp[i]=name[i+5]; temp[3]='\0';}
|
715 |
|
|
sscanf(temp,"%3i", &route);
|
716 |
|
|
|
717 |
cafagna |
1.2 |
for (i=0;i<Rcount;i++)
|
718 |
|
|
{
|
719 |
cafagna |
1.3 |
for(j=0;j<22;j++) temp[j]=cln1_file[j+strlen(cln1_file)-22];
|
720 |
|
|
temp[22]='\0';
|
721 |
|
|
oss.str("");
|
722 |
|
|
oss << "INSERT INTO RAW_FILES (cirquit_n, route_n, counter, NumCadr, CRCerr, cln1_name, cln1_size)"
|
723 |
|
|
<< " VALUES ("<< cirquit_no << ","<< route << ","<< i+1 <<","<< Num_kadrs[i]<< "," << Num_bad_kadrs[i] << ",'"
|
724 |
|
|
<< temp << "'," << count_ident[i]-Num_kadrs[i]*9 << ")";
|
725 |
cafagna |
1.4 |
if (print_flag>0) cout<<oss.str().c_str()<<" table RAW_FILES\n";
|
726 |
cafagna |
1.3 |
TSQLResult *res=sqlServer->Query(oss.str().c_str());
|
727 |
|
|
|
728 |
cafagna |
1.2 |
Num_good_kadrs[i]=Num_kadrs[i]-Num_bad_kadrs[i];
|
729 |
cafagna |
1.3 |
if (packet_first[i]>1)
|
730 |
|
|
{first_missed[i]=(float)(1.)-float(packet_first[i]-1.)/(float)(packet_last[i]);}
|
731 |
|
|
else if (packet_first[i]==0)
|
732 |
|
|
{first_missed[i]=1.;}
|
733 |
|
|
|
734 |
|
|
|
735 |
cafagna |
1.2 |
quality[i]=(float)(1.)-(float)(Num_bad_kadrs[i])/(float)(Num_kadrs[i]);
|
736 |
|
|
fprintf(fo,"\nRoute number=%i: number of normal cadres= %i: number of errors=%i; \n",NumRout[i],Num_good_kadrs[i],Num_bad_kadrs[i]);
|
737 |
cafagna |
1.3 |
fprintf(fo,"size of identified cadres =%lli bytes;",count_ident[i]);
|
738 |
cafagna |
1.1 |
fprintf(fo," total size of route=%lli bytes;\n",count_tot[i]);
|
739 |
cafagna |
1.3 |
fprintf(fo,"first cadre number= %lli:", packet_first[i]);
|
740 |
cafagna |
1.2 |
fprintf(fo," last cadre number= %lli:", packet_last[i]);
|
741 |
cafagna |
1.4 |
fprintf(fo," Number of missed cadres= %lli: Number of double transmitted cadres= %lli\n",
|
742 |
|
|
count_missed[i], count_sec_missed[i]);
|
743 |
cafagna |
1.3 |
fprintf(fo,"number of identified cadres=%lli: quality index=%f: completness=%f \n", Num_kadrs[i], quality[i],
|
744 |
|
|
first_missed[i]);
|
745 |
cafagna |
1.1 |
}
|
746 |
|
|
|
747 |
cafagna |
1.4 |
//***route number log file**************************************
|
748 |
cafagna |
1.1 |
for (i=0;i<Rcount;i++) {fprintf(fo_route,"%1c",(char)(NumRout[i]));}
|
749 |
cafagna |
1.3 |
|
750 |
cafagna |
1.2 |
|
751 |
cafagna |
1.1 |
//***************************************************************
|
752 |
|
|
fin.close();
|
753 |
cafagna |
1.3 |
fclose(fout);
|
754 |
|
|
fo_info.close();
|
755 |
cafagna |
1.1 |
fclose(fo);
|
756 |
|
|
fclose(foRout);
|
757 |
|
|
fclose(foMiss);
|
758 |
|
|
fo_cln1.close();
|
759 |
|
|
fclose(fo_log_kadr);
|
760 |
|
|
fokadr_cln1.close();
|
761 |
|
|
fclose(fo_route);
|
762 |
|
|
}
|
763 |
|
|
|