diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-09-29 10:48:42 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-09-29 10:48:42 +0100 |
| commit | ee6d8422aed1f4f1571005de89d8a4a43fe9ce76 (patch) | |
| tree | 247780b93ecd6e73576f5c6ee54991592ed642c4 /src | |
| parent | 1ec0627fab0541144dea4960977601590895afb2 (diff) | |
| download | rabbitmq-server-git-ee6d8422aed1f4f1571005de89d8a4a43fe9ce76.tar.gz | |
refactor
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 9 |
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). |
