diff options
| author | Paul J. Davis <paul.joseph.davis@gmail.com> | 2020-08-06 12:34:29 -0500 |
|---|---|---|
| committer | Paul J. Davis <paul.joseph.davis@gmail.com> | 2020-09-30 10:08:44 -0500 |
| commit | ddae72a707ce51c229da9188275f18664302cba7 (patch) | |
| tree | 1906984ae1baa9a63419103c2072223cfd6501a9 | |
| parent | f1906774e727982621a1acd8961a7a0483314ffb (diff) | |
| download | couchdb-ddae72a707ce51c229da9188275f18664302cba7.tar.gz | |
Export fabric2_fdb:chunkify_binary/1,2
| -rw-r--r-- | src/fabric/src/fabric2_fdb.erl | 33 |
1 files changed, 18 insertions, 15 deletions
diff --git a/src/fabric/src/fabric2_fdb.erl b/src/fabric/src/fabric2_fdb.erl index 52303cef1..36fa451ab 100644 --- a/src/fabric/src/fabric2_fdb.erl +++ b/src/fabric/src/fabric2_fdb.erl @@ -77,6 +77,9 @@ get_approximate_tx_size/1, + chunkify_binary/1, + chunkify_binary/2, + debug_cluster/0, debug_cluster/2 ]). @@ -1176,6 +1179,21 @@ get_approximate_tx_size(#{} = TxDb) -> erlfdb:wait(erlfdb:get_approximate_size(Tx)). +chunkify_binary(Data) -> + chunkify_binary(Data, binary_chunk_size()). + + +chunkify_binary(Data, Size) -> + case Data of + <<>> -> + []; + <<Head:Size/binary, Rest/binary>> -> + [Head | chunkify_binary(Rest, Size)]; + <<_/binary>> when size(Data) < Size -> + [Data] + end. + + debug_cluster() -> debug_cluster(<<>>, <<16#FE, 16#FF, 16#FF>>). @@ -1677,21 +1695,6 @@ sum_rem_rev_sizes(RevInfos) -> end, 0, RevInfos). -chunkify_binary(Data) -> - chunkify_data(Data, binary_chunk_size()). - - -chunkify_data(Data, Size) -> - case Data of - <<>> -> - []; - <<Head:Size/binary, Rest/binary>> -> - [Head | chunkify_data(Rest, Size)]; - <<_/binary>> when size(Data) < Size -> - [Data] - end. - - get_fold_acc(Db, RangePrefix, UserCallback, UserAcc, Options) when is_map(Db) orelse Db =:= undefined -> |