diff --git a/internal/vfs/sftpfs.go b/internal/vfs/sftpfs.go index 2ea85c01..0b2bfd4c 100644 --- a/internal/vfs/sftpfs.go +++ b/internal/vfs/sftpfs.go @@ -1167,11 +1167,10 @@ func (c *sftpConnectionsCache) Get(config *SFTPFsConfig, sessionID string) (*sft c.Lock() defer c.Unlock() - var oldKey string for { if val, ok := c.items[key]; ok { activeSessions := val.ActiveSessions() - if activeSessions < maxSessionsPerConnection || key == oldKey { + if activeSessions < maxSessionsPerConnection { logger.Debug(logSenderSFTPCache, "", "reusing connection for session ID %q, key %s, active sessions %d, active connections: %d", sessionID, key, activeSessions+1, len(c.items)) @@ -1179,11 +1178,10 @@ func (c *sftpConnectionsCache) Get(config *SFTPFsConfig, sessionID string) (*sft return val, nil } partition++ - oldKey = key key = config.getUniqueID(partition) logger.Debug(logSenderSFTPCache, "", - "connection full, generated new key for partition: %d, active sessions: %d, key: %s, old key: %s", - partition, activeSessions, oldKey, key) + "connection full, generated new key for partition: %d, active sessions: %d, key: %s", + partition, activeSessions, key) } else { conn := newSFTPConnection(config, sessionID) signer, err := config.getKeySigner()