From 6da9e99a221c814c50804783c598ec12f78e38d8 Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Sun, 17 Aug 2025 03:43:08 +0800 Subject: Add some stubs --- forged/internal/common/misc/net.go | 38 ++++++++++++++++++++++++++++++++++++ forged/internal/common/misc/usock.go | 23 ---------------------- 2 files changed, 38 insertions(+), 23 deletions(-) create mode 100644 forged/internal/common/misc/net.go delete mode 100644 forged/internal/common/misc/usock.go (limited to 'forged/internal/common/misc') diff --git a/forged/internal/common/misc/net.go b/forged/internal/common/misc/net.go new file mode 100644 index 0000000..2c6b0a5 --- /dev/null +++ b/forged/internal/common/misc/net.go @@ -0,0 +1,38 @@ +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 +} + +func Listen(net_, addr string) (listener net.Listener, err error) { + if net_ == "unix" { + listener, _, err = ListenUnixSocket(addr) + if err != nil { + return listener, fmt.Errorf("listen unix socket for web: %w", err) + } + } else { + listener, err = net.Listen(net_, addr) + if err != nil { + return listener, fmt.Errorf("listen %s for web: %w", net_, err) + } + } + return listener, nil +} diff --git a/forged/internal/common/misc/usock.go b/forged/internal/common/misc/usock.go deleted file mode 100644 index 357fa43..0000000 --- a/forged/internal/common/misc/usock.go +++ /dev/null @@ -1,23 +0,0 @@ -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