MCPcopy Create free account
hub / github.com/apache/iotdb-client-go / dropSession

Method dropSession

client/sessionpool.go:177–190  ·  view source on GitHub ↗
(session Session)

Source from the content-addressed store, hash-verified

175}
176
177func (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
192func (spool *SessionPool) Close() {
193 close(spool.ch)

Callers 4

InsertMethod · 0.80
ExecuteQueryStatementMethod · 0.80
CloseMethod · 0.80

Calls 1

CloseMethod · 0.65

Tested by

no test coverage detected