diff --git a/pkg/common/cns-lib/volume/listview.go b/pkg/common/cns-lib/volume/listview.go index 01f54f5249..10b54ecca6 100644 --- a/pkg/common/cns-lib/volume/listview.go +++ b/pkg/common/cns-lib/volume/listview.go @@ -118,6 +118,8 @@ func (l *ListViewImpl) ResetVirtualCenter(ctx context.Context, virtualCenter *cn log.Info("cancelling ongoing listView context to trigger restart with new credentials") if l.waitForUpdatesCancelFunc != nil { l.waitForUpdatesCancelFunc() + log.Info("called waitForUpdatesCancelFunc") + log.Infof("waitForUpdatesContext %+v", l.waitForUpdatesContext) } log.Info("updated VirtualCenter object reference in ListView") } @@ -187,6 +189,8 @@ func (l *ListViewImpl) AddTask(ctx context.Context, taskMoRef types.ManagedObjec log.Infof("cancelling ongoing listView context to re-create listview object") if l.waitForUpdatesCancelFunc != nil { l.waitForUpdatesCancelFunc() + log.Info("called waitForUpdatesCancelFunc") + log.Infof("waitForUpdatesContext %+v", l.waitForUpdatesContext) } return fmt.Errorf("%w. task: %v, err: %v", ErrListViewTaskAddition, taskMoRef, err) } @@ -240,6 +244,8 @@ func (l *ListViewImpl) RemoveTask(ctx context.Context, taskMoRef types.ManagedOb log.Infof("cancelling ongoing listView context to re-create listview object") if l.waitForUpdatesCancelFunc != nil { l.waitForUpdatesCancelFunc() + log.Info("called waitForUpdatesCancelFunc") + log.Infof("waitForUpdatesContext %+v", l.waitForUpdatesContext) } return logger.LogNewErrorf(log, "failed to remove task %v from ListView. error: %+v", taskMoRef, err) } @@ -285,6 +291,7 @@ func (l *ListViewImpl) listenToTaskUpdates() { } log.Info("Starting listening for task updates...") + log.Infof("waitForUpdatesContext %v", l.waitForUpdatesContext) pc := property.DefaultCollector(l.virtualCenter.Client.Client) err := property.WaitForUpdatesEx(l.waitForUpdatesContext, pc, filter, func(updates []types.ObjectUpdate) bool { log.Debugf("Got %d property collector update(s)", len(updates))