Skip to content

Commit 9cccbed

Browse files
authored
Fix mutex not released on error (#891)
Follow up of #873
1 parent 1353ff8 commit 9cccbed

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pkg/sqlcache/informer/factory/informer_factory.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -192,6 +192,8 @@ func (f *CacheFactory) cacheForLocked(ctx context.Context, gi *guardedInformer,
192192
shouldEncrypt := f.encryptAll || encryptResourceAlways
193193
i, err := f.newInformer(f.ctx, client, fields, externalUpdateInfo, selfUpdateInfo, transform, gvk, f.dbClient, shouldEncrypt, namespaced, watchable, f.gcInterval, f.gcKeepCount)
194194
if err != nil {
195+
gi.informerMutex.Unlock()
196+
log.Errorf("Error creating informer for %v: %v", gvk, err)
195197
return nil, err
196198
}
197199

0 commit comments

Comments
 (0)