Преглед изворни кода

fix: remove traces of previous attempt at fixing timestamps and dead test

Thales Macedo Garitezi пре 1 година
родитељ
комит
532c8ec9bb

+ 2 - 2
apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_state.erl

@@ -519,7 +519,7 @@ commit(
     ok = store_batch(
         SessionId,
         lists:flatten([
-            {?TS, MetadataOp},
+            MetadataOp,
             SubsOps,
             SubStatesOps,
             StreamsOps,
@@ -1292,7 +1292,7 @@ pmap_commit(
                 (K, dirty, Acc) ->
                     V = cache_get(Domain, K, Cache),
                     Msg = to_domain_msg(Domain, SessionId, K, V),
-                    [{?TS, Msg} | Acc]
+                    [Msg | Acc]
             end,
             [],
             Dirty

+ 0 - 28
apps/emqx/test/emqx_persistent_session_ds_state_tests.erl

@@ -114,34 +114,6 @@ prop_stream_order_internal_keys() ->
             clean()
         end
     ).
-
-prop_domain_msg_roundtrip() ->
-    ?FORALL(
-        {SessionId, Domain, Val},
-        {session_id_gen(), domain_gen(), value_gen()},
-        ?FORALL(
-            Key,
-            key_gen(Domain),
-            begin
-                Msg = emqx_persistent_session_ds_state:to_domain_msg(Domain, SessionId, Key, Val),
-                Parsed = emqx_persistent_session_ds_state:from_domain_msg(Msg),
-                Expected = #{
-                    domain => Domain,
-                    session_id => SessionId,
-                    key => Key,
-                    val => Val
-                },
-                ?WHENFAIL(
-                    begin
-                        io:format(user, " *** Expected =~n       ~p~n", [Expected]),
-                        io:format(user, " *** Got =~n       ~p~n", [Parsed]),
-                        ok
-                    end,
-                    Expected =:= Parsed
-                )
-            end
-        )
-    ).
 %% -ifdef(STORE_STATE_IN_DS).
 -endif.