From e77908a89e63891834c8c3f67b21bc54d9a5bcb9 Mon Sep 17 00:00:00 2001 From: ginuerzh Date: Wed, 31 Aug 2022 10:09:31 +0800 Subject: [PATCH] remove invalidFilter for selector --- chain/selector.go | 22 ---------------------- 1 file changed, 22 deletions(-) diff --git a/chain/selector.go b/chain/selector.go index 3fdc580..b6e0414 100644 --- a/chain/selector.go +++ b/chain/selector.go @@ -2,8 +2,6 @@ package chain import ( "math/rand" - "net" - "strconv" "sync" "sync/atomic" "time" @@ -151,23 +149,3 @@ func (f *failFilter) Filter(nodes ...*Node) []*Node { } return nl } - -type invalidFilter struct{} - -// InvalidFilter filters the invalid node. -// A node is invalid if its port is invalid (negative or zero value). -func InvalidFilter() Filter { - return &invalidFilter{} -} - -// Filter filters invalid nodes. -func (f *invalidFilter) Filter(nodes ...*Node) []*Node { - var nl []*Node - for _, node := range nodes { - _, sport, _ := net.SplitHostPort(node.Addr) - if port, _ := strconv.Atoi(sport); port > 0 { - nl = append(nl, node) - } - } - return nl -}