╭ changed ───╮ │src/push.zig│ ╰────────────╯ ╭───────────╮ │← all files│ ╰───────────╯ ╭──────────╮ │← previous│ ╰──────────╯ ╭─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │291 var moment = try DB.HashMap(.read_write).init(cursor.*); │ │292 const state = State(.read_write){ .core = ctx.core, .extra = .{ .moment = &moment } }; │ │292 - try xit.net_server_receive_pack.run(.xit, repo_opts, state, ctx.io, ctx.allocator, ctx.reader, ctx.writer, .{ .allowed_ref = "refs/heads/" ++ fork.ref.name, .deferred_response = ctx.response }, ctx.progress);│ │293 + try xit.net_server_receive_pack.run(.xit, repo_opts, state, ctx.io, ctx.allocator, ctx.reader, ctx.writer, .{ .allowed_ref = "refs/heads/" ++ fork.ref.name, .deferred_response = ctx.response }, ctx.sideband);│ │294 try writeReceivedPatches(repo_opts, state, ctx.io, ctx.allocator, ctx.response, ctx.writer); │ │294 - if (ctx.progress.gone) return error.ClientGone; │ │295 + if (ctx.sideband.gone) return error.ClientGone; │ │296 │ │297 // copy the target history needed to preserve the merge base │ │298 const source_oid = (try rf.readRecur(.xit, repo_opts, state.readOnly(), ctx.io, .{ .ref = fork.ref })) orelse return error.CancelTransaction; │ ╰─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭─────────────────────────────────────────────────────────╮ │378 .timestamp = timestamp, │ │379 .newest = newest, │ │380 .revision_id_maybe = &revision_id_maybe,│ │380 - .progress = &progress, │ │381 + .sideband = &sideband, │ │382 }); │ │383 }; │ │384 result catch |err| { │ ╰─────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────────────╮ │392 }; │ │393 if (!published) return response.finish(writer, null); │ │394 │ │394 - progress.run(io, .{ .text = "Updating patches" }) catch {}; │ │395 - progress.run(io, .{ .start = .{ .kind = .writing_patch, .estimated_total_items = 1 } }) catch {};│ │395 + sideband.run(io, .{ .text = "Updating patches" }) catch {}; │ │396 + sideband.run(io, .{ .start = .{ .kind = .writing_patch, .estimated_total_items = 1 } }) catch {};│ │397 │ │398 // best-effort update the published patch so it has the new revision │ │399 var refreshed = false; │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────────────╯ ╭──────────────────────────────────────────────────────────────────────────────────────────────────╮ │427 } │ │428 │ │429 if (!refreshed) pch.refreshMergeability(repo_opts, io, allocator, target_repo, patch_id);│ │429 - progress.run(io, .{ .complete_one = .writing_patch }) catch {}; │ │430 - progress.run(io, .{ .end = .writing_patch }) catch {}; │ │430 + sideband.run(io, .{ .complete_one = .writing_patch }) catch {}; │ │431 + sideband.run(io, .{ .end = .writing_patch }) catch {}; │ │432 │ │433 // the client may read either repo as soon as it gets the final response. │ │434 try response.finish(writer, null); │ ╰──────────────────────────────────────────────────────────────────────────────────────────────────╯