this repo has no description
Perform compactions for Storage XKS
+8
-1
+8
-1
lib/servers/storage.ex
+8
-1
lib/servers/storage.ex
···
148
148
def init(%{cluster: %Cluster{} = cluster, path: _path, id: id, storage_team_id: storage_team_id}) do
149
149
# Init new storage server
150
150
assert is_integer(id)
151
-
xks = XKS.new()
151
+
# TODO: larger outside sim
152
+
xks = XKS.new(block_size: 1024, lsm_subtable_size: 1024)
152
153
153
154
# TODO: init state_partition (currently initialized by new())
154
155
XKS.init_partition(xks, @special_partiton)
···
387
388
end
388
389
389
390
defp flush(%State{} = state) do
391
+
%{xks: xks} = state
392
+
case XKS.perform_compaction(xks) do
393
+
:ok -> XKS.garbage_collect_tables(xks)
394
+
:error -> :noop
395
+
end
396
+
390
397
# TODO: compute durable_version from XKS
391
398
durable_version = max(state.data_version - mvcc_window(), 0)
392
399