From 15cf2419d11887356488812ac7607858e41fc2a2 Mon Sep 17 00:00:00 2001
From: Vladislav Shpilevoy <v.shpilevoy@tarantool.org>
Date: Thu, 6 Jun 2024 21:46:29 +0200
Subject: [PATCH] box: move replicaset.vclock into instance_vclock
Storing vclock of the instance in replicaset.vclock wasn't right.
It wasn't vclock of the whole replicaset. It was local to this
instance. There is no such thing as "replicaset vclock".
The patch moves it to box.h/cc.
Part of #10113
NO_DOC=refactoring
NO_TEST=refactoring
NO_CHANGELOG=refactoring
(cherry picked from commit f1e8e4e1cfa0abb0b7d6e9c0b43983b6f038fa0c)
---
src/box/applier.cc | 14 ++++-----
src/box/box.cc | 65 ++++++++++++++++++++++++------------------
src/box/box.h | 8 +++++-
src/box/iproto.cc | 2 +-
src/box/lua/info.c | 2 +-
src/box/relay.cc | 5 ++--
src/box/replication.cc | 13 ++++-----
src/box/replication.h | 5 ----
src/box/wal.c | 15 ++++++----
src/box/wal.h | 1 +
10 files changed, 74 insertions(+), 56 deletions(-)
diff --git a/src/box/applier.cc b/src/box/applier.cc
index 70042f226a..b51fed1036 100644
--- a/src/box/applier.cc
+++ b/src/box/applier.cc
@@ -157,7 +157,7 @@ applier_check_sync(struct applier *applier)
if (applier->state == APPLIER_SYNC &&
applier->lag <= replication_sync_lag &&
vclock_compare_ignore0(&applier->remote_vclock_at_subscribe,
- &replicaset.vclock) <= 0) {
+ instance_vclock) <= 0) {
/* Applier is synced, switch to "follow". */
applier_set_state(applier, APPLIER_FOLLOW);
}
@@ -788,7 +788,7 @@ applier_wait_snapshot(struct applier *applier)
* Used to initialize the replica's initial
* vclock in bootstrap_from_master()
*/
- xrow_decode_vclock_xc(&row, &replicaset.vclock);
+ xrow_decode_vclock_xc(&row, instance_vclock);
}
coio_read_xrow(io, ibuf, &row);
@@ -844,7 +844,7 @@ applier_wait_snapshot(struct applier *applier)
* vclock yet, do it now. In 1.7+
* this vclock is not used.
*/
- xrow_decode_vclock_xc(&row, &replicaset.vclock);
+ xrow_decode_vclock_xc(&row, instance_vclock);
}
break; /* end of stream */
} else if (iproto_type_is_error(row.type)) {
@@ -1234,7 +1234,7 @@ applier_rollback_by_wal_io(int64_t signature)
trigger_run(&replicaset.applier.on_rollback, NULL);
/* Rollback applier vclock to the committed one. */
- vclock_copy(&replicaset.applier.vclock, &replicaset.vclock);
+ vclock_copy(&replicaset.applier.vclock, instance_vclock);
}
static int
@@ -1510,7 +1510,7 @@ apply_final_join_tx(uint32_t replica_id, struct stailq *rows)
&stailq_last_entry(rows, struct applier_tx_row, next)->row;
int rc = 0;
/* WAL isn't enabled yet, so follow vclock manually. */
- vclock_follow_xrow(&replicaset.vclock, last_row);
+ vclock_follow_xrow(instance_vclock, last_row);
if (unlikely(iproto_type_is_synchro_request(txr->row.type))) {
rc = apply_synchro_req(replica_id, &txr->row,
&txr->req.synchro);
@@ -1746,7 +1746,7 @@ applier_signal_ack(struct applier *applier)
applier->txn_last_tm = 0;
applier->ack_msg.vclock_sync = applier->last_vclock_sync;
applier->ack_msg.term = box_raft()->term;
- vclock_copy(&applier->ack_msg.vclock, &replicaset.vclock);
+ vclock_copy(&applier->ack_msg.vclock, instance_vclock);
cmsg_init(&applier->ack_msg.base, applier->ack_route);
cpipe_push(&applier->applier_thread->thread_pipe,
&applier->ack_msg.base);
@@ -2373,7 +2373,7 @@ applier_subscribe(struct applier *applier)
struct subscribe_request req;
memset(&req, 0, sizeof(req));
- vclock_copy(&req.vclock, &replicaset.vclock);
+ vclock_copy(&req.vclock, instance_vclock);
ERROR_INJECT(ERRINJ_REPLICASET_VCLOCK, {
vclock_create(&req.vclock);
});
diff --git a/src/box/box.cc b/src/box/box.cc
index dd66285a45..2bd6c421cb 100644
--- a/src/box/box.cc
+++ b/src/box/box.cc
@@ -99,6 +99,15 @@
static char status[64] = "unconfigured";
+/**
+ * Storage for WAL vclock. Not in-memory but specifically for what is the
+ * vclock of the end of WAL.
+ *
+ * It is encapsulated inside this file to protect it from any illegal changes
+ * by outside code.
+ */
+static struct vclock instance_vclock_storage;
+
/** box.stat rmean */
struct rmean *rmean_box;
@@ -109,7 +118,8 @@ double txn_timeout_default;
struct rlist box_on_shutdown_trigger_list =
RLIST_HEAD_INITIALIZER(box_on_shutdown_trigger_list);
-const struct vclock *box_vclock = &replicaset.vclock;
+const struct vclock *box_vclock = instance_vclock;
+struct vclock *instance_vclock = &instance_vclock_storage;
const char *box_auth_type;
@@ -293,10 +303,10 @@ box_broadcast_ballot_on_timeout(ev_loop *loop, ev_timer *timer, int events)
(void)timer;
(void)events;
static struct vclock broadcast_vclock;
- if (vclock_compare_ignore0(&broadcast_vclock, &replicaset.vclock) == 0)
+ if (vclock_compare_ignore0(&broadcast_vclock, instance_vclock) == 0)
return;
box_broadcast_ballot();
- vclock_copy(&broadcast_vclock, &replicaset.vclock);
+ vclock_copy(&broadcast_vclock, instance_vclock);
}
/**
@@ -2327,7 +2337,7 @@ box_collect_confirmed_vclock(struct vclock *confirmed_vclock, double deadline)
* We should check the vclock on self plus vclock_count - 1 remote
* instances.
*/
- vclock_copy(confirmed_vclock, &replicaset.vclock);
+ vclock_copy(confirmed_vclock, instance_vclock);
if (vclock_count <= 1)
return 0;
@@ -2407,7 +2417,7 @@ box_wait_vclock_f(struct trigger *trigger, void *event)
(void)event;
struct box_wait_vclock_data *data =
(struct box_wait_vclock_data *)trigger->data;
- if (vclock_compare_ignore0(data->vclock, &replicaset.vclock) <= 0) {
+ if (vclock_compare_ignore0(data->vclock, instance_vclock) <= 0) {
data->is_ready = true;
fiber_wakeup(data->waiter);
}
@@ -2421,7 +2431,7 @@ box_wait_vclock_f(struct trigger *trigger, void *event)
static int
box_wait_vclock(const struct vclock *vclock, double deadline)
{
- if (vclock_compare_ignore0(vclock, &replicaset.vclock) <= 0)
+ if (vclock_compare_ignore0(vclock, instance_vclock) <= 0)
return 0;
struct trigger on_wal_write;
struct box_wait_vclock_data data = {
@@ -3910,7 +3920,7 @@ box_process_fetch_snapshot(struct iostream *io,
/* Remember master's vclock after the last request */
struct vclock stop_vclock;
- vclock_copy(&stop_vclock, &replicaset.vclock);
+ vclock_copy(&stop_vclock, instance_vclock);
/* Send end of snapshot data marker */
struct xrow_header row;
@@ -3937,7 +3947,7 @@ static void
box_localize_vclock(const struct vclock *remote, struct vclock *local)
{
vclock_copy(local, remote);
- vclock_reset(local, 0, vclock_get(&replicaset.vclock, 0));
+ vclock_reset(local, 0, vclock_get(instance_vclock, 0));
}
void
@@ -4009,7 +4019,7 @@ box_process_register(struct iostream *io, const struct xrow_header *header)
tnt_raise(ClientError, ER_CANNOT_REGISTER);
/* Remember master's vclock after the last request */
struct vclock stop_vclock;
- vclock_copy(&stop_vclock, &replicaset.vclock);
+ vclock_copy(&stop_vclock, instance_vclock);
/*
* Feed replica with WALs up to the REGISTER itself so that it gets own
* registration entry.
@@ -4021,7 +4031,7 @@ box_process_register(struct iostream *io, const struct xrow_header *header)
RegionGuard region_guard(&fiber()->gc);
struct xrow_header row;
/* Send end of WAL stream marker */
- xrow_encode_vclock(&row, &replicaset.vclock);
+ xrow_encode_vclock(&row, instance_vclock);
row.sync = header->sync;
coio_write_xrow(io, &row);
@@ -4126,8 +4136,8 @@ box_process_join(struct iostream *io, const struct xrow_header *header)
* Register the replica as a WAL consumer so that
* it can resume FINAL JOIN where INITIAL JOIN ends.
*/
- struct gc_consumer *gc = gc_consumer_register(&replicaset.vclock,
- "replica %s", tt_uuid_str(&req.instance_uuid));
+ struct gc_consumer *gc = gc_consumer_register(
+ instance_vclock, "replica %s", tt_uuid_str(&req.instance_uuid));
if (gc == NULL)
diag_raise();
auto gc_guard = make_scoped_guard([&] { gc_consumer_unregister(gc); });
@@ -4158,7 +4168,7 @@ box_process_join(struct iostream *io, const struct xrow_header *header)
/* Remember master's vclock after the last request */
struct vclock stop_vclock;
- vclock_copy(&stop_vclock, &replicaset.vclock);
+ vclock_copy(&stop_vclock, instance_vclock);
/* Send end of initial stage data marker */
struct xrow_header row;
RegionGuard region_guard(&fiber()->gc);
@@ -4175,7 +4185,7 @@ box_process_join(struct iostream *io, const struct xrow_header *header)
say_info("final data sent.");
/* Send end of WAL stream marker */
- xrow_encode_vclock(&row, &replicaset.vclock);
+ xrow_encode_vclock(&row, instance_vclock);
row.sync = header->sync;
coio_write_xrow(io, &row);
@@ -4303,7 +4313,7 @@ box_process_subscribe(struct iostream *io, const struct xrow_header *header)
*/
struct subscribe_response rsp;
memset(&rsp, 0, sizeof(rsp));
- vclock_copy(&rsp.vclock, &replicaset.vclock);
+ vclock_copy(&rsp.vclock, instance_vclock);
rsp.replicaset_uuid = REPLICASET_UUID;
struct xrow_header row;
RegionGuard region_guard(&fiber()->gc);
@@ -4364,7 +4374,7 @@ box_process_vote(struct ballot *ballot)
ballot->is_anon = replication_anon;
ballot->is_ro = is_ro_summary;
ballot->is_booted = is_box_configured;
- vclock_copy(&ballot->vclock, &replicaset.vclock);
+ vclock_copy(&ballot->vclock, instance_vclock);
vclock_copy(&ballot->gc_vclock, &gc.vclock);
ballot->bootstrap_leader_uuid = bootstrap_leader_uuid;
int i = 0;
@@ -4581,7 +4591,7 @@ bootstrap_from_master(struct replica *master)
* Process final data (WALs).
*/
engine_begin_final_recovery_xc();
- recovery_journal_create(&replicaset.vclock);
+ recovery_journal_create(&instance_vclock_storage);
if (!replication_anon) {
applier_resume_to_state(applier, APPLIER_JOINED,
@@ -4744,7 +4754,7 @@ local_recovery(const struct tt_uuid *instance_uuid,
*/
box_vclock = &recovery->vclock;
auto guard = make_scoped_guard([&]{
- box_vclock = &replicaset.vclock;
+ box_vclock = instance_vclock;
recovery_delete(recovery);
});
@@ -4754,10 +4764,10 @@ local_recovery(const struct tt_uuid *instance_uuid,
* so we must reflect this in replicaset vclock to
* not attempt to apply these rows twice.
*/
- recovery_scan(recovery, &replicaset.vclock, &gc.vclock,
+ recovery_scan(recovery, &instance_vclock_storage, &gc.vclock,
&wal_stream.base);
box_broadcast_ballot();
- say_info("instance vclock %s", vclock_to_string(&replicaset.vclock));
+ say_info("instance vclock %s", vclock_to_string(instance_vclock));
if (wal_dir_lock >= 0) {
if (box_listen() != 0)
@@ -4859,11 +4869,11 @@ local_recovery(const struct tt_uuid *instance_uuid,
* Advance replica set vclock to reflect records
* applied in hot standby mode.
*/
- vclock_copy(&replicaset.vclock, &recovery->vclock);
+ vclock_copy(&instance_vclock_storage, &recovery->vclock);
if (box_listen() != 0)
diag_raise();
box_update_replication();
- } else if (vclock_compare(&replicaset.vclock, &recovery->vclock) != 0) {
+ } else if (vclock_compare(instance_vclock, &recovery->vclock) != 0) {
/*
* There are several reasons for a node to recover a vclock not
* matching the one scanned initially:
@@ -4889,12 +4899,13 @@ local_recovery(const struct tt_uuid *instance_uuid,
const char *mismatch_str =
tt_sprintf("Replicaset vclock %s doesn't match "
"recovered data %s",
- vclock_to_string(&replicaset.vclock),
+ vclock_to_string(instance_vclock),
vclock_to_string(&recovery->vclock));
if (box_is_force_recovery) {
say_warn("%s: ignoring, because 'force_recovery' "
"configuration option is set.", mismatch_str);
- vclock_copy(&replicaset.vclock, &recovery->vclock);
+ vclock_copy(&instance_vclock_storage,
+ &recovery->vclock);
} else {
panic("Can't proceed. %s.", mismatch_str);
}
@@ -5053,7 +5064,7 @@ box_cfg_xc(void)
* replicaset.applier.vclock is filled with real
* value where local restore has already completed
*/
- vclock_copy(&replicaset.applier.vclock, &replicaset.vclock);
+ vclock_copy(&replicaset.applier.vclock, instance_vclock);
/*
* Exclude self from GC delay because we care
@@ -5100,7 +5111,7 @@ box_cfg_xc(void)
struct raft *raft = box_raft();
if (!replication_anon)
raft_cfg_instance_id(raft, instance_id);
- raft_cfg_vclock(raft, &replicaset.vclock);
+ raft_cfg_vclock(raft, instance_vclock);
if (box_set_election_timeout() != 0)
diag_raise();
@@ -5446,7 +5457,7 @@ box_storage_init(void)
double wal_retention_period = box_check_wal_retention_period_xc();
if (wal_init(wal_mode, cfg_gets("wal_dir"), wal_max_size,
wal_retention_period, &INSTANCE_UUID,
- on_wal_garbage_collection,
+ &instance_vclock_storage, on_wal_garbage_collection,
on_wal_checkpoint_threshold) != 0) {
diag_raise();
}
diff --git a/src/box/box.h b/src/box/box.h
index abfc3d3445..9cea1360c8 100644
--- a/src/box/box.h
+++ b/src/box/box.h
@@ -57,12 +57,18 @@ struct vclock;
* Pointer to TX thread local vclock.
*
* During recovery it points to the current recovery position.
- * Once recovery is complete, it is set to &replicaset.vclock.
+ * Once recovery is complete, it is set to instance_vclock.
*
* We need it for reporting the actual vclock in box.info while
* the instance is in hot standby mode.
*/
extern const struct vclock *box_vclock;
+/**
+ * Vclock of the instance as it is stored on disk. It means that during
+ * recovery this vclock points to the end of WAL, not to the current recovery
+ * position.
+ */
+extern struct vclock *instance_vclock;
/**
* Name of the authentication method that is currently used on
diff --git a/src/box/iproto.cc b/src/box/iproto.cc
index 4c37a869da..2808303b80 100644
--- a/src/box/iproto.cc
+++ b/src/box/iproto.cc
@@ -2434,7 +2434,7 @@ tx_process_misc(struct cmsg *m)
::schema_version);
break;
case IPROTO_VOTE_DEPRECATED:
- iproto_reply_vclock_xc(out, &replicaset.vclock,
+ iproto_reply_vclock_xc(out, instance_vclock,
msg->header.sync,
::schema_version);
break;
diff --git a/src/box/lua/info.c b/src/box/lua/info.c
index 988b2abb67..96253734bf 100644
--- a/src/box/lua/info.c
+++ b/src/box/lua/info.c
@@ -168,7 +168,7 @@ lbox_pushreplica(lua_State *L, struct replica *replica)
lua_settable(L, -3);
lua_pushstring(L, "lsn");
- luaL_pushuint64(L, vclock_get(&replicaset.vclock, replica->id));
+ luaL_pushuint64(L, vclock_get(instance_vclock, replica->id));
lua_settable(L, -3);
if (applier != NULL && applier->state != APPLIER_OFF) {
diff --git a/src/box/relay.cc b/src/box/relay.cc
index 50acaa43da..bc4eb39768 100644
--- a/src/box/relay.cc
+++ b/src/box/relay.cc
@@ -57,6 +57,7 @@
#include "wal.h"
#include "txn_limbo.h"
#include "raft.h"
+#include "box.h"
#include <stdlib.h>
@@ -584,7 +585,7 @@ relay_final_join(struct replica *replica, struct iostream *io, uint64_t sync,
tnt_raise(ClientError, ER_INJECTION, "relay final join"));
ERROR_INJECT(ERRINJ_RELAY_FINAL_SLEEP, {
- while (vclock_compare(stop_vclock, &replicaset.vclock) == 0)
+ while (vclock_compare(stop_vclock, instance_vclock) == 0)
fiber_sleep(0.001);
});
}
@@ -1127,7 +1128,7 @@ relay_subscribe(struct replica *replica, struct iostream *io, uint64_t sync,
replica_on_relay_stop(replica);
});
- vclock_copy(&relay->local_vclock_at_subscribe, &replicaset.vclock);
+ vclock_copy(&relay->local_vclock_at_subscribe, instance_vclock);
/*
* Save the first vclock as 'received'. Because it was really received.
*/
diff --git a/src/box/replication.cc b/src/box/replication.cc
index 213318c272..389b8b214a 100644
--- a/src/box/replication.cc
+++ b/src/box/replication.cc
@@ -180,12 +180,11 @@ replication_init(int num_threads)
memset(&replicaset, 0, sizeof(replicaset));
replica_hash_new(&replicaset.hash);
rlist_create(&replicaset.anon);
- vclock_create(&replicaset.vclock);
fiber_cond_create(&replicaset.applier.cond);
latch_create(&replicaset.applier.order_latch);
vclock_create(&replicaset.applier.vclock);
- vclock_copy(&replicaset.applier.vclock, &replicaset.vclock);
+ vclock_copy(&replicaset.applier.vclock, instance_vclock);
rlist_create(&replicaset.applier.on_rollback);
rlist_create(&replicaset.applier.on_wal_write);
@@ -350,7 +349,7 @@ replica_set_id(struct replica *replica, uint32_t replica_id)
* anonymous to a normal one.
*/
assert(replica->gc == NULL);
- replica->gc = gc_consumer_register(&replicaset.vclock,
+ replica->gc = gc_consumer_register(instance_vclock,
"replica %s",
tt_uuid_str(&replica->uuid));
}
@@ -1036,8 +1035,7 @@ replicaset_needs_rejoin(struct replica **master)
continue;
const struct ballot *ballot = &applier->ballot;
- if (vclock_compare(&ballot->gc_vclock,
- &replicaset.vclock) <= 0) {
+ if (vclock_compare(&ballot->gc_vclock, instance_vclock) <= 0) {
/*
* There's at least one master that still stores
* WALs needed by this instance. Proceed to local
@@ -1049,14 +1047,15 @@ replicaset_needs_rejoin(struct replica **master)
const char *uuid_str = tt_uuid_str(&replica->uuid);
const char *addr_str = sio_strfaddr(&applier->addr,
applier->addr_len);
- const char *local_vclock_str = vclock_to_string(&replicaset.vclock);
+ const char *local_vclock_str =
+ vclock_to_string(instance_vclock);
const char *remote_vclock_str = vclock_to_string(&ballot->vclock);
const char *gc_vclock_str = vclock_to_string(&ballot->gc_vclock);
say_info("can't follow %s at %s: required %s available %s",
uuid_str, addr_str, local_vclock_str, gc_vclock_str);
- if (vclock_compare(&replicaset.vclock, &ballot->vclock) > 0) {
+ if (vclock_compare(instance_vclock, &ballot->vclock) > 0) {
/*
* Replica has some rows that are not present on
* the master. Don't rebootstrap as we don't want
diff --git a/src/box/replication.h b/src/box/replication.h
index 71cfa36ce7..46837347f2 100644
--- a/src/box/replication.h
+++ b/src/box/replication.h
@@ -248,11 +248,6 @@ struct replicaset {
* to connect and those that failed to connect.
*/
struct rlist anon;
- /**
- * TX thread local vclock reflecting the state
- * of the cluster as maintained by appliers.
- */
- struct vclock vclock;
/**
* This flag is set while the instance is bootstrapping
* from a remote master.
diff --git a/src/box/wal.c b/src/box/wal.c
index 9e1c583b20..486c99c0a8 100644
--- a/src/box/wal.c
+++ b/src/box/wal.c
@@ -103,6 +103,8 @@ struct wal_writer
struct cpipe wal_pipe;
/** A memory pool for messages. */
struct mempool msg_pool;
+ /** Vclock to propagate on write. */
+ struct vclock *instance_vclock;
/**
* A last journal entry submitted to write. This is a
* 'rollback border'. When rollback starts, all
@@ -375,7 +377,7 @@ tx_complete_batch(struct cmsg *msg)
tx_complete_rollback();
}
/* Update the tx vclock to the latest written by wal. */
- vclock_copy(&replicaset.vclock, &batch->vclock);
+ vclock_copy(writer->instance_vclock, &batch->vclock);
tx_schedule_queue(&batch->commit);
trigger_run(&wal_on_write, NULL);
mempool_free(&writer->msg_pool, container_of(msg, struct wal_msg, base));
@@ -420,9 +422,11 @@ wal_writer_create(struct wal_writer *writer, enum wal_mode wal_mode,
const char *wal_dirname, int64_t wal_max_size,
double wal_retention_period,
const struct tt_uuid *instance_uuid,
+ struct vclock *instance_vclock,
wal_on_garbage_collection_f on_garbage_collection,
wal_on_checkpoint_threshold_f on_checkpoint_threshold)
{
+ writer->instance_vclock = instance_vclock;
writer->wal_mode = wal_mode;
writer->wal_max_size = wal_max_size;
@@ -546,13 +550,14 @@ int
wal_init(enum wal_mode wal_mode, const char *wal_dirname,
int64_t wal_max_size, double wal_retention_period,
const struct tt_uuid *instance_uuid,
+ struct vclock *instance_vclock,
wal_on_garbage_collection_f on_garbage_collection,
wal_on_checkpoint_threshold_f on_checkpoint_threshold)
{
/* Initialize the state. */
struct wal_writer *writer = &wal_writer_singleton;
wal_writer_create(writer, wal_mode, wal_dirname, wal_max_size,
- wal_retention_period, instance_uuid,
+ wal_retention_period, instance_uuid, instance_vclock,
on_garbage_collection, on_checkpoint_threshold);
/* Start WAL thread. */
@@ -571,7 +576,7 @@ wal_enable(void)
struct wal_writer *writer = &wal_writer_singleton;
/* Initialize the writer vclock from the recovery state. */
- vclock_copy(&writer->vclock, &replicaset.vclock);
+ vclock_copy(&writer->vclock, writer->instance_vclock);
/*
* Scan the WAL directory to build an index of all
@@ -1223,7 +1228,7 @@ wal_write_to_disk(struct cmsg *msg)
}
/*
* Remember the vclock of the last successfully written row so
- * that we can update replicaset.vclock once this message gets
+ * that we can update instance_vclock once this message gets
* back to tx.
*/
vclock_copy(&wal_msg->vclock, &writer->vclock);
@@ -1398,7 +1403,7 @@ wal_write_none_async(struct journal *journal,
vclock_create(&vclock_diff);
wal_assign_lsn(&vclock_diff, &writer->vclock, entry);
vclock_merge(&writer->vclock, &vclock_diff);
- vclock_copy(&replicaset.vclock, &writer->vclock);
+ vclock_copy(writer->instance_vclock, &writer->vclock);
entry->res = vclock_sum(&writer->vclock);
journal_async_complete(entry);
return 0;
diff --git a/src/box/wal.h b/src/box/wal.h
index 81e9831574..8ce194b6d1 100644
--- a/src/box/wal.h
+++ b/src/box/wal.h
@@ -109,6 +109,7 @@ int
wal_init(enum wal_mode wal_mode, const char *wal_dirname,
int64_t wal_max_size, double wal_retention_period,
const struct tt_uuid *instance_uuid,
+ struct vclock *instance_vclock,
wal_on_garbage_collection_f on_garbage_collection,
wal_on_checkpoint_threshold_f on_checkpoint_threshold);
--
GitLab