aboutsummaryrefslogtreecommitdiff
path: root/reuseport
diff options
context:
space:
mode:
authorGravatar Aliaksandr Valialkin <valyala@gmail.com> 2015-11-20 14:55:22 +0200
committerGravatar Aliaksandr Valialkin <valyala@gmail.com> 2015-11-20 14:55:22 +0200
commita109d2bb6e22471701982efe0c882f1c9670aa14 (patch)
tree38f56e6a2a41ddcc03fd1e54dcf5dbff2e6373a9 /reuseport
parentAdded net.Listener with reuseport support (diff)
downloadfasthttp-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.go6
-rw-r--r--reuseport/reuseport_test.go2
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)
}