Mercurial > gemma
comparison auth/pool.go @ 240:9012e4045da4
Implemented /user delete controller.
| author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
|---|---|
| date | Thu, 26 Jul 2018 17:56:02 +0200 |
| parents | 11d1a488b08f |
| children | 0777aa6de45b |
comparison
equal
deleted
inserted
replaced
| 239:713234a04a87 | 240:9012e4045da4 |
|---|---|
| 294 } | 294 } |
| 295 } | 295 } |
| 296 return <-res | 296 return <-res |
| 297 } | 297 } |
| 298 | 298 |
| 299 func (pcp *ConnectionPool) Logout(user string) { | |
| 300 pcp.cmds <- func(pcp *ConnectionPool) { | |
| 301 for token, con := range pcp.conns { | |
| 302 if con.session.User == user { | |
| 303 if db := con.db; db != nil { | |
| 304 con.db = nil | |
| 305 db.Close() | |
| 306 } | |
| 307 delete(pcp.conns, token) | |
| 308 pcp.remove(token) | |
| 309 } | |
| 310 } | |
| 311 } | |
| 312 } | |
| 313 | |
| 299 func (pcp *ConnectionPool) Shutdown() error { | 314 func (pcp *ConnectionPool) Shutdown() error { |
| 300 if db := pcp.storage; db != nil { | 315 if db := pcp.storage; db != nil { |
| 301 log.Println("info: shutdown persistent connection pool.") | 316 log.Println("info: shutdown persistent connection pool.") |
| 302 pcp.storage = nil | 317 pcp.storage = nil |
| 303 return db.Close() | 318 return db.Close() |