diff --git a/lib/MySQL_Monitor.cpp b/lib/MySQL_Monitor.cpp index 5f2ea9192..552e2ddd7 100644 --- a/lib/MySQL_Monitor.cpp +++ b/lib/MySQL_Monitor.cpp @@ -1284,7 +1284,7 @@ void * MySQL_Monitor::run() { mysql_thr->refresh_variables(); //wqueue queue; ConsumerThread **threads= (ConsumerThread **)malloc(sizeof(ConsumerThread *)*num_threads); - for (int i=0;istart(); } @@ -1302,10 +1302,10 @@ void * MySQL_Monitor::run() { } usleep(500000); } - for (int i=0;iqueue.add(NULL); } - for (int i=0;ijoin(); } free(threads);