Browse Source

graphEchantTabl moins verbeux

Citnop 3 years ago
parent
commit
f1cf555fab
1 changed files with 25 additions and 23 deletions
  1. 25 23
      cpp/main.cpp

+ 25 - 23
cpp/main.cpp

@@ -103,7 +103,7 @@ int main(int argc, char **argv)
103 103
 		std::cout << "thread n°" << i << " lancé." << std::endl;
104 104
 	}
105 105
 	
106
-	std::cout << ".............................main()..............................." << std::endl;
106
+	//~ std::cout << ".............................main()..............................." << std::endl;
107 107
 	
108 108
 	rctr = pthread_join(tr, NULL); // attente thread lecture
109 109
 	if (rctr) // vérification que le thread lecteur est bien arrêté
@@ -131,7 +131,7 @@ int main(int argc, char **argv)
131 131
 		error(1, rctw, "pthread_join : écriture"); // le thread écriture pas arrêté 
132 132
 	}
133 133
 	
134
-	std::cout << "fin du main" << std::endl;
134
+	//~ std::cout << "fin du main" << std::endl;
135 135
 	return 0;
136 136
 }
137 137
 
@@ -170,7 +170,7 @@ void* thread_lecture(void* args)
170 170
 			{
171 171
 				//std::cout << "9" << '\n';
172 172
 				fileQ.push(ligne);
173
-				std::cout << fileQ.size() << '\n';
173
+				//~ std::cout << fileQ.size() << '\n'; // très verbeux
174 174
 			}
175 175
 			if (infile.eof()) // end of file ----
176 176
 			{
@@ -190,7 +190,7 @@ void* thread_lecture(void* args)
190 190
 		//std::cin.ignore(); // ???
191 191
 	}
192 192
 	infile.close();
193
-	std::cout << "fin du thread de lecture" << std::endl;
193
+	//~ std::cout << "fin du thread de lecture" << std::endl;
194 194
 	// end thread.
195 195
 	pthread_exit(NULL);
196 196
 }
@@ -204,7 +204,7 @@ void* threadworker(void* args)
204 204
 {
205 205
 	int idth = *(int*) args; // args est un int : numéro du worker, 0..15
206 206
 	free(args); // calloc(1, sizeof(int))
207
-	std::cout << "début du thread de travail " << idth << "." << '\n';
207
+	//~ std::cout << "début du thread de travail " << idth << "." << '\n';
208 208
 	// attendre, au début la fileQ est vide, et on prendrait/relâcherait plusieurs fois un lock.
209 209
 	struct timespec sleeptime;
210 210
 	sleeptime.tv_sec = 0;
@@ -270,7 +270,7 @@ void* threadworker(void* args)
270 270
 					// Packet(int timestamp, int duration, 
271 271
 					// 		std::string ipsrc, std::string ipdst, 
272 272
 					//		uint16_t srcport, uint16_t dstport, int taille);
273
-					std::cout << idth;
273
+					//~ std::cout << idth;
274 274
 					//std::cout << "DEBUG1 : " << date2epoch(regsrxmatch[3], regsrxmatch[5]) << '\n';
275 275
 					//std::cout << "DEBUG2 : " << stoi(regsrxmatch[25]) << '\n';
276 276
 					//std::cin.ignore();
@@ -285,20 +285,22 @@ void* threadworker(void* args)
285 285
 				}
286 286
 				else
287 287
 				{
288
+					/*//~ 
288 289
 					std::cerr << "\e[33m" << "Destination invalide." << "\e[0m" << " : " << 
289 290
 						ligne << " does not match : " << 
290 291
 						site2ipsubnet(nomSite, "/home/administrateur/site2ip.csv") << 
291 292
 						", got : " << regsrxmatch[17] << '\n';
293
+					*/
292 294
 				}
293 295
 			}
294 296
 			else
295 297
 			{
296
-				std::cerr << "\e[33m" << "Ligne invalide." << "\e[0m" << " : " << ligne << '\n';
298
+				//~ std::cerr << "\e[33m" << "Ligne invalide." << "\e[0m" << " : " << ligne << '\n';
297 299
 			}
298 300
 			/// // fin travail
299 301
 		}
300 302
 	} while (endoffile == false || fileQ.size() != 0);
301
-	std::cout << " fin fic " << endoffile << " fic taille " << fileQ.size() << '\n'; 
303
+	//~ std::cout << " fin fic " << endoffile << " fic taille " << fileQ.size() << '\n'; 
302 304
 	// on passe au thread finaliseur // prise du mutex, et test ok.
303 305
 	if (int lockQTraf = pthread_mutex_lock(&resQTmutex)) // lock Traffic mutex
304 306
 	{
@@ -332,7 +334,7 @@ void* threadworker(void* args)
332 334
 		error(1, unlockQDraf, tmpmsg.c_str()); // lock error, EXIT_FAILURE
333 335
 	}
334 336
 	// fin du thread
335
-	std::cout << "je suis le thread n°" << idth << " et mon v est de taille : " << lsTraf->size() << std::endl;
337
+	//~ std::cout << "je suis le thread n°" << idth << " et mon v est de taille : " << lsTraf->size() << std::endl;
336 338
 	pthread_exit(NULL); // fin du thread.
337 339
 }
338 340
 /**
@@ -344,10 +346,10 @@ void* threadworker(void* args)
344 346
  */
345 347
 void* threadwrite(void* args)
346 348
 {
347
-	std::cout << "début du thread d'écriture" << '\n';
349
+	//~ std::cout << "début du thread d'écriture" << '\n';
348 350
 	// free/delete
349 351
 	/// Traffic()
350
-	std::cout << "taille de resQT : " << resQT.size() << '\n';
352
+	//~ std::cout << "taille de resQT : " << resQT.size() << '\n';
351 353
 	for (unsigned int i=0;i<resQT.size();i++)
352 354
 	{
353 355
 		//for (unsigned int j=0;j<resQT.at(i)->size();j++)
@@ -367,20 +369,20 @@ void* threadwrite(void* args)
367 369
 		{
368 370
 			resval->add2traffic(resQD.at(i)->getTrafficAt(temps), temps);
369 371
 		}
370
-		std::cout << "Attempting to free Data n°" << i << '\n';
372
+		//~ std::cout << "Attempting to free Data n°" << i << '\n';
371 373
 		//resQD.at(i)->toString();
372 374
 		//resQD.at(i)->writeout();
373
-		std::cin.ignore();
375
+		//~ std::cin.ignore();
374 376
 		delete resQD.at(i);
375 377
 	}
376
-	std::cin.ignore(); //
378
+	//~ std::cin.ignore(); //
377 379
 	
378 380
 	//~moyData(resval); // moyenne + écriture
379 381
 	sma(resval);
380 382
 	
381 383
 	//resval->writeout(); // écriture des données.
382 384
 	//
383
-	std::cout << "fin du thread d'écriture" << std::endl;
385
+	//~ std::cout << "fin du thread d'écriture" << std::endl;
384 386
 	pthread_exit(NULL);
385 387
 }
386 388
 ////////////////////////////////////////////////////////////////////////////////////////////////////
@@ -469,7 +471,7 @@ bool makeDataTraffic(Packet* pq, Data* dt, std::vector<Traffic>* lstf)
469 471
  */
470 472
 bool moyData(Data* vData)
471 473
 {
472
-	std::cout << "début de moyData" << '\n';
474
+	//~ std::cout << "début de moyData" << '\n';
473 475
 	// déclaration
474 476
 	std::vector<int> resval; // [0, 0, ..., 0], 86 400 fois
475 477
 	resval.reserve(86'400); //'// vecteur de secondes => taille connue
@@ -478,7 +480,7 @@ bool moyData(Data* vData)
478 480
 	{
479 481
 		resval.push_back(0);
480 482
 	}
481
-	std::cout << "Fin initialisation" << '\n';
483
+	//~ std::cout << "Fin initialisation" << '\n';
482 484
 	// travail
483 485
 	for (unsigned int i=0;i<86'400;i++) //' //  86 400s
484 486
 	{
@@ -489,7 +491,7 @@ bool moyData(Data* vData)
489 491
 		}
490 492
 		resval.at(i) = somme;
491 493
 	}
492
-	std::cout << "Fin travail" << '\n';
494
+	//~ std::cout << "Fin travail" << '\n';
493 495
 	// écriture
494 496
 	std::ofstream outfile("/tmp/bargraph.csv", std::ios_base::out);
495 497
 	std::stringstream ss; 
@@ -500,7 +502,7 @@ bool moyData(Data* vData)
500 502
 	}
501 503
 	outfile << ss.str();
502 504
 	outfile.close();
503
-	std::cout << "Fin écriture" << '\n';
505
+	//~ std::cout << "Fin écriture" << '\n';
504 506
 	return true;
505 507
 }
506 508
 /**
@@ -513,7 +515,7 @@ bool moyData(Data* vData)
513 515
 bool sma(Data* vData)
514 516
 {
515 517
 	// https://en.wikipedia.org/wiki/Moving_average
516
-	std::cout << "début de moyData" << '\n';
518
+	//~ std::cout << "début de moyData" << '\n';
517 519
 	// déclaration
518 520
 	//std::vector<int> resval; // [0, 0, ..., 0], 86 400 fois
519 521
 	std::vector<uint64_t> resval; // [0, 0, ..., 0], 86 400 fois
@@ -523,7 +525,7 @@ bool sma(Data* vData)
523 525
 	{
524 526
 		resval.push_back((uint64_t) 0);
525 527
 	}
526
-	std::cout << "Fin initialisation" << '\n';
528
+	//~ std::cout << "Fin initialisation" << '\n';
527 529
 	// travail
528 530
 	
529 531
 	///
@@ -577,7 +579,7 @@ bool sma(Data* vData)
577 579
 	}
578 580
 	///
579 581
 	
580
-	std::cout << "Fin travail" << '\n';
582
+	//~ std::cout << "Fin travail" << '\n';
581 583
 	// écriture
582 584
 	std::ofstream outfile(NomFicOut, std::ios_base::out);
583 585
 	std::stringstream ss; 
@@ -588,6 +590,6 @@ bool sma(Data* vData)
588 590
 	}
589 591
 	outfile << ss.str();
590 592
 	outfile.close();
591
-	std::cout << "Fin écriture" << '\n';
593
+	//~ std::cout << "Fin écriture" << '\n';
592 594
 	return true;
593 595
 }