summaryrefslogtreecommitdiff
path: root/src/couch_log/src/couch_log_writer_file.erl
diff options
context:
space:
mode:
Diffstat (limited to 'src/couch_log/src/couch_log_writer_file.erl')
-rw-r--r--src/couch_log/src/couch_log_writer_file.erl11
1 files changed, 0 insertions, 11 deletions
diff --git a/src/couch_log/src/couch_log_writer_file.erl b/src/couch_log/src/couch_log_writer_file.erl
index 1fe35a8ab..9b7255050 100644
--- a/src/couch_log/src/couch_log_writer_file.erl
+++ b/src/couch_log/src/couch_log_writer_file.erl
@@ -13,18 +13,15 @@
-module(couch_log_writer_file).
-behaviour(couch_log_writer).
-
-export([
init/0,
terminate/2,
write/2
]).
-
-include_lib("kernel/include/file.hrl").
-include("couch_log.hrl").
-
-record(st, {
file_path,
fd,
@@ -32,17 +29,14 @@
last_check
}).
-
-define(CHECK_INTERVAL, 30000000).
-
-ifdef(TEST).
-export([
maybe_reopen/1
]).
-endif.
-
init() ->
FilePath = config:get("log", "file", "./couch.log"),
Opts = [append, raw] ++ buffer_opt(),
@@ -69,14 +63,12 @@ init() ->
EnsureDirError
end.
-
terminate(_, St) ->
% Apparently delayed_write can require two closes
file:close(St#st.fd),
file:close(St#st.fd),
ok.
-
write(Entry, St) ->
{ok, NewSt} = maybe_reopen(St),
#log_entry{
@@ -99,7 +91,6 @@ write(Entry, St) ->
ok = file:write(NewSt#st.fd, [Data, Msg, "\n"]),
{ok, NewSt}.
-
buffer_opt() ->
WriteBuffer = config:get_integer("log", "write_buffer", 0),
WriteDelay = config:get_integer("log", "write_delay", 0),
@@ -110,7 +101,6 @@ buffer_opt() ->
[]
end.
-
maybe_reopen(St) ->
#st{
last_check = LastCheck
@@ -121,7 +111,6 @@ maybe_reopen(St) ->
false -> {ok, St}
end.
-
reopen(St) ->
case file:read_file_info(St#st.file_path) of
{ok, FInfo} ->