mbk-lab
/
wide
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

stat

This commit is contained in:
Liang Ding 2014-12-05 17:31:21 +08:00
parent 6600fec368
commit ec6267f0d8
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
session/sessions.go
View File

@ -108,13 +108,14 @@ func FixedTimeRelease() {
type userReport struct {
username string
sessionCnt int
processCnt int
updated time.Time
}
// report returns a online user statistics in pretty format.
func (u *userReport) report() string {
return "[" + u.username + "] has [" + strconv.Itoa(u.sessionCnt) + "] sessions, latest activity [" +
u.updated.Format("2006-01-02 15:04:05") + "]"
return "[" + u.username + "] has [" + strconv.Itoa(u.sessionCnt) + "] sessions and [" + strconv.Itoa(u.processCnt) +
"] running processes, latest activity [" + u.updated.Format("2006-01-02 15:04:05") + "]"
}
// FixedTimeReport reports the Wide sessions status periodically (10 minutes).
@ -124,14 +125,17 @@ func FixedTimeReport() {
users := map[string]*userReport{} // <username, *userReport>
for _, s := range WideSessions {
processCnt := len(s.Processes)
if report, exists := users[s.Username]; exists {
if s.Updated.After(report.updated) {
users[s.Username].updated = s.Updated
}
report.sessionCnt++
report.processCnt += processCnt
} else {
users[s.Username] = &userReport{username: s.Username, sessionCnt: 1, updated: s.Updated}
users[s.Username] = &userReport{username: s.Username, sessionCnt: 1, processCnt: processCnt, updated: s.Updated}
}
}