Packages
ra
2.0.7
3.1.9
3.1.8
3.1.7
3.1.6
3.1.5
3.1.4
3.1.3
3.1.2
3.1.1
3.1.0
3.0.2
3.0.1
3.0.0
3.0.0-beta.1
2.17.3
2.17.2
2.17.1
2.17.0
2.16.13
2.16.12
2.16.11
2.16.10
2.16.9
2.16.8
2.16.7
2.16.6
2.16.5
2.16.4
2.16.3
2.16.2
2.16.1
2.16.0
2.16.0-pre.12
2.16.0-pre.11
2.16.0-pre.10
2.16.0-pre.9
2.16.0-pre.8
2.16.0-pre.7
2.16.0-pre.6
2.16.0-pre.5
2.16.0-pre.4
2.16.0-pre.3
2.16.0-pre.2
2.16.0-pre.1
2.15.4
2.15.3
2.15.2
2.15.1
2.15.0
2.14.0
2.13.6
2.13.5
2.13.4
2.13.3
2.13.2
2.13.1
2.13.0
2.13.0-pre.1
2.12.0
2.11.0
2.11.0-pre.1
2.10.2-pre.2
2.10.2-pre.1
2.10.1
2.10.0
2.10.0-pre.3
2.10.0-pre.2
2.10.0-pre.1
2.9.10-pre.1
2.9.1
2.9.1-pre.2
2.9.1-pre.1
2.9.0
2.8.0
retired
2.7.3
2.7.2
2.7.1
2.7.0
2.7.0-pre.3
2.7.0-pre.2
2.7.0-pre.1
2.6.3
2.6.2
2.6.1
2.6.0-pre.1
2.5.1
2.5.1-pre.1
2.5.0
2.4.9
2.4.8
2.4.7
2.4.6
2.4.5
2.4.4
2.4.3
2.4.2
retired
2.4.1
2.4.0
2.3.0
2.2.0
2.1.0
2.0.13
2.0.12
2.0.11
2.0.10
2.0.9
2.0.8
2.0.7
2.0.6
2.0.5
2.0.4
2.0.3
2.0.2
2.0.1
2.0.0
1.1.9
1.1.8
1.1.7
1.1.6
1.1.5
1.1.4
1.1.3
1.1.2
1.1.1
1.1.0
1.0.8
1.0.7
1.0.6
1.0.5
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
0.9.6
0.9.5
0.9.4
0.9.2
0.3.3
retired
0.3.2
retired
0.3.1
retired
Raft library
Current section
Files
Jump to
Current section
Files
src/ra_file_handle.erl
%% This Source Code Form is subject to the terms of the Mozilla Public
%% License, v. 2.0. If a copy of the MPL was not distributed with this
%% file, You can obtain one at https://mozilla.org/MPL/2.0/.
%%
%% Copyright (c) 2017-2022 VMware, Inc. or its affiliates. All rights reserved.
%%
%% @hidden
-module(ra_file_handle).
-include("ra.hrl").
-behaviour(gen_server).
-export([start_link/0]).
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
terminate/2, code_change/3]).
-export([open/2, close/1, sync/1, datasync/1, none/1, write/2, read/2, position/2]).
-export([pwrite/2, pwrite/3, pread/2, pread/3]).
-define(SERVER, ?MODULE).
-define(TABLE, ra_io_metrics).
-define(COUNT_TIME, [io_sync, io_seek, io_file_handle_open_attempt]).
-define(COUNT_TIME_BYTES, [io_read, io_write]).
-record(state, {monitors = #{} :: #{pid() => reference()}}).
open(File, Modes) ->
gen_server:cast(?MODULE, {open, self()}),
update(io_file_handle_open_attempt, fun() -> file:open(File, Modes) end).
close(Fd) ->
gen_server:cast(?MODULE, {close, self()}),
file:close(Fd).
sync(Fd) ->
update(io_sync, fun() -> file:sync(Fd) end).
datasync(Fd) ->
update(io_sync, fun() -> file:datasync(Fd) end).
%% called when wal does not sync at all
none(_Fd) ->
ok.
write(Fd, Bytes) ->
update(io_write, iolist_size(Bytes), fun() -> file:write(Fd, Bytes) end).
read(Fd, Bytes) ->
update(io_read, Bytes, fun() -> file:read(Fd, Bytes) end).
position(Fd, Location) ->
update(io_seek, fun() -> file:position(Fd, Location) end).
pwrite(Fd, LocBytes) ->
update(io_write, fun() -> file:pwrite(Fd, LocBytes) end).
pwrite(Fd, Location, Bytes) ->
update(io_write, iolist_size(Bytes),
fun() -> file:pwrite(Fd, Location, Bytes) end).
pread(Fd, LocBytes) ->
update(io_read, fun() -> file:pread(Fd, LocBytes) end).
pread(Fd, Location, Number) ->
update(io_read, Number, fun() -> file:pread(Fd, Location, Number) end).
update(Op, Bytes, Thunk) ->
{Time, Res} = timer_tc(Thunk),
_ = ets:update_counter(?TABLE, {Op, count}, 1),
_ = ets:update_counter(?TABLE, {Op, bytes}, Bytes),
_ = ets:update_counter(?TABLE, {Op, time}, Time),
Res.
update(Op, Thunk) ->
{Time, Res} = timer_tc(Thunk),
_ = ets:update_counter(?TABLE, {Op, count}, 1),
_ = ets:update_counter(?TABLE, {Op, time}, Time),
Res.
timer_tc(Thunk) ->
T1 = erlang:monotonic_time(),
Res = Thunk(),
T2 = erlang:monotonic_time(),
Diff = erlang:convert_time_unit(T2 - T1, native, micro_seconds),
{Diff, Res}.
start_link() ->
gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
init([]) ->
process_flag(trap_exit, true),
[ets:insert(?TABLE, {{Op, Counter}, 0}) || Op <- ?COUNT_TIME_BYTES,
Counter <- [count, bytes, time]],
[ets:insert(?TABLE, {{Op, Counter}, 0}) || Op <- ?COUNT_TIME,
Counter <- [count, time]],
{ok, #state{}}.
handle_call(_Request, _From, State) ->
Reply = ok,
{reply, Reply, State}.
handle_cast({open, Pid}, #state{monitors = Monitors} = State) ->
ets:update_counter(ra_open_file_metrics, Pid, 1, {Pid, 0}),
case Monitors of
#{Pid := _MRef} ->
{noreply, State};
_ ->
MRef = erlang:monitor(process, Pid),
{noreply, State#state{monitors = Monitors#{Pid => MRef}}}
end;
handle_cast({close, Pid}, State) ->
ets:update_counter(ra_open_file_metrics, Pid, -1, {Pid, 0}),
{noreply, State};
handle_cast(_Msg, State) ->
{noreply, State}.
handle_info({'DOWN', MRef, process, Pid, _},
#state{monitors = Monitors0} = State) ->
case maps:take(Pid, Monitors0) of
{MRef, Monitors} ->
ets:delete(ra_open_file_metrics, Pid),
{noreply, State#state{monitors = Monitors}};
error ->
{noreply, State}
end;
handle_info(_Info, State) ->
{noreply, State}.
terminate(_Reason, _State) ->
ok.
code_change(_OldVsn, State, _Extra) ->
{ok, State}.