lywsvip/cloudpods
1
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-07-01 01:36:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Websockets 不再拉取 ActionLog 的消息 (#398)

Browse Source
This commit is contained in:
rex zhasm
2019-04-15 15:24:10 +08:00
committed by yunion-ci-robot
parent eab87ed6df
commit 2fe357ad9b
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
pkg/logger/models/actionlog.go
View File

@@ -69,17 +69,19 @@ func (action *SActionlog) CustomizeCreate(ctx context.Context, userCred mcclient
return nil
}
func (manager *SActionlogManager) OnCreateComplete(ctx context.Context, items []db.IModel, userCred mcclient.TokenCredential, query jsonutils.JSONObject, data jsonutils.JSONObject) {
actionLog := items[0].(*SActionlog)
if IsInActionWhiteList(actionLog.Action) {
select {
case logQueue <- actionLog:
return
default:
log.Warningf("Log queue full, insert failed, log ignored: %s", actionLog.Action)
}
}
}
// Websockets 不再拉取 ActionLog 的消息，因此注释掉如下代码
// 可以保留，以便有需求时，再次打开
// func (manager *SActionlogManager) OnCreateComplete(ctx context.Context, items []db.IModel, userCred mcclient.TokenCredential, query jsonutils.JSONObject, data jsonutils.JSONObject) {
// actionLog := items[0].(*SActionlog)
// if IsInActionWhiteList(actionLog.Action) {
// select {
// case logQueue <- actionLog:
// return
// default:
// log.Warningf("Log queue full, insert failed, log ignored: %s", actionLog.Action)
// }
// }
// }
func StartNotifyToWebsocketWorker() {
go func() {