yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(ds): Log generation operations

This commit is contained in:
ieQu1 2024-05-18 15:54:25 +02:00
parent aca2d9586c
commit 1526c527d0
No known key found for this signature in database
GPG Key ID: 488654DF3FED6FDE
1 changed files with 25 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
apps/emqx_durable_storage/src/emqx_ds_replication_layer.erl
View File

@ -761,6 +761,14 @@ apply(
#{?tag := add_generation, ?since := Since}, #{?tag := add_generation, ?since := Since},
#{db_shard := DBShard, latest := Latest0} = State0 #{db_shard := DBShard, latest := Latest0} = State0
) -> ) ->
?tp(
info,
ds_replication_layer_add_generation,
#{
shard => DBShard,
since => Since
}
),
{Timestamp, Latest} = ensure_monotonic_timestamp(Since, Latest0), {Timestamp, Latest} = ensure_monotonic_timestamp(Since, Latest0),
Result = emqx_ds_storage_layer:add_generation(DBShard, Timestamp), Result = emqx_ds_storage_layer:add_generation(DBShard, Timestamp),
State = State0#{latest := Latest}, State = State0#{latest := Latest},
@ -771,6 +779,15 @@ apply(
#{?tag := update_config, ?since := Since, ?config := Opts}, #{?tag := update_config, ?since := Since, ?config := Opts},
#{db_shard := DBShard, latest := Latest0} = State0 #{db_shard := DBShard, latest := Latest0} = State0
) -> ) ->
?tp(
notice,
ds_replication_layer_update_config,
#{
shard => DBShard,
config => Opts,
since => Since
}
),
{Timestamp, Latest} = ensure_monotonic_timestamp(Since, Latest0), {Timestamp, Latest} = ensure_monotonic_timestamp(Since, Latest0),
Result = emqx_ds_storage_layer:update_config(DBShard, Timestamp, Opts), Result = emqx_ds_storage_layer:update_config(DBShard, Timestamp, Opts),
State = State0#{latest := Latest}, State = State0#{latest := Latest},
@ -780,6 +797,14 @@ apply(
#{?tag := drop_generation, ?generation := GenId}, #{?tag := drop_generation, ?generation := GenId},
#{db_shard := DBShard} = State #{db_shard := DBShard} = State
) -> ) ->
?tp(
info,
ds_replication_layer_drop_generation,
#{
shard => DBShard,
generation => GenId
}
),
Result = emqx_ds_storage_layer:drop_generation(DBShard, GenId), Result = emqx_ds_storage_layer:drop_generation(DBShard, GenId),
{State, Result}; {State, Result};
apply( apply(