Unexported funcs
This commit is contained in:
parent
177aca0a68
commit
595f9a463e
5 changed files with 10 additions and 7 deletions
|
@ -136,7 +136,7 @@ load_ets_table(Conn, ETS) ->
|
||||||
{ok, Fs} = machi_cr_client:list_files(Conn),
|
{ok, Fs} = machi_cr_client:list_files(Conn),
|
||||||
[begin
|
[begin
|
||||||
{ok, InfoBin} = machi_cr_client:checksum_list(Conn, File),
|
{ok, InfoBin} = machi_cr_client:checksum_list(Conn, File),
|
||||||
{PosList, _} = machi_flu1:split_checksum_list_blob_decode(InfoBin),
|
{PosList, _} = machi_csum_table:split_checksum_list_blob_decode(InfoBin),
|
||||||
StartKey = ets:update_counter(ETS, max_key, 0),
|
StartKey = ets:update_counter(ETS, max_key, 0),
|
||||||
%% _EndKey = lists:foldl(fun({Off,Sz,CSum}, K) ->
|
%% _EndKey = lists:foldl(fun({Off,Sz,CSum}, K) ->
|
||||||
%% V = {File, Off, Sz, CSum},
|
%% V = {File, Off, Sz, CSum},
|
||||||
|
|
|
@ -117,6 +117,8 @@
|
||||||
simple_chain_state_transition_is_sane/3,
|
simple_chain_state_transition_is_sane/3,
|
||||||
simple_chain_state_transition_is_sane/5,
|
simple_chain_state_transition_is_sane/5,
|
||||||
chain_state_transition_is_sane/6]).
|
chain_state_transition_is_sane/6]).
|
||||||
|
-export([perhaps_call/5, % for partition simulator use w/machi_fitness
|
||||||
|
init_remember_down_list/0]).
|
||||||
%% Exports so that EDoc docs generated for these internal funcs.
|
%% Exports so that EDoc docs generated for these internal funcs.
|
||||||
-export([mk/3]).
|
-export([mk/3]).
|
||||||
|
|
||||||
|
@ -129,8 +131,7 @@
|
||||||
-export([test_calc_projection/2,
|
-export([test_calc_projection/2,
|
||||||
test_write_public_projection/2,
|
test_write_public_projection/2,
|
||||||
test_read_latest_public_projection/2]).
|
test_read_latest_public_projection/2]).
|
||||||
-export([perhaps_call/5, % for partition simulator use w/machi_fitness
|
-export([update_remember_down_list/1,
|
||||||
init_remember_down_list/0, update_remember_down_list/1,
|
|
||||||
get_remember_down_list/0]).
|
get_remember_down_list/0]).
|
||||||
|
|
||||||
-ifdef(EQC).
|
-ifdef(EQC).
|
||||||
|
|
|
@ -210,7 +210,7 @@ make_repair_directives(ConsistencyMode, RepairMode, File, Size, EpochID,
|
||||||
Proxy, EpochID, File, ?LONG_TIMEOUT) of
|
Proxy, EpochID, File, ?LONG_TIMEOUT) of
|
||||||
{ok, InfoBin} ->
|
{ok, InfoBin} ->
|
||||||
{Info, _} =
|
{Info, _} =
|
||||||
machi_flu1:split_checksum_list_blob_decode(InfoBin),
|
machi_csum_table:split_checksum_list_blob_decode(InfoBin),
|
||||||
Info;
|
Info;
|
||||||
{error, no_such_file} ->
|
{error, no_such_file} ->
|
||||||
[]
|
[]
|
||||||
|
|
|
@ -5,14 +5,16 @@
|
||||||
all_trimmed/2,
|
all_trimmed/2,
|
||||||
sync/1,
|
sync/1,
|
||||||
calc_unwritten_bytes/1,
|
calc_unwritten_bytes/1,
|
||||||
|
split_checksum_list_blob_decode/1,
|
||||||
close/1, delete/1]).
|
close/1, delete/1]).
|
||||||
|
|
||||||
-export([encode_csum_file_entry/3, decode_csum_file_entry/1]).
|
-export([encode_csum_file_entry/3, encode_csum_file_entry_bin/3,
|
||||||
|
decode_csum_file_entry/1]).
|
||||||
|
|
||||||
-include("machi.hrl").
|
-include("machi.hrl").
|
||||||
|
|
||||||
-ifdef(TEST).
|
-ifdef(TEST).
|
||||||
-export([split_checksum_list_blob_decode/1, all/1]).
|
-export([all/1]).
|
||||||
-endif.
|
-endif.
|
||||||
|
|
||||||
-record(machi_csum_table,
|
-record(machi_csum_table,
|
||||||
|
|
|
@ -180,7 +180,7 @@ checksum_list(#yessir{name=Name,chunk_size=ChunkSize}, _EpochID, File) ->
|
||||||
MaxOffset ->
|
MaxOffset ->
|
||||||
C = machi_util:make_tagged_csum(client_sha,
|
C = machi_util:make_tagged_csum(client_sha,
|
||||||
make_csum(Name, ChunkSize)),
|
make_csum(Name, ChunkSize)),
|
||||||
Cs = [machi_flu1:encode_csum_file_entry_bin(Offset, ChunkSize, C) ||
|
Cs = [machi_csum_table:encode_csum_file_entry_bin(Offset, ChunkSize, C) ||
|
||||||
Offset <- lists:seq(?MINIMUM_OFFSET, MaxOffset, ChunkSize)],
|
Offset <- lists:seq(?MINIMUM_OFFSET, MaxOffset, ChunkSize)],
|
||||||
{ok, Cs}
|
{ok, Cs}
|
||||||
end.
|
end.
|
||||||
|
|
Loading…
Reference in a new issue