|
@@ -310,7 +310,7 @@ static int dlm_recovery_thread(void *data)
|
|
mlog(0, "dlm thread running for %s...\n", dlm->name);
|
|
mlog(0, "dlm thread running for %s...\n", dlm->name);
|
|
|
|
|
|
while (!kthread_should_stop()) {
|
|
while (!kthread_should_stop()) {
|
|
- if (dlm_joined(dlm)) {
|
|
|
|
|
|
+ if (dlm_domain_fully_joined(dlm)) {
|
|
status = dlm_do_recovery(dlm);
|
|
status = dlm_do_recovery(dlm);
|
|
if (status == -EAGAIN) {
|
|
if (status == -EAGAIN) {
|
|
/* do not sleep, recheck immediately. */
|
|
/* do not sleep, recheck immediately. */
|