This commit is contained in:
esrrhs 2019-10-26 20:01:51 +08:00
parent 2ffba2224b
commit 82045f9e55

View File

@ -132,7 +132,7 @@ func (fm *FrameMgr) calSendList() {
cur := time.Now().UnixNano() cur := time.Now().UnixNano()
for e := fm.sendwin.Front(); e != nil; e = e.Next() { for e := fm.sendwin.Front(); e != nil; e = e.Next() {
f := e.Value.(*Frame) f := e.Value.(*Frame)
if f.Resend || cur-f.Sendtime > int64(fm.resend_timems*1000) { if f.Resend || cur-f.Sendtime > int64(fm.resend_timems*(int)(time.Millisecond)) {
f.Sendtime = cur f.Sendtime = cur
fm.sendlist.PushBack(f) fm.sendlist.PushBack(f)
f.Resend = false f.Resend = false
@ -368,7 +368,7 @@ func (fm *FrameMgr) IsRemoteClosed() bool {
func (fm *FrameMgr) ping() { func (fm *FrameMgr) ping() {
cur := time.Now().UnixNano() cur := time.Now().UnixNano()
if cur-fm.lastPingTime > int64(1000*1000) { if cur-fm.lastPingTime > (int64)(time.Second) {
f := &Frame{Type: (int32)(Frame_PING), Resend: false, Sendtime: cur, f := &Frame{Type: (int32)(Frame_PING), Resend: false, Sendtime: cur,
Id: 0} Id: 0}
fm.sendlist.PushBack(f) fm.sendlist.PushBack(f)