From 899b77e290bb5d5d72d4a5d9d77cc717826a8e9a Mon Sep 17 00:00:00 2001 From: yury Date: Sun, 24 Aug 2008 15:53:47 +0000 Subject: [PATCH] b=14608 r=wangdi,shadow - new recov thread code; - cleanups and fixes. --- lustre/obdclass/llog.c | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/lustre/obdclass/llog.c b/lustre/obdclass/llog.c index 2a36b27..62105b3 100644 --- a/lustre/obdclass/llog.c +++ b/lustre/obdclass/llog.c @@ -245,11 +245,11 @@ static int llog_process_thread(void *arg) cfs_daemonize_ctxt("llog_process_thread"); if (cd != NULL) { - last_called_index = cd->first_idx; - index = cd->first_idx + 1; + last_called_index = cd->lpcd_first_idx; + index = cd->lpcd_first_idx + 1; } - if (cd != NULL && cd->last_idx) - last_index = cd->last_idx; + if (cd != NULL && cd->lpcd_last_idx) + last_index = cd->lpcd_last_idx; else last_index = LLOG_BITMAP_BYTES * 8 - 1; @@ -347,7 +347,7 @@ static int llog_process_thread(void *arg) out: if (cd != NULL) - cd->last_idx = last_called_index; + cd->lpcd_last_idx = last_called_index; if (buf) OBD_FREE(buf, LLOG_CHUNK_SIZE); lpi->lpi_rc = rc; @@ -414,9 +414,9 @@ int llog_reverse_process(struct llog_handle *loghandle, llog_cb_t cb, RETURN(-ENOMEM); if (cd != NULL) - first_index = cd->first_idx + 1; - if (cd != NULL && cd->last_idx) - index = cd->last_idx; + first_index = cd->lpcd_first_idx + 1; + if (cd != NULL && cd->lpcd_last_idx) + index = cd->lpcd_last_idx; else index = LLOG_BITMAP_BYTES * 8 - 1; -- 1.8.3.1