nonoo/kappanhang
1
0
Fork 0
mirror of https://github.com/nonoo/kappanhang.git synced 2026-03-12 08:13:49 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Cleanup

Browse source
This commit is contained in:
Nonoo 2020-10-18 21:35:36 +02:00
parent 2df73b2811
commit 6f2826c134
3 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
audiostream.go
View file

@ -89,8 +89,7 @@ func (s *audioStream) start() {
s.timeoutTimer = time.NewTimer(audioTimeoutDuration)
s.common.pkt7.sendSeq = 1
s.common.pkt7.startPeriodicSend(&s.common)
s.common.pkt7.startPeriodicSend(&s.common, 1)
s.audioSendSeq = 1

3
controlstream.go
View file

@ -241,8 +241,7 @@ func (s *controlStream) start() {
s.sendPkt0()
s.sendRequestSerialAndAudio()
s.common.pkt7.sendSeq = 5
s.common.pkt7.startPeriodicSend(&s.common)
s.common.pkt7.startPeriodicSend(&s.common, 5)
pkt0SendTicker := time.NewTicker(100 * time.Millisecond)
reauthTicker := time.NewTicker(60 * time.Second)

3
pkt7.go
View file

@ -98,7 +98,8 @@ func (p *pkt7Type) sendReply(s *streamCommon, replyID []byte, seq uint16) {
p.sendDo(s, replyID, seq)
}
func (p *pkt7Type) startPeriodicSend(s *streamCommon) {
func (p *pkt7Type) startPeriodicSend(s *streamCommon, firstSeqNo uint16) {
p.sendSeq = firstSeqNo
p.lastConfirmedSeq = p.sendSeq - 1
p.sendTicker = time.NewTicker(100 * time.Millisecond)