summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/async/async_worker.c6
-rw-r--r--src/btree/bt_evict.c19
-rw-r--r--src/conn/conn_cache_pool.c2
-rw-r--r--src/conn/conn_ckpt.c2
-rw-r--r--src/conn/conn_log.c2
-rw-r--r--src/conn/conn_stat.c2
-rw-r--r--src/conn/conn_sweep.c2
-rw-r--r--src/lsm/lsm_manager.c2
-rw-r--r--src/lsm/lsm_worker.c2
9 files changed, 18 insertions, 21 deletions
diff --git a/src/async/async_worker.c b/src/async/async_worker.c
index 3d807395ddc..7a88ac9dd6e 100644
--- a/src/async/async_worker.c
+++ b/src/async/async_worker.c
@@ -340,11 +340,11 @@ __wt_async_worker(void *arg)
}
if (0) {
-err: __wt_err(session, ret, "async worker error");
+err: WT_PANIC_MSG(session, ret, "async worker error");
}
/*
- * Worker thread cleanup, close our cached cursors and
- * free all the WT_ASYNC_CURSOR structures.
+ * Worker thread cleanup, close our cached cursors and free all the
+ * WT_ASYNC_CURSOR structures.
*/
ac = STAILQ_FIRST(&worker.cursorqh);
while (ac != NULL) {
diff --git a/src/btree/bt_evict.c b/src/btree/bt_evict.c
index ff049553c7f..d26abfff379 100644
--- a/src/btree/bt_evict.c
+++ b/src/btree/bt_evict.c
@@ -195,13 +195,8 @@ __evict_server(void *arg)
WT_ERR(__wt_verbose(session, WT_VERB_EVICTSERVER, "waking"));
}
- WT_ERR(__wt_verbose(session, WT_VERB_EVICTSERVER, "exiting"));
-
-err:
- if (ret != 0) {
- WT_PANIC_MSG(session, ret, "eviction server error");
- return (NULL);
- }
+ WT_ERR(__wt_verbose(
+ session, WT_VERB_EVICTSERVER, "cache eviction server exiting"));
if (cache->pages_inmem != cache->pages_evict)
__wt_errx(session,
@@ -219,6 +214,9 @@ err:
" bytes dirty and %" PRIu64 " pages dirty",
cache->bytes_dirty, cache->pages_dirty);
+ if (0) {
+err: WT_PANIC_MSG(session, ret, "cache eviction server error");
+ }
return (NULL);
}
@@ -364,13 +362,12 @@ __evict_worker(void *arg)
else
WT_ERR(__evict_lru_pages(session, 1));
}
+ WT_ERR(__wt_verbose(
+ session, WT_VERB_EVICTSERVER, "cache eviction worker exiting"));
if (0) {
-err: __wt_err(session, ret, "cache eviction helper error");
+err: WT_PANIC_MSG(session, ret, "cache eviction worker error");
}
-
- WT_TRET(__wt_verbose(session, WT_VERB_EVICTSERVER, "helper exiting"));
-
return (NULL);
}
diff --git a/src/conn/conn_cache_pool.c b/src/conn/conn_cache_pool.c
index ba80ac15267..ee0148e29d9 100644
--- a/src/conn/conn_cache_pool.c
+++ b/src/conn/conn_cache_pool.c
@@ -633,7 +633,7 @@ __wt_cache_pool_server(void *arg)
}
if (0) {
-err: __wt_err(session, ret, "cache pool manager server error");
+err: WT_PANIC_MSG(session, ret, "cache pool manager server error");
}
return (NULL);
}
diff --git a/src/conn/conn_ckpt.c b/src/conn/conn_ckpt.c
index ab97d4ead46..e631752f1ea 100644
--- a/src/conn/conn_ckpt.c
+++ b/src/conn/conn_ckpt.c
@@ -99,7 +99,7 @@ __ckpt_server(void *arg)
}
if (0) {
-err: __wt_err(session, ret, "checkpoint server error");
+err: WT_PANIC_MSG(session, ret, "checkpoint server error");
}
return (NULL);
}
diff --git a/src/conn/conn_log.c b/src/conn/conn_log.c
index b2555cfebf5..446aa07800f 100644
--- a/src/conn/conn_log.c
+++ b/src/conn/conn_log.c
@@ -158,7 +158,7 @@ __log_archive_server(void *arg)
}
if (0) {
-err: __wt_err(session, ret, "log archive server error");
+err: WT_PANIC_MSG(session, ret, "log archive server error");
}
if (locked_archive)
WT_TRET(__wt_writeunlock(session, log->log_archive_lock));
diff --git a/src/conn/conn_stat.c b/src/conn/conn_stat.c
index f7229504898..dd49e7359cc 100644
--- a/src/conn/conn_stat.c
+++ b/src/conn/conn_stat.c
@@ -413,7 +413,7 @@ __statlog_server(void *arg)
}
if (0) {
-err: __wt_err(session, ret, "statistics log server error");
+err: WT_PANIC_MSG(session, ret, "statistics log server error");
}
__wt_buf_free(session, &path);
__wt_buf_free(session, &tmp);
diff --git a/src/conn/conn_sweep.c b/src/conn/conn_sweep.c
index 3bccc5814be..7d427f6c816 100644
--- a/src/conn/conn_sweep.c
+++ b/src/conn/conn_sweep.c
@@ -117,7 +117,7 @@ __sweep_server(void *arg)
}
if (0) {
-err: __wt_err(session, ret, "handle sweep server error");
+err: WT_PANIC_MSG(session, ret, "handle sweep server error");
}
return (NULL);
}
diff --git a/src/lsm/lsm_manager.c b/src/lsm/lsm_manager.c
index 8f4b3ba49ef..71e4724f91c 100644
--- a/src/lsm/lsm_manager.c
+++ b/src/lsm/lsm_manager.c
@@ -499,7 +499,7 @@ __lsm_worker_manager(void *arg)
WT_ERR(__lsm_manager_worker_shutdown(session));
if (ret != 0) {
-err: __wt_err(session, ret, "LSM worker manager thread error");
+err: WT_PANIC_MSG(session, ret, "LSM worker manager thread error");
}
F_CLR(S2C(session), WT_CONN_SERVER_LSM);
return (NULL);
diff --git a/src/lsm/lsm_worker.c b/src/lsm/lsm_worker.c
index f24e58148b1..955dd09193b 100644
--- a/src/lsm/lsm_worker.c
+++ b/src/lsm/lsm_worker.c
@@ -160,7 +160,7 @@ __lsm_worker(void *arg)
if (ret != 0) {
err: __wt_lsm_manager_free_work_unit(session, entry);
- __wt_err(session, ret,
+ WT_PANIC_MSG(session, ret,
"Error in LSM worker thread %d", cookie->id);
}
return (NULL);