Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 8c1bb695b8 | |||
| f58951fd92 | |||
| 70786da8c6 |
6
.vscode/launch.json
vendored
6
.vscode/launch.json
vendored
@@ -17,8 +17,6 @@
|
||||
"10G",
|
||||
"--disk-path",
|
||||
"tmp/disk",
|
||||
"--upstream",
|
||||
"http://192.168.2.88:80",
|
||||
"--verbose",
|
||||
],
|
||||
},
|
||||
@@ -33,8 +31,6 @@
|
||||
"10G",
|
||||
"--disk-path",
|
||||
"tmp/disk",
|
||||
"--upstream",
|
||||
"http://192.168.2.88:80",
|
||||
"--verbose",
|
||||
],
|
||||
},
|
||||
@@ -47,8 +43,6 @@
|
||||
"args": [
|
||||
"--memory",
|
||||
"1G",
|
||||
"--upstream",
|
||||
"http://192.168.2.88:80",
|
||||
"--verbose",
|
||||
],
|
||||
}
|
||||
|
||||
@@ -79,18 +79,15 @@ func New(address string, memorySize string, memoryMultiplier int, diskSize strin
|
||||
//memory only mode - no disk
|
||||
|
||||
c.SetSlow(mgc)
|
||||
logger.Logger.Info().Bool("memory", true).Bool("disk", false).Msg("configuration")
|
||||
} else if disksize != 0 && memorysize == 0 {
|
||||
// disk only mode
|
||||
|
||||
c.SetSlow(dgc)
|
||||
logger.Logger.Info().Bool("memory", false).Bool("disk", true).Msg("configuration")
|
||||
} else if disksize != 0 && memorysize != 0 {
|
||||
// memory and disk mode
|
||||
|
||||
c.SetFast(mgc)
|
||||
c.SetSlow(dgc)
|
||||
logger.Logger.Info().Bool("memory", true).Bool("disk", true).Msg("configuration")
|
||||
} else {
|
||||
// no memory or disk isn't a valid configuration
|
||||
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() {
|
||||
logger.Logger.Info().Str("address", sc.address).Str("version", version.Version).Msg("listening")
|
||||
|
||||
if sc.upstream != "" {
|
||||
_, err := http.Get(sc.upstream)
|
||||
if err != nil {
|
||||
logger.Logger.Error().Err(err).Str("upstream", sc.upstream).Msg("Failed to connect to upstream server")
|
||||
os.Exit(1)
|
||||
}
|
||||
logger.Logger.Info().Str("upstream", sc.upstream).Msg("connected")
|
||||
}
|
||||
|
||||
sc.mu.Lock()
|
||||
@@ -161,8 +155,12 @@ func (sc *SteamCache) LogStats() {
|
||||
defer sc.mu.Unlock()
|
||||
if sc.dirty {
|
||||
|
||||
logger.Logger.Info().Msg("") // empty line to separate log entries for better readability
|
||||
up := sc.upstream
|
||||
if up == "" {
|
||||
up = "{host in request}"
|
||||
}
|
||||
|
||||
logger.Logger.Info().Str("address", sc.address).Str("version", version.Version).Str("upstream", up).Msg("listening")
|
||||
if sc.memory != nil { // only log memory if memory is enabled
|
||||
lifetimeBytes, lifetimeFiles, reclaimedBytes, deletedFiles, gcTime := sc.memorygc.Stats()
|
||||
|
||||
@@ -206,12 +204,13 @@ func (sc *SteamCache) LogStats() {
|
||||
logger.Logger.Info().
|
||||
Str("alloc", units.HumanSize(float64(m.Alloc))).
|
||||
Str("sys", units.HumanSize(float64(m.Sys))).
|
||||
Msg("go_gc")
|
||||
Msg("app_gc")
|
||||
|
||||
logger.Logger.Info().
|
||||
Str("hitrate", fmt.Sprintf("%.2f%%", sc.hits.Avg()*100)).
|
||||
Msg("cache")
|
||||
|
||||
logger.Logger.Info().Msg("") // empty line to separate log entries for better readability
|
||||
sc.dirty = false
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user