Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 70786da8c6 |
@@ -79,18 +79,15 @@ func New(address string, memorySize string, memoryMultiplier int, diskSize strin
|
|||||||
//memory only mode - no disk
|
//memory only mode - no disk
|
||||||
|
|
||||||
c.SetSlow(mgc)
|
c.SetSlow(mgc)
|
||||||
logger.Logger.Info().Bool("memory", true).Bool("disk", false).Msg("configuration")
|
|
||||||
} else if disksize != 0 && memorysize == 0 {
|
} else if disksize != 0 && memorysize == 0 {
|
||||||
// disk only mode
|
// disk only mode
|
||||||
|
|
||||||
c.SetSlow(dgc)
|
c.SetSlow(dgc)
|
||||||
logger.Logger.Info().Bool("memory", false).Bool("disk", true).Msg("configuration")
|
|
||||||
} else if disksize != 0 && memorysize != 0 {
|
} else if disksize != 0 && memorysize != 0 {
|
||||||
// memory and disk mode
|
// memory and disk mode
|
||||||
|
|
||||||
c.SetFast(mgc)
|
c.SetFast(mgc)
|
||||||
c.SetSlow(dgc)
|
c.SetSlow(dgc)
|
||||||
logger.Logger.Info().Bool("memory", true).Bool("disk", true).Msg("configuration")
|
|
||||||
} else {
|
} else {
|
||||||
// no memory or disk isn't a valid configuration
|
// no memory or disk isn't a valid configuration
|
||||||
logger.Logger.Error().Bool("memory", false).Bool("disk", false).Msg("configuration invalid :( exiting")
|
logger.Logger.Error().Bool("memory", false).Bool("disk", false).Msg("configuration invalid :( exiting")
|
||||||
@@ -122,15 +119,12 @@ func New(address string, memorySize string, memoryMultiplier int, diskSize strin
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (sc *SteamCache) Run() {
|
func (sc *SteamCache) Run() {
|
||||||
logger.Logger.Info().Str("address", sc.address).Str("version", version.Version).Msg("listening")
|
|
||||||
|
|
||||||
if sc.upstream != "" {
|
if sc.upstream != "" {
|
||||||
_, err := http.Get(sc.upstream)
|
_, err := http.Get(sc.upstream)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Logger.Error().Err(err).Str("upstream", sc.upstream).Msg("Failed to connect to upstream server")
|
logger.Logger.Error().Err(err).Str("upstream", sc.upstream).Msg("Failed to connect to upstream server")
|
||||||
os.Exit(1)
|
os.Exit(1)
|
||||||
}
|
}
|
||||||
logger.Logger.Info().Str("upstream", sc.upstream).Msg("connected")
|
|
||||||
}
|
}
|
||||||
|
|
||||||
sc.mu.Lock()
|
sc.mu.Lock()
|
||||||
@@ -161,8 +155,7 @@ func (sc *SteamCache) LogStats() {
|
|||||||
defer sc.mu.Unlock()
|
defer sc.mu.Unlock()
|
||||||
if sc.dirty {
|
if sc.dirty {
|
||||||
|
|
||||||
logger.Logger.Info().Msg("") // empty line to separate log entries for better readability
|
logger.Logger.Info().Str("address", sc.address).Str("version", version.Version).Str("upstream", sc.upstream).Msg("listening")
|
||||||
|
|
||||||
if sc.memory != nil { // only log memory if memory is enabled
|
if sc.memory != nil { // only log memory if memory is enabled
|
||||||
lifetimeBytes, lifetimeFiles, reclaimedBytes, deletedFiles, gcTime := sc.memorygc.Stats()
|
lifetimeBytes, lifetimeFiles, reclaimedBytes, deletedFiles, gcTime := sc.memorygc.Stats()
|
||||||
|
|
||||||
@@ -206,12 +199,13 @@ func (sc *SteamCache) LogStats() {
|
|||||||
logger.Logger.Info().
|
logger.Logger.Info().
|
||||||
Str("alloc", units.HumanSize(float64(m.Alloc))).
|
Str("alloc", units.HumanSize(float64(m.Alloc))).
|
||||||
Str("sys", units.HumanSize(float64(m.Sys))).
|
Str("sys", units.HumanSize(float64(m.Sys))).
|
||||||
Msg("go_gc")
|
Msg("app_gc")
|
||||||
|
|
||||||
logger.Logger.Info().
|
logger.Logger.Info().
|
||||||
Str("hitrate", fmt.Sprintf("%.2f%%", sc.hits.Avg()*100)).
|
Str("hitrate", fmt.Sprintf("%.2f%%", sc.hits.Avg()*100)).
|
||||||
Msg("cache")
|
Msg("cache")
|
||||||
|
|
||||||
|
logger.Logger.Info().Msg("") // empty line to separate log entries for better readability
|
||||||
sc.dirty = false
|
sc.dirty = false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user