(session Session)
| 175 | } |
| 176 | |
| 177 | func (spool *SessionPool) dropSession(session Session) { |
| 178 | defer func() { |
| 179 | if e := recover(); e != nil { |
| 180 | if session.trans != nil && session.trans.IsOpen() { |
| 181 | session.Close() |
| 182 | } |
| 183 | } |
| 184 | }() |
| 185 | err := session.Close() |
| 186 | if err != nil { |
| 187 | log.Println("Failed to close session ", session) |
| 188 | } |
| 189 | <-spool.sem |
| 190 | } |
| 191 | |
| 192 | func (spool *SessionPool) Close() { |
| 193 | close(spool.ch) |
no test coverage detected