this repo has no description
Refresh cluster at the end of cycle and enable recovery test
+8
-8
+3
-3
lib/servers/manager.ex
+3
-3
lib/servers/manager.ex
···
311
311
%Server{pid: old_tlog_pid} = Map.fetch!(state.cluster.servers, hd(state.recovered_tlogs).id)
312
312
{:ok, meta_pairs} = TLog.read_meta_store(old_tlog_pid, min_dv)
313
313
314
-
dbg {state.cluster.generation, max_kcv, min_dv}
315
-
dbg {meta_pairs, state.cluster.tlog_generations}
314
+
#dbg {state.cluster.generation, max_kcv, min_dv}
315
+
#dbg {meta_pairs, state.cluster.tlog_generations}
316
316
317
317
ids = allocate_server_ids(state, state.config.num_tlogs + state.config.num_commit_buffers + 3)
318
318
{tlog_ids, ids} = Enum.split(ids, state.config.num_tlogs)
···
346
346
# even if nothing was copied from the last generation
347
347
recovery_commit_version = max(new_tlog_generation.start_version, last_batch_version + 1)
348
348
state = write_recovery_commit(state, new_tlog_generation, last_batch_version, recovery_commit_version)
349
-
dbg {last_batch_version, recovery_commit_version}
349
+
#dbg {last_batch_version, recovery_commit_version}
350
350
351
351
# Recruit the rest of the new transaction system
352
352
state =
+1
lib/workloads/cycle.ex
+1
lib/workloads/cycle.ex
+4
-5
test/hobbes_test.exs
+4
-5
test/hobbes_test.exs
···
109
109
defmodule CycleRecoveryWorkloadTest do
110
110
use ExUnit.Case, async: true
111
111
@tag :cycle_recovery
112
-
@tag :disable
113
112
test "Cycle Recovery", %{test: test} do
114
113
Workloads.run([
115
114
{Workloads.Cycle, [
116
115
keys: 80,
117
-
clients: 100,
116
+
clients: 20,
118
117
client_tick_ms: 100,
119
-
duration_ms: 30_000,
118
+
duration_ms: 10_000,
120
119
]},
121
120
{Workloads.KillServers, [
122
-
delay_ms: 10_000,
123
-
duration_ms: 20_000,
121
+
delay_ms: 3_000,
122
+
duration_ms: 0,
124
123
]},
125
124
], HobbesTest.SimOpts.sim_opts(name: test, cluster_opts: [
126
125
num_commit_buffers: 6,