this repo has no description
Remove dead code
+2
-34
+2
-34
lib/btree/writer.ex
+2
-34
lib/btree/writer.ex
···
1
1
defmodule Hobbes.BTree.Writer do
2
2
alias Hobbes.BTree
3
-
alias Hobbes.BTree.{Store, FreeList, Page}
3
+
alias Hobbes.BTree.{Store, FreeList}
4
4
5
5
import ExUnit.Assertions, only: [assert: 1]
6
6
import Hobbes.BTree.Utils
···
243
243
end
244
244
end
245
245
246
-
defp do_flush_leaf(btree, page_data, _page_sk, page_ek) do
247
-
{page_type, pairs} = Page.decode_page(page_data)
248
-
assert page_type == :leaf
249
-
250
-
pairs = fill_leaf(btree.write_buffer, page_ek, pairs)
251
-
252
-
Page.encode_page_from_pairs(page_type, btree.opts.page_size, pairs, page_ek)
253
-
end
254
-
255
-
defp fill_leaf(write_buffer, page_ek, pairs_acc) do
256
-
case :ets.first_lookup(write_buffer) do
257
-
{_key, [{key, value}]} when key < page_ek ->
258
-
:ets.delete(write_buffer, key)
259
-
260
-
pairs_acc = BTree.write_pair(pairs_acc, key, value)
261
-
fill_leaf(write_buffer, page_ek, pairs_acc)
262
-
263
-
_ -> pairs_acc
264
-
end
265
-
end
266
-
267
246
def write_root(%BTree{} = btree, pairs) do
268
247
write_inner(btree, "\xFF\xFF\xFF\xFF", pairs)
269
248
end
···
299
278
pad_bytes = opt_page_size - data_size
300
279
assert pad_bytes >= 0
301
280
302
-
slots_data = encode_slots(offsets, "")
281
+
slots_data = encode_offset_slots(offsets, "")
303
282
type_byte = 0x00
304
283
305
284
# See constant: c_page_trailer_bytes()
···
378
357
offsets_acc = [offset | offsets_acc]
379
358
count_acc = count_acc + 1
380
359
do_write_inner(pairs_rest, keys_acc, pointers_acc, offsets_acc, count_acc)
381
-
end
382
-
383
-
defp encode_slots([], slots_acc), do: slots_acc
384
-
defp encode_slots([offset | offsets_rest], slots_acc) do
385
-
assert offset < (2 ** 16)
386
-
# See constant: c_page_slot_entry_bytes()
387
-
slots_acc = <<
388
-
slots_acc::binary,
389
-
offset::integer-16,
390
-
>>
391
-
encode_slots(offsets_rest, slots_acc)
392
360
end
393
361
394
362
defp flush_leaf(%BTree{} = btree, page_data, _page_sk, page_ek) do