diff options
| author | John DeTreville <jdetreville@vmware.com> | 2011-03-27 22:47:23 -0700 |
|---|---|---|
| committer | John DeTreville <jdetreville@vmware.com> | 2011-03-27 22:47:23 -0700 |
| commit | def8eb73452ce2c2e9604c1585693eb6f31e8c4e (patch) | |
| tree | 03d2547ac82b6400211296064986804e49d98447 | |
| parent | 9a691de3894f11e903b1b74b86b231d0a34d6d46 (diff) | |
| download | rabbitmq-server-def8eb73452ce2c2e9604c1585693eb6f31e8c4e.tar.gz | |
Passes all tests (except as noted).
| -rw-r--r-- | src/rabbit_mnesia_queue.erl | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/src/rabbit_mnesia_queue.erl b/src/rabbit_mnesia_queue.erl index c5e91ed0..72a67946 100644 --- a/src/rabbit_mnesia_queue.erl +++ b/src/rabbit_mnesia_queue.erl @@ -159,17 +159,14 @@ init(QueueName, IsDurable, Recover, _AsyncCallback, _SyncCallback) -> end), State. -terminate(State = #state { q_table = QTable, p_table = PTable }) -> +terminate(State = #state { p_table = PTable }) -> {atomic, ok} = mnesia:clear_table(PTable), - {atomic, ok} = mnesia:dump_tables([QTable, PTable]), State. delete_and_terminate(State = #state { q_table = QTable, p_table = PTable }) -> - {atomic, _} = - mnesia:transaction(fun () -> ok = clear_table(QTable), - ok = clear_table(PTable) - end), - {atomic, ok} = mnesia:dump_tables([QTable, PTable]), + {atomic, _} = mnesia:transaction(fun () -> ok = clear_table(QTable), + ok = clear_table(PTable) + end), State. purge(State = #state { q_table = QTable }) -> @@ -298,7 +295,7 @@ create_table(Table, RecordName, Type, Attributes) -> case mnesia:create_table(Table, [{record_name, RecordName}, {type, Type}, {attributes, Attributes}, - {ram_copies, [node()]}]) of + {disc_copies, [node()]}]) of {atomic, ok} -> ok; {aborted, {already_exists, Table}} -> RecordName = mnesia:table_info(Table, record_name), |
