|
@@ -2073,8 +2073,6 @@ static void restart_threads(void)
|
|
|
{
|
|
{
|
|
|
int i, stale;
|
|
int i, stale;
|
|
|
|
|
|
|
|
- block_changed = BLOCK_NONE;
|
|
|
|
|
-
|
|
|
|
|
/* Discard staged work that is now stale */
|
|
/* Discard staged work that is now stale */
|
|
|
stale = discard_stale();
|
|
stale = discard_stale();
|
|
|
|
|
|
|
@@ -4115,11 +4113,6 @@ static void *watchdog_thread(void *userdata)
|
|
|
mutex_unlock(&curses_lock);
|
|
mutex_unlock(&curses_lock);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if (unlikely(work_restart[watchdog_thr_id].restart)) {
|
|
|
|
|
- restart_threads();
|
|
|
|
|
- work_restart[watchdog_thr_id].restart = 0;
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
gettimeofday(&now, NULL);
|
|
gettimeofday(&now, NULL);
|
|
|
|
|
|
|
|
for (i = 0; i < total_pools; i++) {
|
|
for (i = 0; i < total_pools; i++) {
|