diff options
author | ZhangYunHao <zyunhjob@163.com> | 2019-10-22 15:55:44 +0800 |
---|---|---|
committer | Erik Dubbelboer <erik@dubbelboer.com> | 2019-10-22 15:55:44 +0800 |
commit | 18c619fb0432fa6b21cb134d35118e6b09d9d9ce (patch) | |
tree | b10b537978dc82dd468e4a599807ced1c4b24bef /fasthttputil | |
parent | Use least total connections instead of round robin for lbclient (#673) (diff) | |
download | fasthttp-18c619fb0432fa6b21cb134d35118e6b09d9d9ce.tar.gz fasthttp-18c619fb0432fa6b21cb134d35118e6b09d9d9ce.tar.bz2 fasthttp-18c619fb0432fa6b21cb134d35118e6b09d9d9ce.zip |
fasthttputil: add errInmemoryListenerClosed (#678)
* add errInmemoryListenerClosed
* Fix test error
* Expose ErrInmemoryListenerClosed
* rename
Diffstat (limited to 'fasthttputil')
-rw-r--r-- | fasthttputil/inmemory_listener.go | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/fasthttputil/inmemory_listener.go b/fasthttputil/inmemory_listener.go index 1b1a5f3..fd41fc8 100644 --- a/fasthttputil/inmemory_listener.go +++ b/fasthttputil/inmemory_listener.go @@ -1,11 +1,13 @@ package fasthttputil import ( - "fmt" + "errors" "net" "sync" ) +var ErrInmemoryListenerClosed = errors.New("InmemoryListener is already closed: use of closed network connection") + // InmemoryListener provides in-memory dialer<->net.Listener implementation. // // It may be used either for fast in-process client<->server communications @@ -36,7 +38,7 @@ func NewInmemoryListener() *InmemoryListener { func (ln *InmemoryListener) Accept() (net.Conn, error) { c, ok := <-ln.conns if !ok { - return nil, fmt.Errorf("InmemoryListener is already closed: use of closed network connection") + return nil, ErrInmemoryListenerClosed } close(c.accepted) return c.conn, nil @@ -51,7 +53,7 @@ func (ln *InmemoryListener) Close() error { close(ln.conns) ln.closed = true } else { - err = fmt.Errorf("InmemoryListener is already closed") + err = ErrInmemoryListenerClosed } ln.lock.Unlock() return err @@ -88,7 +90,7 @@ func (ln *InmemoryListener) Dial() (net.Conn, error) { ln.lock.Unlock() if cConn == nil { - return nil, fmt.Errorf("InmemoryListener is already closed") + return nil, ErrInmemoryListenerClosed } return cConn, nil } |