fanhuadesenlinnn/cloudpods
1
0
Fork 0
mirror of https://hubproxy.babadafafafafa.cn/https://github.com/yunionio/cloudpods.git synced 2026-09-20 08:03:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(devtool): panic occurred cause of nil ctx

Browse Source
This commit is contained in:
Zexi Li
2023-04-10 17:10:38 +08:00
parent fde49d1b9c
commit 279a623467
3 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/apigateway/handler/syslog_webservices.go
View File

@@ -132,11 +132,11 @@ func handleSyslogWebServiceMessage(ctx context.Context, w http.ResponseWriter, r
httperrors.ForbiddenError(ctx, w, "syslog webservice not enabled")
return
}
resp := fetchSyslogMessage(r)
resp := fetchSyslogMessage(ctx, r)
appsrv.SendJSON(w, resp)
}
func fetchSyslogMessage(r *http.Request) jsonutils.JSONObject {
func fetchSyslogMessage(ctx context.Context, r *http.Request) jsonutils.JSONObject {
token := r.FormValue("token")
date := r.FormValue("date")
eventId := r.FormValue("eventId")
@@ -170,7 +170,7 @@ func fetchSyslogMessage(r *http.Request) jsonutils.JSONObject {
params.Add(jsonutils.NewString(moduleType), "service")
}
sess := auth.GetAdminSession(nil, "")
sess := auth.GetAdminSession(ctx, "")
logs, err := modules.Actions.List(sess, params)
if err != nil {
ret.Code = 2

8
pkg/devtool/models/devtoolcronjob.go
View File

@@ -110,10 +110,10 @@ func AddOneCronjob(item *SCronjob, s *mcclient.ClientSession) error {
return nil
}
func InitializeCronjobs() error {
func InitializeCronjobs(ctx context.Context) error {
DevToolCronManager = cronman.InitCronJobManager(true, 8)
DevToolCronManager.Start()
Session := auth.GetAdminSession(nil, "")
Session := auth.GetAdminSession(ctx, "")
go func() {
items := make([]SCronjob, 0)
@@ -131,7 +131,7 @@ func InitializeCronjobs() error {
}
func (job *SCronjob) PostCreate(ctx context.Context, userCred mcclient.TokenCredential, ownerID mcclient.IIdentityProvider, query jsonutils.JSONObject, data jsonutils.JSONObject) {
Session := auth.GetAdminSession(nil, "")
Session := auth.GetAdminSession(ctx, "")
job.SStandaloneResourceBase.PostCreate(ctx, userCred, nil, query, data)
AddOneCronjob(job, Session)
}
@@ -141,7 +141,7 @@ func (job *SCronjob) PostDelete(ctx context.Context, userCred mcclient.TokenCred
}
func (job *SCronjob) PostUpdate(ctx context.Context, userCred mcclient.TokenCredential, query jsonutils.JSONObject, data jsonutils.JSONObject) {
Session := auth.GetAdminSession(nil, "")
Session := auth.GetAdminSession(ctx, "")
job.SStandaloneResourceBase.PostUpdate(ctx, userCred, query, data)
DevToolCronManager.Remove(job.Id)
AddOneCronjob(job, Session)

2
pkg/devtool/service/service.go
View File

@@ -54,7 +54,7 @@ func StartService() {
InitHandlers(app)
db.EnsureAppSyncDB(app, dbOpts, models.InitDB)
models.InitializeCronjobs()
models.InitializeCronjobs(app.GetContext())
app_common.ServeForeverWithCleanup(app, baseOpts, func() {
cloudcommon.CloseDB()