From b48037f4dc602bd35b38c9cba0f50dd0f8033288 Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Thu, 14 Aug 2025 09:30:08 +0800 Subject: Refactoring --- forged/internal/misc/usock.go | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 forged/internal/misc/usock.go (limited to 'forged/internal/misc/usock.go') diff --git a/forged/internal/misc/usock.go b/forged/internal/misc/usock.go new file mode 100644 index 0000000..357fa43 --- /dev/null +++ b/forged/internal/misc/usock.go @@ -0,0 +1,23 @@ +package misc + +import ( + "errors" + "fmt" + "net" + "syscall" +) + +func ListenUnixSocket(path string) (listener net.Listener, replaced bool, err error) { + listener, err = net.Listen("unix", path) + if errors.Is(err, syscall.EADDRINUSE) { + replaced = true + if unlinkErr := syscall.Unlink(path); unlinkErr != nil { + return listener, false, fmt.Errorf("remove existing socket %q: %w", path, unlinkErr) + } + listener, err = net.Listen("unix", path) + } + if err != nil { + return listener, replaced, fmt.Errorf("listen on unix socket %q: %w", path, err) + } + return listener, replaced, nil +} -- cgit v1.2.3