diff options
author | Aliaksandr Valialkin <valyala@gmail.com> | 2015-11-20 14:55:22 +0200 |
---|---|---|
committer | Aliaksandr Valialkin <valyala@gmail.com> | 2015-11-20 14:55:22 +0200 |
commit | a109d2bb6e22471701982efe0c882f1c9670aa14 (patch) | |
tree | 38f56e6a2a41ddcc03fd1e54dcf5dbff2e6373a9 /reuseport | |
parent | Added net.Listener with reuseport support (diff) | |
download | fasthttp-a109d2bb6e22471701982efe0c882f1c9670aa14.tar.gz fasthttp-a109d2bb6e22471701982efe0c882f1c9670aa14.tar.bz2 fasthttp-a109d2bb6e22471701982efe0c882f1c9670aa14.zip |
Renamed NewListener to Listener to be consistent with go's net package
Diffstat (limited to 'reuseport')
-rw-r--r-- | reuseport/reuseport.go | 6 | ||||
-rw-r--r-- | reuseport/reuseport_test.go | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/reuseport/reuseport.go b/reuseport/reuseport.go index dba030c..13092ef 100644 --- a/reuseport/reuseport.go +++ b/reuseport/reuseport.go @@ -3,7 +3,7 @@ // SO_REUSEPORT allows linear scaling server performance on multi-CPU servers. // See https://www.nginx.com/blog/socket-sharding-nginx-release-1-9-1/ for more details :) // -// Package reuseport is based on https://github.com/kavu/go_reuseport . +// The package is based on https://github.com/kavu/go_reuseport . package reuseport import ( @@ -41,12 +41,12 @@ func (e *ErrNoReusePort) Error() string { return fmt.Sprintf("The OS doesn't support SO_REUSEPORT: %s", e.err) } -// NewListener returns TCP listener with SO_REUSEPORT option set. +// Listen returns TCP listener with SO_REUSEPORT option set. // // Only tcp4 network is supported. // // ErrNoReusePort error is returned if the system doesn't support SO_REUSEPORT. -func NewListener(network, addr string) (l net.Listener, err error) { +func Listen(network, addr string) (l net.Listener, err error) { var ( soType, fd int file *os.File diff --git a/reuseport/reuseport_test.go b/reuseport/reuseport_test.go index c1879f1..3492902 100644 --- a/reuseport/reuseport_test.go +++ b/reuseport/reuseport_test.go @@ -17,7 +17,7 @@ func TestNewListener(t *testing.T) { doneCh := make(chan struct{}, serversCount) for i := 0; i < serversCount; i++ { - ln, err := NewListener("tcp4", addr) + ln, err := Listen("tcp4", addr) if err != nil { t.Fatalf("cannot create listener %d: %s", i, err) } |