[Tarantool-patches] [PATCH 16/17] box: use _xc helpers of recovery code
Cyrill Gorcunov
gorcunov at gmail.com
Tue Apr 28 19:11:36 MSK 2020
To shrink code a bit.
Signed-off-by: Cyrill Gorcunov <gorcunov at gmail.com>
---
src/box/box.cc | 30 +++++++++++-------------------
1 file changed, 11 insertions(+), 19 deletions(-)
diff --git a/src/box/box.cc b/src/box/box.cc
index 01ef3318f..802aa27a2 100644
--- a/src/box/box.cc
+++ b/src/box/box.cc
@@ -2221,11 +2221,9 @@ local_recovery(const struct tt_uuid *instance_uuid,
wal_stream_create(&wal_stream);
struct recovery *recovery;
- recovery = recovery_new(cfg_gets("wal_dir"),
- cfg_geti("force_recovery"),
- checkpoint_vclock);
- if (recovery == NULL)
- diag_raise();
+ recovery = recovery_new_xc(cfg_gets("wal_dir"),
+ cfg_geti("force_recovery"),
+ checkpoint_vclock);
/*
* Make sure we report the actual recovery position
@@ -2243,8 +2241,7 @@ local_recovery(const struct tt_uuid *instance_uuid,
* so we must reflect this in replicaset vclock to
* not attempt to apply these rows twice.
*/
- if (recovery_scan(recovery, &replicaset.vclock, &gc.vclock) != 0)
- diag_raise();
+ recovery_scan_xc(recovery, &replicaset.vclock, &gc.vclock);
say_info("instance vclock %s", vclock_to_string(&replicaset.vclock));
if (wal_dir_lock >= 0) {
@@ -2285,8 +2282,7 @@ local_recovery(const struct tt_uuid *instance_uuid,
memtx_engine_recover_snapshot_xc(memtx, checkpoint_vclock);
engine_begin_final_recovery_xc();
- if (recover_remaining_wals(recovery, &wal_stream.base, NULL, false) != 0)
- diag_raise();
+ recover_remaining_wals_xc(recovery, &wal_stream.base, NULL, false);
engine_end_recovery_xc();
/*
* Leave hot standby mode, if any, only after
@@ -2295,22 +2291,19 @@ local_recovery(const struct tt_uuid *instance_uuid,
if (wal_dir_lock < 0) {
title("hot_standby");
say_info("Entering hot standby mode");
- if (recovery_follow_local(recovery, &wal_stream.base, "hot_standby",
- cfg_getd("wal_dir_rescan_delay")) != 0)
- diag_raise();
+ recovery_follow_local_xc(recovery, &wal_stream.base, "hot_standby",
+ cfg_getd("wal_dir_rescan_delay"));
while (true) {
if (path_lock(cfg_gets("wal_dir"), &wal_dir_lock)) {
- recovery_stop_local(recovery);
+ recovery_stop_local_xc(recovery);
diag_raise();
}
if (wal_dir_lock >= 0)
break;
fiber_sleep(0.1);
}
- if (recovery_stop_local(recovery))
- diag_raise();
- if (recover_remaining_wals(recovery, &wal_stream.base, NULL, true) != 0)
- diag_raise();
+ recovery_stop_local_xc(recovery);
+ recover_remaining_wals_xc(recovery, &wal_stream.base, NULL, true);
/*
* Advance replica set vclock to reflect records
* applied in hot standby mode.
@@ -2320,8 +2313,7 @@ local_recovery(const struct tt_uuid *instance_uuid,
box_sync_replication(false);
}
- if (recovery_finalize(recovery) != 0)
- diag_raise();
+ recovery_finalize_xc(recovery);
/*
* We must enable WAL before finalizing engine recovery,
--
2.20.1
More information about the Tarantool-patches
mailing list