mirror of
https://github.com/ollama/ollama.git
synced 2026-11-12 03:46:14 -06:00
Daniel HiltgenandGitHub
cc4069396f
* transfer: bound stall retries and let the watchdog interrupt them A download that stalls could never recover. copy derived its own cancellable context, but the request was built from the parent, so cancelling on a stall never reached the in-flight body and the read stayed parked. The stall watchdog could detect a stall it had no way to stop. Stall retries were also unbounded: they never incremented attempt, so the retry loop had no limit, and because backoff was gated on attempt > 0 they retried with no delay at all. The request now owns the cancellable context and passes its cancel down to copy, so a stall aborts the read. Stalls get their own retry budget before counting against the limit, and backoff is keyed to every retry rather than only the counted ones. * move out of x/
32 lines
858 B
Go
32 lines
858 B
Go
//go:build windows
|
|
|
|
package transfer
|
|
|
|
import (
|
|
"os"
|
|
|
|
"golang.org/x/sys/windows"
|
|
)
|
|
|
|
// setSparse sets the FSCTL_SET_SPARSE attribute on Windows files.
|
|
// This allows the OS to not allocate disk blocks for zero-filled regions,
|
|
// which is useful for large files that may not be fully written (e.g., partial
|
|
// downloads). Without this, Windows may pre-allocate disk space for the full
|
|
// file size even if most of it is zeros.
|
|
//
|
|
// Note: Errors are intentionally ignored because:
|
|
// 1. The file will still work correctly without sparse support
|
|
// 2. Not all Windows filesystems support sparse files (e.g., FAT32)
|
|
// 3. This is an optimization, not a requirement
|
|
func setSparse(file *os.File) {
|
|
var bytesReturned uint32
|
|
_ = windows.DeviceIoControl(
|
|
windows.Handle(file.Fd()),
|
|
windows.FSCTL_SET_SPARSE,
|
|
nil, 0,
|
|
nil, 0,
|
|
&bytesReturned,
|
|
nil,
|
|
)
|
|
}
|