diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-11-24 17:19:13 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-11-24 17:19:13 +0000 |
| commit | 823ec255d39a636a05af0ecd6085f39b48c73e4a (patch) | |
| tree | 38ef04aab7fae89ec48cf32e25204d05283ee61a /src | |
| parent | d2a6da1d866701a886b9014b1e40836f698d4e72 (diff) | |
| download | rabbitmq-server-git-823ec255d39a636a05af0ecd6085f39b48c73e4a.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/file_handle_cache.erl | 29 |
1 files changed, 15 insertions, 14 deletions
diff --git a/src/file_handle_cache.erl b/src/file_handle_cache.erl index fca4441b26..6631730f3d 100644 --- a/src/file_handle_cache.erl +++ b/src/file_handle_cache.erl @@ -94,7 +94,7 @@ -spec(open/3 :: (string(), [any()], [any()]) -> ({'ok', ref()} | error())). -spec(close/1 :: (ref()) -> ('ok' | error())). -spec(read/2 :: (ref(), integer()) -> - ({'ok', ([char()]|binary())} | eof | error())). + ({'ok', ([char()]|binary())} | eof | error())). -spec(append/2 :: (ref(), iodata()) -> ok_or_error()). -spec(sync/1 :: (ref()) -> ok_or_error()). -spec(position/2 :: (ref(), position()) -> @@ -106,7 +106,7 @@ -spec(append_write_buffer/1 :: (ref()) -> ok_or_error()). -spec(copy/3 :: (ref(), ref(), non_neg_integer()) -> ({'ok', integer()} | error())). --spec(set_maximum_since_use/1 :: (non_neg_integer()) -> 'ok'). +-spec(set_maximum_since_use/1 :: (non_neg_integer()) -> 'ok'). -endif. @@ -115,7 +115,8 @@ %%---------------------------------------------------------------------------- start_link() -> - gen_server2:start_link({local, ?SERVER}, ?MODULE, [], [{timeout, infinity}]). + gen_server2:start_link({local, ?SERVER}, ?MODULE, [], + [{timeout, infinity}]). open(Path, Mode, Options) -> case is_appender(Mode) of @@ -353,17 +354,17 @@ with_flushed_handles(Refs, Args, Fun) -> with_handles( Refs, Args, fun (Args1, Handles) -> - ResHandles1 = - lists:foldl( - fun (Handle, {ok, HandlesAcc}) -> - {Res, Handle1} = write_buffer(Handle), - {Res, [Handle1 | HandlesAcc]}; - (Handle, {Error, HandlesAcc}) -> - {Error, [Handle | HandlesAcc]} - end, {ok, []}, Handles), - case ResHandles1 of - {ok, Handles1} -> erlang:apply(Fun, [Args1, lists:reverse(Handles1)]); - {Error, Handles1} -> {Error, lists:reverse(Handles1)} + case lists:foldl( + fun (Handle, {ok, HandlesAcc}) -> + {Res, Handle1} = write_buffer(Handle), + {Res, [Handle1 | HandlesAcc]}; + (Handle, {Error, HandlesAcc}) -> + {Error, [Handle | HandlesAcc]} + end, {ok, []}, Handles) of + {ok, Handles1} -> + erlang:apply(Fun, [Args1, lists:reverse(Handles1)]); + {Error, Handles1} -> + {Error, lists:reverse(Handles1)} end end). |