()
| 403 | } |
| 404 | |
| 405 | func refreshChannelRuntimeCache() { |
| 406 | if common.MemoryCacheEnabled { |
| 407 | func() { |
| 408 | defer func() { |
| 409 | if r := recover(); r != nil { |
| 410 | common.SysLog(fmt.Sprintf("InitChannelCache panic: %v", r)) |
| 411 | } |
| 412 | }() |
| 413 | model.InitChannelCache() |
| 414 | }() |
| 415 | } |
| 416 | service.ResetProxyClientCache() |
| 417 | } |
| 418 | |
| 419 | func shouldSendUpstreamModelUpdateNotification(now int64, changedChannels int, failedChannels int) bool { |
| 420 | if changedChannels <= 0 && failedChannels <= 0 { |
no test coverage detected