diff --git a/internal/handler/sendfile_test.go b/internal/handler/sendfile_test.go index ba11279..0f603b7 100644 --- a/internal/handler/sendfile_test.go +++ b/internal/handler/sendfile_test.go @@ -35,7 +35,7 @@ func TestCopyFile(t *testing.T) { tmpFile := filepath.Join(tmpDir, "test.txt") content := []byte("Hello, World! This is test content for copyFile.") - if err := os.WriteFile(tmpFile, content, 0644); err != nil { + if err := os.WriteFile(tmpFile, content, 0o644); err != nil { t.Fatalf("Failed to create temp file: %v", err) } @@ -145,7 +145,7 @@ func TestSendFile_SmallFile(t *testing.T) { tmpFile := filepath.Join(tmpDir, "small.txt") content := []byte("small file content") - if err := os.WriteFile(tmpFile, content, 0644); err != nil { + if err := os.WriteFile(tmpFile, content, 0o644); err != nil { t.Fatalf("Failed to create temp file: %v", err) } @@ -174,7 +174,7 @@ func TestSendFile_WithOffset(t *testing.T) { tmpFile := filepath.Join(tmpDir, "test.txt") content := []byte("0123456789ABCDEF") - if err := os.WriteFile(tmpFile, content, 0644); err != nil { + if err := os.WriteFile(tmpFile, content, 0o644); err != nil { t.Fatalf("Failed to create temp file: %v", err) } @@ -203,7 +203,7 @@ func TestSendFile_ZeroLength(t *testing.T) { tmpDir := t.TempDir() tmpFile := filepath.Join(tmpDir, "empty.txt") - if err := os.WriteFile(tmpFile, []byte{}, 0644); err != nil { + if err := os.WriteFile(tmpFile, []byte{}, 0o644); err != nil { t.Fatalf("Failed to create temp file: %v", err) } @@ -241,7 +241,7 @@ func TestCopyFile_Error(t *testing.T) { tmpFile := filepath.Join(tmpDir, "test.txt") content := []byte("test content") - if err := os.WriteFile(tmpFile, content, 0644); err != nil { + if err := os.WriteFile(tmpFile, content, 0o644); err != nil { t.Fatalf("Failed to create temp file: %v", err) } @@ -265,7 +265,7 @@ func TestLinuxSendfile_NilConn(t *testing.T) { tmpDir := t.TempDir() tmpFile := filepath.Join(tmpDir, "test.txt") content := []byte("test") - _ = os.WriteFile(tmpFile, content, 0644) + _ = os.WriteFile(tmpFile, content, 0o644) file, err := os.Open(tmpFile) if err != nil { diff --git a/internal/proxy/health.go b/internal/proxy/health.go index fff545d..c598657 100644 --- a/internal/proxy/health.go +++ b/internal/proxy/health.go @@ -189,7 +189,6 @@ func (h *HealthChecker) checkTarget(target *loadbalance.Target) { // 执行带超时的健康检查 err := h.client.DoTimeout(req, resp, h.timeout) - if err != nil { // 连接失败或超时 - 标记为不健康 target.Healthy.Store(false) diff --git a/internal/proxy/tempfile.go b/internal/proxy/tempfile.go index 0b73f04..5530426 100644 --- a/internal/proxy/tempfile.go +++ b/internal/proxy/tempfile.go @@ -93,7 +93,7 @@ func NewTempFileManager(tempPath, threshold, maxSize string) (*TempFileManager, } // 确保临时目录存在 - if err := os.MkdirAll(tempPath, 0755); err != nil { + if err := os.MkdirAll(tempPath, 0o755); err != nil { return nil, fmt.Errorf("创建临时目录失败: %w", err) } @@ -456,8 +456,10 @@ func (w *DynamicTempFileWriter) Cleanup() { } // defaultTempFileManager 默认临时文件管理器(未配置时使用)。 -var defaultTempFileManager *TempFileManager -var defaultTempFileManagerOnce sync.Once +var ( + defaultTempFileManager *TempFileManager + defaultTempFileManagerOnce sync.Once +) // GetDefaultTempFileManager 获取默认临时文件管理器。 //