Skip to documentation
SLOP

tiny.sql.importHistoryPackBytes

Reference tiny.sql importHistoryPackBytes

Defined in sync.

Called byCallstest sourcelib.sql.src.synctest: sync byte packs import and fetc...test sourcelib.sql.src.synctest: sync pack import rejects tamper...test sourcelib.sql.src.synctest: sync record packs re-export fro...private sourcelib.sql.src.sync.ByteReaderfinishprivate sourcelib.sql.src.sync.ByteReaderinitprivate sourcelib.sql.src.sync.ByteReaderreadBytesprivate sourcelib.sql.src.sync.ByteReaderreadU32private sourcelib.sql.src.syncdecodeFrameKind+3 moresyncimportBytes
Static calls · unresolved targets: 0 · external targets: 5.

Source

Source: lib/sql/src/sync.zig:1236

zig
pub fn importBytes(allocator: Allocator, target: *history_mod.History, bytes: []const u8) Error!Stats {    var reader = ByteReader.init(bytes);    var sections = try decodePackSections(allocator, &reader);    defer sections.deinit(allocator);    var stats = Stats{};    var index: usize = 0;    while (index < sections.frame_count) : (index += 1) {        const kind = try decodeFrameKind(try reader.readU32());        const payload = try reader.readBytes();        if (try target.importPackRecord(kind, payload)) stats.records += 1;    }    try reader.finish();    for (sections.commits) |commit_object| {        const commit = version.Commit.init(commit_object.root, commit_object.parents);        if (!version.same(commit.hash, commit_object.hash)) return error.InvalidPack;        if (try target.importPackCommit(commit_object.root, commit_object.parents)) stats.commits += 1;    }    for (sections.refs) |ref_value| {        try target.putRef(.{            .name = ref_value.name,            .target = ref_value.target,        });        stats.refs += 1;    }    try target.flushSync();    return stats;}

Source: lib/sql/src/root.zig:143

zig
pub const importHistoryPackBytes = sync.importBytes;

Complete call list

8 direct calls.

Audit

Definitions1
Public names2
Members0
Version26.7.0
Revisiondaab053ee433