fix listenAndServe comment
This commit is contained in:
parent
b345eb3899
commit
0de1d25448
1 changed files with 3 additions and 2 deletions
|
@ -117,6 +117,7 @@ func (t *Frontend) Stop() stop.Result {
|
||||||
return c.Result()
|
return c.Result()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// listen resolves the address and binds the server socket.
|
||||||
func (t *Frontend) listen() error {
|
func (t *Frontend) listen() error {
|
||||||
udpAddr, err := net.ResolveUDPAddr("udp", t.Addr)
|
udpAddr, err := net.ResolveUDPAddr("udp", t.Addr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -126,7 +127,7 @@ func (t *Frontend) listen() error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// listenAndServe blocks while listening and serving UDP BitTorrent requests
|
// serve blocks while listening and serving UDP BitTorrent requests
|
||||||
// until Stop() is called or an error is returned.
|
// until Stop() is called or an error is returned.
|
||||||
func (t *Frontend) serve() error {
|
func (t *Frontend) serve() error {
|
||||||
pool := bytepool.New(2048)
|
pool := bytepool.New(2048)
|
||||||
|
@ -138,7 +139,7 @@ func (t *Frontend) serve() error {
|
||||||
// Check to see if we need to shutdown.
|
// Check to see if we need to shutdown.
|
||||||
select {
|
select {
|
||||||
case <-t.closing:
|
case <-t.closing:
|
||||||
log.Debug("udp listenAndServe() received shutdown signal")
|
log.Debug("udp serve() received shutdown signal")
|
||||||
return nil
|
return nil
|
||||||
default:
|
default:
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Reference in a new issue