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

report

This commit is contained in:
Liang Ding 2014-12-07 12:08:10 +08:00
parent aa746186eb
commit 3b916aeaad
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
session/sessions.go
View File

@ -125,9 +125,11 @@ func FixedTimeReport() {
go func() { go func() {
for _ = range time.Tick(10 * time.Minute) { for _ = range time.Tick(10 * time.Minute) {
users := map[string]*userReport{} // <username, *userReport> users := map[string]*userReport{} // <username, *userReport>
processSum := 0
for _, s := range WideSessions { for _, s := range WideSessions {
processCnt := len(s.Processes) processCnt := len(s.Processes)
processSum += processCnt
if report, exists := users[s.Username]; exists { if report, exists := users[s.Username]; exists {
if s.Updated.After(report.updated) { if s.Updated.After(report.updated) {
@ -142,8 +144,8 @@ func FixedTimeReport() {
} }
var buf bytes.Buffer var buf bytes.Buffer
buf.WriteString("\n [" + strconv.Itoa(len(users)) + "] users are online and [" + strconv.Itoa(len(WideSessions)) + buf.WriteString("\n [" + strconv.Itoa(len(users)) + "] users are online, [" + strconv.Itoa(processSum) + "] running processes and [" +
"] sessions currently\n") strconv.Itoa(len(WideSessions)) + "] sessions currently\n")
for _, t := range users { for _, t := range users {
buf.WriteString(" " + t.report() + "\n") buf.WriteString(" " + t.report() + "\n")