mirror of https://github.com/schollz/croc.git
delete old rooms
This commit is contained in:
parent
cc6edd24d1
commit
2fb21245ab
|
@ -30,13 +30,25 @@ func Run(debugLevel, port string) {
|
||||||
rooms.Lock()
|
rooms.Lock()
|
||||||
rooms.rooms = make(map[string]roomInfo)
|
rooms.rooms = make(map[string]roomInfo)
|
||||||
rooms.Unlock()
|
rooms.Unlock()
|
||||||
|
|
||||||
|
// delete old rooms
|
||||||
|
go func() {
|
||||||
|
for {
|
||||||
|
time.Sleep(10 * time.Minute)
|
||||||
|
rooms.Lock()
|
||||||
|
for room := range rooms.rooms {
|
||||||
|
if time.Since(rooms.rooms[room].opened) > 3*time.Hour {
|
||||||
|
delete(rooms.rooms, room)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
rooms.Unlock()
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
err := run(port)
|
err := run(port)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error(err)
|
log.Error(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO:
|
|
||||||
// delete old rooms
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func run(port string) (err error) {
|
func run(port string) (err error) {
|
||||||
|
|
Loading…
Reference in New Issue