windowsApiUpdateThreadRun

Type definitions in this namespace

Types

Status
TerminalMode
Options
Node: Represents one unit of progress.

Initializes a global Progress instance.

Functions

start: Initializes a global Progress instance.
setStatus
lockStdErr: Allows the caller to freely write to stderr until `unlockStdErr` is called.
unlockStdErr
lockStderrWriter: Allows the caller to freely write to the returned `Writer`,
unlockStderrWriter

= switch (builtin.os.tag) { .wasi, .freestanding, .windows => false, else => true, }

Values

have_ipc: = switch (builtin.os.tag) { .wasi, .freestanding, .windows => false, else => true, }

Source

Implementation

fn windowsApiUpdateThreadRun() void {
    var serialized_buffer: Serialized.Buffer = undefined;

    {
        const resize_flag = wait(global_progress.initial_delay_ns);
        if (@atomicLoad(bool, &global_progress.done, .monotonic)) return;
        maybeUpdateSize(resize_flag);

        const buffer, const nl_n = computeRedraw(&serialized_buffer);
        if (stderr_mutex.tryLock()) {
            defer stderr_mutex.unlock();
            windowsApiWriteMarker();
            write(buffer) catch return;
            global_progress.need_clear = true;
            windowsApiMoveToMarker(nl_n) catch return;
        }
    }

    while (true) {
        const resize_flag = wait(global_progress.refresh_rate_ns);

        if (@atomicLoad(bool, &global_progress.done, .monotonic)) {
            stderr_mutex.lock();
            defer stderr_mutex.unlock();
            return clearWrittenWindowsApi() catch {};
        }

        maybeUpdateSize(resize_flag);

        const buffer, const nl_n = computeRedraw(&serialized_buffer);
        if (stderr_mutex.tryLock()) {
            defer stderr_mutex.unlock();
            clearWrittenWindowsApi() catch return;
            windowsApiWriteMarker();
            write(buffer) catch return;
            global_progress.need_clear = true;
            windowsApiMoveToMarker(nl_n) catch return;
        }
    }
}