|
@@ -342,3 +342,14 @@ func CacheGetChannel(id int) (*Channel, error) {
|
|
|
}
|
|
}
|
|
|
return c, nil
|
|
return c, nil
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+func CacheUpdateChannelStatus(id int, status int) {
|
|
|
|
|
+ if (!common.MemoryCacheEnabled) {
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+ channelSyncLock.Lock()
|
|
|
|
|
+ defer channelSyncLock.Unlock()
|
|
|
|
|
+ if channel, ok := channelsIDM[id]; ok {
|
|
|
|
|
+ channel.Status = status
|
|
|
|
|
+ }
|
|
|
|
|
+}
|