pali112
/
ollama
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

linter

This commit is contained in:
jmorganca 2025-12-20 22:46:46 -08:00
parent bdb9ea4772
commit bf63d18b11
3 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/download.go
View File

@ -340,6 +340,9 @@ func (b *blobDownload) run(ctx context.Context, requestURL *url.URL, opts *regis
return err return err
} }
defer file.Close() defer file.Close()
setSparse(file)
_ = file.Truncate(b.Total)
directURL, err := func() (*url.URL, error) { directURL, err := func() (*url.URL, error) {
ctx, cancel := context.WithTimeout(ctx, 30*time.Second) ctx, cancel := context.WithTimeout(ctx, 30*time.Second)

28
server/download_test.go
View File

@ -13,7 +13,7 @@ func TestSpeedTracker_Median(t *testing.T) {
s := &speedTracker{} s := &speedTracker{}
// Less than 10 samples returns 0 // Less than 10 samples returns 0
for i := 0; i < 9; i++ { for i := range 9 {
s.Record(float64(100 + i*10)) s.Record(float64(100 + i*10))
} }
if got := s.Median(); got != 0 { if got := s.Median(); got != 0 {
@ -40,7 +40,7 @@ func TestSpeedTracker_RollingWindow(t *testing.T) {
s := &speedTracker{} s := &speedTracker{}
// Add 35 samples (should keep only last 30) // Add 35 samples (should keep only last 30)
for i := 0; i < 35; i++ { for i := range 35 {
s.Record(float64(i)) s.Record(float64(i))
} }
@ -59,7 +59,7 @@ func TestSpeedTracker_Concurrent(t *testing.T) {
s := &speedTracker{} s := &speedTracker{}
var wg sync.WaitGroup var wg sync.WaitGroup
for i := 0; i < 100; i++ { for i := range 100 {
wg.Add(1) wg.Add(1)
go func(v int) { go func(v int) {
defer wg.Done() defer wg.Done()
@ -79,7 +79,7 @@ func TestSpeedTracker_Concurrent(t *testing.T) {
func TestStreamHasher_Sequential(t *testing.T) { func TestStreamHasher_Sequential(t *testing.T) {
// Create temp file // Create temp file
f, err := os.CreateTemp("", "streamhasher_test") f, err := os.CreateTemp(t.TempDir(), "streamhasher_test")
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
@ -122,7 +122,7 @@ func TestStreamHasher_Sequential(t *testing.T) {
func TestStreamHasher_OutOfOrderCompletion(t *testing.T) { func TestStreamHasher_OutOfOrderCompletion(t *testing.T) {
// Create temp file // Create temp file
f, err := os.CreateTemp("", "streamhasher_test") f, err := os.CreateTemp(t.TempDir(), "streamhasher_test")
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
@ -166,7 +166,7 @@ func TestStreamHasher_OutOfOrderCompletion(t *testing.T) {
func TestStreamHasher_Stop(t *testing.T) { func TestStreamHasher_Stop(t *testing.T) {
// Create temp file // Create temp file
f, err := os.CreateTemp("", "streamhasher_test") f, err := os.CreateTemp(t.TempDir(), "streamhasher_test")
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
@ -197,7 +197,7 @@ func TestStreamHasher_Stop(t *testing.T) {
func TestStreamHasher_HashedProgress(t *testing.T) { func TestStreamHasher_HashedProgress(t *testing.T) {
// Create temp file with known data // Create temp file with known data
f, err := os.CreateTemp("", "streamhasher_test") f, err := os.CreateTemp(t.TempDir(), "streamhasher_test")
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
@ -232,7 +232,7 @@ func TestStreamHasher_HashedProgress(t *testing.T) {
sh.Done(0) sh.Done(0)
// Give hasher time to process // Give hasher time to process
for i := 0; i < 100; i++ { for range 100 {
if sh.Hashed() >= 500 { if sh.Hashed() >= 500 {
break break
} }
@ -250,7 +250,7 @@ func TestStreamHasher_HashedProgress(t *testing.T) {
func BenchmarkSpeedTracker_Record(b *testing.B) { func BenchmarkSpeedTracker_Record(b *testing.B) {
s := &speedTracker{} s := &speedTracker{}
b.ResetTimer() b.ResetTimer()
for i := 0; i < b.N; i++ { for i := range b.N {
s.Record(float64(i)) s.Record(float64(i))
} }
} }
@ -258,18 +258,18 @@ func BenchmarkSpeedTracker_Record(b *testing.B) {
func BenchmarkSpeedTracker_Median(b *testing.B) { func BenchmarkSpeedTracker_Median(b *testing.B) {
s := &speedTracker{} s := &speedTracker{}
// Pre-populate with 100 samples // Pre-populate with 100 samples
for i := 0; i < 100; i++ { for i := range 100 {
s.Record(float64(i)) s.Record(float64(i))
} }
b.ResetTimer() b.ResetTimer()
for i := 0; i < b.N; i++ { for range b.N {
s.Median() s.Median()
} }
} }
func BenchmarkStreamHasher(b *testing.B) { func BenchmarkStreamHasher(b *testing.B) {
// Create temp file with test data // Create temp file with test data
f, err := os.CreateTemp("", "streamhasher_bench") f, err := os.CreateTemp(b.TempDir(), "streamhasher_bench")
if err != nil { if err != nil {
b.Fatal(err) b.Fatal(err)
} }
@ -290,7 +290,7 @@ func BenchmarkStreamHasher(b *testing.B) {
b.SetBytes(int64(size)) b.SetBytes(int64(size))
b.ResetTimer() b.ResetTimer()
for i := 0; i < b.N; i++ { for range b.N {
sh := newStreamHasher(f, parts, int64(size)) sh := newStreamHasher(f, parts, int64(size))
sh.Done(0) sh.Done(0)
@ -312,7 +312,7 @@ func BenchmarkHashThroughput(b *testing.B) {
b.SetBytes(int64(size)) b.SetBytes(int64(size))
b.ResetTimer() b.ResetTimer()
for i := 0; i < b.N; i++ { for range b.N {
h := sha256.New() h := sha256.New()
h.Write(data) h.Write(data)
h.Sum(nil) h.Sum(nil)

1
server/routes.go
View File

@ -2395,4 +2395,3 @@ func filterThinkTags(msgs []api.Message, m *Model) []api.Message {
} }
return msgs return msgs
} }