Miki
a0753ca9ea
producer: rimuove tutti i record tranne il primo ( il piu' recente ) lrange(1, -1) main: options: xymon: manda stato a xymon
69 lines
1.5 KiB
Go
69 lines
1.5 KiB
Go
// iterator
|
|
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/garyburd/redigo/redis"
|
|
"log"
|
|
"time"
|
|
)
|
|
|
|
type produced struct {
|
|
user string
|
|
logins []string
|
|
}
|
|
|
|
func producer(id int) {
|
|
conn := dbs.rdb.Get()
|
|
defer conn.Close()
|
|
|
|
for loop[id] {
|
|
|
|
start := time.Now()
|
|
// estrae un userid dalla lista degli utenti che hanno fatto login
|
|
user, err := redis.String(conn.Do("spop", "llindex"))
|
|
// if opts.Debug {
|
|
// log.Printf("SPOP: %+v - %+v\n", user, err)
|
|
// fmt.Printf("SPOP: %+v - %+v\n", user, err)
|
|
// }
|
|
// se non ci sono piu' userid esce
|
|
if err != nil {
|
|
if opts.Debug {
|
|
fmt.Printf("LLINDEX empty: %v\n", err)
|
|
}
|
|
log.Printf("LLINDEX empty: %v\n", err)
|
|
//loop[id] = false
|
|
//done[id] <- true
|
|
break
|
|
}
|
|
|
|
// estrae tutti i login dell'utente "user"
|
|
logs, err := redis.Strings(conn.Do("lrange", user, "1", "-1"))
|
|
if err != nil {
|
|
if opts.Debug {
|
|
fmt.Printf("LRANGE: %+v - %+v\n", err, logs)
|
|
}
|
|
log.Printf("LRANGE: %+v - %+v\n", err, logs)
|
|
}
|
|
// if opts.Debug {
|
|
// fmt.Printf("LRANGE: %s - %d\n", user, len(logs))
|
|
// log.Printf("LRANGE: %s - %d\n", user, len(logs))
|
|
// }
|
|
|
|
if opts.Debug {
|
|
fmt.Printf("PROD (%d): user=%s login=%d in %v - conn=%d\n", id, user, len(logs), time.Since(start), dbs.rdb.ActiveCount())
|
|
// log.Printf("PROD (%d): user=%s login=%d in %v - conn=%d\n", id, user, len(logs), time.Since(start), dbs.rdb.ActiveCount())
|
|
}
|
|
|
|
count.AddUser()
|
|
wg.Add(1)
|
|
count.AddWG(id)
|
|
|
|
consume[id] <- produced{
|
|
user: user,
|
|
logins: logs,
|
|
}
|
|
}
|
|
|
|
done[id] <- true
|
|
}
|