update webroot
This commit is contained in:
parent
aebc95b0ae
commit
c211de4975
|
@ -51,12 +51,13 @@ func NewCollector(collectType string) *Collector {
|
||||||
queue: make(chan *Response, 400),
|
queue: make(chan *Response, 400),
|
||||||
}
|
}
|
||||||
|
|
||||||
go collector.sendOnce()
|
|
||||||
go collector.sender()
|
go collector.sender()
|
||||||
|
|
||||||
go collector.receiver()
|
go collector.receiver()
|
||||||
go collector.parser()
|
go collector.parser()
|
||||||
|
|
||||||
|
collector.sendOnce()
|
||||||
|
|
||||||
return collector
|
return collector
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -67,6 +68,7 @@ func (coll *Collector) Close() {
|
||||||
|
|
||||||
func (coll *Collector) sendOnce() {
|
func (coll *Collector) sendOnce() {
|
||||||
coll.sendPacket(net.JoinHostPort(MultiCastGroup,Port))
|
coll.sendPacket(net.JoinHostPort(MultiCastGroup,Port))
|
||||||
|
log.Println("send request")
|
||||||
}
|
}
|
||||||
|
|
||||||
func (coll *Collector) sendPacket(address string) {
|
func (coll *Collector) sendPacket(address string) {
|
||||||
|
|
Loading…
Reference in New Issue