add
This commit is contained in:
parent
284dcccd18
commit
b1fd10de27
@ -372,7 +372,7 @@ func (fm *FrameMgr) processPing(f *Frame) {
|
|||||||
func (fm *FrameMgr) processPong(f *Frame) {
|
func (fm *FrameMgr) processPong(f *Frame) {
|
||||||
cur := time.Now().UnixNano()
|
cur := time.Now().UnixNano()
|
||||||
if cur > f.Sendtime {
|
if cur > f.Sendtime {
|
||||||
rtt := (cur - f.Sendtime) / 1000
|
rtt := (cur - f.Sendtime) / (int64)(time.Millisecond)
|
||||||
fm.rttms = (fm.rttms + (int)(rtt)) / 2
|
fm.rttms = (fm.rttms + (int)(rtt)) / 2
|
||||||
loggo.Debug("recv pong %d %d", rtt, fm.rttms)
|
loggo.Debug("recv pong %d %d", rtt, fm.rttms)
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user