fix(plc4go/connection-cache): drain lease chan on timeout

apache · Aug 31, 2022 · e6609cc · e6609cc
1 parent a0b7d0b
commit e6609cc
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/plc4go/pkg/api/cache/plc_connection_cache.go b/plc4go/pkg/api/cache/plc_connection_cache.go
@@ -167,6 +167,11 @@ func (t *plcConnectionCache) GetConnection(connectionString string) <-chan plc4g
 
 		// Timeout after the maximum waiting time.
 		case <-maximumWaitTimeout.C:
+			// In this case we need to drain the chan and return it immediate
+			go func() {
+				<-leaseChan
+				_ = connection.returnConnection(StateIdle)
+			}()
 			if t.tracer != nil {
 				t.tracer.AddTransactionalTrace(txId, "get-connection", "timeout")
 			}