dlss
/
FedP2P
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

use Debug flag

This commit is contained in:
whr819987540 2023-05-08 11:30:36 +08:00
parent 9a636d2326
commit a68c49defc
2 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
peerconn.go
View File

@ -950,7 +950,9 @@ another:
return false return false
} }
// 完成一次写入, 打印日志 // 完成一次写入, 打印日志
log.Printf("write %d to %s",len(state.data),c.RemoteAddr) if Debug {
log.Printf("write %d to %s", len(state.data), c.RemoteAddr)
}
goto another goto another
} }
return true return true

22
tracker_scraper.go
View File

@ -72,7 +72,6 @@ type trackerAnnounceResult struct {
} }
func (me *trackerScraper) getIp() (ip net.IP, err error) { func (me *trackerScraper) getIp() (ip net.IP, err error) {
// log.Printf("in get ip function")
trackerURL := me.u.String() trackerURL := me.u.String()
var ips []net.IP var ips []net.IP
// 内置函数查找tracker IP // 内置函数查找tracker IP
@ -96,10 +95,15 @@ func (me *trackerScraper) getIp() (ip net.IP, err error) {
err = errors.New("client is closed") err = errors.New("client is closed")
return return
} }
log.Printf("tracker(%s),ips(%v)", trackerURL, ips) if Debug {
log.Printf("dns resolve: tracker(%s),ips(%v)", trackerURL, ips)
}
for _, ip = range ips { for _, ip = range ips {
if me.t.cl.ipIsBlocked(ip) { if me.t.cl.ipIsBlocked(ip) {
log.Printf("%s(%s) blocked", me.u.String(), ip.String()) if Debug {
log.Printf("%s(%s) blocked", me.u.String(), ip.String())
}
continue continue
} }
switch me.u.Scheme { switch me.u.Scheme {
@ -112,7 +116,9 @@ func (me *trackerScraper) getIp() (ip net.IP, err error) {
continue continue
} }
default: default:
log.Printf("%s", me.u.Scheme) if Debug {
log.Printf("%s", me.u.Scheme)
}
} }
return return
} }
@ -188,12 +194,14 @@ func (me *trackerScraper) announce(ctx context.Context, event tracker.AnnounceEv
}.Do() }.Do()
me.t.logger.WithDefaultLevel(log.Debug).Printf("announce to %q returned %#v: %v", me.u.String(), res, err) me.t.logger.WithDefaultLevel(log.Debug).Printf("announce to %q returned %#v: %v", me.u.String(), res, err)
if err != nil { if err != nil {
log.Printf("annouce error:%v", err) if Debug {
log.Printf("annouce error:%v", err)
}
ret.Err = fmt.Errorf("announcing: %w", err) ret.Err = fmt.Errorf("announcing: %w", err)
return return
} }
log.Printf("announce ok %s(%s)",me.trackerUrl(ip),ip) log.Printf("announce ok %s(%s)", me.trackerUrl(ip), ip)
me.t.AddPeers(peerInfos(nil).AppendFromTracker(res.Peers)) me.t.AddPeers(peerInfos(nil).AppendFromTracker(res.Peers))
ret.NumPeers = len(res.Peers) ret.NumPeers = len(res.Peers)
ret.Interval = time.Duration(res.Interval) * time.Second ret.Interval = time.Duration(res.Interval) * time.Second