mirror of
https://github.com/nonoo/kappanhang.git
synced 2026-04-04 14:07:31 +00:00
Cleanup
This commit is contained in:
parent
179fb6facf
commit
b86459b244
2 changed files with 5 additions and 3 deletions
|
|
@ -13,6 +13,8 @@ const controlStreamPort = 50001
|
|||
const serialStreamPort = 50002
|
||||
const audioStreamPort = 50003
|
||||
|
||||
const statusLogInterval = 3 * time.Second
|
||||
|
||||
type controlStream struct {
|
||||
common streamCommon
|
||||
serial serialStream
|
||||
|
|
@ -237,7 +239,7 @@ func (s *controlStream) loop() {
|
|||
<-s.reauthTimeoutTimer.C
|
||||
|
||||
reauthTicker := time.NewTicker(25 * time.Second)
|
||||
statusLogTicker := time.NewTicker(3 * time.Second)
|
||||
statusLogTicker := time.NewTicker(statusLogInterval)
|
||||
|
||||
for {
|
||||
select {
|
||||
|
|
|
|||
|
|
@ -217,8 +217,8 @@ func (s *seqBuf) watcher() {
|
|||
s.watcherCloseDoneChan <- true
|
||||
}()
|
||||
|
||||
entryAvailableTimer := time.NewTimer(s.length)
|
||||
entryAvailableTimer.Stop()
|
||||
entryAvailableTimer := time.NewTimer(0)
|
||||
<-entryAvailableTimer.C
|
||||
var entryAvailableTimerRunning bool
|
||||
|
||||
for {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue