CODEWITHSUNDEEP
erlangsynchronizationschemareplicationmnesia
muehsi
muehsi

Reputation: 586

Erlang ensure Mnesia schema replication

I have a distributed application. In this, a Master node starts a mnesia schema with 4 tables. Some of them are replicated to other nodes, some are not. When a node spawns, it registers at the master node and is added to the schema and the data are replicated to this node.

How can I ensure that my replication is finished? I tried the following:

Timeout=60000,
TabList = [tab1, tab2, tab3, tab4],
mnesia:wait_for_tables(TabList, Timeout).

However, it does not take 60 seconds, not even 5 seconds until I get an error:

{{badmatch,{aborted,{no_exists,tab1}}}

Obviously it does not work..

When a new node joins a cluster, a rpc call from the master node performs the following function on the new node:

start_Mnesia(MasterNode) ->
mnesia:start(),
mnesia:change_config(extra_db_nodes, [MasterNode]),
Tabs=mnesia:system_info(tables) -- [schema], 
[mnesia:add_table_copy(Tab, node(), ram_copies) || Tab <- Tabs].

Is it also waiting until it is written to ram_copies?

Thanks.

Upvotes: 2

Views: 962

Answers (1)

Michael
Michael

Reputation: 3729

When a node joins your mnesia cluster it is already synchronised, regardless of copies of tables it, or other nodes, do or do not have.

You should see that a new node, after registering with your master and being added to the cluster, can already access all your tables. Adding a copy of a table doesn't change that, regardless of the state/stage of that copy.

When you add a copy of a table on your new node you can continue to run transactions, during and after replication, and the data that is or is not replicated to the node originating the transaction will make no difference to the correctness of the result.

So, if you are concerned just with synchronisation in terms of keeping your transactions ACID, then don't worry.

If you are concerned when when your data is actually replicated and stored safely on the other nodes, that's a different thing. In this case, I have observed that when you runmnesia:add_table_copy(Table, NewNode, disc_copies) it blocks, and returns only when NewNode has copied the data to the filesystem.

Remember though, unless you run mnesia:sync_transaction/3 all the time you don't have guarantees about data actually being on any disc after a transaction completes anyway.

Upvotes: 2

Related Questions