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 -}