blob: 79f1ce0b74108e6a76b6a99f4b27b8bd53508272 [file] [log] [blame]
// Copyright (c) 2014 The WebRTC project authors. All Rights Reserved.
// Use of this source code is governed by a BSD-style license
// that can be found in the LICENSE file in the root of the source
// tree.
package collider
import (
"sync"
"time"
)
const maxErrLogLen = 128
type errEvent struct {
Time time.Time `json:"t"`
Err string `json:"e"`
}
type dashboard struct {
lock sync.Mutex
startTime time.Time
totalWs int
totalRecvMsgs int
totalSendMsgs int
wsErrs int
httpErrs int
}
type statusReport struct {
UpTimeSec float64 `json:"upsec"`
OpenWs int `json:"openws"`
TotalWs int `json:"totalws"`
WsErrs int `json:"wserrors"`
HttpErrs int `json:"httperrors"`
}
func newDashboard() *dashboard {
return &dashboard{startTime: time.Now()}
}
func (db *dashboard) getReport(rs *roomTable) statusReport {
db.lock.Lock()
defer db.lock.Unlock()
upTime := time.Since(db.startTime)
return statusReport{
UpTimeSec: upTime.Seconds(),
OpenWs: rs.wsCount(),
TotalWs: db.totalWs,
WsErrs: db.wsErrs,
HttpErrs: db.httpErrs,
}
}
func (db *dashboard) incrWs() {
db.lock.Lock()
defer db.lock.Unlock()
db.totalWs += 1
}
func (db *dashboard) onWsErr(err error) {
db.lock.Lock()
defer db.lock.Unlock()
db.wsErrs += 1
}
func (db *dashboard) onHttpErr(err error) {
db.lock.Lock()
defer db.lock.Unlock()
db.httpErrs += 1
}