summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2010-09-29 10:48:42 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2010-09-29 10:48:42 +0100
commitee6d8422aed1f4f1571005de89d8a4a43fe9ce76 (patch)
tree247780b93ecd6e73576f5c6ee54991592ed642c4 /src
parent1ec0627fab0541144dea4960977601590895afb2 (diff)
downloadrabbitmq-server-git-ee6d8422aed1f4f1571005de89d8a4a43fe9ce76.tar.gz
refactor
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_queue_index.erl9
1 files changed, 4 insertions, 5 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl
index d4b613ffe5..9b4255da01 100644
--- a/src/rabbit_queue_index.erl
+++ b/src/rabbit_queue_index.erl
@@ -228,13 +228,11 @@
init(Name, false, _MsgStoreRecovered, _ContainsCheckFun, OnSyncFun) ->
State = #qistate { dir = Dir } = blank_state(Name),
false = filelib:is_file(Dir), %% is_file == is file or dir
- {0, [], State #qistate { on_sync = OnSyncFun,
- unsynced_guids = []}};
+ {0, [], State #qistate { on_sync = OnSyncFun }};
init(Name, true, MsgStoreRecovered, ContainsCheckFun, OnSyncFun) ->
State = #qistate { dir = Dir } = blank_state(Name),
- State1 = State #qistate { on_sync = OnSyncFun,
- unsynced_guids = [] },
+ State1 = State #qistate { on_sync = OnSyncFun },
Terms = case read_shutdown_terms(Dir) of
{error, _} -> [];
{ok, Terms1} -> Terms1
@@ -381,7 +379,8 @@ blank_state(QueueName) ->
segments = segments_new(),
journal_handle = undefined,
dirty_count = 0,
- max_journal_entries = MaxJournal }.
+ max_journal_entries = MaxJournal,
+ unsynced_guids = [] }.
clean_file_name(Dir) -> filename:join(Dir, ?CLEAN_FILENAME).