fix(common): context with time (#22708)

Author: ioito

pkg/cloudcommon/cronman/cronman.go

@@ -33,6 +33,7 @@ import (
 	"yunion.io/x/onecloud/pkg/mcclient"
 	"yunion.io/x/onecloud/pkg/mcclient/auth"
 	"yunion.io/x/onecloud/pkg/mcclient/modules/yunionconf"
+	"yunion.io/x/onecloud/pkg/util/ctx"
 )
 
 var (
@@ -361,7 +362,7 @@ func (self *SCronJobManager) Start2(ctx context.Context, electObj *elect.Elect)
 }
 
 func (self *SCronJobManager) Start() {
-	ctx := context.Background()
+	ctx := ctx.CtxWithTime()
 	ctx, self.stopFunc = context.WithCancel(ctx)
 	self.start(ctx)
 }

pkg/cloudcommon/db/rolecache.go

@@ -32,6 +32,7 @@ import (
 	"yunion.io/x/onecloud/pkg/mcclient/auth"
 	"yunion.io/x/onecloud/pkg/mcclient/informer"
 	modules "yunion.io/x/onecloud/pkg/mcclient/modules/identity"
+	"yunion.io/x/onecloud/pkg/util/ctx"
 	"yunion.io/x/onecloud/pkg/util/stringutils2"
 )
 
@@ -192,7 +193,7 @@ func (manager *SRoleCacheManager) OnAdd(obj *jsonutils.JSONDict) {
 		log.Errorf("unable to get Id: %v", err)
 		return
 	}
-	ctx := context.Background()
+	ctx := ctx.CtxWithTime()
 	lockman.LockRawObject(ctx, manager.KeywordPlural(), id)
 	defer lockman.ReleaseRawObject(ctx, manager.KeywordPlural(), id)
 	role := new(SRole)
@@ -212,7 +213,7 @@ func (manager *SRoleCacheManager) OnUpdate(oldObj, newObj *jsonutils.JSONDict) {
 		log.Errorf("unable to get Id: %v", err)
 		return
 	}
-	ctx := context.Background()
+	ctx := ctx.CtxWithTime()
 	role, err := manager.fetchRole(ctx, id, true, nil)
 	if err != nil {
 		log.Errorf("unable to fetch Role from db: %v", err)
@@ -242,7 +243,7 @@ func (manager *SRoleCacheManager) OnDelete(obj *jsonutils.JSONDict) {
 		log.Errorf("unable to get Id: %v", err)
 		return
 	}
-	ctx := context.Background()
+	ctx := ctx.CtxWithTime()
 	role, err := manager.fetchRole(ctx, id, true, nil)
 	if err != nil {
 		log.Errorf("unable to fetch Role from db: %v", err)
@@ -263,7 +264,7 @@ func (manager *SRoleCacheManager) StartWatchRoleInKeystone() error {
 	if manager.watching {
 		return nil
 	}
-	ctx := context.Background()
+	ctx := ctx.CtxWithTime()
 	s := auth.GetAdminSession(ctx, "")
 	watchMan, err := informer.NewWatchManagerBySession(s)
 	if err != nil {

pkg/cloudcommon/informer/etcd.go

@@ -25,6 +25,7 @@ import (
 	"yunion.io/x/pkg/errors"
 
 	"yunion.io/x/onecloud/pkg/cloudcommon/etcd"
+	"yunion.io/x/onecloud/pkg/util/ctx"
 )
 
 const (
@@ -85,7 +86,7 @@ func NewEtcdBackend(opt *etcd.SEtcdOptions, onKeepaliveFailure func()) (*EtcdBac
 	if err != nil {
 		return nil, err
 	}
-	ctx := context.Background()
+	ctx := ctx.CtxWithTime()
 	be.initClientResources(ctx)
 	be.StartClientWatch(ctx)
 	return be, nil

pkg/cloudcommon/syncman/watcher/watcher.go

@@ -15,8 +15,6 @@
 package watcher
 
 import (
-	"context"
-
 	"yunion.io/x/jsonutils"
 	"yunion.io/x/log"
 	"yunion.io/x/pkg/errors"
@@ -28,6 +26,7 @@ import (
 	"yunion.io/x/onecloud/pkg/mcclient"
 	"yunion.io/x/onecloud/pkg/mcclient/auth"
 	"yunion.io/x/onecloud/pkg/mcclient/informer"
+	"yunion.io/x/onecloud/pkg/util/ctx"
 )
 
 type SInformerSyncManager struct {
@@ -81,7 +80,7 @@ func (manager *SInformerSyncManager) StartWatching(resMan informer.IResourceMana
 
 func (manager *SInformerSyncManager) startWatcher() error {
 	log.Infof("[%s] Start resource informer watcher for %s", manager.Name(), manager.resourceManager.GetKeyword())
-	ctx := context.Background()
+	ctx := ctx.CtxWithTime()
 	s := auth.GetAdminSession(ctx, consts.GetRegion())
 	informer.NewWatchManagerBySessionBg(s, func(watchMan *informer.SWatchManager) error {
 		if err := watchMan.For(manager.resourceManager).AddEventHandler(ctx, manager); err != nil {

pkg/util/logclient/logclient.go

@@ -34,6 +34,7 @@ import (
 	"yunion.io/x/onecloud/pkg/mcclient"
 	"yunion.io/x/onecloud/pkg/mcclient/auth"
 	"yunion.io/x/onecloud/pkg/mcclient/modules/logger"
+	"yunion.io/x/onecloud/pkg/util/ctx"
 	// "yunion.io/x/onecloud/pkg/mcclient/modules/websocket"
 )
 
@@ -242,7 +243,7 @@ type logTask struct {
 }
 
 func (t *logTask) Run() {
-	ctx := context.Background()
+	ctx := ctx.CtxWithTime()
 	ctx = context.WithValue(ctx, appctx.APP_CONTEXT_KEY_APPNAME, consts.GetServiceType())
 	s := DefaultSessionGenerator(ctx, t.userCred, "")
 	_, err := t.api.Create(s, t.logentry)