summaryrefslogtreecommitdiff
path: root/util/network.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-12-27 00:59:10 +0300
committerValery Piashchynski <[email protected]>2020-12-27 00:59:10 +0300
commit8df4896deabdab9a50a5ad3c6da6e1c7f05922af (patch)
treec2fa71733902b999c02e5abd608bff4bc7449c5c /util/network.go
parent1aaf6e6ffb015cd5a21d9d938ad84c18723973c5 (diff)
Util -> Utils
Diffstat (limited to 'util/network.go')
-rwxr-xr-xutil/network.go59
1 files changed, 0 insertions, 59 deletions
diff --git a/util/network.go b/util/network.go
deleted file mode 100755
index c2475f4a..00000000
--- a/util/network.go
+++ /dev/null
@@ -1,59 +0,0 @@
-// +build linux darwin freebsd
-
-package util
-
-import (
- "errors"
- "fmt"
- "net"
- "os"
- "strings"
- "syscall"
-
- "github.com/valyala/tcplisten"
-)
-
-// CreateListener crates socket listener based on DSN definition.
-func CreateListener(address string) (net.Listener, error) {
- dsn := strings.Split(address, "://")
- if len(dsn) != 2 {
- return nil, errors.New("invalid DSN (tcp://:6001, unix://file.sock)")
- }
-
- if dsn[0] != "unix" && dsn[0] != "tcp" {
- return nil, errors.New("invalid Protocol (tcp://:6001, unix://file.sock)")
- }
-
- // create unix listener
- if dsn[0] == "unix" {
- // check if the file exist
- if fileExists(dsn[1]) {
- err := syscall.Unlink(dsn[1])
- if err != nil {
- return nil, fmt.Errorf("error during the unlink syscall: error %v", err)
- }
- }
- return net.Listen(dsn[0], dsn[1])
- }
-
- // configure and create tcp4 listener
- cfg := tcplisten.Config{
- ReusePort: true,
- DeferAccept: true,
- FastOpen: true,
- Backlog: 0,
- }
-
- // only tcp4 is currently supported
- return cfg.NewListener("tcp4", dsn[1])
-}
-
-// fileExists checks if a file exists and is not a directory before we
-// try using it to prevent further errors.
-func fileExists(filename string) bool {
- info, err := os.Stat(filename)
- if os.IsNotExist(err) {
- return false
- }
- return !info.IsDir()
-}