Context Navigation

← Previous Change
Next Change →

Changeset 157 for trunk

Timestamp:

10/18/11 16:40:41 (11 years ago)

Author:

andreu

Message:

renetcol mib update

Files:

: 1 modified

trunk/src/renetcolAgg.c (modified) (4 diffs)

Legend:

: Unmodified
: Added
: Removed

trunk/src/renetcolAgg.c

r154	r157
1	1	/*
2	2	* File: renetcolAgg.c
3		*
4		* Authors: ANDREU Francois-Xavier
5	3	*
6		* Copyright (C) 2007-2011 GIP RENATER
	4	* Authors: ANDREU Francois-Xavier
	5	*
	6	* Copyright (C) 2007-2011 GIP RENATER
7	7	*/
8	8
9		/* This file is part of renetcol.
	9	/* This file is part of renetcol.
10	10	*
11	11	* renetcol is free software; you can redistribute it and/or modify
…	…
28	28	* the rrd files which contain the statistique for each subnet.
29	29	* When your system is too fast and the number of your subnet too big
30		* (> 1024), the create and update process can be too fast and before the
	30	* (> 1024), the create and update process can be too fast and before the
31	31	* end of creation. So the maximum number of files which can be opened for one
32	32	* process in the same time is reached and we must temporize.
…	…
40	40	main(int argc, char *argv[])
41	41	{
42		int shmid;
43		int i, j, k = 0;
44		int index = 1;
45		int rrd_update_er_ct = 0;
46		int rrd_update_ok_ct = 0;
47		int rrd_already_created_ct = 0;
48		int rrd_create_er_ct = 0;
49		int rrd_create_ok_ct = 0;
50		int isFirstUpdate = 1;
51		key_t key;
52		static char buf[2048];
53		static char name[2048];
54		static char ipStr[24];
	42	int shmid;
	43	int i, j, k = 0;
	44	int index = 1;
	45	int rrd_update_er_ct = 0;
	46	int rrd_update_ok_ct = 0;
	47	int rrd_already_created_ct = 0;
	48	int rrd_create_er_ct = 0;
	49	int rrd_create_ok_ct = 0;
	50	int isFirstUpdate = 1;
	51	key_t key;
	52	static char buf[2048];
	53	static char name[2048];
	54	static char ipStr[24];
55	55	#ifdef IPV6LINKAGG
56		static char ipv6LinkStr[40]; /* 10_0_0_1_20_136 <router address> + <sampling> + <SNMP index> */
	56	static char ipv6LinkStr[40]; /* 10_0_0_1_20_136 <router address> + <sampling> + <SNMP index> */
57	57	#endif
58	58	#if defined(MATRIX) && defined(IPV4AGGIDR)
59		static char indexStr[24];
	59	static char indexStr[24];
60	60	#endif
61		static char asStr[7];
62		static char createstr[2048];
63		char *opt[27];
64		char *optUpdate[3];
65		FILE *fp;
66		static time_t now, now2;
67
68		key = 8765;
69		if ((shmid = shmget(key, SHMSIZE, 0666)) < 0) {
70		perror("shmget");
71		exit(1);
72		}
73		if ((shmForAgg = (struct SHMForAgg )shmat(shmid, (void )0, 0)) == (void *) -1) {
74		perror("shmat");
75		exit(1);
76		}
77
78		fprintf(stderr, "renetcolAgg: I become a deamon, next messages via syslogd. Bye.\n");
79		if (fork () != 0)
80		exit (0);
81		if (setsid() == -1){
82		exit(4);
83		}
84
85		do {
86		if (shmForAgg->readed == 1) {
87		shmForAgg->readed = 0;
88		if (shmForAgg->currentTable == 0) {
89		index = 1;
90		}else{
91		index = 0;
92		}
93		now = time((time_t *)NULL);
94		if (isFirstUpdate == 0) {
95		/* RRD ACCOUNTING for prefixV4Tab */
96		for (i=0; i<shmForAgg->v4PrefixNb; i++){
97		/* HERE create or update RRD FILE */
98		if (shmForAgg->prefixV4Tab[index][i].sampling != 0) {
99		for (j=0; j<strlen(name); j++) {name[j] = '\0';}
100		for (j=0; j<strlen(createstr); j++) {createstr[j] = '\0';}
101		for (j=0; j<strlen(ipStr); j++) {ipStr[j] = '\0';}
102		for (j=0; j<strlen(buf); j++) {buf[j] = '\0';}
103		strcat(name, PREFIX_RRD_LOCATION);
104		sprintf(ipStr, "%lu_%lu_%lu_%lu_%hu_%lu",
105		shmForAgg->prefixV4Tab[index][i].beginning>>24,
106		shmForAgg->prefixV4Tab[index][i].beginning<<8>>24,
107		shmForAgg->prefixV4Tab[index][i].beginning<<16>>24,
108		shmForAgg->prefixV4Tab[index][i].beginning<<24>>24,
109		shmForAgg->prefixV4Tab[index][i].mask,
110		shmForAgg->prefixV4Tab[index][i].sampling
111		);
112		strcat(name, ipStr);
113		strcat(name, RRD_EXTENSION);
114		if ( (fp=fopen(name,"r")) == NULL ){
115		opt[0]= (char ) malloc((strlen(RRD_PARAM_PREFIX_0) + 1) sizeof(char));
116		strcpy(opt[0], RRD_PARAM_PREFIX_0);
117		opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
118		strcpy(opt[1], name);
119		opt[2]= (char ) malloc((strlen(RRD_PARAM_PREFIX_1) + 1) sizeof(char));
120		strcpy(opt[2], RRD_PARAM_PREFIX_1);
121		opt[3]= (char ) malloc((strlen(RRD_PARAM_PREFIX_2) + 1) sizeof(char));
122		strcpy(opt[3], RRD_PARAM_PREFIX_2);
123		opt[4]= (char ) malloc((strlen(RRD_PARAM_PREFIX_3) + 1) sizeof(char));
124		strcpy(opt[4], RRD_PARAM_PREFIX_3);
125		opt[5]= (char ) malloc((strlen(RRD_PARAM_PREFIX_4) + 1) sizeof(char));
126		strcpy(opt[5], RRD_PARAM_PREFIX_4);
127		opt[6]= (char ) malloc((strlen(RRD_PARAM_PREFIX_5) + 1) sizeof(char));
128		strcpy(opt[6], RRD_PARAM_PREFIX_5);
129		opt[7]= (char ) malloc((strlen(RRD_PARAM_PREFIX_6) + 1) sizeof(char));
130		strcpy(opt[7], RRD_PARAM_PREFIX_6);
131		opt[8]= (char ) malloc((strlen(RRD_PARAM_PREFIX_7) + 1) sizeof(char));
132		strcpy(opt[8], RRD_PARAM_PREFIX_7);
133		opt[9]= (char ) malloc((strlen(RRD_PARAM_PREFIX_8) + 1) sizeof(char));
134		strcpy(opt[9], RRD_PARAM_PREFIX_8);
135		opt[10]= (char ) malloc((strlen(RRD_PARAM_PREFIX_9) + 1) sizeof(char));
136		strcpy(opt[10], RRD_PARAM_PREFIX_9);
137		opt[11]= (char ) malloc((strlen(RRD_PARAM_PREFIX_10) + 1) sizeof(char));
138		strcpy(opt[11], RRD_PARAM_PREFIX_10);
139		opt[12]= (char ) malloc((strlen(RRD_PARAM_PREFIX_11) + 1) sizeof(char));
140		strcpy(opt[12], RRD_PARAM_PREFIX_11);
141		opt[13]= (char ) malloc((strlen(RRD_PARAM_PREFIX_12) + 1) sizeof(char));
142		strcpy(opt[13], RRD_PARAM_PREFIX_12);
143		opt[14]= (char ) malloc((strlen(RRD_PARAM_PREFIX_13) + 1) sizeof(char));
144		strcpy(opt[14], RRD_PARAM_PREFIX_13);
145		opt[15]= (char ) malloc((strlen(RRD_PARAM_PREFIX_14) + 1) sizeof(char));
146		strcpy(opt[15], RRD_PARAM_PREFIX_14);
147		opt[16]= (char ) malloc((strlen(RRD_PARAM_PREFIX_15) + 1) sizeof(char));
148		strcpy(opt[16], RRD_PARAM_PREFIX_15);
149		opt[17]= (char ) malloc((strlen(RRD_PARAM_PREFIX_16) + 1) sizeof(char));
150		strcpy(opt[17], RRD_PARAM_PREFIX_16);
151		opt[18]= (char ) malloc((strlen(RRD_PARAM_PREFIX_17) + 1) sizeof(char));
152		strcpy(opt[18], RRD_PARAM_PREFIX_17);
153		opt[19]= (char ) malloc((strlen(RRD_PARAM_PREFIX_18) + 1) sizeof(char));
154		strcpy(opt[19], RRD_PARAM_PREFIX_18);
155		opt[20]= (char ) malloc((strlen(RRD_PARAM_PREFIX_19) + 1) sizeof(char));
156		strcpy(opt[20], RRD_PARAM_PREFIX_19);
157		opt[21]= (char ) malloc((strlen(RRD_PARAM_PREFIX_20) + 1) sizeof(char));
158		strcpy(opt[21], RRD_PARAM_PREFIX_20);
159		opt[22]= (char ) malloc((strlen(RRD_PARAM_PREFIX_21) + 1) sizeof(char));
160		strcpy(opt[22], RRD_PARAM_PREFIX_21);
161		opt[23]= (char ) malloc((strlen(RRD_PARAM_PREFIX_22) + 1) sizeof(char));
162		strcpy(opt[23], RRD_PARAM_PREFIX_22);
163		opt[24]= (char ) malloc((strlen(RRD_PARAM_PREFIX_23) + 1) sizeof(char));
164		strcpy(opt[24], RRD_PARAM_PREFIX_23);
165		opt[25]= (char ) malloc((strlen(RRD_PARAM_PREFIX_24) + 1) sizeof(char));
166		strcpy(opt[25], RRD_PARAM_PREFIX_24);
167		opt[26]= (char ) malloc((strlen(RRD_PARAM_PREFIX_25) + 1) sizeof(char));
168		strcpy(opt[26], RRD_PARAM_PREFIX_25);
169		optind = opterr = 0;
170		rrd_clear_error();
171		if ( rrd_create(27,opt) < 0) {
172		syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
173		rrd_create_er_ct++;
174		} else {
175		rrd_create_ok_ct++;
176		}
177		for ( j=0; j<27; j++) {
178		free(opt[j]);
179		opt[j] = NULL;
180		}
181		}else{
182		fclose(fp);
183		rrd_already_created_ct++;
184		snprintf(buf,
185		2048,
186		"%lu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu",
187		now-300, /* or ctime(&now) with %s */
188		shmForAgg->prefixV4Tab[index][i].flowNbIN, /* 1 */
189		shmForAgg->prefixV4Tab[index][i].flowNbOUT,
190		shmForAgg->prefixV4Tab[index][i].bytesNbIN,
191		shmForAgg->prefixV4Tab[index][i].bytesNbOUT,
192		shmForAgg->prefixV4Tab[index][i].pktsNbIN, /* 5 */
193		shmForAgg->prefixV4Tab[index][i].pktsNbOUT,
194		shmForAgg->prefixV4Tab[index][i].firstCoSIN,
195		shmForAgg->prefixV4Tab[index][i].firstCoSOUT,
196		shmForAgg->prefixV4Tab[index][i].secondCoSIN,
197		shmForAgg->prefixV4Tab[index][i].secondCoSOUT,
198		shmForAgg->prefixV4Tab[index][i].thirdCoSIN,
199		shmForAgg->prefixV4Tab[index][i].thirdCoSOUT,
200		shmForAgg->prefixV4Tab[index][i].fourthCoSIN,
201		shmForAgg->prefixV4Tab[index][i].fourthCoSOUT
202		);
203		optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
204		strcpy(optUpdate[0], RRD_UPDATE_0);
205		optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
206		strcpy(optUpdate[1], name);
207		optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
208		strcpy(optUpdate[2], buf);
209		optind = opterr = 0;
210		rrd_clear_error();
211		if ( rrd_update(3, optUpdate) < 0 ) {
212		syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
213		rrd_update_er_ct++;
214		} else {
215		rrd_update_ok_ct++;
216		}
217		for ( j=0; j<3; j++) {
218		free(optUpdate[j]);
219		optUpdate[j] = NULL;
220		}
221		}
222		/* Reinit the shared tables */
223		shmForAgg->prefixV4Tab[index][i].flowNbIN = 0;
224		shmForAgg->prefixV4Tab[index][i].bytesNbIN = 0;
225		shmForAgg->prefixV4Tab[index][i].pktsNbIN = 0;
226		shmForAgg->prefixV4Tab[index][i].flowNbOUT = 0;
227		shmForAgg->prefixV4Tab[index][i].bytesNbOUT = 0;
228		shmForAgg->prefixV4Tab[index][i].pktsNbOUT = 0;
229		shmForAgg->prefixV4Tab[index][i].firstCoSIN = 0;
230		shmForAgg->prefixV4Tab[index][i].secondCoSIN = 0;
231		shmForAgg->prefixV4Tab[index][i].thirdCoSIN = 0;
232		shmForAgg->prefixV4Tab[index][i].fourthCoSIN = 0;
233		shmForAgg->prefixV4Tab[index][i].firstCoSOUT = 0;
234		shmForAgg->prefixV4Tab[index][i].secondCoSOUT = 0;
235		shmForAgg->prefixV4Tab[index][i].thirdCoSOUT = 0;
236		shmForAgg->prefixV4Tab[index][i].fourthCoSOUT = 0;
237		}
238		}
239		/* ACCOUNTING for prefixV4SubnetTab */
240		for (i=0; i<shmForAgg->v4SubnetNb; i++){
241		/* HERE create or update RRD FILE */
242		if (shmForAgg->prefixV4SubnetTab[index][i].sampling != 0) {
243		for (j=0; j<strlen(name); j++) {name[j] = '\0';}
244		for (j=0; j<strlen(createstr); j++) {createstr[j] = '\0';}
245		for (j=0; j<strlen(ipStr); j++) {ipStr[j] = '\0';}
246		for (j=0; j<strlen(buf); j++) {buf[j] = '\0';}
247		strcat(name, PREFIX_RRD_LOCATION);
248		sprintf(ipStr, "%lu_%lu_%lu_%lu_%hu_%lu",
249		shmForAgg->prefixV4SubnetTab[index][i].beginning>>24,
250		shmForAgg->prefixV4SubnetTab[index][i].beginning<<8>>24,
251		shmForAgg->prefixV4SubnetTab[index][i].beginning<<16>>24,
252		shmForAgg->prefixV4SubnetTab[index][i].beginning<<24>>24,
253		shmForAgg->prefixV4SubnetTab[index][i].mask,
254		shmForAgg->prefixV4SubnetTab[index][i].sampling
255		);
256		strcat(name, ipStr);
257		strcat(name, RRD_EXTENSION);
258		if ( (fp=fopen(name,"r")) == NULL ){
259		opt[0]= (char ) malloc((strlen(RRD_PARAM_PREFIX_0) + 1) sizeof(char));
260		strcpy(opt[0], RRD_PARAM_PREFIX_0);
261		opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
262		strcpy(opt[1], name);
263		opt[2]= (char ) malloc((strlen(RRD_PARAM_PREFIX_1) + 1) sizeof(char));
264		strcpy(opt[2], RRD_PARAM_PREFIX_1);
265		opt[3]= (char ) malloc((strlen(RRD_PARAM_PREFIX_2) + 1) sizeof(char));
266		strcpy(opt[3], RRD_PARAM_PREFIX_2);
267		opt[4]= (char ) malloc((strlen(RRD_PARAM_PREFIX_3) + 1) sizeof(char));
268		strcpy(opt[4], RRD_PARAM_PREFIX_3);
269		opt[5]= (char ) malloc((strlen(RRD_PARAM_PREFIX_4) + 1) sizeof(char));
270		strcpy(opt[5], RRD_PARAM_PREFIX_4);
271		opt[6]= (char ) malloc((strlen(RRD_PARAM_PREFIX_5) + 1) sizeof(char));
272		strcpy(opt[6], RRD_PARAM_PREFIX_5);
273		opt[7]= (char ) malloc((strlen(RRD_PARAM_PREFIX_6) + 1) sizeof(char));
274		strcpy(opt[7], RRD_PARAM_PREFIX_6);
275		opt[8]= (char ) malloc((strlen(RRD_PARAM_PREFIX_7) + 1) sizeof(char));
276		strcpy(opt[8], RRD_PARAM_PREFIX_7);
277		opt[9]= (char ) malloc((strlen(RRD_PARAM_PREFIX_8) + 1) sizeof(char));
278		strcpy(opt[9], RRD_PARAM_PREFIX_8);
279		opt[10]= (char ) malloc((strlen(RRD_PARAM_PREFIX_9) + 1) sizeof(char));
280		strcpy(opt[10], RRD_PARAM_PREFIX_9);
281		opt[11]= (char ) malloc((strlen(RRD_PARAM_PREFIX_10) + 1) sizeof(char));
282		strcpy(opt[11], RRD_PARAM_PREFIX_10);
283		opt[12]= (char ) malloc((strlen(RRD_PARAM_PREFIX_11) + 1) sizeof(char));
284		strcpy(opt[12], RRD_PARAM_PREFIX_11);
285		opt[13]= (char ) malloc((strlen(RRD_PARAM_PREFIX_12) + 1) sizeof(char));
286		strcpy(opt[13], RRD_PARAM_PREFIX_12);
287		opt[14]= (char ) malloc((strlen(RRD_PARAM_PREFIX_13) + 1) sizeof(char));
288		strcpy(opt[14], RRD_PARAM_PREFIX_13);
289		opt[15]= (char ) malloc((strlen(RRD_PARAM_PREFIX_14) + 1) sizeof(char));
290		strcpy(opt[15], RRD_PARAM_PREFIX_14);
291		opt[16]= (char ) malloc((strlen(RRD_PARAM_PREFIX_15) + 1) sizeof(char));
292		strcpy(opt[16], RRD_PARAM_PREFIX_15);
293		opt[17]= (char ) malloc((strlen(RRD_PARAM_PREFIX_16) + 1) sizeof(char));
294		strcpy(opt[17], RRD_PARAM_PREFIX_16);
295		opt[18]= (char ) malloc((strlen(RRD_PARAM_PREFIX_17) + 1) sizeof(char));
296		strcpy(opt[18], RRD_PARAM_PREFIX_17);
297		opt[19]= (char ) malloc((strlen(RRD_PARAM_PREFIX_18) + 1) sizeof(char));
298		strcpy(opt[19], RRD_PARAM_PREFIX_18);
299		opt[20]= (char ) malloc((strlen(RRD_PARAM_PREFIX_19) + 1) sizeof(char));
300		strcpy(opt[20], RRD_PARAM_PREFIX_19);
301		opt[21]= (char ) malloc((strlen(RRD_PARAM_PREFIX_20) + 1) sizeof(char));
302		strcpy(opt[21], RRD_PARAM_PREFIX_20);
303		opt[22]= (char ) malloc((strlen(RRD_PARAM_PREFIX_21) + 1) sizeof(char));
304		strcpy(opt[22], RRD_PARAM_PREFIX_21);
305		opt[23]= (char ) malloc((strlen(RRD_PARAM_PREFIX_22) + 1) sizeof(char));
306		strcpy(opt[23], RRD_PARAM_PREFIX_22);
307		opt[24]= (char ) malloc((strlen(RRD_PARAM_PREFIX_23) + 1) sizeof(char));
308		strcpy(opt[24], RRD_PARAM_PREFIX_23);
309		opt[25]= (char ) malloc((strlen(RRD_PARAM_PREFIX_24) + 1) sizeof(char));
310		strcpy(opt[25], RRD_PARAM_PREFIX_24);
311		opt[26]= (char ) malloc((strlen(RRD_PARAM_PREFIX_25) + 1) sizeof(char));
312		strcpy(opt[26], RRD_PARAM_PREFIX_25);
313		optind = opterr = 0;
314		rrd_clear_error();
315		if ( rrd_create(27,opt) < 0) {
316		syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
317		rrd_create_er_ct++;
318		} else {
319		rrd_create_ok_ct++;
320		}
321		for ( j=0; j<27; j++) {
322		free(opt[j]);
323		opt[j] = NULL;
324		}
325		}else{
326		fclose(fp);
327		rrd_already_created_ct++;
328		snprintf(buf,
329		2048,
330		"%lu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu",
331		now-300, /* or ctime(&now) with %s */
332		shmForAgg->prefixV4SubnetTab[index][i].flowNbIN, /* 1 */
333		shmForAgg->prefixV4SubnetTab[index][i].flowNbOUT,
334		shmForAgg->prefixV4SubnetTab[index][i].bytesNbIN,
335		shmForAgg->prefixV4SubnetTab[index][i].bytesNbOUT,
336		shmForAgg->prefixV4SubnetTab[index][i].pktsNbIN, /* 5 */
337		shmForAgg->prefixV4SubnetTab[index][i].pktsNbOUT,
338		shmForAgg->prefixV4SubnetTab[index][i].firstCoSIN,
339		shmForAgg->prefixV4SubnetTab[index][i].firstCoSOUT,
340		shmForAgg->prefixV4SubnetTab[index][i].secondCoSIN,
341		shmForAgg->prefixV4SubnetTab[index][i].secondCoSOUT,
342		shmForAgg->prefixV4SubnetTab[index][i].thirdCoSIN,
343		shmForAgg->prefixV4SubnetTab[index][i].thirdCoSOUT,
344		shmForAgg->prefixV4SubnetTab[index][i].fourthCoSIN,
345		shmForAgg->prefixV4SubnetTab[index][i].fourthCoSOUT
346		);
347		optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
348		strcpy(optUpdate[0], RRD_UPDATE_0);
349		optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
350		strcpy(optUpdate[1], name);
351		optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
352		strcpy(optUpdate[2], buf);
353		optind = opterr = 0;
354		rrd_clear_error();
355		if ( rrd_update(3, optUpdate) < 0 ) {
356		syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
357		rrd_update_er_ct++;
358		} else {
359		rrd_update_ok_ct++;
360		}
361		for ( j=0; j<3; j++) {
362		free(optUpdate[j]);
363		optUpdate[j] = NULL;
364		}
365		}
366		/* Reinit the shared tables */
367		shmForAgg->prefixV4SubnetTab[index][i].flowNbIN = 0;
368		shmForAgg->prefixV4SubnetTab[index][i].bytesNbIN = 0;
369		shmForAgg->prefixV4SubnetTab[index][i].pktsNbIN = 0;
370		shmForAgg->prefixV4SubnetTab[index][i].flowNbOUT = 0;
371		shmForAgg->prefixV4SubnetTab[index][i].bytesNbOUT = 0;
372		shmForAgg->prefixV4SubnetTab[index][i].pktsNbOUT = 0;
373		shmForAgg->prefixV4SubnetTab[index][i].firstCoSIN = 0;
374		shmForAgg->prefixV4SubnetTab[index][i].secondCoSIN = 0;
375		shmForAgg->prefixV4SubnetTab[index][i].thirdCoSIN = 0;
376		shmForAgg->prefixV4SubnetTab[index][i].fourthCoSIN = 0;
377		shmForAgg->prefixV4SubnetTab[index][i].firstCoSOUT = 0;
378		shmForAgg->prefixV4SubnetTab[index][i].secondCoSOUT = 0;
379		shmForAgg->prefixV4SubnetTab[index][i].thirdCoSOUT = 0;
380		shmForAgg->prefixV4SubnetTab[index][i].fourthCoSOUT = 0;
381		}
382		}
	61	static char asStr[7];
	62	static char createstr[2048];
	63	char *opt[27];
	64	char *optUpdate[3];
	65	FILE *fp;
	66	static time_t now, now2;
	67
	68	key = 8765;
	69	if ((shmid = shmget(key, SHMSIZE, 0666)) < 0)
	70	{
	71	perror("shmget");
	72	exit(1);
	73	}
	74	if ((shmForAgg = (struct SHMForAgg )shmat(shmid, (void )0, 0)) == (void *) -1)
	75	{
	76	perror("shmat");
	77	exit(1);
	78	}
	79
	80	fprintf(stderr, "renetcolAgg: I become a deamon, next messages via syslogd. Bye.\n");
	81	if (fork () != 0)
	82	exit (0);
	83	if (setsid() == -1)
	84	{
	85	exit(4);
	86	}
	87
	88	do
	89	{
	90	if (shmForAgg->readed == 1)
	91	{
	92	shmForAgg->readed = 0;
	93	if (shmForAgg->currentTable == 0)
	94	{
	95	index = 1;
	96	}
	97	else
	98	{
	99	index = 0;
	100	}
	101	now = time((time_t *)NULL);
	102	if (isFirstUpdate == 0)
	103	{
	104	/* RRD ACCOUNTING for prefixV4Tab */
	105	for (i=0; i<shmForAgg->v4PrefixNb; i++)
	106	{
	107	/* HERE create or update RRD FILE */
	108	if (shmForAgg->prefixV4Tab[index][i].sampling != 0)
	109	{
	110	for (j=0; j<strlen(name); j++)
	111	{
	112	name[j] = '\0';
	113	}
	114	for (j=0; j<strlen(createstr); j++)
	115	{
	116	createstr[j] = '\0';
	117	}
	118	for (j=0; j<strlen(ipStr); j++)
	119	{
	120	ipStr[j] = '\0';
	121	}
	122	for (j=0; j<strlen(buf); j++)
	123	{
	124	buf[j] = '\0';
	125	}
	126	strcat(name, PREFIX_RRD_LOCATION);
	127	sprintf(ipStr, "%lu_%lu_%lu_%lu_%hu_%lu",
	128	shmForAgg->prefixV4Tab[index][i].beginning>>24,
	129	shmForAgg->prefixV4Tab[index][i].beginning<<8>>24,
	130	shmForAgg->prefixV4Tab[index][i].beginning<<16>>24,
	131	shmForAgg->prefixV4Tab[index][i].beginning<<24>>24,
	132	shmForAgg->prefixV4Tab[index][i].mask,
	133	shmForAgg->prefixV4Tab[index][i].sampling
	134	);
	135	strcat(name, ipStr);
	136	strcat(name, RRD_EXTENSION);
	137	if ( (fp=fopen(name,"r")) == NULL )
	138	{
	139	opt[0]= (char ) malloc((strlen(RRD_PARAM_PREFIX_0) + 1) sizeof(char));
	140	strcpy(opt[0], RRD_PARAM_PREFIX_0);
	141	opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	142	strcpy(opt[1], name);
	143	opt[2]= (char ) malloc((strlen(RRD_PARAM_PREFIX_1) + 1) sizeof(char));
	144	strcpy(opt[2], RRD_PARAM_PREFIX_1);
	145	opt[3]= (char ) malloc((strlen(RRD_PARAM_PREFIX_2) + 1) sizeof(char));
	146	strcpy(opt[3], RRD_PARAM_PREFIX_2);
	147	opt[4]= (char ) malloc((strlen(RRD_PARAM_PREFIX_3) + 1) sizeof(char));
	148	strcpy(opt[4], RRD_PARAM_PREFIX_3);
	149	opt[5]= (char ) malloc((strlen(RRD_PARAM_PREFIX_4) + 1) sizeof(char));
	150	strcpy(opt[5], RRD_PARAM_PREFIX_4);
	151	opt[6]= (char ) malloc((strlen(RRD_PARAM_PREFIX_5) + 1) sizeof(char));
	152	strcpy(opt[6], RRD_PARAM_PREFIX_5);
	153	opt[7]= (char ) malloc((strlen(RRD_PARAM_PREFIX_6) + 1) sizeof(char));
	154	strcpy(opt[7], RRD_PARAM_PREFIX_6);
	155	opt[8]= (char ) malloc((strlen(RRD_PARAM_PREFIX_7) + 1) sizeof(char));
	156	strcpy(opt[8], RRD_PARAM_PREFIX_7);
	157	opt[9]= (char ) malloc((strlen(RRD_PARAM_PREFIX_8) + 1) sizeof(char));
	158	strcpy(opt[9], RRD_PARAM_PREFIX_8);
	159	opt[10]= (char ) malloc((strlen(RRD_PARAM_PREFIX_9) + 1) sizeof(char));
	160	strcpy(opt[10], RRD_PARAM_PREFIX_9);
	161	opt[11]= (char ) malloc((strlen(RRD_PARAM_PREFIX_10) + 1) sizeof(char));
	162	strcpy(opt[11], RRD_PARAM_PREFIX_10);
	163	opt[12]= (char ) malloc((strlen(RRD_PARAM_PREFIX_11) + 1) sizeof(char));
	164	strcpy(opt[12], RRD_PARAM_PREFIX_11);
	165	opt[13]= (char ) malloc((strlen(RRD_PARAM_PREFIX_12) + 1) sizeof(char));
	166	strcpy(opt[13], RRD_PARAM_PREFIX_12);
	167	opt[14]= (char ) malloc((strlen(RRD_PARAM_PREFIX_13) + 1) sizeof(char));
	168	strcpy(opt[14], RRD_PARAM_PREFIX_13);
	169	opt[15]= (char ) malloc((strlen(RRD_PARAM_PREFIX_14) + 1) sizeof(char));
	170	strcpy(opt[15], RRD_PARAM_PREFIX_14);
	171	opt[16]= (char ) malloc((strlen(RRD_PARAM_PREFIX_15) + 1) sizeof(char));
	172	strcpy(opt[16], RRD_PARAM_PREFIX_15);
	173	opt[17]= (char ) malloc((strlen(RRD_PARAM_PREFIX_16) + 1) sizeof(char));
	174	strcpy(opt[17], RRD_PARAM_PREFIX_16);
	175	opt[18]= (char ) malloc((strlen(RRD_PARAM_PREFIX_17) + 1) sizeof(char));
	176	strcpy(opt[18], RRD_PARAM_PREFIX_17);
	177	opt[19]= (char ) malloc((strlen(RRD_PARAM_PREFIX_18) + 1) sizeof(char));
	178	strcpy(opt[19], RRD_PARAM_PREFIX_18);
	179	opt[20]= (char ) malloc((strlen(RRD_PARAM_PREFIX_19) + 1) sizeof(char));
	180	strcpy(opt[20], RRD_PARAM_PREFIX_19);
	181	opt[21]= (char ) malloc((strlen(RRD_PARAM_PREFIX_20) + 1) sizeof(char));
	182	strcpy(opt[21], RRD_PARAM_PREFIX_20);
	183	opt[22]= (char ) malloc((strlen(RRD_PARAM_PREFIX_21) + 1) sizeof(char));
	184	strcpy(opt[22], RRD_PARAM_PREFIX_21);
	185	opt[23]= (char ) malloc((strlen(RRD_PARAM_PREFIX_22) + 1) sizeof(char));
	186	strcpy(opt[23], RRD_PARAM_PREFIX_22);
	187	opt[24]= (char ) malloc((strlen(RRD_PARAM_PREFIX_23) + 1) sizeof(char));
	188	strcpy(opt[24], RRD_PARAM_PREFIX_23);
	189	opt[25]= (char ) malloc((strlen(RRD_PARAM_PREFIX_24) + 1) sizeof(char));
	190	strcpy(opt[25], RRD_PARAM_PREFIX_24);
	191	opt[26]= (char ) malloc((strlen(RRD_PARAM_PREFIX_25) + 1) sizeof(char));
	192	strcpy(opt[26], RRD_PARAM_PREFIX_25);
	193	optind = opterr = 0;
	194	rrd_clear_error();
	195	if ( rrd_create(27,opt) < 0)
	196	{
	197	syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
	198	rrd_create_er_ct++;
	199	}
	200	else
	201	{
	202	rrd_create_ok_ct++;
	203	}
	204	for ( j=0; j<27; j++)
	205	{
	206	free(opt[j]);
	207	opt[j] = NULL;
	208	}
	209	}
	210	else
	211	{
	212	fclose(fp);
	213	rrd_already_created_ct++;
	214	snprintf(buf,
	215	2048,
	216	"%lu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu",
	217	now-300, /* or ctime(&now) with %s */
	218	shmForAgg->prefixV4Tab[index][i].flowNbIN, /* 1 */
	219	shmForAgg->prefixV4Tab[index][i].flowNbOUT,
	220	shmForAgg->prefixV4Tab[index][i].bytesNbIN,
	221	shmForAgg->prefixV4Tab[index][i].bytesNbOUT,
	222	shmForAgg->prefixV4Tab[index][i].pktsNbIN, /* 5 */
	223	shmForAgg->prefixV4Tab[index][i].pktsNbOUT,
	224	shmForAgg->prefixV4Tab[index][i].firstCoSIN,
	225	shmForAgg->prefixV4Tab[index][i].firstCoSOUT,
	226	shmForAgg->prefixV4Tab[index][i].secondCoSIN,
	227	shmForAgg->prefixV4Tab[index][i].secondCoSOUT,
	228	shmForAgg->prefixV4Tab[index][i].thirdCoSIN,
	229	shmForAgg->prefixV4Tab[index][i].thirdCoSOUT,
	230	shmForAgg->prefixV4Tab[index][i].fourthCoSIN,
	231	shmForAgg->prefixV4Tab[index][i].fourthCoSOUT
	232	);
	233	optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
	234	strcpy(optUpdate[0], RRD_UPDATE_0);
	235	optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	236	strcpy(optUpdate[1], name);
	237	optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
	238	strcpy(optUpdate[2], buf);
	239	optind = opterr = 0;
	240	rrd_clear_error();
	241	if ( rrd_update(3, optUpdate) < 0 )
	242	{
	243	syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
	244	rrd_update_er_ct++;
	245	}
	246	else
	247	{
	248	rrd_update_ok_ct++;
	249	}
	250	for ( j=0; j<3; j++)
	251	{
	252	free(optUpdate[j]);
	253	optUpdate[j] = NULL;
	254	}
	255	}
	256	/* Reinit the shared tables */
	257	shmForAgg->prefixV4Tab[index][i].flowNbIN = 0;
	258	shmForAgg->prefixV4Tab[index][i].bytesNbIN = 0;
	259	shmForAgg->prefixV4Tab[index][i].pktsNbIN = 0;
	260	shmForAgg->prefixV4Tab[index][i].flowNbOUT = 0;
	261	shmForAgg->prefixV4Tab[index][i].bytesNbOUT = 0;
	262	shmForAgg->prefixV4Tab[index][i].pktsNbOUT = 0;
	263	shmForAgg->prefixV4Tab[index][i].firstCoSIN = 0;
	264	shmForAgg->prefixV4Tab[index][i].secondCoSIN = 0;
	265	shmForAgg->prefixV4Tab[index][i].thirdCoSIN = 0;
	266	shmForAgg->prefixV4Tab[index][i].fourthCoSIN = 0;
	267	shmForAgg->prefixV4Tab[index][i].firstCoSOUT = 0;
	268	shmForAgg->prefixV4Tab[index][i].secondCoSOUT = 0;
	269	shmForAgg->prefixV4Tab[index][i].thirdCoSOUT = 0;
	270	shmForAgg->prefixV4Tab[index][i].fourthCoSOUT = 0;
	271	}
	272	}
	273	/* ACCOUNTING for prefixV4SubnetTab */
	274	for (i=0; i<shmForAgg->v4SubnetNb; i++)
	275	{
	276	/* HERE create or update RRD FILE */
	277	if (shmForAgg->prefixV4SubnetTab[index][i].sampling != 0)
	278	{
	279	for (j=0; j<strlen(name); j++)
	280	{
	281	name[j] = '\0';
	282	}
	283	for (j=0; j<strlen(createstr); j++)
	284	{
	285	createstr[j] = '\0';
	286	}
	287	for (j=0; j<strlen(ipStr); j++)
	288	{
	289	ipStr[j] = '\0';
	290	}
	291	for (j=0; j<strlen(buf); j++)
	292	{
	293	buf[j] = '\0';
	294	}
	295	strcat(name, PREFIX_RRD_LOCATION);
	296	sprintf(ipStr, "%lu_%lu_%lu_%lu_%hu_%lu",
	297	shmForAgg->prefixV4SubnetTab[index][i].beginning>>24,
	298	shmForAgg->prefixV4SubnetTab[index][i].beginning<<8>>24,
	299	shmForAgg->prefixV4SubnetTab[index][i].beginning<<16>>24,
	300	shmForAgg->prefixV4SubnetTab[index][i].beginning<<24>>24,
	301	shmForAgg->prefixV4SubnetTab[index][i].mask,
	302	shmForAgg->prefixV4SubnetTab[index][i].sampling
	303	);
	304	strcat(name, ipStr);
	305	strcat(name, RRD_EXTENSION);
	306	if ( (fp=fopen(name,"r")) == NULL )
	307	{
	308	opt[0]= (char ) malloc((strlen(RRD_PARAM_PREFIX_0) + 1) sizeof(char));
	309	strcpy(opt[0], RRD_PARAM_PREFIX_0);
	310	opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	311	strcpy(opt[1], name);
	312	opt[2]= (char ) malloc((strlen(RRD_PARAM_PREFIX_1) + 1) sizeof(char));
	313	strcpy(opt[2], RRD_PARAM_PREFIX_1);
	314	opt[3]= (char ) malloc((strlen(RRD_PARAM_PREFIX_2) + 1) sizeof(char));
	315	strcpy(opt[3], RRD_PARAM_PREFIX_2);
	316	opt[4]= (char ) malloc((strlen(RRD_PARAM_PREFIX_3) + 1) sizeof(char));
	317	strcpy(opt[4], RRD_PARAM_PREFIX_3);
	318	opt[5]= (char ) malloc((strlen(RRD_PARAM_PREFIX_4) + 1) sizeof(char));
	319	strcpy(opt[5], RRD_PARAM_PREFIX_4);
	320	opt[6]= (char ) malloc((strlen(RRD_PARAM_PREFIX_5) + 1) sizeof(char));
	321	strcpy(opt[6], RRD_PARAM_PREFIX_5);
	322	opt[7]= (char ) malloc((strlen(RRD_PARAM_PREFIX_6) + 1) sizeof(char));
	323	strcpy(opt[7], RRD_PARAM_PREFIX_6);
	324	opt[8]= (char ) malloc((strlen(RRD_PARAM_PREFIX_7) + 1) sizeof(char));
	325	strcpy(opt[8], RRD_PARAM_PREFIX_7);
	326	opt[9]= (char ) malloc((strlen(RRD_PARAM_PREFIX_8) + 1) sizeof(char));
	327	strcpy(opt[9], RRD_PARAM_PREFIX_8);
	328	opt[10]= (char ) malloc((strlen(RRD_PARAM_PREFIX_9) + 1) sizeof(char));
	329	strcpy(opt[10], RRD_PARAM_PREFIX_9);
	330	opt[11]= (char ) malloc((strlen(RRD_PARAM_PREFIX_10) + 1) sizeof(char));
	331	strcpy(opt[11], RRD_PARAM_PREFIX_10);
	332	opt[12]= (char ) malloc((strlen(RRD_PARAM_PREFIX_11) + 1) sizeof(char));
	333	strcpy(opt[12], RRD_PARAM_PREFIX_11);
	334	opt[13]= (char ) malloc((strlen(RRD_PARAM_PREFIX_12) + 1) sizeof(char));
	335	strcpy(opt[13], RRD_PARAM_PREFIX_12);
	336	opt[14]= (char ) malloc((strlen(RRD_PARAM_PREFIX_13) + 1) sizeof(char));
	337	strcpy(opt[14], RRD_PARAM_PREFIX_13);
	338	opt[15]= (char ) malloc((strlen(RRD_PARAM_PREFIX_14) + 1) sizeof(char));
	339	strcpy(opt[15], RRD_PARAM_PREFIX_14);
	340	opt[16]= (char ) malloc((strlen(RRD_PARAM_PREFIX_15) + 1) sizeof(char));
	341	strcpy(opt[16], RRD_PARAM_PREFIX_15);
	342	opt[17]= (char ) malloc((strlen(RRD_PARAM_PREFIX_16) + 1) sizeof(char));
	343	strcpy(opt[17], RRD_PARAM_PREFIX_16);
	344	opt[18]= (char ) malloc((strlen(RRD_PARAM_PREFIX_17) + 1) sizeof(char));
	345	strcpy(opt[18], RRD_PARAM_PREFIX_17);
	346	opt[19]= (char ) malloc((strlen(RRD_PARAM_PREFIX_18) + 1) sizeof(char));
	347	strcpy(opt[19], RRD_PARAM_PREFIX_18);
	348	opt[20]= (char ) malloc((strlen(RRD_PARAM_PREFIX_19) + 1) sizeof(char));
	349	strcpy(opt[20], RRD_PARAM_PREFIX_19);
	350	opt[21]= (char ) malloc((strlen(RRD_PARAM_PREFIX_20) + 1) sizeof(char));
	351	strcpy(opt[21], RRD_PARAM_PREFIX_20);
	352	opt[22]= (char ) malloc((strlen(RRD_PARAM_PREFIX_21) + 1) sizeof(char));
	353	strcpy(opt[22], RRD_PARAM_PREFIX_21);
	354	opt[23]= (char ) malloc((strlen(RRD_PARAM_PREFIX_22) + 1) sizeof(char));
	355	strcpy(opt[23], RRD_PARAM_PREFIX_22);
	356	opt[24]= (char ) malloc((strlen(RRD_PARAM_PREFIX_23) + 1) sizeof(char));
	357	strcpy(opt[24], RRD_PARAM_PREFIX_23);
	358	opt[25]= (char ) malloc((strlen(RRD_PARAM_PREFIX_24) + 1) sizeof(char));
	359	strcpy(opt[25], RRD_PARAM_PREFIX_24);
	360	opt[26]= (char ) malloc((strlen(RRD_PARAM_PREFIX_25) + 1) sizeof(char));
	361	strcpy(opt[26], RRD_PARAM_PREFIX_25);
	362	optind = opterr = 0;
	363	rrd_clear_error();
	364	if ( rrd_create(27,opt) < 0)
	365	{
	366	syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
	367	rrd_create_er_ct++;
	368	}
	369	else
	370	{
	371	rrd_create_ok_ct++;
	372	}
	373	for ( j=0; j<27; j++)
	374	{
	375	free(opt[j]);
	376	opt[j] = NULL;
	377	}
	378	}
	379	else
	380	{
	381	fclose(fp);
	382	rrd_already_created_ct++;
	383	snprintf(buf,
	384	2048,
	385	"%lu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu",
	386	now-300, /* or ctime(&now) with %s */
	387	shmForAgg->prefixV4SubnetTab[index][i].flowNbIN, /* 1 */
	388	shmForAgg->prefixV4SubnetTab[index][i].flowNbOUT,
	389	shmForAgg->prefixV4SubnetTab[index][i].bytesNbIN,
	390	shmForAgg->prefixV4SubnetTab[index][i].bytesNbOUT,
	391	shmForAgg->prefixV4SubnetTab[index][i].pktsNbIN, /* 5 */
	392	shmForAgg->prefixV4SubnetTab[index][i].pktsNbOUT,
	393	shmForAgg->prefixV4SubnetTab[index][i].firstCoSIN,
	394	shmForAgg->prefixV4SubnetTab[index][i].firstCoSOUT,
	395	shmForAgg->prefixV4SubnetTab[index][i].secondCoSIN,
	396	shmForAgg->prefixV4SubnetTab[index][i].secondCoSOUT,
	397	shmForAgg->prefixV4SubnetTab[index][i].thirdCoSIN,
	398	shmForAgg->prefixV4SubnetTab[index][i].thirdCoSOUT,
	399	shmForAgg->prefixV4SubnetTab[index][i].fourthCoSIN,
	400	shmForAgg->prefixV4SubnetTab[index][i].fourthCoSOUT
	401	);
	402	optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
	403	strcpy(optUpdate[0], RRD_UPDATE_0);
	404	optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	405	strcpy(optUpdate[1], name);
	406	optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
	407	strcpy(optUpdate[2], buf);
	408	optind = opterr = 0;
	409	rrd_clear_error();
	410	if ( rrd_update(3, optUpdate) < 0 )
	411	{
	412	syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
	413	rrd_update_er_ct++;
	414	}
	415	else
	416	{
	417	rrd_update_ok_ct++;
	418	}
	419	for ( j=0; j<3; j++)
	420	{
	421	free(optUpdate[j]);
	422	optUpdate[j] = NULL;
	423	}
	424	}
	425	/* Reinit the shared tables */
	426	shmForAgg->prefixV4SubnetTab[index][i].flowNbIN = 0;
	427	shmForAgg->prefixV4SubnetTab[index][i].bytesNbIN = 0;
	428	shmForAgg->prefixV4SubnetTab[index][i].pktsNbIN = 0;
	429	shmForAgg->prefixV4SubnetTab[index][i].flowNbOUT = 0;
	430	shmForAgg->prefixV4SubnetTab[index][i].bytesNbOUT = 0;
	431	shmForAgg->prefixV4SubnetTab[index][i].pktsNbOUT = 0;
	432	shmForAgg->prefixV4SubnetTab[index][i].firstCoSIN = 0;
	433	shmForAgg->prefixV4SubnetTab[index][i].secondCoSIN = 0;
	434	shmForAgg->prefixV4SubnetTab[index][i].thirdCoSIN = 0;
	435	shmForAgg->prefixV4SubnetTab[index][i].fourthCoSIN = 0;
	436	shmForAgg->prefixV4SubnetTab[index][i].firstCoSOUT = 0;
	437	shmForAgg->prefixV4SubnetTab[index][i].secondCoSOUT = 0;
	438	shmForAgg->prefixV4SubnetTab[index][i].thirdCoSOUT = 0;
	439	shmForAgg->prefixV4SubnetTab[index][i].fourthCoSOUT = 0;
	440	}
	441	}
383	442	#if defined(MATRIX) && defined(IPV4AGGIDR)
384		/* MATRIX INTER POP ACCOUNTING */
385		/* rrd */
386		for (i=0; i<ROUTER_INDEX_MAX; i++){
387		for (j=0; j<ROUTER_INDEX_MAX; j++){
388		/* HERE create or update RRD FILE */
389		for (k=0; k<strlen(name); k++) {name[k] = '\0';}
390		for (k=0; k<strlen(createstr); k++) {createstr[k] = '\0';}
391		for (k=0; k<strlen(indexStr); k++) {indexStr[k] = '\0';}
392		for (k=0; k<strlen(buf); k++) {buf[k] = '\0';}
393		strcat(name, MATRIX_RRD_LOCATION);
394		sprintf(indexStr, "%d_%d",
395		i,
396		j
397		);
398		strcat(name, indexStr);
399		strcat(name, RRD_EXTENSION);
400		if ( (fp=fopen(name,"r")) == NULL ){
401		opt[0]= (char ) malloc((strlen(RRD_PARAM_MATRIX_0) + 1) sizeof(char));
402		strcpy(opt[0], RRD_PARAM_MATRIX_0);
403		opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
404		strcpy(opt[1], name);
405		opt[2]= (char ) malloc((strlen(RRD_PARAM_MATRIX_1) + 1) sizeof(char));
406		strcpy(opt[2], RRD_PARAM_MATRIX_1);
407		opt[3]= (char ) malloc((strlen(RRD_PARAM_MATRIX_2) + 1) sizeof(char));
408		strcpy(opt[3], RRD_PARAM_MATRIX_2);
409		opt[4]= (char ) malloc((strlen(RRD_PARAM_MATRIX_3) + 1) sizeof(char));
410		strcpy(opt[4], RRD_PARAM_MATRIX_3);
411		opt[5]= (char ) malloc((strlen(RRD_PARAM_MATRIX_4) + 1) sizeof(char));
412		strcpy(opt[5], RRD_PARAM_MATRIX_4);
413		opt[6]= (char ) malloc((strlen(RRD_PARAM_MATRIX_5) + 1) sizeof(char));
414		strcpy(opt[6], RRD_PARAM_MATRIX_5);
415		opt[7]= (char ) malloc((strlen(RRD_PARAM_MATRIX_6) + 1) sizeof(char));
416		strcpy(opt[7], RRD_PARAM_MATRIX_6);
417		opt[8]= (char ) malloc((strlen(RRD_PARAM_MATRIX_7) + 1) sizeof(char));
418		strcpy(opt[8], RRD_PARAM_MATRIX_7);
419		opt[9]= (char ) malloc((strlen(RRD_PARAM_MATRIX_8) + 1) sizeof(char));
420		strcpy(opt[9], RRD_PARAM_MATRIX_8);
421		opt[10]= (char ) malloc((strlen(RRD_PARAM_MATRIX_9) + 1) sizeof(char));
422		strcpy(opt[10], RRD_PARAM_MATRIX_9);
423		opt[11]= (char ) malloc((strlen(RRD_PARAM_MATRIX_10) + 1) sizeof(char));
424		strcpy(opt[11], RRD_PARAM_MATRIX_10);
425		opt[12]= (char ) malloc((strlen(RRD_PARAM_MATRIX_11) + 1) sizeof(char));
426		strcpy(opt[12], RRD_PARAM_MATRIX_11);
427		opt[13]= (char ) malloc((strlen(RRD_PARAM_MATRIX_12) + 1) sizeof(char));
428		strcpy(opt[13], RRD_PARAM_MATRIX_12);
429		opt[14]= (char ) malloc((strlen(RRD_PARAM_MATRIX_13) + 1) sizeof(char));
430		strcpy(opt[14], RRD_PARAM_MATRIX_13);
431		opt[15]= (char ) malloc((strlen(RRD_PARAM_MATRIX_14) + 1) sizeof(char));
432		strcpy(opt[15], RRD_PARAM_MATRIX_14);
433		optind = opterr = 0;
434		rrd_clear_error();
435		if ( rrd_create(16,opt) < 0) {
436		syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
437		rrd_create_er_ct++;
438		} else {
439		rrd_create_ok_ct++;
440		}
441		for ( k=0; k<16; k++) {
442		free(opt[k]);
443		opt[k] = NULL;
444		}
445		}else{
446		fclose(fp);
447		rrd_already_created_ct++;
448		snprintf(buf,
449		2048,
450		"%lu:%llu:%llu:%llu",
451		now-300, /* or ctime(&now) with %s */
452		shmForAgg->matrixPOP[index][i][j].flowNb,
453		shmForAgg->matrixPOP[index][i][j].bytesNb,
454		shmForAgg->matrixPOP[index][i][j].pktsNb
455		);
456		optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
457		strcpy(optUpdate[0], RRD_UPDATE_0);
458		optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
459		strcpy(optUpdate[1], name);
460		optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
461		strcpy(optUpdate[2], buf);
462		optind = opterr = 0;
463		rrd_clear_error();
464		if ( rrd_update(3, optUpdate) < 0 ) {
465		syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
466		rrd_update_er_ct++;
467		} else {
468		rrd_update_ok_ct++;
469		}
470		for ( k=0; k<3; k++) {
471		free(optUpdate[k]);
472		optUpdate[k] = NULL;
473		}
474		}
475
476		}
477		}
478		/* reinit */
479		for (i=0; i<ROUTER_INDEX_MAX; i++){
480		for (j=0; j<ROUTER_INDEX_MAX; j++) {
481		shmForAgg->matrixPOP[index][i][j].bytesNb = 0;
482		shmForAgg->matrixPOP[index][i][j].pktsNb = 0;
483		shmForAgg->matrixPOP[index][i][j].flowNb = 0;
484		}
485		}
486		/* END MATRIX INTER POP ACC */
	443	/* MATRIX INTER POP ACCOUNTING */
	444	/* rrd */
	445	for (i=0; i<ROUTER_INDEX_MAX; i++)
	446	{
	447	for (j=0; j<ROUTER_INDEX_MAX; j++)
	448	{
	449	/* HERE create or update RRD FILE */
	450	for (k=0; k<strlen(name); k++)
	451	{
	452	name[k] = '\0';
	453	}
	454	for (k=0; k<strlen(createstr); k++)
	455	{
	456	createstr[k] = '\0';
	457	}
	458	for (k=0; k<strlen(indexStr); k++)
	459	{
	460	indexStr[k] = '\0';
	461	}
	462	for (k=0; k<strlen(buf); k++)
	463	{
	464	buf[k] = '\0';
	465	}
	466	strcat(name, MATRIX_RRD_LOCATION);
	467	sprintf(indexStr, "%d_%d",
	468	i,
	469	j
	470	);
	471	strcat(name, indexStr);
	472	strcat(name, RRD_EXTENSION);
	473	if ( (fp=fopen(name,"r")) == NULL )
	474	{
	475	opt[0]= (char ) malloc((strlen(RRD_PARAM_MATRIX_0) + 1) sizeof(char));
	476	strcpy(opt[0], RRD_PARAM_MATRIX_0);
	477	opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	478	strcpy(opt[1], name);
	479	opt[2]= (char ) malloc((strlen(RRD_PARAM_MATRIX_1) + 1) sizeof(char));
	480	strcpy(opt[2], RRD_PARAM_MATRIX_1);
	481	opt[3]= (char ) malloc((strlen(RRD_PARAM_MATRIX_2) + 1) sizeof(char));
	482	strcpy(opt[3], RRD_PARAM_MATRIX_2);
	483	opt[4]= (char ) malloc((strlen(RRD_PARAM_MATRIX_3) + 1) sizeof(char));
	484	strcpy(opt[4], RRD_PARAM_MATRIX_3);
	485	opt[5]= (char ) malloc((strlen(RRD_PARAM_MATRIX_4) + 1) sizeof(char));
	486	strcpy(opt[5], RRD_PARAM_MATRIX_4);
	487	opt[6]= (char ) malloc((strlen(RRD_PARAM_MATRIX_5) + 1) sizeof(char));
	488	strcpy(opt[6], RRD_PARAM_MATRIX_5);
	489	opt[7]= (char ) malloc((strlen(RRD_PARAM_MATRIX_6) + 1) sizeof(char));
	490	strcpy(opt[7], RRD_PARAM_MATRIX_6);
	491	opt[8]= (char ) malloc((strlen(RRD_PARAM_MATRIX_7) + 1) sizeof(char));
	492	strcpy(opt[8], RRD_PARAM_MATRIX_7);
	493	opt[9]= (char ) malloc((strlen(RRD_PARAM_MATRIX_8) + 1) sizeof(char));
	494	strcpy(opt[9], RRD_PARAM_MATRIX_8);
	495	opt[10]= (char ) malloc((strlen(RRD_PARAM_MATRIX_9) + 1) sizeof(char));
	496	strcpy(opt[10], RRD_PARAM_MATRIX_9);
	497	opt[11]= (char ) malloc((strlen(RRD_PARAM_MATRIX_10) + 1) sizeof(char));
	498	strcpy(opt[11], RRD_PARAM_MATRIX_10);
	499	opt[12]= (char ) malloc((strlen(RRD_PARAM_MATRIX_11) + 1) sizeof(char));
	500	strcpy(opt[12], RRD_PARAM_MATRIX_11);
	501	opt[13]= (char ) malloc((strlen(RRD_PARAM_MATRIX_12) + 1) sizeof(char));
	502	strcpy(opt[13], RRD_PARAM_MATRIX_12);
	503	opt[14]= (char ) malloc((strlen(RRD_PARAM_MATRIX_13) + 1) sizeof(char));
	504	strcpy(opt[14], RRD_PARAM_MATRIX_13);
	505	opt[15]= (char ) malloc((strlen(RRD_PARAM_MATRIX_14) + 1) sizeof(char));
	506	strcpy(opt[15], RRD_PARAM_MATRIX_14);
	507	optind = opterr = 0;
	508	rrd_clear_error();
	509	if ( rrd_create(16,opt) < 0)
	510	{
	511	syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
	512	rrd_create_er_ct++;
	513	}
	514	else
	515	{
	516	rrd_create_ok_ct++;
	517	}
	518	for ( k=0; k<16; k++)
	519	{
	520	free(opt[k]);
	521	opt[k] = NULL;
	522	}
	523	}
	524	else
	525	{
	526	fclose(fp);
	527	rrd_already_created_ct++;
	528	snprintf(buf,
	529	2048,
	530	"%lu:%llu:%llu:%llu",
	531	now-300, /* or ctime(&now) with %s */
	532	shmForAgg->matrixPOP[index][i][j].flowNb,
	533	shmForAgg->matrixPOP[index][i][j].bytesNb,
	534	shmForAgg->matrixPOP[index][i][j].pktsNb
	535	);
	536	optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
	537	strcpy(optUpdate[0], RRD_UPDATE_0);
	538	optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	539	strcpy(optUpdate[1], name);
	540	optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
	541	strcpy(optUpdate[2], buf);
	542	optind = opterr = 0;
	543	rrd_clear_error();
	544	if ( rrd_update(3, optUpdate) < 0 )
	545	{
	546	syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
	547	rrd_update_er_ct++;
	548	}
	549	else
	550	{
	551	rrd_update_ok_ct++;
	552	}
	553	for ( k=0; k<3; k++)
	554	{
	555	free(optUpdate[k]);
	556	optUpdate[k] = NULL;
	557	}
	558	}
	559
	560	}
	561	}
	562	/* reinit */
	563	for (i=0; i<ROUTER_INDEX_MAX; i++)
	564	{
	565	for (j=0; j<ROUTER_INDEX_MAX; j++)
	566	{
	567	shmForAgg->matrixPOP[index][i][j].bytesNb = 0;
	568	shmForAgg->matrixPOP[index][i][j].pktsNb = 0;
	569	shmForAgg->matrixPOP[index][i][j].flowNb = 0;
	570	}
	571	}
	572	/* END MATRIX INTER POP ACC */
487	573	#endif /* MATRIX */
488	574	#ifdef ASACC
489		/*
490		*
491		* AS ACCOUNTING
492		*
493		*/
494		for (i=0; i<shmForAgg->ASNb; i++){
495		/* HERE create or update RRD FILE */
496		if (shmForAgg->ASTab[index][i].sampling != 0) {
497		for (j=0; j<strlen(name); j++) {name[j] = '\0';}
498		for (j=0; j<strlen(createstr); j++) {createstr[j] = '\0';}
499		for (j=0; j<strlen(asStr); j++) {asStr[j] = '\0';}
500		for (j=0; j<strlen(buf); j++) {buf[j] = '\0';}
501		strcat(name, AS_RRD_LOCATION);
502		sprintf(asStr, "%hu_%lu",
503		shmForAgg->ASTab[index][i].as,
504		shmForAgg->ASTab[index][i].sampling
505		);
506		strcat(name, asStr);
507		strcat(name, RRD_EXTENSION);
508		if ( (fp=fopen(name,"r")) == NULL ){
509		opt[0]= (char ) malloc((strlen(RRD_PARAM_AS_0) + 1) sizeof(char));
510		strcpy(opt[0], RRD_PARAM_AS_0);
511		opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
512		strcpy(opt[1], name);
513		opt[2]= (char ) malloc((strlen(RRD_PARAM_AS_1) + 1) sizeof(char));
514		strcpy(opt[2], RRD_PARAM_AS_1);
515		opt[3]= (char ) malloc((strlen(RRD_PARAM_AS_2) + 1) sizeof(char));
516		strcpy(opt[3], RRD_PARAM_AS_2);
517		opt[4]= (char ) malloc((strlen(RRD_PARAM_AS_3) + 1) sizeof(char));
518		strcpy(opt[4], RRD_PARAM_AS_3);
519		opt[5]= (char ) malloc((strlen(RRD_PARAM_AS_4) + 1) sizeof(char));
520		strcpy(opt[5], RRD_PARAM_AS_4);
521		opt[6]= (char ) malloc((strlen(RRD_PARAM_AS_5) + 1) sizeof(char));
522		strcpy(opt[6], RRD_PARAM_AS_5);
523		opt[7]= (char ) malloc((strlen(RRD_PARAM_AS_6) + 1) sizeof(char));
524		strcpy(opt[7], RRD_PARAM_AS_6);
525		opt[8]= (char ) malloc((strlen(RRD_PARAM_AS_7) + 1) sizeof(char));
526		strcpy(opt[8], RRD_PARAM_AS_7);
527		opt[9]= (char ) malloc((strlen(RRD_PARAM_AS_8) + 1) sizeof(char));
528		strcpy(opt[9], RRD_PARAM_AS_8);
529		opt[10]= (char ) malloc((strlen(RRD_PARAM_AS_9) + 1) sizeof(char));
530		strcpy(opt[10], RRD_PARAM_AS_9);
531		opt[11]= (char ) malloc((strlen(RRD_PARAM_AS_10) + 1) sizeof(char));
532		strcpy(opt[11], RRD_PARAM_AS_10);
533		opt[12]= (char ) malloc((strlen(RRD_PARAM_AS_11) + 1) sizeof(char));
534		strcpy(opt[12], RRD_PARAM_AS_11);
535		opt[13]= (char ) malloc((strlen(RRD_PARAM_AS_12) + 1) sizeof(char));
536		strcpy(opt[13], RRD_PARAM_AS_12);
537		opt[14]= (char ) malloc((strlen(RRD_PARAM_AS_13) + 1) sizeof(char));
538		strcpy(opt[14], RRD_PARAM_AS_13);
539		opt[15]= (char ) malloc((strlen(RRD_PARAM_AS_14) + 1) sizeof(char));
540		strcpy(opt[15], RRD_PARAM_AS_14);
541		opt[16]= (char ) malloc((strlen(RRD_PARAM_AS_15) + 1) sizeof(char));
542		strcpy(opt[16], RRD_PARAM_AS_15);
543		opt[17]= (char ) malloc((strlen(RRD_PARAM_AS_16) + 1) sizeof(char));
544		strcpy(opt[17], RRD_PARAM_AS_16);
545		opt[18]= (char ) malloc((strlen(RRD_PARAM_AS_17) + 1) sizeof(char));
546		strcpy(opt[18], RRD_PARAM_AS_17);
547		optind = opterr = 0;
548		rrd_clear_error();
549		if ( rrd_create(19,opt) < 0) {
550		syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
551		rrd_create_er_ct++;
552		} else {
553		rrd_create_ok_ct++;
554		}
555		for ( j=0; j<19; j++) {
556		free(opt[j]);
557		opt[j] = NULL;
558		}
559		}else{
560		fclose(fp);
561		rrd_already_created_ct++;
562		snprintf(buf,
563		2048,
564		"%lu:%llu:%llu:%llu:%llu:%llu:%llu",
565		now-300, /* or ctime(&now) with %s */
566		shmForAgg->ASTab[index][i].flowNbIN, /* 1 */
567		shmForAgg->ASTab[index][i].flowNbOUT,
568		shmForAgg->ASTab[index][i].bytesNbIN,
569		shmForAgg->ASTab[index][i].bytesNbOUT,
570		shmForAgg->ASTab[index][i].pktsNbIN, /* 5 */
571		shmForAgg->ASTab[index][i].pktsNbOUT
572		);
573		optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
574		strcpy(optUpdate[0], RRD_UPDATE_0);
575		optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
576		strcpy(optUpdate[1], name);
577		optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
578		strcpy(optUpdate[2], buf);
579		optind = opterr = 0;
580		rrd_clear_error();
581		if ( rrd_update(3, optUpdate) < 0 ) {
582		syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
583		rrd_update_er_ct++;
584		} else {
585		rrd_update_ok_ct++;
586		}
587		for ( j=0; j<3; j++) {
588		free(optUpdate[j]);
589		optUpdate[j] = NULL;
590		}
591		}
592		/* Reinit the shared tables */
593		shmForAgg->ASTab[index][i].flowNbIN = 0;
594		shmForAgg->ASTab[index][i].bytesNbIN = 0;
595		shmForAgg->ASTab[index][i].pktsNbIN = 0;
596		shmForAgg->ASTab[index][i].flowNbOUT = 0;
597		shmForAgg->ASTab[index][i].bytesNbOUT = 0;
598		shmForAgg->ASTab[index][i].pktsNbOUT = 0;
599		}
600		}
	575	/*
	576	*
	577	* AS ACCOUNTING
	578	*
	579	*/
	580	for (i=0; i<shmForAgg->ASNb; i++)
	581	{
	582	/* HERE create or update RRD FILE */
	583	if (shmForAgg->ASTab[index][i].sampling != 0)
	584	{
	585	for (j=0; j<strlen(name); j++)
	586	{
	587	name[j] = '\0';
	588	}
	589	for (j=0; j<strlen(createstr); j++)
	590	{
	591	createstr[j] = '\0';
	592	}
	593	for (j=0; j<strlen(asStr); j++)
	594	{
	595	asStr[j] = '\0';
	596	}
	597	for (j=0; j<strlen(buf); j++)
	598	{
	599	buf[j] = '\0';
	600	}
	601	strcat(name, AS_RRD_LOCATION);
	602	sprintf(asStr, "%hu_%lu",
	603	shmForAgg->ASTab[index][i].as,
	604	shmForAgg->ASTab[index][i].sampling
	605	);
	606	strcat(name, asStr);
	607	strcat(name, RRD_EXTENSION);
	608	if ( (fp=fopen(name,"r")) == NULL )
	609	{
	610	opt[0]= (char ) malloc((strlen(RRD_PARAM_AS_0) + 1) sizeof(char));
	611	strcpy(opt[0], RRD_PARAM_AS_0);
	612	opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	613	strcpy(opt[1], name);
	614	opt[2]= (char ) malloc((strlen(RRD_PARAM_AS_1) + 1) sizeof(char));
	615	strcpy(opt[2], RRD_PARAM_AS_1);
	616	opt[3]= (char ) malloc((strlen(RRD_PARAM_AS_2) + 1) sizeof(char));
	617	strcpy(opt[3], RRD_PARAM_AS_2);
	618	opt[4]= (char ) malloc((strlen(RRD_PARAM_AS_3) + 1) sizeof(char));
	619	strcpy(opt[4], RRD_PARAM_AS_3);
	620	opt[5]= (char ) malloc((strlen(RRD_PARAM_AS_4) + 1) sizeof(char));
	621	strcpy(opt[5], RRD_PARAM_AS_4);
	622	opt[6]= (char ) malloc((strlen(RRD_PARAM_AS_5) + 1) sizeof(char));
	623	strcpy(opt[6], RRD_PARAM_AS_5);
	624	opt[7]= (char ) malloc((strlen(RRD_PARAM_AS_6) + 1) sizeof(char));
	625	strcpy(opt[7], RRD_PARAM_AS_6);
	626	opt[8]= (char ) malloc((strlen(RRD_PARAM_AS_7) + 1) sizeof(char));
	627	strcpy(opt[8], RRD_PARAM_AS_7);
	628	opt[9]= (char ) malloc((strlen(RRD_PARAM_AS_8) + 1) sizeof(char));
	629	strcpy(opt[9], RRD_PARAM_AS_8);
	630	opt[10]= (char ) malloc((strlen(RRD_PARAM_AS_9) + 1) sizeof(char));
	631	strcpy(opt[10], RRD_PARAM_AS_9);
	632	opt[11]= (char ) malloc((strlen(RRD_PARAM_AS_10) + 1) sizeof(char));
	633	strcpy(opt[11], RRD_PARAM_AS_10);
	634	opt[12]= (char ) malloc((strlen(RRD_PARAM_AS_11) + 1) sizeof(char));
	635	strcpy(opt[12], RRD_PARAM_AS_11);
	636	opt[13]= (char ) malloc((strlen(RRD_PARAM_AS_12) + 1) sizeof(char));
	637	strcpy(opt[13], RRD_PARAM_AS_12);
	638	opt[14]= (char ) malloc((strlen(RRD_PARAM_AS_13) + 1) sizeof(char));
	639	strcpy(opt[14], RRD_PARAM_AS_13);
	640	opt[15]= (char ) malloc((strlen(RRD_PARAM_AS_14) + 1) sizeof(char));
	641	strcpy(opt[15], RRD_PARAM_AS_14);
	642	opt[16]= (char ) malloc((strlen(RRD_PARAM_AS_15) + 1) sizeof(char));
	643	strcpy(opt[16], RRD_PARAM_AS_15);
	644	opt[17]= (char ) malloc((strlen(RRD_PARAM_AS_16) + 1) sizeof(char));
	645	strcpy(opt[17], RRD_PARAM_AS_16);
	646	opt[18]= (char ) malloc((strlen(RRD_PARAM_AS_17) + 1) sizeof(char));
	647	strcpy(opt[18], RRD_PARAM_AS_17);
	648	optind = opterr = 0;
	649	rrd_clear_error();
	650	if ( rrd_create(19,opt) < 0)
	651	{
	652	syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
	653	rrd_create_er_ct++;
	654	}
	655	else
	656	{
	657	rrd_create_ok_ct++;
	658	}
	659	for ( j=0; j<19; j++)
	660	{
	661	free(opt[j]);
	662	opt[j] = NULL;
	663	}
	664	}
	665	else
	666	{
	667	fclose(fp);
	668	rrd_already_created_ct++;
	669	snprintf(buf,
	670	2048,
	671	"%lu:%llu:%llu:%llu:%llu:%llu:%llu",
	672	now-300, /* or ctime(&now) with %s */
	673	shmForAgg->ASTab[index][i].flowNbIN, /* 1 */
	674	shmForAgg->ASTab[index][i].flowNbOUT,
	675	shmForAgg->ASTab[index][i].bytesNbIN,
	676	shmForAgg->ASTab[index][i].bytesNbOUT,
	677	shmForAgg->ASTab[index][i].pktsNbIN, /* 5 */
	678	shmForAgg->ASTab[index][i].pktsNbOUT
	679	);
	680	optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
	681	strcpy(optUpdate[0], RRD_UPDATE_0);
	682	optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	683	strcpy(optUpdate[1], name);
	684	optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
	685	strcpy(optUpdate[2], buf);
	686	optind = opterr = 0;
	687	rrd_clear_error();
	688	if ( rrd_update(3, optUpdate) < 0 )
	689	{
	690	syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
	691	rrd_update_er_ct++;
	692	}
	693	else
	694	{
	695	rrd_update_ok_ct++;
	696	}
	697	for ( j=0; j<3; j++)
	698	{
	699	free(optUpdate[j]);
	700	optUpdate[j] = NULL;
	701	}
	702	}
	703	/* Reinit the shared tables */
	704	shmForAgg->ASTab[index][i].flowNbIN = 0;
	705	shmForAgg->ASTab[index][i].bytesNbIN = 0;
	706	shmForAgg->ASTab[index][i].pktsNbIN = 0;
	707	shmForAgg->ASTab[index][i].flowNbOUT = 0;
	708	shmForAgg->ASTab[index][i].bytesNbOUT = 0;
	709	shmForAgg->ASTab[index][i].pktsNbOUT = 0;
	710	}
	711	}
601	712	#ifdef IPV6LINKAGG
602		/*
603		*
604		* IPv6 Links ACCOUNTING
605		*
606		*/
607		for (i=0; i<ROUTER_INDEX_MAX; i++){
608		for (j=0; j<MAX_INDEX_BY_ROUTER; j++) {
609		/* HERE create or update RRD FILE for IPV6 LINKs AGGregation */
610		if (shmForAgg->indexV6Tab[index][i][j].hasStats == 1) {
611		for (k=0; k<strlen(name); k++) {name[k] = '\0';}
612		for (k=0; k<strlen(createstr); k++) {createstr[k] = '\0';}
613		for (k=0; k<strlen(ipv6LinkStr); k++) {ipv6LinkStr[k] = '\0';}
614		for (k=0; k<strlen(buf); k++) {buf[k] = '\0';}
615		strcat(name, SNMP_INDEX_RRD_LOCATION);
616		sprintf(ipv6LinkStr, "%lu_%lu_%lu_%lu_%hu_%hu",
617		shmForAgg->indexV6Tab[index][i][j].routerIPAddress>>24,
618		shmForAgg->indexV6Tab[index][i][j].routerIPAddress<<8>>24,
619		shmForAgg->indexV6Tab[index][i][j].routerIPAddress<<16>>24,
620		shmForAgg->indexV6Tab[index][i][j].routerIPAddress<<24>>24,
621		(unsigned short) 1,
622		shmForAgg->indexV6Tab[index][i][j].indexSNMP
623		);
624		strcat(name, ipv6LinkStr);
625		strcat(name, RRD_EXTENSION);
626		if ( (fp=fopen(name,"r")) == NULL ){
627		opt[0]= (char ) malloc((strlen(RRD_PARAM_INDEX_0) + 1) sizeof(char));
628		strcpy(opt[0], RRD_PARAM_INDEX_0);
629		opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
630		strcpy(opt[1], name);
631		opt[2]= (char ) malloc((strlen(RRD_PARAM_INDEX_1) + 1) sizeof(char));
632		strcpy(opt[2], RRD_PARAM_INDEX_1);
633		opt[3]= (char ) malloc((strlen(RRD_PARAM_INDEX_2) + 1) sizeof(char));
634		strcpy(opt[3], RRD_PARAM_INDEX_2);
635		opt[4]= (char ) malloc((strlen(RRD_PARAM_INDEX_3) + 1) sizeof(char));
636		strcpy(opt[4], RRD_PARAM_INDEX_3);
637		opt[5]= (char ) malloc((strlen(RRD_PARAM_INDEX_4) + 1) sizeof(char));
638		strcpy(opt[5], RRD_PARAM_INDEX_4);
639		opt[6]= (char ) malloc((strlen(RRD_PARAM_INDEX_5) + 1) sizeof(char));
640		strcpy(opt[6], RRD_PARAM_INDEX_5);
641		opt[7]= (char ) malloc((strlen(RRD_PARAM_INDEX_6) + 1) sizeof(char));
642		strcpy(opt[7], RRD_PARAM_INDEX_6);
643		opt[8]= (char ) malloc((strlen(RRD_PARAM_INDEX_7) + 1) sizeof(char));
644		strcpy(opt[8], RRD_PARAM_INDEX_7);
645		opt[9]= (char ) malloc((strlen(RRD_PARAM_INDEX_8) + 1) sizeof(char));
646		strcpy(opt[9], RRD_PARAM_INDEX_8);
647		opt[10]= (char ) malloc((strlen(RRD_PARAM_INDEX_9) + 1) sizeof(char));
648		strcpy(opt[10], RRD_PARAM_INDEX_9);
649		opt[11]= (char ) malloc((strlen(RRD_PARAM_INDEX_10) + 1) sizeof(char));
650		strcpy(opt[11], RRD_PARAM_INDEX_10);
651		opt[12]= (char ) malloc((strlen(RRD_PARAM_INDEX_11) + 1) sizeof(char));
652		strcpy(opt[12], RRD_PARAM_INDEX_11);
653		opt[13]= (char ) malloc((strlen(RRD_PARAM_INDEX_12) + 1) sizeof(char));
654		strcpy(opt[13], RRD_PARAM_INDEX_12);
655		opt[14]= (char ) malloc((strlen(RRD_PARAM_INDEX_13) + 1) sizeof(char));
656		strcpy(opt[14], RRD_PARAM_INDEX_13);
657		opt[15]= (char ) malloc((strlen(RRD_PARAM_INDEX_14) + 1) sizeof(char));
658		strcpy(opt[15], RRD_PARAM_INDEX_14);
659		opt[16]= (char ) malloc((strlen(RRD_PARAM_INDEX_15) + 1) sizeof(char));
660		strcpy(opt[16], RRD_PARAM_INDEX_15);
661		opt[17]= (char ) malloc((strlen(RRD_PARAM_INDEX_16) + 1) sizeof(char));
662		strcpy(opt[17], RRD_PARAM_INDEX_16);
663		opt[18]= (char ) malloc((strlen(RRD_PARAM_INDEX_17) + 1) sizeof(char));
664		strcpy(opt[18], RRD_PARAM_INDEX_17);
665		optind = opterr = 0;
666		rrd_clear_error();
667		if ( rrd_create(19,opt) < 0) {
668		syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
669		rrd_create_er_ct++;
670		} else {
671		rrd_create_ok_ct++;
672		}
673		for ( k=0; k<19; k++) {
674		free(opt[k]);
675		opt[k] = NULL;
676		}
677		}else{
678		fclose(fp);
679		rrd_already_created_ct++;
680		snprintf(buf,
681		2048,
682		"%lu:%llu:%llu:%llu:%llu:%llu:%llu",
683		now-300, /* or ctime(&now) with %s */
684		shmForAgg->indexV6Tab[index][i][j].flowNbIN, /* 1 */
685		shmForAgg->indexV6Tab[index][i][j].flowNbOUT,
686		shmForAgg->indexV6Tab[index][i][j].bytesNbIN,
687		shmForAgg->indexV6Tab[index][i][j].bytesNbOUT,
688		shmForAgg->indexV6Tab[index][i][j].pktsNbIN, /* 5 */
689		shmForAgg->indexV6Tab[index][i][j].pktsNbOUT
690		);
691		optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
692		strcpy(optUpdate[0], RRD_UPDATE_0);
693		optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
694		strcpy(optUpdate[1], name);
695		optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
696		strcpy(optUpdate[2], buf);
697		optind = opterr = 0;
698		rrd_clear_error();
699		if ( rrd_update(3, optUpdate) < 0 ) {
700		syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
701		rrd_update_er_ct++;
702		} else {
703		rrd_update_ok_ct++;
704		}
705		for ( k=0; k<3; k++) {
706		free(optUpdate[k]);
707		optUpdate[k] = NULL;
708		}
709		}
710		shmForAgg->indexV6Tab[index][i][j].bytesNbIN = 0;
711		shmForAgg->indexV6Tab[index][i][j].pktsNbIN = 0;
712		shmForAgg->indexV6Tab[index][i][j].flowNbIN = 0;
713		shmForAgg->indexV6Tab[index][i][j].bytesNbOUT = 0;
714		shmForAgg->indexV6Tab[index][i][j].pktsNbOUT = 0;
715		shmForAgg->indexV6Tab[index][i][j].flowNbOUT = 0;
716		}
717		}
718		}
	713	/*
	714	*
	715	* IPv6 Links ACCOUNTING
	716	*
	717	*/
	718	for (i=0; i<ROUTER_INDEX_MAX; i++)
	719	{
	720	for (j=0; j<MAX_INDEX_BY_ROUTER; j++)
	721	{
	722	/* HERE create or update RRD FILE for IPV6 LINKs AGGregation */
	723	if (shmForAgg->indexV6Tab[index][i][j].hasStats == 1)
	724	{
	725	for (k=0; k<strlen(name); k++)
	726	{
	727	name[k] = '\0';
	728	}
	729	for (k=0; k<strlen(createstr); k++)
	730	{
	731	createstr[k] = '\0';
	732	}
	733	for (k=0; k<strlen(ipv6LinkStr); k++)
	734	{
	735	ipv6LinkStr[k] = '\0';
	736	}
	737	for (k=0; k<strlen(buf); k++)
	738	{
	739	buf[k] = '\0';
	740	}
	741	strcat(name, SNMP_INDEX_RRD_LOCATION);
	742	sprintf(ipv6LinkStr, "%lu_%lu_%lu_%lu_%hu_%hu",
	743	shmForAgg->indexV6Tab[index][i][j].routerIPAddress>>24,
	744	shmForAgg->indexV6Tab[index][i][j].routerIPAddress<<8>>24,
	745	shmForAgg->indexV6Tab[index][i][j].routerIPAddress<<16>>24,
	746	shmForAgg->indexV6Tab[index][i][j].routerIPAddress<<24>>24,
	747	(unsigned short) 1,
	748	shmForAgg->indexV6Tab[index][i][j].indexSNMP
	749	);
	750	strcat(name, ipv6LinkStr);
	751	strcat(name, RRD_EXTENSION);
	752	if ( (fp=fopen(name,"r")) == NULL )
	753	{
	754	opt[0]= (char ) malloc((strlen(RRD_PARAM_INDEX_0) + 1) sizeof(char));
	755	strcpy(opt[0], RRD_PARAM_INDEX_0);
	756	opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	757	strcpy(opt[1], name);
	758	opt[2]= (char ) malloc((strlen(RRD_PARAM_INDEX_1) + 1) sizeof(char));
	759	strcpy(opt[2], RRD_PARAM_INDEX_1);
	760	opt[3]= (char ) malloc((strlen(RRD_PARAM_INDEX_2) + 1) sizeof(char));
	761	strcpy(opt[3], RRD_PARAM_INDEX_2);
	762	opt[4]= (char ) malloc((strlen(RRD_PARAM_INDEX_3) + 1) sizeof(char));
	763	strcpy(opt[4], RRD_PARAM_INDEX_3);
	764	opt[5]= (char ) malloc((strlen(RRD_PARAM_INDEX_4) + 1) sizeof(char));
	765	strcpy(opt[5], RRD_PARAM_INDEX_4);
	766	opt[6]= (char ) malloc((strlen(RRD_PARAM_INDEX_5) + 1) sizeof(char));
	767	strcpy(opt[6], RRD_PARAM_INDEX_5);
	768	opt[7]= (char ) malloc((strlen(RRD_PARAM_INDEX_6) + 1) sizeof(char));
	769	strcpy(opt[7], RRD_PARAM_INDEX_6);
	770	opt[8]= (char ) malloc((strlen(RRD_PARAM_INDEX_7) + 1) sizeof(char));
	771	strcpy(opt[8], RRD_PARAM_INDEX_7);
	772	opt[9]= (char ) malloc((strlen(RRD_PARAM_INDEX_8) + 1) sizeof(char));
	773	strcpy(opt[9], RRD_PARAM_INDEX_8);
	774	opt[10]= (char ) malloc((strlen(RRD_PARAM_INDEX_9) + 1) sizeof(char));
	775	strcpy(opt[10], RRD_PARAM_INDEX_9);
	776	opt[11]= (char ) malloc((strlen(RRD_PARAM_INDEX_10) + 1) sizeof(char));
	777	strcpy(opt[11], RRD_PARAM_INDEX_10);
	778	opt[12]= (char ) malloc((strlen(RRD_PARAM_INDEX_11) + 1) sizeof(char));
	779	strcpy(opt[12], RRD_PARAM_INDEX_11);
	780	opt[13]= (char ) malloc((strlen(RRD_PARAM_INDEX_12) + 1) sizeof(char));
	781	strcpy(opt[13], RRD_PARAM_INDEX_12);
	782	opt[14]= (char ) malloc((strlen(RRD_PARAM_INDEX_13) + 1) sizeof(char));
	783	strcpy(opt[14], RRD_PARAM_INDEX_13);
	784	opt[15]= (char ) malloc((strlen(RRD_PARAM_INDEX_14) + 1) sizeof(char));
	785	strcpy(opt[15], RRD_PARAM_INDEX_14);
	786	opt[16]= (char ) malloc((strlen(RRD_PARAM_INDEX_15) + 1) sizeof(char));
	787	strcpy(opt[16], RRD_PARAM_INDEX_15);
	788	opt[17]= (char ) malloc((strlen(RRD_PARAM_INDEX_16) + 1) sizeof(char));
	789	strcpy(opt[17], RRD_PARAM_INDEX_16);
	790	opt[18]= (char ) malloc((strlen(RRD_PARAM_INDEX_17) + 1) sizeof(char));
	791	strcpy(opt[18], RRD_PARAM_INDEX_17);
	792	optind = opterr = 0;
	793	rrd_clear_error();
	794	if ( rrd_create(19,opt) < 0)
	795	{
	796	syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
	797	rrd_create_er_ct++;
	798	}
	799	else
	800	{
	801	rrd_create_ok_ct++;
	802	}
	803	for ( k=0; k<19; k++)
	804	{
	805	free(opt[k]);
	806	opt[k] = NULL;
	807	}
	808	}
	809	else
	810	{
	811	fclose(fp);
	812	rrd_already_created_ct++;
	813	snprintf(buf,
	814	2048,
	815	"%lu:%llu:%llu:%llu:%llu:%llu:%llu",
	816	now-300, /* or ctime(&now) with %s */
	817	shmForAgg->indexV6Tab[index][i][j].flowNbIN, /* 1 */
	818	shmForAgg->indexV6Tab[index][i][j].flowNbOUT,
	819	shmForAgg->indexV6Tab[index][i][j].bytesNbIN,
	820	shmForAgg->indexV6Tab[index][i][j].bytesNbOUT,
	821	shmForAgg->indexV6Tab[index][i][j].pktsNbIN, /* 5 */
	822	shmForAgg->indexV6Tab[index][i][j].pktsNbOUT
	823	);
	824	optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
	825	strcpy(optUpdate[0], RRD_UPDATE_0);
	826	optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	827	strcpy(optUpdate[1], name);
	828	optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
	829	strcpy(optUpdate[2], buf);
	830	optind = opterr = 0;
	831	rrd_clear_error();
	832	if ( rrd_update(3, optUpdate) < 0 )
	833	{
	834	syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
	835	rrd_update_er_ct++;
	836	}
	837	else
	838	{
	839	rrd_update_ok_ct++;
	840	}
	841	for ( k=0; k<3; k++)
	842	{
	843	free(optUpdate[k]);
	844	optUpdate[k] = NULL;
	845	}
	846	}
	847	shmForAgg->indexV6Tab[index][i][j].bytesNbIN = 0;
	848	shmForAgg->indexV6Tab[index][i][j].pktsNbIN = 0;
	849	shmForAgg->indexV6Tab[index][i][j].flowNbIN = 0;
	850	shmForAgg->indexV6Tab[index][i][j].bytesNbOUT = 0;
	851	shmForAgg->indexV6Tab[index][i][j].pktsNbOUT = 0;
	852	shmForAgg->indexV6Tab[index][i][j].flowNbOUT = 0;
	853	}
	854	}
	855	}
719	856	#endif
720	857	#endif /* AS */
721		if (rrdMibsUpdate(index) != 1) {syslog(LOG_ERR, "ERROR in RRD MIBs update file\n");}
722		now2 = time((time_t *)NULL);
	858	if (rrdMibsUpdate(index) != 1)
	859	{
	860	syslog(LOG_ERR, "ERROR in RRD MIBs update file\n");
	861	}
	862	if (rrdL7IPv4MibsUpdate(index) != 1)
	863	{
	864	syslog(LOG_ERR, "ERROR in RRD MIBs update file\n");
	865	}
	866	now2 = time((time_t *)NULL);
723	867	#ifdef DEBUGAGG
724		fprintf(stderr, "IPv4 subnet managment (rrd update) : \n %d sec, %d files updated, %d errors, total %d\n %d rrd file already created, %d errors in creation, %d new rrd file creations",
725		(int)now2-now,
726		rrd_update_ok_ct,
727		rrd_update_er_ct,
728		rrd_update_ok_ct+rrd_update_er_ct,
729		rrd_already_created_ct,
730		rrd_create_er_ct,
731		rrd_create_ok_ct);
	868	fprintf(stderr, "IPv4 subnet managment (rrd update) : \n %d sec, %d files updated, %d errors, total %d\n %d rrd file already created, %d errors in creation, %d new rrd file creations",
	869	(int)now2-now,
	870	rrd_update_ok_ct,
	871	rrd_update_er_ct,
	872	rrd_update_ok_ct+rrd_update_er_ct,
	873	rrd_already_created_ct,
	874	rrd_create_er_ct,
	875	rrd_create_ok_ct);
732	876	#endif
733		rrd_update_ok_ct = 0;
734		rrd_update_er_ct = 0;
735		rrd_already_created_ct = 0;
736		rrd_create_er_ct = 0;
737		rrd_create_ok_ct = 0;
738		rrd_clear_error();
739		} else {
740		isFirstUpdate = 0;
741		/* RRD Update only for the MIB counters, else we clear all counters in shared memory (after) */
742		if (rrdMibsUpdate(index) != 1) {syslog(LOG_ERR, "ERROR in RRD MIBs update file\n");}
743		/* CLEAR */
744		for (i=0; i<shmForAgg->v4PrefixNb; i++){
745		shmForAgg->prefixV4Tab[index][i].flowNbIN = 0;
746		shmForAgg->prefixV4Tab[index][i].bytesNbIN = 0;
747		shmForAgg->prefixV4Tab[index][i].pktsNbIN = 0;
748		shmForAgg->prefixV4Tab[index][i].flowNbOUT = 0;
749		shmForAgg->prefixV4Tab[index][i].bytesNbOUT = 0;
750		shmForAgg->prefixV4Tab[index][i].pktsNbOUT = 0;
751		shmForAgg->prefixV4Tab[index][i].firstCoSIN = 0;
752		shmForAgg->prefixV4Tab[index][i].secondCoSIN = 0;
753		shmForAgg->prefixV4Tab[index][i].thirdCoSIN = 0;
754		shmForAgg->prefixV4Tab[index][i].fourthCoSIN = 0;
755		shmForAgg->prefixV4Tab[index][i].firstCoSOUT = 0;
756		shmForAgg->prefixV4Tab[index][i].secondCoSOUT = 0;
757		shmForAgg->prefixV4Tab[index][i].thirdCoSOUT = 0;
758		shmForAgg->prefixV4Tab[index][i].fourthCoSOUT = 0;
759		}
760		for (i=0; i<shmForAgg->v4SubnetNb; i++){
761		shmForAgg->prefixV4SubnetTab[index][i].flowNbIN = 0;
762		shmForAgg->prefixV4SubnetTab[index][i].bytesNbIN = 0;
763		shmForAgg->prefixV4SubnetTab[index][i].pktsNbIN = 0;
764		shmForAgg->prefixV4SubnetTab[index][i].flowNbOUT = 0;
765		shmForAgg->prefixV4SubnetTab[index][i].bytesNbOUT = 0;
766		shmForAgg->prefixV4SubnetTab[index][i].pktsNbOUT = 0;
767		shmForAgg->prefixV4SubnetTab[index][i].firstCoSIN = 0;
768		shmForAgg->prefixV4SubnetTab[index][i].secondCoSIN = 0;
769		shmForAgg->prefixV4SubnetTab[index][i].thirdCoSIN = 0;
770		shmForAgg->prefixV4SubnetTab[index][i].fourthCoSIN = 0;
771		shmForAgg->prefixV4SubnetTab[index][i].firstCoSOUT = 0;
772		shmForAgg->prefixV4SubnetTab[index][i].secondCoSOUT = 0;
773		shmForAgg->prefixV4SubnetTab[index][i].thirdCoSOUT = 0;
774		shmForAgg->prefixV4SubnetTab[index][i].fourthCoSOUT = 0;
775		}
	877	rrd_update_ok_ct = 0;
	878	rrd_update_er_ct = 0;
	879	rrd_already_created_ct = 0;
	880	rrd_create_er_ct = 0;
	881	rrd_create_ok_ct = 0;
	882	rrd_clear_error();
	883	}
	884	else
	885	{
	886	isFirstUpdate = 0;
	887	/* RRD Update only for the MIB counters, else we clear all counters in shared memory (after) */
	888	if (rrdMibsUpdate(index) != 1)
	889	{
	890	syslog(LOG_ERR, "ERROR in RRD MIBs update file\n");
	891	}
	892	if (rrdL7IPv4MibsUpdate(index) != 1)
	893	{
	894	syslog(LOG_ERR, "ERROR in RRD MIBs update file\n");
	895	}
	896	/* CLEAR */
	897	for (i=0; i<shmForAgg->v4PrefixNb; i++)
	898	{
	899	shmForAgg->prefixV4Tab[index][i].flowNbIN = 0;
	900	shmForAgg->prefixV4Tab[index][i].bytesNbIN = 0;
	901	shmForAgg->prefixV4Tab[index][i].pktsNbIN = 0;
	902	shmForAgg->prefixV4Tab[index][i].flowNbOUT = 0;
	903	shmForAgg->prefixV4Tab[index][i].bytesNbOUT = 0;
	904	shmForAgg->prefixV4Tab[index][i].pktsNbOUT = 0;
	905	shmForAgg->prefixV4Tab[index][i].firstCoSIN = 0;
	906	shmForAgg->prefixV4Tab[index][i].secondCoSIN = 0;
	907	shmForAgg->prefixV4Tab[index][i].thirdCoSIN = 0;
	908	shmForAgg->prefixV4Tab[index][i].fourthCoSIN = 0;
	909	shmForAgg->prefixV4Tab[index][i].firstCoSOUT = 0;
	910	shmForAgg->prefixV4Tab[index][i].secondCoSOUT = 0;
	911	shmForAgg->prefixV4Tab[index][i].thirdCoSOUT = 0;
	912	shmForAgg->prefixV4Tab[index][i].fourthCoSOUT = 0;
	913	}
	914	for (i=0; i<shmForAgg->v4SubnetNb; i++)
	915	{
	916	shmForAgg->prefixV4SubnetTab[index][i].flowNbIN = 0;
	917	shmForAgg->prefixV4SubnetTab[index][i].bytesNbIN = 0;
	918	shmForAgg->prefixV4SubnetTab[index][i].pktsNbIN = 0;
	919	shmForAgg->prefixV4SubnetTab[index][i].flowNbOUT = 0;
	920	shmForAgg->prefixV4SubnetTab[index][i].bytesNbOUT = 0;
	921	shmForAgg->prefixV4SubnetTab[index][i].pktsNbOUT = 0;
	922	shmForAgg->prefixV4SubnetTab[index][i].firstCoSIN = 0;
	923	shmForAgg->prefixV4SubnetTab[index][i].secondCoSIN = 0;
	924	shmForAgg->prefixV4SubnetTab[index][i].thirdCoSIN = 0;
	925	shmForAgg->prefixV4SubnetTab[index][i].fourthCoSIN = 0;
	926	shmForAgg->prefixV4SubnetTab[index][i].firstCoSOUT = 0;
	927	shmForAgg->prefixV4SubnetTab[index][i].secondCoSOUT = 0;
	928	shmForAgg->prefixV4SubnetTab[index][i].thirdCoSOUT = 0;
	929	shmForAgg->prefixV4SubnetTab[index][i].fourthCoSOUT = 0;
	930	}
776	931	#ifdef MATRIX
777		for (i=0; i<ROUTER_INDEX_MAX; i++){
778		for (j=0; j<ROUTER_INDEX_MAX; j++) {
779		shmForAgg->matrixPOP[index][i][j].bytesNb = 0;
780		shmForAgg->matrixPOP[index][i][j].pktsNb = 0;
781		shmForAgg->matrixPOP[index][i][j].flowNb = 0;
782		}
783		}
	932	for (i=0; i<ROUTER_INDEX_MAX; i++)
	933	{
	934	for (j=0; j<ROUTER_INDEX_MAX; j++)
	935	{
	936	shmForAgg->matrixPOP[index][i][j].bytesNb = 0;
	937	shmForAgg->matrixPOP[index][i][j].pktsNb = 0;
	938	shmForAgg->matrixPOP[index][i][j].flowNb = 0;
	939	}
	940	}
784	941	#endif
785	942	#ifdef ASACC
786		for (i=0; i<shmForAgg->ASNb; i++){
787		shmForAgg->ASTab[index][i].flowNbIN = 0;
788		shmForAgg->ASTab[index][i].bytesNbIN = 0;
789		shmForAgg->ASTab[index][i].pktsNbIN = 0;
790		shmForAgg->ASTab[index][i].flowNbOUT = 0;
791		shmForAgg->ASTab[index][i].bytesNbOUT = 0;
792		shmForAgg->ASTab[index][i].pktsNbOUT = 0;
793		}
	943	for (i=0; i<shmForAgg->ASNb; i++)
	944	{
	945	shmForAgg->ASTab[index][i].flowNbIN = 0;
	946	shmForAgg->ASTab[index][i].bytesNbIN = 0;
	947	shmForAgg->ASTab[index][i].pktsNbIN = 0;
	948	shmForAgg->ASTab[index][i].flowNbOUT = 0;
	949	shmForAgg->ASTab[index][i].bytesNbOUT = 0;
	950	shmForAgg->ASTab[index][i].pktsNbOUT = 0;
	951	}
794	952	#endif
795	953	#ifdef IPV6LINKAGG
796		for (i=0; i<ROUTER_INDEX_MAX; i++){
797		for (j=0; j<MAX_INDEX_BY_ROUTER; j++) {
798		shmForAgg->indexV6Tab[index][i][j].bytesNbIN = 0;
799		shmForAgg->indexV6Tab[index][i][j].pktsNbIN = 0;
800		shmForAgg->indexV6Tab[index][i][j].flowNbIN = 0;
801		shmForAgg->indexV6Tab[index][i][j].bytesNbOUT = 0;
802		shmForAgg->indexV6Tab[index][i][j].pktsNbOUT = 0;
803		shmForAgg->indexV6Tab[index][i][j].flowNbOUT = 0;
804		}
805		}
	954	for (i=0; i<ROUTER_INDEX_MAX; i++)
	955	{
	956	for (j=0; j<MAX_INDEX_BY_ROUTER; j++)
	957	{
	958	shmForAgg->indexV6Tab[index][i][j].bytesNbIN = 0;
	959	shmForAgg->indexV6Tab[index][i][j].pktsNbIN = 0;
	960	shmForAgg->indexV6Tab[index][i][j].flowNbIN = 0;
	961	shmForAgg->indexV6Tab[index][i][j].bytesNbOUT = 0;
	962	shmForAgg->indexV6Tab[index][i][j].pktsNbOUT = 0;
	963	shmForAgg->indexV6Tab[index][i][j].flowNbOUT = 0;
	964	}
	965	}
806	966	#endif
807		/* reinit */
808		} /* end is first update */
809		} /* end read ok */
810		sleep(10);
811		} while (1);
812		exit(0);
	967	/* reinit */
	968	} /* end is first update */
	969	} /* end read ok */
	970	sleep(10);
	971	}
	972	while (1);
	973	exit(0);
813	974	}
814	975
…	…
819	980	short rrdMibsUpdate(int index)
820	981	{
821		int i, j, k = 0;
822		int rrd_update_er_ct = 0;
823		int rrd_update_ok_ct = 0;
824		int rrd_already_created_ct = 0;
825		int rrd_create_er_ct = 0;
826		int rrd_create_ok_ct = 0;
827		static char buf[2048];
828		static char name[2048];
829		static char createstr[2048];
830		char *opt[27];
831		char *optUpdate[3];
832		FILE *fp;
833		static time_t now, now2;
834
835		now = time((time_t *)NULL);
836		for (k=0; k<strlen(name); k++) {name[k] = '\0';}
837		for (k=0; k<strlen(buf); k++) {buf[k] = '\0';}
838		strcat(name, MIB_RRD_LOCATION);
839		strcat(name, GLOBAL_MIB_RRD_FILE);
840		if ( (fp=fopen(name,"r")) == NULL ){
841		opt[0]= (char ) malloc((strlen(RRD_PARAM_MIB_0) + 1) sizeof(char));
842		strcpy(opt[0], RRD_PARAM_MIB_0);
843		opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
844		strcpy(opt[1], name);
845		opt[2]= (char ) malloc((strlen(RRD_PARAM_MIB_1) + 1) sizeof(char));
846		strcpy(opt[2], RRD_PARAM_MIB_1);
847		opt[3]= (char ) malloc((strlen(RRD_PARAM_MIB_2) + 1) sizeof(char));
848		strcpy(opt[3], RRD_PARAM_MIB_2);
849		opt[4]= (char ) malloc((strlen(RRD_PARAM_MIB_3) + 1) sizeof(char));
850		strcpy(opt[4], RRD_PARAM_MIB_3);
851		opt[5]= (char ) malloc((strlen(RRD_PARAM_MIB_4) + 1) sizeof(char));
852		strcpy(opt[5], RRD_PARAM_MIB_4);
853		opt[6]= (char ) malloc((strlen(RRD_PARAM_MIB_5) + 1) sizeof(char));
854		strcpy(opt[6], RRD_PARAM_MIB_5);
855		opt[7]= (char ) malloc((strlen(RRD_PARAM_MIB_6) + 1) sizeof(char));
856		strcpy(opt[7], RRD_PARAM_MIB_6);
857		opt[8]= (char ) malloc((strlen(RRD_PARAM_MIB_7) + 1) sizeof(char));
858		strcpy(opt[8], RRD_PARAM_MIB_7);
859		opt[9]= (char ) malloc((strlen(RRD_PARAM_MIB_8) + 1) sizeof(char));
860		strcpy(opt[9], RRD_PARAM_MIB_8);
861		opt[10]= (char ) malloc((strlen(RRD_PARAM_MIB_9) + 1) sizeof(char));
862		strcpy(opt[10], RRD_PARAM_MIB_9);
863		opt[11]= (char ) malloc((strlen(RRD_PARAM_MIB_10) + 1) sizeof(char));
864		strcpy(opt[11], RRD_PARAM_MIB_10);
865		opt[12]= (char ) malloc((strlen(RRD_PARAM_MIB_11) + 1) sizeof(char));
866		strcpy(opt[12], RRD_PARAM_MIB_11);
867		opt[13]= (char ) malloc((strlen(RRD_PARAM_MIB_12) + 1) sizeof(char));
868		strcpy(opt[13], RRD_PARAM_MIB_12);
869		opt[14]= (char ) malloc((strlen(RRD_PARAM_MIB_13) + 1) sizeof(char));
870		strcpy(opt[14], RRD_PARAM_MIB_13);
871		opt[15]= (char ) malloc((strlen(RRD_PARAM_MIB_14) + 1) sizeof(char));
872		strcpy(opt[15], RRD_PARAM_MIB_14);
873		opt[16]= (char ) malloc((strlen(RRD_PARAM_MIB_15) + 1) sizeof(char));
874		strcpy(opt[16], RRD_PARAM_MIB_15);
875		opt[17]= (char ) malloc((strlen(RRD_PARAM_MIB_16) + 1) sizeof(char));
876		strcpy(opt[17], RRD_PARAM_MIB_16);
877		opt[18]= (char ) malloc((strlen(RRD_PARAM_MIB_17) + 1) sizeof(char));
878		strcpy(opt[18], RRD_PARAM_MIB_17);
879		opt[19]= (char ) malloc((strlen(RRD_PARAM_MIB_18) + 1) sizeof(char));
880		strcpy(opt[19], RRD_PARAM_MIB_18);
881		opt[20]= (char ) malloc((strlen(RRD_PARAM_MIB_19) + 1) sizeof(char));
882		strcpy(opt[20], RRD_PARAM_MIB_19);
883		opt[21]= (char ) malloc((strlen(RRD_PARAM_MIB_20) + 1) sizeof(char));
884		strcpy(opt[21], RRD_PARAM_MIB_20);
885		opt[22]= (char ) malloc((strlen(RRD_PARAM_MIB_21) + 1) sizeof(char));
886		strcpy(opt[22], RRD_PARAM_MIB_21);
887		opt[23]= (char ) malloc((strlen(RRD_PARAM_MIB_22) + 1) sizeof(char));
888		strcpy(opt[23], RRD_PARAM_MIB_22);
889		optind = opterr = 0;
890		rrd_clear_error();
891		if ( rrd_create(24,opt) < 0) {
892		syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
893		rrd_create_er_ct++;
894		} else {
895		rrd_create_ok_ct++;
	982	int i, j, k = 0;
	983	int rrd_update_er_ct = 0;
	984	int rrd_update_ok_ct = 0;
	985	int rrd_already_created_ct = 0;
	986	int rrd_create_er_ct = 0;
	987	int rrd_create_ok_ct = 0;
	988	static char buf[2048];
	989	static char name[2048];
	990	static char createstr[2048];
	991	char *opt[27];
	992	char *optUpdate[3];
	993	FILE *fp;
	994	static time_t now, now2;
	995
	996	now = time((time_t *)NULL);
	997	for (k=0; k<strlen(name); k++)
	998	{
	999	name[k] = '\0';
896	1000	}
897		for ( ~~k=0; k<24; k++) {~~
898		~~free(opt[k]);~~
899		~~opt[k] = NULL~~;
	1001	for (k=0; k<strlen(buf); k++)
	1002	{
	1003	buf[k] = '\0';
900	1004	}
901		}else{
902		fclose(fp);
903		rrd_already_created_ct++;
904		snprintf(buf,
905		2048,
906		"%lu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu",
907		now-300, /* or ctime(&now) with %s */
908		shmForAgg->myMIB[index].ipPacketNb,
909		shmForAgg->myMIB[index].udpPacketNb,
910		shmForAgg->myMIB[index].v9PacketNb,
911		shmForAgg->myMIB[index].v9UnSeqNb,
912		shmForAgg->myMIB[index].flowSetNb,
913		shmForAgg->myMIB[index].dataFlowSetNb,
914		shmForAgg->myMIB[index].defFlowSetNb,
915		shmForAgg->myMIB[index].optDataFlowSetNb,
916		shmForAgg->myMIB[index].optDefFlowSetNb,
917		shmForAgg->myMIB[index].flowNb,
918		shmForAgg->myMIB[index].realFlowNb
919		);
920		fprintf(stderr,"\n%s\n",buf);
921		optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
922		strcpy(optUpdate[0], RRD_UPDATE_0);
923		optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
924		strcpy(optUpdate[1], name);
925		optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
926		strcpy(optUpdate[2], buf);
927		optind = opterr = 0;
928		rrd_clear_error();
929		if ( rrd_update(3, optUpdate) < 0 ) {
930		syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
931		rrd_update_er_ct++;
932		} else {
933		rrd_update_ok_ct++;
	1005	strcat(name, MIB_RRD_LOCATION);
	1006	strcat(name, GLOBAL_MIB_RRD_FILE);
	1007	if ( (fp=fopen(name,"r")) == NULL )
	1008	{
	1009	opt[0]= (char ) malloc((strlen(RRD_PARAM_MIB_0) + 1) sizeof(char));
	1010	strcpy(opt[0], RRD_PARAM_MIB_0);
	1011	opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	1012	strcpy(opt[1], name);
	1013	opt[2]= (char ) malloc((strlen(RRD_PARAM_MIB_1) + 1) sizeof(char));
	1014	strcpy(opt[2], RRD_PARAM_MIB_1);
	1015	opt[3]= (char ) malloc((strlen(RRD_PARAM_MIB_2) + 1) sizeof(char));
	1016	strcpy(opt[3], RRD_PARAM_MIB_2);
	1017	opt[4]= (char ) malloc((strlen(RRD_PARAM_MIB_3) + 1) sizeof(char));
	1018	strcpy(opt[4], RRD_PARAM_MIB_3);
	1019	opt[5]= (char ) malloc((strlen(RRD_PARAM_MIB_4) + 1) sizeof(char));
	1020	strcpy(opt[5], RRD_PARAM_MIB_4);
	1021	opt[6]= (char ) malloc((strlen(RRD_PARAM_MIB_5) + 1) sizeof(char));
	1022	strcpy(opt[6], RRD_PARAM_MIB_5);
	1023	opt[7]= (char ) malloc((strlen(RRD_PARAM_MIB_6) + 1) sizeof(char));
	1024	strcpy(opt[7], RRD_PARAM_MIB_6);
	1025	opt[8]= (char ) malloc((strlen(RRD_PARAM_MIB_7) + 1) sizeof(char));
	1026	strcpy(opt[8], RRD_PARAM_MIB_7);
	1027	opt[9]= (char ) malloc((strlen(RRD_PARAM_MIB_8) + 1) sizeof(char));
	1028	strcpy(opt[9], RRD_PARAM_MIB_8);
	1029	opt[10]= (char ) malloc((strlen(RRD_PARAM_MIB_9) + 1) sizeof(char));
	1030	strcpy(opt[10], RRD_PARAM_MIB_9);
	1031	opt[11]= (char ) malloc((strlen(RRD_PARAM_MIB_10) + 1) sizeof(char));
	1032	strcpy(opt[11], RRD_PARAM_MIB_10);
	1033	opt[12]= (char ) malloc((strlen(RRD_PARAM_MIB_11) + 1) sizeof(char));
	1034	strcpy(opt[12], RRD_PARAM_MIB_11);
	1035	opt[13]= (char ) malloc((strlen(RRD_PARAM_MIB_12) + 1) sizeof(char));
	1036	strcpy(opt[13], RRD_PARAM_MIB_12);
	1037	opt[14]= (char ) malloc((strlen(RRD_PARAM_MIB_13) + 1) sizeof(char));
	1038	strcpy(opt[14], RRD_PARAM_MIB_13);
	1039	opt[15]= (char ) malloc((strlen(RRD_PARAM_MIB_14) + 1) sizeof(char));
	1040	strcpy(opt[15], RRD_PARAM_MIB_14);
	1041	opt[16]= (char ) malloc((strlen(RRD_PARAM_MIB_15) + 1) sizeof(char));
	1042	strcpy(opt[16], RRD_PARAM_MIB_15);
	1043	opt[17]= (char ) malloc((strlen(RRD_PARAM_MIB_16) + 1) sizeof(char));
	1044	strcpy(opt[17], RRD_PARAM_MIB_16);
	1045	opt[18]= (char ) malloc((strlen(RRD_PARAM_MIB_17) + 1) sizeof(char));
	1046	strcpy(opt[18], RRD_PARAM_MIB_17);
	1047	opt[19]= (char ) malloc((strlen(RRD_PARAM_MIB_18) + 1) sizeof(char));
	1048	strcpy(opt[19], RRD_PARAM_MIB_18);
	1049	opt[20]= (char ) malloc((strlen(RRD_PARAM_MIB_19) + 1) sizeof(char));
	1050	strcpy(opt[20], RRD_PARAM_MIB_19);
	1051	opt[21]= (char ) malloc((strlen(RRD_PARAM_MIB_20) + 1) sizeof(char));
	1052	strcpy(opt[21], RRD_PARAM_MIB_20);
	1053	opt[22]= (char ) malloc((strlen(RRD_PARAM_MIB_21) + 1) sizeof(char));
	1054	strcpy(opt[22], RRD_PARAM_MIB_21);
	1055	opt[23]= (char ) malloc((strlen(RRD_PARAM_MIB_22) + 1) sizeof(char));
	1056	strcpy(opt[23], RRD_PARAM_MIB_22);
	1057	optind = opterr = 0;
	1058	rrd_clear_error();
	1059	if ( rrd_create(24,opt) < 0)
	1060	{
	1061	syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
	1062	rrd_create_er_ct++;
	1063	}
	1064	else
	1065	{
	1066	rrd_create_ok_ct++;
	1067	}
	1068	for ( k=0; k<24; k++)
	1069	{
	1070	free(opt[k]);
	1071	opt[k] = NULL;
	1072	}
934	1073	}
935		for ( k=0; k<3; k++) {
936		free(optUpdate[k]);
937		optUpdate[k] = NULL;
	1074	else
	1075	{
	1076	fclose(fp);
	1077	rrd_already_created_ct++;
	1078	snprintf(buf,
	1079	2048,
	1080	"%lu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu",
	1081	now-300, /* or ctime(&now) with %s */
	1082	shmForAgg->myMIB[index].ipPacketNb,
	1083	shmForAgg->myMIB[index].udpPacketNb,
	1084	shmForAgg->myMIB[index].v9PacketNb,
	1085	shmForAgg->myMIB[index].v9UnSeqNb,
	1086	shmForAgg->myMIB[index].flowSetNb,
	1087	shmForAgg->myMIB[index].dataFlowSetNb,
	1088	shmForAgg->myMIB[index].defFlowSetNb,
	1089	shmForAgg->myMIB[index].optDataFlowSetNb,
	1090	shmForAgg->myMIB[index].optDefFlowSetNb,
	1091	shmForAgg->myMIB[index].flowNb,
	1092	shmForAgg->myMIB[index].realFlowNb
	1093	);
	1094	fprintf(stderr,"\n%s\n",buf);
	1095	optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
	1096	strcpy(optUpdate[0], RRD_UPDATE_0);
	1097	optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	1098	strcpy(optUpdate[1], name);
	1099	optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
	1100	strcpy(optUpdate[2], buf);
	1101	optind = opterr = 0;
	1102	rrd_clear_error();
	1103	if ( rrd_update(3, optUpdate) < 0 )
	1104	{
	1105	syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
	1106	rrd_update_er_ct++;
	1107	}
	1108	else
	1109	{
	1110	rrd_update_ok_ct++;
	1111	}
	1112	for ( k=0; k<3; k++)
	1113	{
	1114	free(optUpdate[k]);
	1115	optUpdate[k] = NULL;
	1116	}
938	1117	}
939		}
940		shmForAgg->myMIB[index].ipPacketNb = 0;
941		shmForAgg->myMIB[index].udpPacketNb = 0;
942		shmForAgg->myMIB[index].v9PacketNb = 0;
943		shmForAgg->myMIB[index].v9UnSeqNb = 0;
944		shmForAgg->myMIB[index].flowSetNb = 0;
945		shmForAgg->myMIB[index].dataFlowSetNb = 0;
946		shmForAgg->myMIB[index].defFlowSetNb = 0;
947		shmForAgg->myMIB[index].optDataFlowSetNb = 0;
948		shmForAgg->myMIB[index].optDefFlowSetNb = 0;
949		shmForAgg->myMIB[index].flowNb = 0;
950		shmForAgg->myMIB[index].realFlowNb = 0;
951		return 1;
	1118	shmForAgg->myMIB[index].ipPacketNb = 0;
	1119	shmForAgg->myMIB[index].udpPacketNb = 0;
	1120	shmForAgg->myMIB[index].v9PacketNb = 0;
	1121	shmForAgg->myMIB[index].v9UnSeqNb = 0;
	1122	shmForAgg->myMIB[index].flowSetNb = 0;
	1123	shmForAgg->myMIB[index].dataFlowSetNb = 0;
	1124	shmForAgg->myMIB[index].defFlowSetNb = 0;
	1125	shmForAgg->myMIB[index].optDataFlowSetNb = 0;
	1126	shmForAgg->myMIB[index].optDefFlowSetNb = 0;
	1127	shmForAgg->myMIB[index].flowNb = 0;
	1128	shmForAgg->myMIB[index].realFlowNb = 0;
	1129	return 1;
952	1130	}
	1131
	1132	/*
	1133	* rrdL7IPv4MibsUpdate
	1134	*/
	1135	short rrdL7IPv4MibsUpdate(int index)
	1136	{
	1137	int i, j, k = 0;
	1138	int rrd_update_er_ct = 0;
	1139	int rrd_update_ok_ct = 0;
	1140	int rrd_already_created_ct = 0;
	1141	int rrd_create_er_ct = 0;
	1142	int rrd_create_ok_ct = 0;
	1143	static char buf[2048];
	1144	static char name[2048];
	1145	static char createstr[2048];
	1146	char *opt[27];
	1147	char *optUpdate[3];
	1148	FILE *fp;
	1149	static time_t now, now2;
	1150
	1151	now = time((time_t *)NULL);
	1152	for (k=0; k<strlen(name); k++)
	1153	{
	1154	name[k] = '\0';
	1155	}
	1156	for (k=0; k<strlen(buf); k++)
	1157	{
	1158	buf[k] = '\0';
	1159	}
	1160	strcat(name, MIB_RRD_LOCATION);
	1161	strcat(name, L7_IPV4_MIB_RRD_FILE);
	1162	if ( (fp=fopen(name,"r")) == NULL )
	1163	{
	1164	opt[0]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_0) + 1) sizeof(char));
	1165	strcpy(opt[0], RRD_PARAM_MIB_IPV4_AP_0);
	1166	opt[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	1167	strcpy(opt[1], name);
	1168	opt[2]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_1) + 1) sizeof(char));
	1169	strcpy(opt[2], RRD_PARAM_MIB_IPV4_AP_1);
	1170	opt[3]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_2) + 1) sizeof(char));
	1171	strcpy(opt[3], RRD_PARAM_MIB_IPV4_AP_2);
	1172	opt[4]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_3) + 1) sizeof(char));
	1173	strcpy(opt[4], RRD_PARAM_MIB_IPV4_AP_3);
	1174	opt[5]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_4) + 1) sizeof(char));
	1175	strcpy(opt[5], RRD_PARAM_MIB_IPV4_AP_4);
	1176	opt[6]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_5) + 1) sizeof(char));
	1177	strcpy(opt[6], RRD_PARAM_MIB_IPV4_AP_5);
	1178	opt[7]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_6) + 1) sizeof(char));
	1179	strcpy(opt[7], RRD_PARAM_MIB_IPV4_AP_6);
	1180	opt[8]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_7) + 1) sizeof(char));
	1181	strcpy(opt[8], RRD_PARAM_MIB_IPV4_AP_7);
	1182	opt[9]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_8) + 1) sizeof(char));
	1183	strcpy(opt[9], RRD_PARAM_MIB_IPV4_AP_8);
	1184	opt[10]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_9) + 1) sizeof(char));
	1185	strcpy(opt[10], RRD_PARAM_MIB_IPV4_AP_9);
	1186	opt[11]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_10) + 1) sizeof(char));
	1187	strcpy(opt[11], RRD_PARAM_MIB_IPV4_AP_10);
	1188	opt[12]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_11) + 1) sizeof(char));
	1189	strcpy(opt[12], RRD_PARAM_MIB_IPV4_AP_11);
	1190	opt[13]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_12) + 1) sizeof(char));
	1191	strcpy(opt[13], RRD_PARAM_MIB_IPV4_AP_12);
	1192	opt[14]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_13) + 1) sizeof(char));
	1193	strcpy(opt[14], RRD_PARAM_MIB_IPV4_AP_13);
	1194	opt[15]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_14) + 1) sizeof(char));
	1195	strcpy(opt[15], RRD_PARAM_MIB_IPV4_AP_14);
	1196	opt[16]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_15) + 1) sizeof(char));
	1197	strcpy(opt[16], RRD_PARAM_MIB_IPV4_AP_15);
	1198	opt[17]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_16) + 1) sizeof(char));
	1199	strcpy(opt[17], RRD_PARAM_MIB_IPV4_AP_16);
	1200	opt[18]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_17) + 1) sizeof(char));
	1201	strcpy(opt[18], RRD_PARAM_MIB_IPV4_AP_17);
	1202	opt[19]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_18) + 1) sizeof(char));
	1203	strcpy(opt[19], RRD_PARAM_MIB_IPV4_AP_18);
	1204	opt[20]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_19) + 1) sizeof(char));
	1205	strcpy(opt[20], RRD_PARAM_MIB_IPV4_AP_19);
	1206	opt[21]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_20) + 1) sizeof(char));
	1207	strcpy(opt[21], RRD_PARAM_MIB_IPV4_AP_20);
	1208	opt[22]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_21) + 1) sizeof(char));
	1209	strcpy(opt[22], RRD_PARAM_MIB_IPV4_AP_21);
	1210	opt[23]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_22) + 1) sizeof(char));
	1211	strcpy(opt[23], RRD_PARAM_MIB_IPV4_AP_22);
	1212	opt[24]= (char ) malloc((strlen(RRD_PARAM_MIB_IPV4_AP_23) + 1) sizeof(char));
	1213	strcpy(opt[24], RRD_PARAM_MIB_IPV4_AP_23);
	1214	optind = opterr = 0;
	1215	rrd_clear_error();
	1216	if ( rrd_create(25,opt) < 0)
	1217	{
	1218	syslog(LOG_ERR, "RRD create file %s, error: %s\n", name, rrd_get_error());
	1219	rrd_create_er_ct++;
	1220	}
	1221	else
	1222	{
	1223	rrd_create_ok_ct++;
	1224	}
	1225	for ( k=0; k<25; k++)
	1226	{
	1227	free(opt[k]);
	1228	opt[k] = NULL;
	1229	}
	1230	}
	1231	else
	1232	{
	1233	fclose(fp);
	1234	rrd_already_created_ct++;
	1235	snprintf(buf,
	1236	2048,
	1237	"%lu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu:%llu",
	1238	now-300, /* or ctime(&now) with %s */
	1239	shmForAgg->myMIB[index].ipv4WebBytesNb,
	1240	shmForAgg->myMIB[index].ipv4WebPcktsNb,
	1241	shmForAgg->myMIB[index].ipv4WebFlowNb,
	1242	shmForAgg->myMIB[index].ipv4MailBytesNb,
	1243	shmForAgg->myMIB[index].ipv4MailPcktsNb,
	1244	shmForAgg->myMIB[index].ipv4MailFlowNb,
	1245	shmForAgg->myMIB[index].ipv4DNSBytesNb,
	1246	shmForAgg->myMIB[index].ipv4DNSPcktsNb,
	1247	shmForAgg->myMIB[index].ipv4DNSFlowNb,
	1248	shmForAgg->myMIB[index].ipv4OthersApBytesNb,
	1249	shmForAgg->myMIB[index].ipv4OthersApPcktsNb,
	1250	shmForAgg->myMIB[index].ipv4OthersApFlowNb
	1251	);
	1252	fprintf(stderr,"\n%s\n",buf);
	1253	optUpdate[0]= (char ) malloc((strlen(RRD_UPDATE_0) + 1) sizeof(char));
	1254	strcpy(optUpdate[0], RRD_UPDATE_0);
	1255	optUpdate[1]= (char ) malloc((strlen(name) + 1) sizeof(char));
	1256	strcpy(optUpdate[1], name);
	1257	optUpdate[2]= (char ) malloc((strlen(buf) + 1) sizeof(char));
	1258	strcpy(optUpdate[2], buf);
	1259	optind = opterr = 0;
	1260	rrd_clear_error();
	1261	if ( rrd_update(3, optUpdate) < 0 )
	1262	{
	1263	syslog(LOG_ERR, "RRD update file %s, error: %s\n", name, rrd_get_error());
	1264	rrd_update_er_ct++;
	1265	}
	1266	else
	1267	{
	1268	rrd_update_ok_ct++;
	1269	}
	1270	for ( k=0; k<3; k++)
	1271	{
	1272	free(optUpdate[k]);
	1273	optUpdate[k] = NULL;
	1274	}
	1275	}
	1276	shmForAgg->myMIB[index].ipv4WebBytesNb = 0;
	1277	shmForAgg->myMIB[index].ipv4WebPcktsNb = 0;
	1278	shmForAgg->myMIB[index].ipv4WebFlowNb = 0;
	1279	shmForAgg->myMIB[index].ipv4MailBytesNb = 0;
	1280	shmForAgg->myMIB[index].ipv4MailPcktsNb = 0;
	1281	shmForAgg->myMIB[index].ipv4MailFlowNb = 0;
	1282	shmForAgg->myMIB[index].ipv4DNSBytesNb = 0;
	1283	shmForAgg->myMIB[index].ipv4DNSPcktsNb = 0;
	1284	shmForAgg->myMIB[index].ipv4DNSFlowNb = 0;
	1285	shmForAgg->myMIB[index].ipv4OthersApBytesNb = 0;
	1286	shmForAgg->myMIB[index].ipv4OthersApPcktsNb = 0;
	1287	shmForAgg->myMIB[index].ipv4OthersApFlowNb = 0;
	1288	return 1;
	1289	}

Context Navigation

Changeset 157 for trunk

Legend:

trunk/src/renetcolAgg.c

Download in other formats: