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

Method PutBack

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

Source from the content-addressed store, hash-verified

163}
164
165func (spool *SessionPool) PutBack(session Session) {
166 defer func() {
167 if r := recover(); r != nil {
168 session.Close()
169 }
170 }()
171 if session.trans != nil && session.trans.IsOpen() {
172 spool.ch <- session
173 }
174 <-spool.sem
175}
176
177func (spool *SessionPool) dropSession(session Session) {
178 defer func() {

Callers 15

useNodeUrlsFunction · 0.80
setStorageGroupFunction · 0.80
deleteStorageGroupFunction · 0.80
deleteStorageGroupsFunction · 0.80
createTimeseriesFunction · 0.80
createAlignedTimeseriesFunction · 0.80
createMultiTimeseriesFunction · 0.80
deleteTimeseriesFunction · 0.80
insertStringRecordFunction · 0.80
insertRecordFunction · 0.80
insertAlignedRecordFunction · 0.80
insertRecordsFunction · 0.80

Calls 1

CloseMethod · 0.65

Tested by

no test coverage detected