Prechádzať zdrojové kódy

fix(emqx_retainer): wait for Mria tables

firest 2 rokov pred
rodič
commit
1202bef6db

+ 1 - 0
apps/emqx_retainer/src/emqx_retainer_mnesia.erl

@@ -127,6 +127,7 @@ create_table(Table, RecordName, Attributes, Type, StorageType) ->
         {storage_properties, StoreProps}
         {storage_properties, StoreProps}
     ]),
     ]),
     ok = mria_rlog:wait_for_shards([?RETAINER_SHARD], infinity),
     ok = mria_rlog:wait_for_shards([?RETAINER_SHARD], infinity),
+    ok = mria:wait_for_tables([Table]),
     case mnesia:table_info(Table, storage_type) of
     case mnesia:table_info(Table, storage_type) of
         Copies ->
         Copies ->
             ok;
             ok;