rc = USERMODEHELPER(argv[0], argv, envp);
if (rc < 0) {
CERROR("Error invoking recovery upcall %s %s %s %s %s: %d; "
- "check /proc/sys/lustre/lustre_upcall\n",
+ "check /proc/sys/lustre/upcall\n",
argv[0], argv[1], argv[2], argv[3], argv[4],rc);
} else {
LASSERT (obd_lustre_upcall != NULL);
if (strcmp(obd_lustre_upcall, "DEFAULT") == 0) {
- CDEBUG(D_ERROR, "%s: starting recovery without upcall\n",
+ CDEBUG(D_HA, "%s: starting recovery without upcall\n",
imp->imp_target_uuid.uuid);
ptlrpc_connect_import(imp, NULL);
}
else if (strcmp(obd_lustre_upcall, "NONE") == 0) {
- CDEBUG(D_ERROR, "%s: recovery diabled\n",
+ CDEBUG(D_HA, "%s: recovery disabled\n",
imp->imp_target_uuid.uuid);
}
else {
- CDEBUG(D_ERROR, "%s: calling upcall to start recovery\n",
+ CDEBUG(D_HA, "%s: calling upcall to start recovery\n",
imp->imp_target_uuid.uuid);
ptlrpc_run_failed_import_upcall(imp);
}
{
int rc = 0;
struct list_head *tmp, *pos;
- struct ptlrpc_request *req;
+ struct ptlrpc_request *req = NULL;
unsigned long flags;
__u64 last_transno;
ENTRY;
*/
list_for_each_safe(tmp, pos, &imp->imp_replay_list) {
req = list_entry(tmp, struct ptlrpc_request, rq_replay_list);
+
+ /* If need to resend, stop on the matching one first. It's
+ possible though it's already been committed, so in that case
+ we'll just continue with replay */
+ if (imp->imp_resend_replay &&
+ req->rq_transno == last_transno) {
+ lustre_msg_add_flags(req->rq_reqmsg, MSG_RESENT);
+ break;
+ }
+
if (req->rq_transno > last_transno) {
- rc = ptlrpc_replay_req(req);
- if (rc) {
- CERROR("recovery replay error %d for req "
- LPD64"\n", rc, req->rq_xid);
- RETURN(rc);
- }
- *inflight = 1;
+ imp->imp_last_replay_transno = req->rq_transno;
break;
}
+
+ req = NULL;
+ }
+
+ imp->imp_resend_replay = 0;
+
+ if (req != NULL) {
+ rc = ptlrpc_replay_req(req);
+ if (rc) {
+ CERROR("recovery replay error %d for req "
+ LPD64"\n", rc, req->rq_xid);
+ RETURN(rc);
+ }
+ *inflight = 1;
}
RETURN(rc);
}
if (rc)
RETURN(rc);
- CDEBUG(D_ERROR, "%s: recovery started, waiting\n",
+ CDEBUG(D_HA, "%s: recovery started, waiting\n",
imp->imp_target_uuid.uuid);
lwi = LWI_TIMEOUT(MAX(obd_timeout * HZ, 1), NULL, NULL);
rc = l_wait_event(imp->imp_recovery_waitq,
!ptlrpc_import_in_recovery(imp), &lwi);
- CDEBUG(D_ERROR, "%s: recovery finished\n",
+ CDEBUG(D_HA, "%s: recovery finished\n",
imp->imp_target_uuid.uuid);
RETURN(rc);