╭─────────────╮ │scroll to top│ ╰─────────────╯ ╭ serve_ssh_protocol.zig ───────────────────────────────────────╮ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ │ ╰───────────────────────────────────────────────────────────────╯
╭────╮ ╭ clone ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ╮ │http│ ssh │ │ ╰────╯ ╰ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ╯
1770 io: std.Io, 1771 allocator: std.mem.Allocator, 1772 sc_cipher: *Cipher, 1773 writer: *std.Io.Writer, 1774 ch: *Channel, 1775 ) !void { 1776 if (ch.local_window >= initial_recv_window / 2) return; 1777 const add = initial_recv_window - ch.local_window; 1778 ch.local_window += add; 1779 var adj: std.ArrayList(u8) = .empty; 1780 defer adj.deinit(allocator); 1781 try adj.append(allocator, SSH_MSG_CHANNEL_WINDOW_ADJUST); 1782 try writeU32(&adj, allocator, ch.remote_id); 1783 try writeU32(&adj, allocator, add); 1784 try sc_cipher.writePacket(io, allocator, writer, adj.items); 1785 } 1786 1787 pub fn writeU32(buf: *std.ArrayList(u8), allocator: std.mem.Allocator, value: u32) !void { 1788 var bytes: [4]u8 = undefined; 1789 std.mem.writeInt(u32, &bytes, value, .big); 1790 try buf.appendSlice(allocator, &bytes); 1791 } 1792