diff options
| author | Bernard Duggan <[email protected]> | 2010-02-12 11:07:37 +1100 |
|---|---|---|
| committer | Erlang/OTP <[email protected]> | 2010-03-30 10:16:29 +0200 |
| commit | 999f1b99b295a69d3c505b601f14554acf4522d3 (patch) | |
| tree | fe29f20c7d41dd97f524696f0d30786d5df8c1e7 /lib/mnesia/src/mnesia_monitor.erl | |
| parent | affd1f70dbcb96ed0bd92bf379ca86c12713ca30 (diff) | |
| download | otp-999f1b99b295a69d3c505b601f14554acf4522d3.tar.gz otp-999f1b99b295a69d3c505b601f14554acf4522d3.tar.bz2 otp-999f1b99b295a69d3c505b601f14554acf4522d3.zip | |
Add mnesia activity subscription message
A process that calls mnesia:subscribe(activity) will receive the message:
{mnesia_activity_event, ActivityID, complete}
when any activity that caused a change to a database has finished
committing its changes. This allows a subscriber to collect messages
already available through the mnesia:subscribe({table, ...}) system
to group them as completed transactions.
Diffstat (limited to 'lib/mnesia/src/mnesia_monitor.erl')
| -rw-r--r-- | lib/mnesia/src/mnesia_monitor.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/lib/mnesia/src/mnesia_monitor.erl b/lib/mnesia/src/mnesia_monitor.erl index 5df5df4969..5bd93d6b9b 100644 --- a/lib/mnesia/src/mnesia_monitor.erl +++ b/lib/mnesia/src/mnesia_monitor.erl @@ -256,6 +256,7 @@ init([Parent]) -> ?ets_new_table(mnesia_gvar, [set, public, named_table]), ?ets_new_table(mnesia_stats, [set, public, named_table]), set(subscribers, []), + set(activity_subscribers, []), mnesia_lib:verbose("~p starting: ~p~n", [?MODULE, self()]), Version = mnesia:system_info(version), set(version, Version), |