- connect:
- rc = ptlrpc_connect_import(imp);
-
- if (rc < 0) {
- CERROR("failed to reconnect to %s@%s: %d\n",
- imp->imp_target_uuid.uuid,
- imp->imp_connection->c_remote_uuid.uuid, rc);
- GOTO(out, rc);
- }
-
- if (imp->imp_state == LUSTRE_IMP_EVICTED) {
- CDEBUG(D_HA, "evicted from %s@%s; invalidating\n",
- imp->imp_target_uuid.uuid,
- imp->imp_connection->c_remote_uuid.uuid);
- ptlrpc_set_import_active(imp, 0);
- CDEBUG(D_HA, "%s: new state: RECOVER\n",
- imp->imp_client->cli_name);
- imp->imp_state = LUSTRE_IMP_RECOVER;
- }
-
- if (imp->imp_state == LUSTRE_IMP_REPLAY) {
- CDEBUG(D_HA, "replay requested by %s\n",
- imp->imp_target_uuid.uuid);
- rc = ptlrpc_replay(imp);
- if (rc)
- GOTO(out, rc);
-
- rc = ldlm_replay_locks(imp);
- if (rc)
- GOTO(out, rc);
-
- rc = signal_completed_replay(imp);
- if (rc)
- GOTO(out, rc);
- CDEBUG(D_HA, "%s: new state: RECOVER\n",
- imp->imp_client->cli_name);
- imp->imp_state = LUSTRE_IMP_RECOVER;
- }
-
- if (imp->imp_state == LUSTRE_IMP_RECOVER) {
- CDEBUG(D_HA, "reconnected to %s@%s\n",
- imp->imp_target_uuid.uuid,
- imp->imp_connection->c_remote_uuid.uuid);
-
- ptlrpc_set_import_active(imp, 1);
- ptlrpc_resend(imp);
- spin_lock_irqsave(&imp->imp_lock, flags);
- CDEBUG(D_HA, "%s: new state: FULL\n",
- imp->imp_client->cli_name);
- imp->imp_state = LUSTRE_IMP_FULL;
- spin_unlock_irqrestore(&imp->imp_lock, flags);
- ptlrpc_wake_delayed(imp);
- }
-
-
- LASSERT(imp->imp_state == LUSTRE_IMP_FULL);
-
- out:
- if (rc != 0) {
- spin_lock_irqsave(&imp->imp_lock, flags);
- imp->imp_state = LUSTRE_IMP_DISCON;
- spin_unlock_irqrestore(&imp->imp_lock, flags);
-
- if (rc == -ENOTCONN) {
- CDEBUG(D_HA, "evicted/aborted by %s@%s during recovery;"
- "invalidating and reconnecting\n",
- imp->imp_target_uuid.uuid,
- imp->imp_connection->c_remote_uuid.uuid);
- GOTO(connect, -ENOTCONN);
- } else if (was_invalid) {
- ptlrpc_set_import_active(imp, 0);
- }
- }
- up(&imp->imp_recovery_sem);