bughz/glider
1
0
Fork 0
mirror of https://github.com/nadoo/glider.git synced 2025-04-21 19:52:07 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Immediately stop check

Browse Source
This commit is contained in:
baixl 2023-07-05 18:35:07 +08:00
parent 95434a3ebd
commit 8b9fc6e69f
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rule/group.go
View File

@ -33,7 +33,7 @@ type FwdrGroup struct {
index uint32 index uint32
priority uint32 priority uint32
next func(addr string) *Forwarder next func(addr string) *Forwarder
stopChan chan bool stopChan chan struct{}
} }
// NewFwdrGroup returns a new forward group. // NewFwdrGroup returns a new forward group.
@ -66,7 +66,7 @@ func NewFwdrGroup(rulePath string, s []string, c *Strategy) *FwdrGroup {
// newFwdrGroup returns a new FwdrGroup. // newFwdrGroup returns a new FwdrGroup.
func newFwdrGroup(name string, fwdrs []*Forwarder, c *Strategy) *FwdrGroup { func newFwdrGroup(name string, fwdrs []*Forwarder, c *Strategy) *FwdrGroup {
p := &FwdrGroup{name: name, fwdrs: fwdrs, config: c} p := &FwdrGroup{name: name, fwdrs: fwdrs, config: c, stopChan: make(chan struct{})}
sort.Sort(p.fwdrs) sort.Sort(p.fwdrs)
p.init() p.init()
@ -240,7 +240,7 @@ func (p *FwdrGroup) check(fwdr *Forwarder, checker Checker) {
case <-p.stopChan: case <-p.stopChan:
log.F("[check] %s: stop checking", p.name) log.F("[check] %s: stop checking", p.name)
return return
default: case <-time.After(intval * time.Duration(wait)):
time.Sleep(intval * time.Duration(wait)) time.Sleep(intval * time.Duration(wait))
// check all forwarders at least one time // check all forwarders at least one time
@ -326,5 +326,5 @@ func (p *FwdrGroup) scheduleDH(dstAddr string) *Forwarder {
// Stop Check // Stop Check
func (p *FwdrGroup) StopCheck() { func (p *FwdrGroup) StopCheck() {
p.stopChan <- true close(p.stopChan)
} }