@@ -365,36 +365,6 @@ t_transaction_on_replicant(_) ->
365
365
mria_rlog_props :no_unexpected_events (Trace )
366
366
end ).
367
367
368
- % % EMQX-11006
369
- % %
370
- % % Test retry of aborted R/O transaction RPCs
371
- t_ro_trans_retry (_ ) ->
372
- Cluster = mria_ct :cluster ([core , replicant ], mria_mnesia_test_util :common_env ()),
373
- ? check_trace (
374
- #{timetrap => 10000 },
375
- try
376
- Nodes = [N1 , N2 ] = mria_ct :start_cluster (mria , Cluster ),
377
- mria_mnesia_test_util :wait_tables (Nodes ),
378
- % % Delay restart of mria on the core until the replicant
379
- % % retries the transaction at least once:
380
- ? force_ordering (
381
- #{? snk_kind := mria_retry_rpc_to_core },
382
- #{? snk_kind := " Starting mnesia" , ? snk_meta := #{node := N1 }}),
383
- % % Restart mria on the core.
384
- ? assertMatch (ok , rpc :call (N1 , mria , stop , [])),
385
- rpc :cast (N1 , mria , start , []),
386
- % % Issue a R/O transaction on the replicant:
387
- TransFun = fun () -> 42 end ,
388
- ? assertMatch ({atomic , 42 },
389
- rpc :call (N2 , mria , ro_transaction , [test_shard , TransFun ]))
390
- after
391
- mria_ct :teardown_cluster (Cluster )
392
- end ,
393
- fun (Trace ) ->
394
- % % Ensure that the replicant retried RPC:
395
- ? assertMatch ([_ |_ ], ? of_kind (mria_retry_rpc_to_core , Trace ))
396
- end ).
397
-
398
368
t_sync_transaction_on_replicant (_ ) ->
399
369
Cluster = mria_ct :cluster ([core , replicant , replicant ], mria_mnesia_test_util :common_env ()),
400
370
? check_trace (
0 commit comments